diff options
| author | chrislu <chris.lu@gmail.com> | 2022-05-10 00:01:43 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-05-10 00:01:43 -0700 |
| commit | 791c29ae9327c23157a2328433d64ffa491bd83b (patch) | |
| tree | e42282974dfc056fefab9482786935c7ff1cd44a | |
| parent | a4ca3ed1f0c2bcde1d36bb48f81dedc3e1924679 (diff) | |
| download | seaweedfs-791c29ae9327c23157a2328433d64ffa491bd83b.tar.xz seaweedfs-791c29ae9327c23157a2328433d64ffa491bd83b.zip | |
remove deprecated function
WithQueryCachePolicyKeepInCache is deprecated and already default behavior
| -rw-r--r-- | weed/filer/ydb/ydb_store_kv.go | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/weed/filer/ydb/ydb_store_kv.go b/weed/filer/ydb/ydb_store_kv.go index d64597764..248d639a9 100644 --- a/weed/filer/ydb/ydb_store_kv.go +++ b/weed/filer/ydb/ydb_store_kv.go @@ -21,8 +21,7 @@ func (store *YdbStore) KvPut(ctx context.Context, key []byte, value []byte) (err fileMeta := FileMeta{dirHash, name, dirStr, value} return store.DB.Table().Do(ctx, func(ctx context.Context, s table.Session) (err error) { _, _, err = s.Execute(ctx, rwTX, *withPragma(&store.tablePathPrefix, insertQuery), - fileMeta.queryParameters(0), - options.WithQueryCachePolicy(options.WithQueryCachePolicyKeepInCache())) + fileMeta.queryParameters(0)) if err != nil { return fmt.Errorf("kv put execute %s: %v", util.NewFullPath(dirStr, name).Name(), err) } @@ -68,8 +67,7 @@ func (store *YdbStore) KvDelete(ctx context.Context, key []byte) (err error) { _, _, err = s.Execute(ctx, rwTX, *withPragma(&store.tablePathPrefix, insertQuery), table.NewQueryParameters( table.ValueParam("$dir_hash", types.Int64Value(dirHash)), - table.ValueParam("$name", types.UTF8Value(name))), - options.WithQueryCachePolicy(options.WithQueryCachePolicyKeepInCache())) + table.ValueParam("$name", types.UTF8Value(name)))) if err != nil { return fmt.Errorf("kv delete %s: %v", util.NewFullPath(dirStr, name).Name(), err) } |