mock

package
v0.10.3-0...-843c1f5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 29, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GRPCClientBase 

type GRPCClientBase[T any] struct {
	GetGrpcClientErr error
	// contains filtered or unexported fields
}

func (*GRPCClientBase[T]) Call 

func (c *GRPCClientBase[T]) Call(ctx context.Context, caller func(client T) (any, error)) (any, error)

func (*GRPCClientBase[T]) Close 

func (c *GRPCClientBase[T]) Close() error

func (*GRPCClientBase[T]) EnableEncryption 

func (c *GRPCClientBase[T]) EnableEncryption()

func (*GRPCClientBase[T]) GetGrpcClient 

func (c *GRPCClientBase[T]) GetGrpcClient(ctx context.Context) (T, error)

func (*GRPCClientBase[T]) GetNodeID 

func (c *GRPCClientBase[T]) GetNodeID() int64

func (*GRPCClientBase[T]) GetRole 

func (c *GRPCClientBase[T]) GetRole() string

func (*GRPCClientBase[T]) ReCall 

func (c *GRPCClientBase[T]) ReCall(ctx context.Context, caller func(client T) (any, error)) (any, error)

func (*GRPCClientBase[T]) SetGetAddrFunc 

func (c *GRPCClientBase[T]) SetGetAddrFunc(f func() (string, error))

func (*GRPCClientBase[T]) SetInternalTLSCertPool 

func (c *GRPCClientBase[T]) SetInternalTLSCertPool(cp *x509.CertPool)

func (*GRPCClientBase[T]) SetNewGrpcClientFunc 

func (c *GRPCClientBase[T]) SetNewGrpcClientFunc(f func(cc *grpc.ClientConn) T)

func (*GRPCClientBase[T]) SetNodeID 

func (c *GRPCClientBase[T]) SetNodeID(nodeID int64)

func (*GRPCClientBase[T]) SetRole 

func (c *GRPCClientBase[T]) SetRole(role string)

func (*GRPCClientBase[T]) SetSession 

func (c *GRPCClientBase[T]) SetSession(sess *sessionutil.Session)

type GrpcDataNodeClient 

type GrpcDataNodeClient struct {
	Err error
}

func (*GrpcDataNodeClient) CheckChannelOperationProgress 

func (m *GrpcDataNodeClient) CheckChannelOperationProgress(ctx context.Context, req *datapb.ChannelWatchInfo, opts ...grpc.CallOption) (*datapb.ChannelOperationProgressResponse, error)

func (*GrpcDataNodeClient) CompactionV2 

func (m *GrpcDataNodeClient) CompactionV2(ctx context.Context, req *datapb.CompactionPlan, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcDataNodeClient) DropCompactionPlan 

func (m *GrpcDataNodeClient) DropCompactionPlan(ctx context.Context, req *datapb.DropCompactionPlanRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcDataNodeClient) DropImport 

func (m *GrpcDataNodeClient) DropImport(ctx context.Context, req *datapb.DropImportRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcDataNodeClient) FlushChannels 

func (m *GrpcDataNodeClient) FlushChannels(ctx context.Context, in *datapb.FlushChannelsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcDataNodeClient) FlushSegments 

func (m *GrpcDataNodeClient) FlushSegments(ctx context.Context, in *datapb.FlushSegmentsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcDataNodeClient) GetCompactionState 

func (m *GrpcDataNodeClient) GetCompactionState(ctx context.Context, in *datapb.CompactionStateRequest, opts ...grpc.CallOption) (*datapb.CompactionStateResponse, error)

func (*GrpcDataNodeClient) GetComponentStates 

func (m *GrpcDataNodeClient) GetComponentStates(ctx context.Context, in *milvuspb.GetComponentStatesRequest, opts ...grpc.CallOption) (*milvuspb.ComponentStates, error)

func (*GrpcDataNodeClient) GetMetrics 

func (m *GrpcDataNodeClient) GetMetrics(ctx context.Context, in *milvuspb.GetMetricsRequest, opts ...grpc.CallOption) (*milvuspb.GetMetricsResponse, error)

func (*GrpcDataNodeClient) GetStatisticsChannel 

func (m *GrpcDataNodeClient) GetStatisticsChannel(ctx context.Context, in *internalpb.GetStatisticsChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)

