提交 454c05f2 编写于 作者: D dragondriver 提交者: yefu.chen

Implement the InvalidateCollectionMetaCacheTask in Proxy

Signed-off-by: Ndragondriver <jiquan.long@zilliz.com>
上级 4d5a9e06
...@@ -25,7 +25,12 @@ func (node *NodeImpl) UpdateStateCode(code internalpb2.StateCode) { ...@@ -25,7 +25,12 @@ func (node *NodeImpl) UpdateStateCode(code internalpb2.StateCode) {
} }
func (node *NodeImpl) InvalidateCollectionMetaCache(ctx context.Context, request *proxypb.InvalidateCollMetaCacheRequest) (*commonpb.Status, error) { func (node *NodeImpl) InvalidateCollectionMetaCache(ctx context.Context, request *proxypb.InvalidateCollMetaCacheRequest) (*commonpb.Status, error) {
panic("implement me") collectionName := request.CollectionName
_ = globalMetaCache.Remove(collectionName) // no need to return error, though collection may be not cached
return &commonpb.Status{
ErrorCode: commonpb.ErrorCode_SUCCESS,
Reason: "",
}, nil
} }
func (node *NodeImpl) CreateCollection(request *milvuspb.CreateCollectionRequest) (*commonpb.Status, error) { func (node *NodeImpl) CreateCollection(request *milvuspb.CreateCollectionRequest) (*commonpb.Status, error) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册