From 09219f062cdbe909b8a7055ac737853560b321a1 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Fri, 1 Oct 2021 09:49:34 +0800 Subject: [PATCH] [skip ci] Add comment for LoadSegments (#8961) Signed-off-by: bigsheeper --- internal/types/types.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/internal/types/types.go b/internal/types/types.go index 1b766687d9..e2aa142f52 100644 --- a/internal/types/types.go +++ b/internal/types/types.go @@ -411,6 +411,14 @@ type QueryNode interface { AddQueryChannel(ctx context.Context, req *querypb.AddQueryChannelRequest) (*commonpb.Status, error) RemoveQueryChannel(ctx context.Context, req *querypb.RemoveQueryChannelRequest) (*commonpb.Status, error) WatchDmChannels(ctx context.Context, req *querypb.WatchDmChannelsRequest) (*commonpb.Status, error) + // LoadSegments notifies QueryNode to load the sealed segments from storage. The load tasks are sync to this + // rpc, QueryNode will return after all the sealed segments are loaded. + // + // Return UnexpectedError code in status: + // If QueryNode isn't in HEALTHY: states not HEALTHY or dynamic checks not HEALTHY. + // If any segment is loaded failed in QueryNode. + // Return Success code in status: + // All the sealed segments are loaded. LoadSegments(ctx context.Context, req *querypb.LoadSegmentsRequest) (*commonpb.Status, error) ReleaseCollection(ctx context.Context, req *querypb.ReleaseCollectionRequest) (*commonpb.Status, error) ReleasePartitions(ctx context.Context, req *querypb.ReleasePartitionsRequest) (*commonpb.Status, error)