func (*GrpcDataNodeClient) ImportV2 

func (m *GrpcDataNodeClient) ImportV2(ctx context.Context, req *datapb.ImportRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcDataNodeClient) NotifyChannelOperation 

func (m *GrpcDataNodeClient) NotifyChannelOperation(ctx context.Context, in *datapb.ChannelOperationsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcDataNodeClient) PreImport 

func (m *GrpcDataNodeClient) PreImport(ctx context.Context, req *datapb.PreImportRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcDataNodeClient) QueryImport 

func (m *GrpcDataNodeClient) QueryImport(ctx context.Context, req *datapb.QueryImportRequest, opts ...grpc.CallOption) (*datapb.QueryImportResponse, error)

func (*GrpcDataNodeClient) QueryPreImport 

func (m *GrpcDataNodeClient) QueryPreImport(ctx context.Context, req *datapb.QueryPreImportRequest, opts ...grpc.CallOption) (*datapb.QueryPreImportResponse, error)

func (*GrpcDataNodeClient) QuerySlot 

func (m *GrpcDataNodeClient) QuerySlot(ctx context.Context, req *datapb.QuerySlotRequest, opts ...grpc.CallOption) (*datapb.QuerySlotResponse, error)

func (*GrpcDataNodeClient) ResendSegmentStats 

func (m *GrpcDataNodeClient) ResendSegmentStats(ctx context.Context, req *datapb.ResendSegmentStatsRequest, opts ...grpc.CallOption) (*datapb.ResendSegmentStatsResponse, error)

func (*GrpcDataNodeClient) ShowConfigurations 

func (m *GrpcDataNodeClient) ShowConfigurations(ctx context.Context, in *internalpb.ShowConfigurationsRequest, opts ...grpc.CallOption) (*internalpb.ShowConfigurationsResponse, error)

func (*GrpcDataNodeClient) SyncSegments 

func (m *GrpcDataNodeClient) SyncSegments(ctx context.Context, in *datapb.SyncSegmentsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcDataNodeClient) WatchDmChannels 

