diff options
| author | Chris Lu <chris.lu@uber.com> | 2019-03-30 23:08:29 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@uber.com> | 2019-03-30 23:08:29 -0700 |
| commit | 97406333a5ecc5b0d2cdaa74ff9901e3100e4bf2 (patch) | |
| tree | 04cb10ddb0fb87663ba1783a7e82397aa2c9c06f /weed/filer2/memdb | |
| parent | 920b4e56aa76fbf37780363d5b345c2882d311b5 (diff) | |
| download | seaweedfs-97406333a5ecc5b0d2cdaa74ff9901e3100e4bf2.tar.xz seaweedfs-97406333a5ecc5b0d2cdaa74ff9901e3100e4bf2.zip | |
support atomic renaming for mysql/postgres filer store
Diffstat (limited to 'weed/filer2/memdb')
| -rw-r--r-- | weed/filer2/memdb/memdb_store.go | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/weed/filer2/memdb/memdb_store.go b/weed/filer2/memdb/memdb_store.go index d4c906f2d..811c87440 100644 --- a/weed/filer2/memdb/memdb_store.go +++ b/weed/filer2/memdb/memdb_store.go @@ -34,6 +34,16 @@ func (store *MemDbStore) Initialize(configuration util.Configuration) (err error return nil } +func (store *MemDbStore) BeginTransaction(ctx context.Context) (context.Context, error){ + return ctx, nil +} +func (store *MemDbStore) CommitTransaction(ctx context.Context) error{ + return nil +} +func (store *MemDbStore) RollbackTransaction(ctx context.Context) error{ + return nil +} + func (store *MemDbStore) InsertEntry(ctx context.Context, entry *filer2.Entry) (err error) { // println("inserting", entry.FullPath) store.tree.ReplaceOrInsert(entryItem{entry}) |