func (m *GrpcDataNodeClient) WatchDmChannels(ctx context.Context, in *datapb.WatchDmChannelsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

type GrpcHealthWatchServer 

type GrpcHealthWatchServer struct {
	// contains filtered or unexported fields
}

func NewGrpcHealthWatchServer 

func NewGrpcHealthWatchServer() *GrpcHealthWatchServer

func (GrpcHealthWatchServer) Chan 

func (m GrpcHealthWatchServer) Chan() <-chan *grpc_health_v1.HealthCheckResponse

func (GrpcHealthWatchServer) Context 

func (m GrpcHealthWatchServer) Context() context.Context

func (GrpcHealthWatchServer) RecvMsg 

func (m GrpcHealthWatchServer) RecvMsg(msg interface{}) error

func (GrpcHealthWatchServer) Send 

func (m GrpcHealthWatchServer) Send(response *grpc_health_v1.HealthCheckResponse) error

func (GrpcHealthWatchServer) SendHeader 

func (m GrpcHealthWatchServer) SendHeader(md metadata.MD) error

func (GrpcHealthWatchServer) SendMsg 

func (m GrpcHealthWatchServer) SendMsg(msg interface{}) error

func (GrpcHealthWatchServer) SetHeader 

func (m GrpcHealthWatchServer) SetHeader(md metadata.MD) error

func (GrpcHealthWatchServer) SetTrailer 

func (m GrpcHealthWatchServer) SetTrailer(md metadata.MD)

type GrpcQueryCoordClient 

type GrpcQueryCoordClient struct {
	Err error
}

func (*GrpcQueryCoordClient) ActivateChecker 

func (m *GrpcQueryCoordClient) ActivateChecker(ctx context.Context, in *querypb.ActivateCheckerRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) CheckHealth 

func (m *GrpcQueryCoordClient) CheckHealth(ctx context.Context, in *milvuspb.CheckHealthRequest, opts ...grpc.CallOption) (*milvuspb.CheckHealthResponse, error)

func (*GrpcQueryCoordClient) CheckQueryNodeDistribution 

func (m *GrpcQueryCoordClient) CheckQueryNodeDistribution(ctx context.Context, req *querypb.CheckQueryNodeDistributionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) CreateResourceGroup 

func (m *GrpcQueryCoordClient) CreateResourceGroup(ctx context.Context, req *milvuspb.CreateResourceGroupRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) DeactivateChecker 

func (m *GrpcQueryCoordClient) DeactivateChecker(ctx context.Context, in *querypb.DeactivateCheckerRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) DescribeResourceGroup 

func (m *GrpcQueryCoordClient) DescribeResourceGroup(ctx context.Context, req *querypb.DescribeResourceGroupRequest, opts ...grpc.CallOption) (*querypb.DescribeResourceGroupResponse, error)

func (*GrpcQueryCoordClient) DropResourceGroup 

func (m *GrpcQueryCoordClient) DropResourceGroup(ctx context.Context, req *milvuspb.DropResourceGroupRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) GetComponentStates 

func (m *GrpcQueryCoordClient) GetComponentStates(ctx context.Context, in *milvuspb.GetComponentStatesRequest, opts ...grpc.CallOption) (*milvuspb.ComponentStates, error)

func (*GrpcQueryCoordClient) GetMetrics 

func (m *GrpcQueryCoordClient) GetMetrics(ctx context.Context, in *milvuspb.GetMetricsRequest, opts ...grpc.CallOption) (*milvuspb.GetMetricsResponse, error)

func (*GrpcQueryCoordClient) GetPartitionStates 

func (m *GrpcQueryCoordClient) GetPartitionStates(ctx context.Context, in *querypb.GetPartitionStatesRequest, opts ...grpc.CallOption) (*querypb.GetPartitionStatesResponse, error)

func (*GrpcQueryCoordClient) GetQueryNodeDistribution 

func (m *GrpcQueryCoordClient) GetQueryNodeDistribution(ctx context.Context, req *querypb.GetQueryNodeDistributionRequest, opts ...grpc.CallOption) (*querypb.GetQueryNodeDistributionResponse, error)

func (*GrpcQueryCoordClient) GetReplicas 

func (m *GrpcQueryCoordClient) GetReplicas(ctx context.Context, in *milvuspb.GetReplicasRequest, opts ...grpc.CallOption) (*milvuspb.GetReplicasResponse, error)

func (*GrpcQueryCoordClient) GetSegmentInfo 

func (m *GrpcQueryCoordClient) GetSegmentInfo(ctx context.Context, in *querypb.GetSegmentInfoRequest, opts ...grpc.CallOption) (*querypb.GetSegmentInfoResponse, error)

func (*GrpcQueryCoordClient) GetShardLeaders 

func (m *GrpcQueryCoordClient) GetShardLeaders(ctx context.Context, in *querypb.GetShardLeadersRequest, opts ...grpc.CallOption) (*querypb.GetShardLeadersResponse, error)

func (*GrpcQueryCoordClient) GetStatisticsChannel 

func (m *GrpcQueryCoordClient) GetStatisticsChannel(ctx context.Context, in *internalpb.GetStatisticsChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)

func (*GrpcQueryCoordClient) GetTimeTickChannel 

func (m *GrpcQueryCoordClient) GetTimeTickChannel(ctx context.Context, in *internalpb.GetTimeTickChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)

func (*GrpcQueryCoordClient) ListCheckers 

func (m *GrpcQueryCoordClient) ListCheckers(ctx context.Context, in *querypb.ListCheckersRequest, opts ...grpc.CallOption) (*querypb.ListCheckersResponse, error)

func (*GrpcQueryCoordClient) ListQueryNode 

func (m *GrpcQueryCoordClient) ListQueryNode(ctx context.Context, req *querypb.ListQueryNodeRequest, opts ...grpc.CallOption) (*querypb.ListQueryNodeResponse, error)

func (*GrpcQueryCoordClient) ListResourceGroups 

func (m *GrpcQueryCoordClient) ListResourceGroups(ctx context.Context, req *milvuspb.ListResourceGroupsRequest, opts ...grpc.CallOption) (*milvuspb.ListResourceGroupsResponse, error)

func (*GrpcQueryCoordClient) LoadBalance 

func (m *GrpcQueryCoordClient) LoadBalance(ctx context.Context, in *querypb.LoadBalanceRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) LoadCollection 

func (m *GrpcQueryCoordClient) LoadCollection(ctx context.Context, in *querypb.LoadCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) LoadPartitions 

func (m *GrpcQueryCoordClient) LoadPartitions(ctx context.Context, in *querypb.LoadPartitionsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) ReleaseCollection 

func (m *GrpcQueryCoordClient) ReleaseCollection(ctx context.Context, in *querypb.ReleaseCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) ReleasePartitions 

func (m *GrpcQueryCoordClient) ReleasePartitions(ctx context.Context, in *querypb.ReleasePartitionsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) ResumeBalance 

func (m *GrpcQueryCoordClient) ResumeBalance(ctx context.Context, req *querypb.ResumeBalanceRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) ResumeNode 

func (m *GrpcQueryCoordClient) ResumeNode(ctx context.Context, req *querypb.ResumeNodeRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) ShowCollections 

func (m *GrpcQueryCoordClient) ShowCollections(ctx context.Context, in *querypb.ShowCollectionsRequest, opts ...grpc.CallOption) (*querypb.ShowCollectionsResponse, error)

func (*GrpcQueryCoordClient) ShowConfigurations 

func (m *GrpcQueryCoordClient) ShowConfigurations(ctx context.Context, in *internalpb.ShowConfigurationsRequest, opts ...grpc.CallOption) (*internalpb.ShowConfigurationsResponse, error)

func (*GrpcQueryCoordClient) ShowPartitions 

func (m *GrpcQueryCoordClient) ShowPartitions(ctx context.Context, in *querypb.ShowPartitionsRequest, opts ...grpc.CallOption) (*querypb.ShowPartitionsResponse, error)

func (*GrpcQueryCoordClient) SuspendBalance 

func (m *GrpcQueryCoordClient) SuspendBalance(ctx context.Context, req *querypb.SuspendBalanceRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) SuspendNode 

func (m *GrpcQueryCoordClient) SuspendNode(ctx context.Context, req *querypb.SuspendNodeRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) SyncNewCreatedPartition 

func (m *GrpcQueryCoordClient) SyncNewCreatedPartition(ctx context.Context, req *querypb.SyncNewCreatedPartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) TransferChannel 

func (m *GrpcQueryCoordClient) TransferChannel(ctx context.Context, req *querypb.TransferChannelRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) TransferNode 

func (m *GrpcQueryCoordClient) TransferNode(ctx context.Context, req *milvuspb.TransferNodeRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) TransferReplica 

func (m *GrpcQueryCoordClient) TransferReplica(ctx context.Context, req *querypb.TransferReplicaRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) TransferSegment 

func (m *GrpcQueryCoordClient) TransferSegment(ctx context.Context, req *querypb.TransferSegmentRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) UpdateLoadConfig 

func (m *GrpcQueryCoordClient) UpdateLoadConfig(ctx context.Context, req *querypb.UpdateLoadConfigRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryCoordClient) UpdateResourceGroups 

func (m *GrpcQueryCoordClient) UpdateResourceGroups(ctx context.Context, req *querypb.UpdateResourceGroupsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

type GrpcQueryNodeClient 

type GrpcQueryNodeClient struct {
	Err error
}

func (*GrpcQueryNodeClient) Close 

func (m *GrpcQueryNodeClient) Close() error

func (*GrpcQueryNodeClient) Delete 

func (m *GrpcQueryNodeClient) Delete(ctx context.Context, in *querypb.DeleteRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryNodeClient) DeleteBatch 

func (m *GrpcQueryNodeClient) DeleteBatch(ctx context.Context, in *querypb.DeleteBatchRequest, opts ...grpc.CallOption) (*querypb.DeleteBatchResponse, error)

func (*GrpcQueryNodeClient) GetComponentStates 

func (m *GrpcQueryNodeClient) GetComponentStates(ctx context.Context, in *milvuspb.GetComponentStatesRequest, opts ...grpc.CallOption) (*milvuspb.ComponentStates, error)

func (*GrpcQueryNodeClient) GetDataDistribution 

func (m *GrpcQueryNodeClient) GetDataDistribution(ctx context.Context, in *querypb.GetDataDistributionRequest, opts ...grpc.CallOption) (*querypb.GetDataDistributionResponse, error)

func (*GrpcQueryNodeClient) GetMetrics 

func (m *GrpcQueryNodeClient) GetMetrics(ctx context.Context, in *milvuspb.GetMetricsRequest, opts ...grpc.CallOption) (*milvuspb.GetMetricsResponse, error)

func (*GrpcQueryNodeClient) GetSegmentInfo 

func (m *GrpcQueryNodeClient) GetSegmentInfo(ctx context.Context, in *querypb.GetSegmentInfoRequest, opts ...grpc.CallOption) (*querypb.GetSegmentInfoResponse, error)

func (*GrpcQueryNodeClient) GetStatistics 

func (m *GrpcQueryNodeClient) GetStatistics(ctx context.Context, in *querypb.GetStatisticsRequest, opts ...grpc.CallOption) (*internalpb.GetStatisticsResponse, error)

func (*GrpcQueryNodeClient) GetStatisticsChannel 

func (m *GrpcQueryNodeClient) GetStatisticsChannel(ctx context.Context, in *internalpb.GetStatisticsChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)

func (*GrpcQueryNodeClient) GetTimeTickChannel 

func (m *GrpcQueryNodeClient) GetTimeTickChannel(ctx context.Context, in *internalpb.GetTimeTickChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)

func (*GrpcQueryNodeClient) LoadPartitions 

func (m *GrpcQueryNodeClient) LoadPartitions(ctx context.Context, req *querypb.LoadPartitionsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryNodeClient) LoadSegments 

func (m *GrpcQueryNodeClient) LoadSegments(ctx context.Context, in *querypb.LoadSegmentsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryNodeClient) Query 

func (m *GrpcQueryNodeClient) Query(ctx context.Context, in *querypb.QueryRequest, opts ...grpc.CallOption) (*internalpb.RetrieveResults, error)

func (*GrpcQueryNodeClient) QuerySegments 

func (m *GrpcQueryNodeClient) QuerySegments(ctx context.Context, in *querypb.QueryRequest, opts ...grpc.CallOption) (*internalpb.RetrieveResults, error)

func (*GrpcQueryNodeClient) QueryStream 

func (m *GrpcQueryNodeClient) QueryStream(ctx context.Context, in *querypb.QueryRequest, opts ...grpc.CallOption) (querypb.QueryNode_QueryStreamClient, error)

func (*GrpcQueryNodeClient) QueryStreamSegments 

func (m *GrpcQueryNodeClient) QueryStreamSegments(ctx context.Context, in *querypb.QueryRequest, opts ...grpc.CallOption) (querypb.QueryNode_QueryStreamSegmentsClient, error)

func (*GrpcQueryNodeClient) ReleaseCollection 

func (m *GrpcQueryNodeClient) ReleaseCollection(ctx context.Context, in *querypb.ReleaseCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryNodeClient) ReleasePartitions 

func (m *GrpcQueryNodeClient) ReleasePartitions(ctx context.Context, in *querypb.ReleasePartitionsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryNodeClient) ReleaseSegments 

func (m *GrpcQueryNodeClient) ReleaseSegments(ctx context.Context, in *querypb.ReleaseSegmentsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryNodeClient) Search 

func (m *GrpcQueryNodeClient) Search(ctx context.Context, in *querypb.SearchRequest, opts ...grpc.CallOption) (*internalpb.SearchResults, error)

func (*GrpcQueryNodeClient) SearchSegments 

func (m *GrpcQueryNodeClient) SearchSegments(ctx context.Context, in *querypb.SearchRequest, opts ...grpc.CallOption) (*internalpb.SearchResults, error)

func (*GrpcQueryNodeClient) ShowConfigurations 

func (m *GrpcQueryNodeClient) ShowConfigurations(ctx context.Context, in *internalpb.ShowConfigurationsRequest, opts ...grpc.CallOption) (*internalpb.ShowConfigurationsResponse, error)

func (*GrpcQueryNodeClient) SyncDistribution 

func (m *GrpcQueryNodeClient) SyncDistribution(ctx context.Context, in *querypb.SyncDistributionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryNodeClient) SyncReplicaSegments 

func (m *GrpcQueryNodeClient) SyncReplicaSegments(ctx context.Context, in *querypb.SyncReplicaSegmentsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryNodeClient) UnsubDmChannel 

func (m *GrpcQueryNodeClient) UnsubDmChannel(ctx context.Context, req *querypb.UnsubDmChannelRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcQueryNodeClient) WatchDmChannels 

func (m *GrpcQueryNodeClient) WatchDmChannels(ctx context.Context, in *querypb.WatchDmChannelsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

type GrpcRootCoordClient 

type GrpcRootCoordClient struct {
	Err error
}

func (*GrpcRootCoordClient) AllocID 

func (m *GrpcRootCoordClient) AllocID(ctx context.Context, in *rootcoordpb.AllocIDRequest, opts ...grpc.CallOption) (*rootcoordpb.AllocIDResponse, error)

func (*GrpcRootCoordClient) AllocTimestamp 

func (m *GrpcRootCoordClient) AllocTimestamp(ctx context.Context, in *rootcoordpb.AllocTimestampRequest, opts ...grpc.CallOption) (*rootcoordpb.AllocTimestampResponse, error)

func (*GrpcRootCoordClient) AlterAlias 

func (m *GrpcRootCoordClient) AlterAlias(ctx context.Context, in *milvuspb.AlterAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) AlterCollection 

func (m *GrpcRootCoordClient) AlterCollection(ctx context.Context, in *milvuspb.AlterCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) AlterDatabase 

func (m *GrpcRootCoordClient) AlterDatabase(ctx context.Context, in *rootcoordpb.AlterDatabaseRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) BackupRBAC 

func (m *GrpcRootCoordClient) BackupRBAC(ctx context.Context, in *milvuspb.BackupRBACMetaRequest, opts ...grpc.CallOption) (*milvuspb.BackupRBACMetaResponse, error)

func (*GrpcRootCoordClient) CheckHealth 

func (m *GrpcRootCoordClient) CheckHealth(ctx context.Context, in *milvuspb.CheckHealthRequest, opts ...grpc.CallOption) (*milvuspb.CheckHealthResponse, error)

func (*GrpcRootCoordClient) Close 

func (m *GrpcRootCoordClient) Close() error

func (*GrpcRootCoordClient) CreateAlias 

func (m *GrpcRootCoordClient) CreateAlias(ctx context.Context, in *milvuspb.CreateAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) CreateCollection 

func (m *GrpcRootCoordClient) CreateCollection(ctx context.Context, in *milvuspb.CreateCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) CreateCredential 

func (m *GrpcRootCoordClient) CreateCredential(ctx context.Context, in *internalpb.CredentialInfo, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) CreateDatabase 

func (m *GrpcRootCoordClient) CreateDatabase(ctx context.Context, in *milvuspb.CreateDatabaseRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) CreatePartition 

func (m *GrpcRootCoordClient) CreatePartition(ctx context.Context, in *milvuspb.CreatePartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) CreatePrivilegeGroup 

func (m *GrpcRootCoordClient) CreatePrivilegeGroup(ctx context.Context, in *milvuspb.CreatePrivilegeGroupRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) CreateRole 

func (m *GrpcRootCoordClient) CreateRole(ctx context.Context, in *milvuspb.CreateRoleRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) DeleteCredential 

func (m *GrpcRootCoordClient) DeleteCredential(ctx context.Context, in *milvuspb.DeleteCredentialRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) DescribeAlias 

func (m *GrpcRootCoordClient) DescribeAlias(ctx context.Context, in *milvuspb.DescribeAliasRequest, opts ...grpc.CallOption) (*milvuspb.DescribeAliasResponse, error)

func (*GrpcRootCoordClient) DescribeCollection 

func (m *GrpcRootCoordClient) DescribeCollection(ctx context.Context, in *milvuspb.DescribeCollectionRequest, opts ...grpc.CallOption) (*milvuspb.DescribeCollectionResponse, error)

func (*GrpcRootCoordClient) DescribeCollectionInternal 

func (m *GrpcRootCoordClient) DescribeCollectionInternal(ctx context.Context, in *milvuspb.DescribeCollectionRequest, opts ...grpc.CallOption) (*milvuspb.DescribeCollectionResponse, error)

func (*GrpcRootCoordClient) DescribeDatabase 

func (m *GrpcRootCoordClient) DescribeDatabase(ctx context.Context, in *rootcoordpb.DescribeDatabaseRequest, opts ...grpc.CallOption) (*rootcoordpb.DescribeDatabaseResponse, error)

func (*GrpcRootCoordClient) DescribeSegment 

func (m *GrpcRootCoordClient) DescribeSegment(ctx context.Context, in *milvuspb.DescribeSegmentRequest, opts ...grpc.CallOption) (*milvuspb.DescribeSegmentResponse, error)

func (*GrpcRootCoordClient) DescribeSegments 

func (m *GrpcRootCoordClient) DescribeSegments(ctx context.Context, in *rootcoordpb.DescribeSegmentsRequest, opts ...grpc.CallOption) (*rootcoordpb.DescribeSegmentsResponse, error)

func (*GrpcRootCoordClient) DropAlias 

func (m *GrpcRootCoordClient) DropAlias(ctx context.Context, in *milvuspb.DropAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) DropCollection 

func (m *GrpcRootCoordClient) DropCollection(ctx context.Context, in *milvuspb.DropCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) DropDatabase 

func (m *GrpcRootCoordClient) DropDatabase(ctx context.Context, in *milvuspb.DropDatabaseRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) DropPartition 

func (m *GrpcRootCoordClient) DropPartition(ctx context.Context, in *milvuspb.DropPartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) DropPrivilegeGroup 

func (m *GrpcRootCoordClient) DropPrivilegeGroup(ctx context.Context, in *milvuspb.DropPrivilegeGroupRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) DropRole 

func (m *GrpcRootCoordClient) DropRole(ctx context.Context, in *milvuspb.DropRoleRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) GetComponentStates 

func (m *GrpcRootCoordClient) GetComponentStates(ctx context.Context, in *milvuspb.GetComponentStatesRequest, opts ...grpc.CallOption) (*milvuspb.ComponentStates, error)

func (*GrpcRootCoordClient) GetCredential 

func (m *GrpcRootCoordClient) GetCredential(ctx context.Context, in *rootcoordpb.GetCredentialRequest, opts ...grpc.CallOption) (*rootcoordpb.GetCredentialResponse, error)

func (*GrpcRootCoordClient) GetMetrics 

func (m *GrpcRootCoordClient) GetMetrics(ctx context.Context, in *milvuspb.GetMetricsRequest, opts ...grpc.CallOption) (*milvuspb.GetMetricsResponse, error)

func (*GrpcRootCoordClient) GetPChannelInfo 

func (m *GrpcRootCoordClient) GetPChannelInfo(ctx context.Context, in *rootcoordpb.GetPChannelInfoRequest, opts ...grpc.CallOption) (*rootcoordpb.GetPChannelInfoResponse, error)

func (*GrpcRootCoordClient) GetStatisticsChannel 

func (m *GrpcRootCoordClient) GetStatisticsChannel(ctx context.Context, in *internalpb.GetStatisticsChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)

func (*GrpcRootCoordClient) GetTimeTickChannel 

func (m *GrpcRootCoordClient) GetTimeTickChannel(ctx context.Context, in *internalpb.GetTimeTickChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)

func (*GrpcRootCoordClient) HasCollection 

func (m *GrpcRootCoordClient) HasCollection(ctx context.Context, in *milvuspb.HasCollectionRequest, opts ...grpc.CallOption) (*milvuspb.BoolResponse, error)

func (*GrpcRootCoordClient) HasPartition 

func (m *GrpcRootCoordClient) HasPartition(ctx context.Context, in *milvuspb.HasPartitionRequest, opts ...grpc.CallOption) (*milvuspb.BoolResponse, error)

func (*GrpcRootCoordClient) InvalidateCollectionMetaCache 

func (m *GrpcRootCoordClient) InvalidateCollectionMetaCache(ctx context.Context, in *proxypb.InvalidateCollMetaCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) ListAliases 

func (m *GrpcRootCoordClient) ListAliases(ctx context.Context, in *milvuspb.ListAliasesRequest, opts ...grpc.CallOption) (*milvuspb.ListAliasesResponse, error)

func (*GrpcRootCoordClient) ListCredUsers 

func (m *GrpcRootCoordClient) ListCredUsers(ctx context.Context, in *milvuspb.ListCredUsersRequest, opts ...grpc.CallOption) (*milvuspb.ListCredUsersResponse, error)

func (*GrpcRootCoordClient) ListDatabases 

func (m *GrpcRootCoordClient) ListDatabases(ctx context.Context, in *milvuspb.ListDatabasesRequest, opts ...grpc.CallOption) (*milvuspb.ListDatabasesResponse, error)

func (*GrpcRootCoordClient) ListPolicy 

func (m *GrpcRootCoordClient) ListPolicy(ctx context.Context, in *internalpb.ListPolicyRequest, opts ...grpc.CallOption) (*internalpb.ListPolicyResponse, error)

func (*GrpcRootCoordClient) ListPrivilegeGroups 

func (m *GrpcRootCoordClient) ListPrivilegeGroups(ctx context.Context, in *milvuspb.ListPrivilegeGroupsRequest, opts ...grpc.CallOption) (*milvuspb.ListPrivilegeGroupsResponse, error)

func (*GrpcRootCoordClient) OperatePrivilege 

func (m *GrpcRootCoordClient) OperatePrivilege(ctx context.Context, in *milvuspb.OperatePrivilegeRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) OperatePrivilegeGroup 

func (m *GrpcRootCoordClient) OperatePrivilegeGroup(ctx context.Context, in *milvuspb.OperatePrivilegeGroupRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) OperateUserRole 

func (m *GrpcRootCoordClient) OperateUserRole(ctx context.Context, in *milvuspb.OperateUserRoleRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) RenameCollection 

func (m *GrpcRootCoordClient) RenameCollection(ctx context.Context, in *milvuspb.RenameCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) RestoreRBAC 

func (m *GrpcRootCoordClient) RestoreRBAC(ctx context.Context, in *milvuspb.RestoreRBACMetaRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) SegmentFlushCompleted 

func (m *GrpcRootCoordClient) SegmentFlushCompleted(ctx context.Context, in *datapb.SegmentFlushCompletedMsg, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) SelectGrant 

func (m *GrpcRootCoordClient) SelectGrant(ctx context.Context, in *milvuspb.SelectGrantRequest, opts ...grpc.CallOption) (*milvuspb.SelectGrantResponse, error)

func (*GrpcRootCoordClient) SelectRole 

func (m *GrpcRootCoordClient) SelectRole(ctx context.Context, in *milvuspb.SelectRoleRequest, opts ...grpc.CallOption) (*milvuspb.SelectRoleResponse, error)

func (*GrpcRootCoordClient) SelectUser 

func (m *GrpcRootCoordClient) SelectUser(ctx context.Context, in *milvuspb.SelectUserRequest, opts ...grpc.CallOption) (*milvuspb.SelectUserResponse, error)

func (*GrpcRootCoordClient) ShowCollections 

func (m *GrpcRootCoordClient) ShowCollections(ctx context.Context, in *milvuspb.ShowCollectionsRequest, opts ...grpc.CallOption) (*milvuspb.ShowCollectionsResponse, error)

func (*GrpcRootCoordClient) ShowConfigurations 

func (m *GrpcRootCoordClient) ShowConfigurations(ctx context.Context, in *internalpb.ShowConfigurationsRequest, opts ...grpc.CallOption) (*internalpb.ShowConfigurationsResponse, error)

func (*GrpcRootCoordClient) ShowPartitions 

func (m *GrpcRootCoordClient) ShowPartitions(ctx context.Context, in *milvuspb.ShowPartitionsRequest, opts ...grpc.CallOption) (*milvuspb.ShowPartitionsResponse, error)

func (*GrpcRootCoordClient) ShowPartitionsInternal 

func (m *GrpcRootCoordClient) ShowPartitionsInternal(ctx context.Context, in *milvuspb.ShowPartitionsRequest, opts ...grpc.CallOption) (*milvuspb.ShowPartitionsResponse, error)

func (*GrpcRootCoordClient) ShowSegments 

func (m *GrpcRootCoordClient) ShowSegments(ctx context.Context, in *milvuspb.ShowSegmentsRequest, opts ...grpc.CallOption) (*milvuspb.ShowSegmentsResponse, error)

func (*GrpcRootCoordClient) UpdateChannelTimeTick 

func (m *GrpcRootCoordClient) UpdateChannelTimeTick(ctx context.Context, in *internalpb.ChannelTimeTickMsg, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*GrpcRootCoordClient) UpdateCredential 

func (m *GrpcRootCoordClient) UpdateCredential(ctx context.Context, in *internalpb.CredentialInfo, opts ...grpc.CallOption) (*commonpb.Status, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.