querypb

package
v0.0.2-0...-5f4bad6 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	QueryCoord_GetComponentStates_FullMethodName         = "/milvus.proto.query.QueryCoord/GetComponentStates"
	QueryCoord_GetTimeTickChannel_FullMethodName         = "/milvus.proto.query.QueryCoord/GetTimeTickChannel"
	QueryCoord_GetStatisticsChannel_FullMethodName       = "/milvus.proto.query.QueryCoord/GetStatisticsChannel"
	QueryCoord_ShowCollections_FullMethodName            = "/milvus.proto.query.QueryCoord/ShowCollections"
	QueryCoord_ShowPartitions_FullMethodName             = "/milvus.proto.query.QueryCoord/ShowPartitions"
	QueryCoord_LoadPartitions_FullMethodName             = "/milvus.proto.query.QueryCoord/LoadPartitions"
	QueryCoord_ReleasePartitions_FullMethodName          = "/milvus.proto.query.QueryCoord/ReleasePartitions"
	QueryCoord_LoadCollection_FullMethodName             = "/milvus.proto.query.QueryCoord/LoadCollection"
	QueryCoord_ReleaseCollection_FullMethodName          = "/milvus.proto.query.QueryCoord/ReleaseCollection"
	QueryCoord_SyncNewCreatedPartition_FullMethodName    = "/milvus.proto.query.QueryCoord/SyncNewCreatedPartition"
	QueryCoord_GetPartitionStates_FullMethodName         = "/milvus.proto.query.QueryCoord/GetPartitionStates"
	QueryCoord_GetSegmentInfo_FullMethodName             = "/milvus.proto.query.QueryCoord/GetSegmentInfo"
	QueryCoord_LoadBalance_FullMethodName                = "/milvus.proto.query.QueryCoord/LoadBalance"
	QueryCoord_ShowConfigurations_FullMethodName         = "/milvus.proto.query.QueryCoord/ShowConfigurations"
	QueryCoord_GetMetrics_FullMethodName                 = "/milvus.proto.query.QueryCoord/GetMetrics"
	QueryCoord_GetReplicas_FullMethodName                = "/milvus.proto.query.QueryCoord/GetReplicas"
	QueryCoord_GetShardLeaders_FullMethodName            = "/milvus.proto.query.QueryCoord/GetShardLeaders"
	QueryCoord_CheckHealth_FullMethodName                = "/milvus.proto.query.QueryCoord/CheckHealth"
	QueryCoord_CreateResourceGroup_FullMethodName        = "/milvus.proto.query.QueryCoord/CreateResourceGroup"
	QueryCoord_UpdateResourceGroups_FullMethodName       = "/milvus.proto.query.QueryCoord/UpdateResourceGroups"
	QueryCoord_DropResourceGroup_FullMethodName          = "/milvus.proto.query.QueryCoord/DropResourceGroup"
	QueryCoord_TransferNode_FullMethodName               = "/milvus.proto.query.QueryCoord/TransferNode"
	QueryCoord_TransferReplica_FullMethodName            = "/milvus.proto.query.QueryCoord/TransferReplica"
	QueryCoord_ListResourceGroups_FullMethodName         = "/milvus.proto.query.QueryCoord/ListResourceGroups"
	QueryCoord_DescribeResourceGroup_FullMethodName      = "/milvus.proto.query.QueryCoord/DescribeResourceGroup"
	QueryCoord_ListCheckers_FullMethodName               = "/milvus.proto.query.QueryCoord/ListCheckers"
	QueryCoord_ActivateChecker_FullMethodName            = "/milvus.proto.query.QueryCoord/ActivateChecker"
	QueryCoord_DeactivateChecker_FullMethodName          = "/milvus.proto.query.QueryCoord/DeactivateChecker"
	QueryCoord_ListQueryNode_FullMethodName              = "/milvus.proto.query.QueryCoord/ListQueryNode"
	QueryCoord_GetQueryNodeDistribution_FullMethodName   = "/milvus.proto.query.QueryCoord/GetQueryNodeDistribution"
	QueryCoord_SuspendBalance_FullMethodName             = "/milvus.proto.query.QueryCoord/SuspendBalance"
	QueryCoord_ResumeBalance_FullMethodName              = "/milvus.proto.query.QueryCoord/ResumeBalance"
	QueryCoord_SuspendNode_FullMethodName                = "/milvus.proto.query.QueryCoord/SuspendNode"
	QueryCoord_ResumeNode_FullMethodName                 = "/milvus.proto.query.QueryCoord/ResumeNode"
	QueryCoord_TransferSegment_FullMethodName            = "/milvus.proto.query.QueryCoord/TransferSegment"
	QueryCoord_TransferChannel_FullMethodName            = "/milvus.proto.query.QueryCoord/TransferChannel"
	QueryCoord_CheckQueryNodeDistribution_FullMethodName = "/milvus.proto.query.QueryCoord/CheckQueryNodeDistribution"
	QueryCoord_UpdateLoadConfig_FullMethodName           = "/milvus.proto.query.QueryCoord/UpdateLoadConfig"
)
View Source 
const (
	QueryNode_GetComponentStates_FullMethodName   = "/milvus.proto.query.QueryNode/GetComponentStates"
	QueryNode_GetTimeTickChannel_FullMethodName   = "/milvus.proto.query.QueryNode/GetTimeTickChannel"
	QueryNode_GetStatisticsChannel_FullMethodName = "/milvus.proto.query.QueryNode/GetStatisticsChannel"
	QueryNode_WatchDmChannels_FullMethodName      = "/milvus.proto.query.QueryNode/WatchDmChannels"
	QueryNode_UnsubDmChannel_FullMethodName       = "/milvus.proto.query.QueryNode/UnsubDmChannel"
	QueryNode_LoadSegments_FullMethodName         = "/milvus.proto.query.QueryNode/LoadSegments"
	QueryNode_ReleaseCollection_FullMethodName    = "/milvus.proto.query.QueryNode/ReleaseCollection"
	QueryNode_LoadPartitions_FullMethodName       = "/milvus.proto.query.QueryNode/LoadPartitions"
	QueryNode_ReleasePartitions_FullMethodName    = "/milvus.proto.query.QueryNode/ReleasePartitions"
	QueryNode_ReleaseSegments_FullMethodName      = "/milvus.proto.query.QueryNode/ReleaseSegments"
	QueryNode_GetSegmentInfo_FullMethodName       = "/milvus.proto.query.QueryNode/GetSegmentInfo"
	QueryNode_SyncReplicaSegments_FullMethodName  = "/milvus.proto.query.QueryNode/SyncReplicaSegments"
	QueryNode_GetStatistics_FullMethodName        = "/milvus.proto.query.QueryNode/GetStatistics"
	QueryNode_Search_FullMethodName               = "/milvus.proto.query.QueryNode/Search"
	QueryNode_SearchSegments_FullMethodName       = "/milvus.proto.query.QueryNode/SearchSegments"
	QueryNode_Query_FullMethodName                = "/milvus.proto.query.QueryNode/Query"
	QueryNode_QueryStream_FullMethodName          = "/milvus.proto.query.QueryNode/QueryStream"
	QueryNode_QuerySegments_FullMethodName        = "/milvus.proto.query.QueryNode/QuerySegments"
	QueryNode_QueryStreamSegments_FullMethodName  = "/milvus.proto.query.QueryNode/QueryStreamSegments"
	QueryNode_ShowConfigurations_FullMethodName   = "/milvus.proto.query.QueryNode/ShowConfigurations"
	QueryNode_GetMetrics_FullMethodName           = "/milvus.proto.query.QueryNode/GetMetrics"
	QueryNode_GetDataDistribution_FullMethodName  = "/milvus.proto.query.QueryNode/GetDataDistribution"
	QueryNode_SyncDistribution_FullMethodName     = "/milvus.proto.query.QueryNode/SyncDistribution"
	QueryNode_Delete_FullMethodName               = "/milvus.proto.query.QueryNode/Delete"
	QueryNode_DeleteBatch_FullMethodName          = "/milvus.proto.query.QueryNode/DeleteBatch"
)

Variables

View Source 
var (
	LoadScope_name = map[int32]string{
		0: "Full",
		1: "Delta",
		2: "Index",
	}
	LoadScope_value = map[string]int32{
		"Full":  0,
		"Delta": 1,
		"Index": 2,
	}
)

Enum value maps for LoadScope.

View Source 
var (
	DataScope_name = map[int32]string{
		0: "UnKnown",
		1: "All",
		2: "Streaming",
		3: "Historical",
	}
	DataScope_value = map[string]int32{
		"UnKnown":    0,
		"All":        1,
		"Streaming":  2,
		"Historical": 3,
	}
)

Enum value maps for DataScope.

View Source 
var (
	PartitionState_name = map[int32]string{
		0: "NotExist",
		1: "NotPresent",
		2: "OnDisk",
		3: "PartialInMemory",
		4: "InMemory",
		5: "PartialInGPU",
		6: "InGPU",
	}
	PartitionState_value = map[string]int32{
		"NotExist":        0,
		"NotPresent":      1,
		"OnDisk":          2,
		"PartialInMemory": 3,
		"InMemory":        4,
		"PartialInGPU":    5,
		"InGPU":           6,
	}
)

Enum value maps for PartitionState.

View Source 
var (
	TriggerCondition_name = map[int32]string{
		0: "UnKnowCondition",
		1: "Handoff",
		2: "LoadBalance",
		3: "GrpcRequest",
		4: "NodeDown",
	}
	TriggerCondition_value = map[string]int32{
		"UnKnowCondition": 0,
		"Handoff":         1,
		"LoadBalance":     2,
		"GrpcRequest":     3,
		"NodeDown":        4,
	}
)

Enum value maps for TriggerCondition.

View Source 
var (
	LoadType_name = map[int32]string{
		0: "UnKnownType",
		1: "LoadPartition",
		2: "LoadCollection",
	}
	LoadType_value = map[string]int32{
		"UnKnownType":    0,
		"LoadPartition":  1,
		"LoadCollection": 2,
	}
)

Enum value maps for LoadType.

View Source 
var (
	LoadStatus_name = map[int32]string{
		0: "Invalid",
		1: "Loading",
		2: "Loaded",
	}
	LoadStatus_value = map[string]int32{
		"Invalid": 0,
		"Loading": 1,
		"Loaded":  2,
	}
)

Enum value maps for LoadStatus.

View Source 
var (
	SyncType_name = map[int32]string{
		0: "Remove",
		1: "Set",
		2: "Amend",
		3: "UpdateVersion",
		4: "UpdatePartitionStats",
	}
	SyncType_value = map[string]int32{
		"Remove":               0,
		"Set":                  1,
		"Amend":                2,
		"UpdateVersion":        3,
		"UpdatePartitionStats": 4,
	}
)

Enum value maps for SyncType.

View Source 
var File_query_coord_proto protoreflect.FileDescriptor
View Source 
var QueryCoord_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "milvus.proto.query.QueryCoord",
	HandlerType: (*QueryCoordServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetComponentStates",
			Handler:    _QueryCoord_GetComponentStates_Handler,
		},
		{
			MethodName: "GetTimeTickChannel",
			Handler:    _QueryCoord_GetTimeTickChannel_Handler,
		},
		{
			MethodName: "GetStatisticsChannel",
			Handler:    _QueryCoord_GetStatisticsChannel_Handler,
		},
		{
			MethodName: "ShowCollections",
			Handler:    _QueryCoord_ShowCollections_Handler,
		},
		{
			MethodName: "ShowPartitions",
			Handler:    _QueryCoord_ShowPartitions_Handler,
		},
		{
			MethodName: "LoadPartitions",
			Handler:    _QueryCoord_LoadPartitions_Handler,
		},
		{
			MethodName: "ReleasePartitions",
			Handler:    _QueryCoord_ReleasePartitions_Handler,
		},
		{
			MethodName: "LoadCollection",
			Handler:    _QueryCoord_LoadCollection_Handler,
		},
		{
			MethodName: "ReleaseCollection",
			Handler:    _QueryCoord_ReleaseCollection_Handler,
		},
		{
			MethodName: "SyncNewCreatedPartition",
			Handler:    _QueryCoord_SyncNewCreatedPartition_Handler,
		},
		{
			MethodName: "GetPartitionStates",
			Handler:    _QueryCoord_GetPartitionStates_Handler,
		},
		{
			MethodName: "GetSegmentInfo",
			Handler:    _QueryCoord_GetSegmentInfo_Handler,
		},
		{
			MethodName: "LoadBalance",
			Handler:    _QueryCoord_LoadBalance_Handler,
		},
		{
			MethodName: "ShowConfigurations",
			Handler:    _QueryCoord_ShowConfigurations_Handler,
		},
		{
			MethodName: "GetMetrics",
			Handler:    _QueryCoord_GetMetrics_Handler,
		},
		{
			MethodName: "GetReplicas",
			Handler:    _QueryCoord_GetReplicas_Handler,
		},
		{
			MethodName: "GetShardLeaders",
			Handler:    _QueryCoord_GetShardLeaders_Handler,
		},
		{
			MethodName: "CheckHealth",
			Handler:    _QueryCoord_CheckHealth_Handler,
		},
		{
			MethodName: "CreateResourceGroup",
			Handler:    _QueryCoord_CreateResourceGroup_Handler,
		},
		{
			MethodName: "UpdateResourceGroups",
			Handler:    _QueryCoord_UpdateResourceGroups_Handler,
		},
		{
			MethodName: "DropResourceGroup",
			Handler:    _QueryCoord_DropResourceGroup_Handler,
		},
		{
			MethodName: "TransferNode",
			Handler:    _QueryCoord_TransferNode_Handler,
		},
		{
			MethodName: "TransferReplica",
			Handler:    _QueryCoord_TransferReplica_Handler,
		},
		{
			MethodName: "ListResourceGroups",
			Handler:    _QueryCoord_ListResourceGroups_Handler,
		},
		{
			MethodName: "DescribeResourceGroup",
			Handler:    _QueryCoord_DescribeResourceGroup_Handler,
		},
		{
			MethodName: "ListCheckers",
			Handler:    _QueryCoord_ListCheckers_Handler,
		},
		{
			MethodName: "ActivateChecker",
			Handler:    _QueryCoord_ActivateChecker_Handler,
		},
		{
			MethodName: "DeactivateChecker",
			Handler:    _QueryCoord_DeactivateChecker_Handler,
		},
		{
			MethodName: "ListQueryNode",
			Handler:    _QueryCoord_ListQueryNode_Handler,
		},
		{
			MethodName: "GetQueryNodeDistribution",
			Handler:    _QueryCoord_GetQueryNodeDistribution_Handler,
		},
		{
			MethodName: "SuspendBalance",
			Handler:    _QueryCoord_SuspendBalance_Handler,
		},
		{
			MethodName: "ResumeBalance",
			Handler:    _QueryCoord_ResumeBalance_Handler,
		},
		{
			MethodName: "SuspendNode",
			Handler:    _QueryCoord_SuspendNode_Handler,
		},
		{
			MethodName: "ResumeNode",
			Handler:    _QueryCoord_ResumeNode_Handler,
		},
		{
			MethodName: "TransferSegment",
			Handler:    _QueryCoord_TransferSegment_Handler,
		},
		{
			MethodName: "TransferChannel",
			Handler:    _QueryCoord_TransferChannel_Handler,
		},
		{
			MethodName: "CheckQueryNodeDistribution",
			Handler:    _QueryCoord_CheckQueryNodeDistribution_Handler,
		},
		{
			MethodName: "UpdateLoadConfig",
			Handler:    _QueryCoord_UpdateLoadConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "query_coord.proto",
}

QueryCoord_ServiceDesc is the grpc.ServiceDesc for QueryCoord service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var QueryNode_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "milvus.proto.query.QueryNode",
	HandlerType: (*QueryNodeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetComponentStates",
			Handler:    _QueryNode_GetComponentStates_Handler,
		},
		{
			MethodName: "GetTimeTickChannel",
			Handler:    _QueryNode_GetTimeTickChannel_Handler,
		},
		{
			MethodName: "GetStatisticsChannel",
			Handler:    _QueryNode_GetStatisticsChannel_Handler,
		},
		{
			MethodName: "WatchDmChannels",
			Handler:    _QueryNode_WatchDmChannels_Handler,
		},
		{
			MethodName: "UnsubDmChannel",
			Handler:    _QueryNode_UnsubDmChannel_Handler,
		},
		{
			MethodName: "LoadSegments",
			Handler:    _QueryNode_LoadSegments_Handler,
		},
		{
			MethodName: "ReleaseCollection",
			Handler:    _QueryNode_ReleaseCollection_Handler,
		},
		{
			MethodName: "LoadPartitions",
			Handler:    _QueryNode_LoadPartitions_Handler,
		},
		{
			MethodName: "ReleasePartitions",
			Handler:    _QueryNode_ReleasePartitions_Handler,
		},
		{
			MethodName: "ReleaseSegments",
			Handler:    _QueryNode_ReleaseSegments_Handler,
		},
		{
			MethodName: "GetSegmentInfo",
			Handler:    _QueryNode_GetSegmentInfo_Handler,
		},
		{
			MethodName: "SyncReplicaSegments",
			Handler:    _QueryNode_SyncReplicaSegments_Handler,
		},
		{
			MethodName: "GetStatistics",
			Handler:    _QueryNode_GetStatistics_Handler,
		},
		{
			MethodName: "Search",
			Handler:    _QueryNode_Search_Handler,
		},
		{
			MethodName: "SearchSegments",
			Handler:    _QueryNode_SearchSegments_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _QueryNode_Query_Handler,
		},
		{
			MethodName: "QuerySegments",
			Handler:    _QueryNode_QuerySegments_Handler,
		},
		{
			MethodName: "ShowConfigurations",
			Handler:    _QueryNode_ShowConfigurations_Handler,
		},
		{
			MethodName: "GetMetrics",
			Handler:    _QueryNode_GetMetrics_Handler,
		},
		{
			MethodName: "GetDataDistribution",
			Handler:    _QueryNode_GetDataDistribution_Handler,
		},
		{
			MethodName: "SyncDistribution",
			Handler:    _QueryNode_SyncDistribution_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _QueryNode_Delete_Handler,
		},
		{
			MethodName: "DeleteBatch",
			Handler:    _QueryNode_DeleteBatch_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "QueryStream",
			Handler:       _QueryNode_QueryStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "QueryStreamSegments",
			Handler:       _QueryNode_QueryStreamSegments_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "query_coord.proto",
}

QueryNode_ServiceDesc is the grpc.ServiceDesc for QueryNode service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterQueryCoordServer 

func RegisterQueryCoordServer(s grpc.ServiceRegistrar, srv QueryCoordServer)

func RegisterQueryNodeServer 

func RegisterQueryNodeServer(s grpc.ServiceRegistrar, srv QueryNodeServer)

Types

type ActivateCheckerRequest 

type ActivateCheckerRequest struct {
	Base      *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CheckerID int32             `protobuf:"varint,2,opt,name=checkerID,proto3" json:"checkerID,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivateCheckerRequest) Descriptor deprecated 

func (*ActivateCheckerRequest) Descriptor() ([]byte, []int)

Deprecated: Use ActivateCheckerRequest.ProtoReflect.Descriptor instead.

func (*ActivateCheckerRequest) GetBase 

func (x *ActivateCheckerRequest) GetBase() *commonpb.MsgBase

func (*ActivateCheckerRequest) GetCheckerID 

func (x *ActivateCheckerRequest) GetCheckerID() int32

func (*ActivateCheckerRequest) ProtoMessage 

func (*ActivateCheckerRequest) ProtoMessage()

func (*ActivateCheckerRequest) ProtoReflect 

func (x *ActivateCheckerRequest) ProtoReflect() protoreflect.Message

func (*ActivateCheckerRequest) Reset 

func (x *ActivateCheckerRequest) Reset()

func (*ActivateCheckerRequest) String 

func (x *ActivateCheckerRequest) String() string

type ChannelNodeInfo 

type ChannelNodeInfo struct {
	RwNodes []int64 `protobuf:"varint,6,rep,packed,name=rw_nodes,json=rwNodes,proto3" json:"rw_nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelNodeInfo) Descriptor deprecated 

func (*ChannelNodeInfo) Descriptor() ([]byte, []int)

Deprecated: Use ChannelNodeInfo.ProtoReflect.Descriptor instead.

func (*ChannelNodeInfo) GetRwNodes 

func (x *ChannelNodeInfo) GetRwNodes() []int64

func (*ChannelNodeInfo) ProtoMessage 

func (*ChannelNodeInfo) ProtoMessage()

func (*ChannelNodeInfo) ProtoReflect 

func (x *ChannelNodeInfo) ProtoReflect() protoreflect.Message

func (*ChannelNodeInfo) Reset 

func (x *ChannelNodeInfo) Reset()

func (*ChannelNodeInfo) String 

func (x *ChannelNodeInfo) String() string

type ChannelTarget 

type ChannelTarget struct {
	ChannelName       string             `protobuf:"bytes,1,opt,name=channelName,proto3" json:"channelName,omitempty"`
	DroppedSegmentIDs []int64            `protobuf:"varint,2,rep,packed,name=dropped_segmentIDs,json=droppedSegmentIDs,proto3" json:"dropped_segmentIDs,omitempty"`
	GrowingSegmentIDs []int64            `protobuf:"varint,3,rep,packed,name=growing_segmentIDs,json=growingSegmentIDs,proto3" json:"growing_segmentIDs,omitempty"`
	PartitionTargets  []*PartitionTarget `protobuf:"bytes,4,rep,name=partition_targets,json=partitionTargets,proto3" json:"partition_targets,omitempty"`
	SeekPosition      *msgpb.MsgPosition `protobuf:"bytes,5,opt,name=seek_position,json=seekPosition,proto3" json:"seek_position,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelTarget) Descriptor deprecated 

func (*ChannelTarget) Descriptor() ([]byte, []int)

Deprecated: Use ChannelTarget.ProtoReflect.Descriptor instead.

func (*ChannelTarget) GetChannelName 

func (x *ChannelTarget) GetChannelName() string

func (*ChannelTarget) GetDroppedSegmentIDs 

func (x *ChannelTarget) GetDroppedSegmentIDs() []int64

func (*ChannelTarget) GetGrowingSegmentIDs 

func (x *ChannelTarget) GetGrowingSegmentIDs() []int64

func (*ChannelTarget) GetPartitionTargets 

func (x *ChannelTarget) GetPartitionTargets() []*PartitionTarget

func (*ChannelTarget) GetSeekPosition 

func (x *ChannelTarget) GetSeekPosition() *msgpb.MsgPosition

func (*ChannelTarget) ProtoMessage 

func (*ChannelTarget) ProtoMessage()

func (*ChannelTarget) ProtoReflect 

func (x *ChannelTarget) ProtoReflect() protoreflect.Message

func (*ChannelTarget) Reset 

func (x *ChannelTarget) Reset()

func (*ChannelTarget) String 

func (x *ChannelTarget) String() string

type ChannelVersionInfo 

type ChannelVersionInfo struct {
	Channel    string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Collection int64  `protobuf:"varint,2,opt,name=collection,proto3" json:"collection,omitempty"`
	Version    int64  `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelVersionInfo) Descriptor deprecated 

func (*ChannelVersionInfo) Descriptor() ([]byte, []int)

Deprecated: Use ChannelVersionInfo.ProtoReflect.Descriptor instead.

func (*ChannelVersionInfo) GetChannel 

func (x *ChannelVersionInfo) GetChannel() string

func (*ChannelVersionInfo) GetCollection 

func (x *ChannelVersionInfo) GetCollection() int64

func (*ChannelVersionInfo) GetVersion 

func (x *ChannelVersionInfo) GetVersion() int64

func (*ChannelVersionInfo) ProtoMessage 

func (*ChannelVersionInfo) ProtoMessage()

func (*ChannelVersionInfo) ProtoReflect 

func (x *ChannelVersionInfo) ProtoReflect() protoreflect.Message

func (*ChannelVersionInfo) Reset 

func (x *ChannelVersionInfo) Reset()

func (*ChannelVersionInfo) String 

func (x *ChannelVersionInfo) String() string

type CheckQueryNodeDistributionRequest 

type CheckQueryNodeDistributionRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	SourceNodeID int64             `protobuf:"varint,3,opt,name=source_nodeID,json=sourceNodeID,proto3" json:"source_nodeID,omitempty"`
	TargetNodeID int64             `protobuf:"varint,4,opt,name=target_nodeID,json=targetNodeID,proto3" json:"target_nodeID,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckQueryNodeDistributionRequest) Descriptor deprecated 

func (*CheckQueryNodeDistributionRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckQueryNodeDistributionRequest.ProtoReflect.Descriptor instead.

func (*CheckQueryNodeDistributionRequest) GetBase 

func (x *CheckQueryNodeDistributionRequest) GetBase() *commonpb.MsgBase

func (*CheckQueryNodeDistributionRequest) GetSourceNodeID 

func (x *CheckQueryNodeDistributionRequest) GetSourceNodeID() int64

func (*CheckQueryNodeDistributionRequest) GetTargetNodeID 

func (x *CheckQueryNodeDistributionRequest) GetTargetNodeID() int64

func (*CheckQueryNodeDistributionRequest) ProtoMessage 

func (*CheckQueryNodeDistributionRequest) ProtoMessage()

func (*CheckQueryNodeDistributionRequest) ProtoReflect 

func (x *CheckQueryNodeDistributionRequest) ProtoReflect() protoreflect.Message

func (*CheckQueryNodeDistributionRequest) Reset 

func (x *CheckQueryNodeDistributionRequest) Reset()

func (*CheckQueryNodeDistributionRequest) String 

func (x *CheckQueryNodeDistributionRequest) String() string

type CheckerInfo 

type CheckerInfo struct {
	Id        int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Desc      string `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
	Activated bool   `protobuf:"varint,3,opt,name=activated,proto3" json:"activated,omitempty"`
	Found     bool   `protobuf:"varint,4,opt,name=found,proto3" json:"found,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckerInfo) Descriptor deprecated 

func (*CheckerInfo) Descriptor() ([]byte, []int)

Deprecated: Use CheckerInfo.ProtoReflect.Descriptor instead.

func (*CheckerInfo) GetActivated 

func (x *CheckerInfo) GetActivated() bool

func (*CheckerInfo) GetDesc 

func (x *CheckerInfo) GetDesc() string

func (*CheckerInfo) GetFound 

func (x *CheckerInfo) GetFound() bool

func (*CheckerInfo) GetId 

func (x *CheckerInfo) GetId() int32

func (*CheckerInfo) ProtoMessage 

func (*CheckerInfo) ProtoMessage()

func (*CheckerInfo) ProtoReflect 

func (x *CheckerInfo) ProtoReflect() protoreflect.Message

func (*CheckerInfo) Reset 

func (x *CheckerInfo) Reset()

func (*CheckerInfo) String 

func (x *CheckerInfo) String() string

type CollectionInfo 

type CollectionInfo struct {
	CollectionID         int64                      `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionIDs         []int64                    `protobuf:"varint,2,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	PartitionStates      []*PartitionStates         `protobuf:"bytes,3,rep,name=partition_states,json=partitionStates,proto3" json:"partition_states,omitempty"`
	LoadType             LoadType                   `protobuf:"varint,4,opt,name=load_type,json=loadType,proto3,enum=milvus.proto.query.LoadType" json:"load_type,omitempty"`
	Schema               *schemapb.CollectionSchema `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	ReleasedPartitionIDs []int64                    `` /* 129-byte string literal not displayed */
	InMemoryPercentage   int64                      `protobuf:"varint,7,opt,name=inMemory_percentage,json=inMemoryPercentage,proto3" json:"inMemory_percentage,omitempty"`
	ReplicaIds           []int64                    `protobuf:"varint,8,rep,packed,name=replica_ids,json=replicaIds,proto3" json:"replica_ids,omitempty"`
	ReplicaNumber        int32                      `protobuf:"varint,9,opt,name=replica_number,json=replicaNumber,proto3" json:"replica_number,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectionInfo) Descriptor deprecated 

func (*CollectionInfo) Descriptor() ([]byte, []int)

Deprecated: Use CollectionInfo.ProtoReflect.Descriptor instead.

func (*CollectionInfo) GetCollectionID 

func (x *CollectionInfo) GetCollectionID() int64

func (*CollectionInfo) GetInMemoryPercentage 

func (x *CollectionInfo) GetInMemoryPercentage() int64

func (*CollectionInfo) GetLoadType 

func (x *CollectionInfo) GetLoadType() LoadType

func (*CollectionInfo) GetPartitionIDs 

func (x *CollectionInfo) GetPartitionIDs() []int64

func (*CollectionInfo) GetPartitionStates 

func (x *CollectionInfo) GetPartitionStates() []*PartitionStates

func (*CollectionInfo) GetReleasedPartitionIDs 

func (x *CollectionInfo) GetReleasedPartitionIDs() []int64

func (*CollectionInfo) GetReplicaIds 

func (x *CollectionInfo) GetReplicaIds() []int64

func (*CollectionInfo) GetReplicaNumber 

func (x *CollectionInfo) GetReplicaNumber() int32

func (*CollectionInfo) GetSchema 

func (x *CollectionInfo) GetSchema() *schemapb.CollectionSchema

func (*CollectionInfo) ProtoMessage 

func (*CollectionInfo) ProtoMessage()

func (*CollectionInfo) ProtoReflect 

func (x *CollectionInfo) ProtoReflect() protoreflect.Message

func (*CollectionInfo) Reset 

func (x *CollectionInfo) Reset()

func (*CollectionInfo) String 

func (x *CollectionInfo) String() string

type CollectionLoadInfo 

type CollectionLoadInfo struct {
	CollectionID       int64           `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	ReleasedPartitions []int64         `protobuf:"varint,2,rep,packed,name=released_partitions,json=releasedPartitions,proto3" json:"released_partitions,omitempty"` // Deprecated: No longer used; kept for compatibility.
	ReplicaNumber      int32           `protobuf:"varint,3,opt,name=replica_number,json=replicaNumber,proto3" json:"replica_number,omitempty"`
	Status             LoadStatus      `protobuf:"varint,4,opt,name=status,proto3,enum=milvus.proto.query.LoadStatus" json:"status,omitempty"`
	FieldIndexID       map[int64]int64 `` /* 187-byte string literal not displayed */
	LoadType           LoadType        `protobuf:"varint,6,opt,name=load_type,json=loadType,proto3,enum=milvus.proto.query.LoadType" json:"load_type,omitempty"`
	RecoverTimes       int32           `protobuf:"varint,7,opt,name=recover_times,json=recoverTimes,proto3" json:"recover_times,omitempty"`
	LoadFields         []int64         `protobuf:"varint,8,rep,packed,name=load_fields,json=loadFields,proto3" json:"load_fields,omitempty"`
	DbID               int64           `protobuf:"varint,9,opt,name=dbID,proto3" json:"dbID,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectionLoadInfo) Descriptor deprecated 

func (*CollectionLoadInfo) Descriptor() ([]byte, []int)

Deprecated: Use CollectionLoadInfo.ProtoReflect.Descriptor instead.

func (*CollectionLoadInfo) GetCollectionID 

func (x *CollectionLoadInfo) GetCollectionID() int64

func (*CollectionLoadInfo) GetDbID 

func (x *CollectionLoadInfo) GetDbID() int64

func (*CollectionLoadInfo) GetFieldIndexID 

func (x *CollectionLoadInfo) GetFieldIndexID() map[int64]int64

func (*CollectionLoadInfo) GetLoadFields 

func (x *CollectionLoadInfo) GetLoadFields() []int64

func (*CollectionLoadInfo) GetLoadType 

func (x *CollectionLoadInfo) GetLoadType() LoadType

func (*CollectionLoadInfo) GetRecoverTimes 

func (x *CollectionLoadInfo) GetRecoverTimes() int32

func (*CollectionLoadInfo) GetReleasedPartitions 

func (x *CollectionLoadInfo) GetReleasedPartitions() []int64

func (*CollectionLoadInfo) GetReplicaNumber 

func (x *CollectionLoadInfo) GetReplicaNumber() int32

func (*CollectionLoadInfo) GetStatus 

func (x *CollectionLoadInfo) GetStatus() LoadStatus

func (*CollectionLoadInfo) ProtoMessage 

func (*CollectionLoadInfo) ProtoMessage()

func (*CollectionLoadInfo) ProtoReflect 

func (x *CollectionLoadInfo) ProtoReflect() protoreflect.Message

func (*CollectionLoadInfo) Reset 

func (x *CollectionLoadInfo) Reset()

func (*CollectionLoadInfo) String 

func (x *CollectionLoadInfo) String() string

type CollectionTarget 

type CollectionTarget struct {
	CollectionID   int64            `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	ChannelTargets []*ChannelTarget `protobuf:"bytes,2,rep,name=Channel_targets,json=ChannelTargets,proto3" json:"Channel_targets,omitempty"`
	Version        int64            `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectionTarget) Descriptor deprecated 

func (*CollectionTarget) Descriptor() ([]byte, []int)

Deprecated: Use CollectionTarget.ProtoReflect.Descriptor instead.

func (*CollectionTarget) GetChannelTargets 

func (x *CollectionTarget) GetChannelTargets() []*ChannelTarget

func (*CollectionTarget) GetCollectionID 

func (x *CollectionTarget) GetCollectionID() int64

func (*CollectionTarget) GetVersion 

func (x *CollectionTarget) GetVersion() int64

func (*CollectionTarget) ProtoMessage 

func (*CollectionTarget) ProtoMessage()

func (*CollectionTarget) ProtoReflect 

func (x *CollectionTarget) ProtoReflect() protoreflect.Message

func (*CollectionTarget) Reset 

func (x *CollectionTarget) Reset()

func (*CollectionTarget) String 

func (x *CollectionTarget) String() string

type DataScope 

type DataScope int32
const (
	DataScope_UnKnown    DataScope = 0
	DataScope_All        DataScope = 1
	DataScope_Streaming  DataScope = 2
	DataScope_Historical DataScope = 3
)

func (DataScope) Descriptor 

func (DataScope) Descriptor() protoreflect.EnumDescriptor

func (DataScope) Enum 

func (x DataScope) Enum() *DataScope

func (DataScope) EnumDescriptor deprecated 

func (DataScope) EnumDescriptor() ([]byte, []int)

Deprecated: Use DataScope.Descriptor instead.

func (DataScope) Number 

func (x DataScope) Number() protoreflect.EnumNumber

func (DataScope) String 

func (x DataScope) String() string

func (DataScope) Type 

func (DataScope) Type() protoreflect.EnumType

type DeactivateCheckerRequest 

type DeactivateCheckerRequest struct {
	Base      *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CheckerID int32             `protobuf:"varint,2,opt,name=checkerID,proto3" json:"checkerID,omitempty"`
	// contains filtered or unexported fields
}

func (*DeactivateCheckerRequest) Descriptor deprecated 

func (*DeactivateCheckerRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeactivateCheckerRequest.ProtoReflect.Descriptor instead.

func (*DeactivateCheckerRequest) GetBase 

func (x *DeactivateCheckerRequest) GetBase() *commonpb.MsgBase

func (*DeactivateCheckerRequest) GetCheckerID 

func (x *DeactivateCheckerRequest) GetCheckerID() int32

func (*DeactivateCheckerRequest) ProtoMessage 

func (*DeactivateCheckerRequest) ProtoMessage()

func (*DeactivateCheckerRequest) ProtoReflect 

func (x *DeactivateCheckerRequest) ProtoReflect() protoreflect.Message

func (*DeactivateCheckerRequest) Reset 

func (x *DeactivateCheckerRequest) Reset()

func (*DeactivateCheckerRequest) String 

func (x *DeactivateCheckerRequest) String() string

type DeleteBatchRequest 

type DeleteBatchRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CollectionId int64             `protobuf:"varint,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	PartitionId  int64             `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	VchannelName string            `protobuf:"bytes,4,opt,name=vchannel_name,json=vchannelName,proto3" json:"vchannel_name,omitempty"`
	SegmentIds   []int64           `protobuf:"varint,5,rep,packed,name=segment_ids,json=segmentIds,proto3" json:"segment_ids,omitempty"`
	PrimaryKeys  *schemapb.IDs     `protobuf:"bytes,6,opt,name=primary_keys,json=primaryKeys,proto3" json:"primary_keys,omitempty"`
	Timestamps   []uint64          `protobuf:"varint,7,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	Scope        DataScope         `protobuf:"varint,8,opt,name=scope,proto3,enum=milvus.proto.query.DataScope" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBatchRequest) Descriptor deprecated 

func (*DeleteBatchRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteBatchRequest.ProtoReflect.Descriptor instead.

func (*DeleteBatchRequest) GetBase 

func (x *DeleteBatchRequest) GetBase() *commonpb.MsgBase

func (*DeleteBatchRequest) GetCollectionId 

func (x *DeleteBatchRequest) GetCollectionId() int64

func (*DeleteBatchRequest) GetPartitionId 

func (x *DeleteBatchRequest) GetPartitionId() int64

func (*DeleteBatchRequest) GetPrimaryKeys 

func (x *DeleteBatchRequest) GetPrimaryKeys() *schemapb.IDs

func (*DeleteBatchRequest) GetScope 

func (x *DeleteBatchRequest) GetScope() DataScope

func (*DeleteBatchRequest) GetSegmentIds 

func (x *DeleteBatchRequest) GetSegmentIds() []int64

func (*DeleteBatchRequest) GetTimestamps 

func (x *DeleteBatchRequest) GetTimestamps() []uint64

func (*DeleteBatchRequest) GetVchannelName 

func (x *DeleteBatchRequest) GetVchannelName() string

func (*DeleteBatchRequest) ProtoMessage 

func (*DeleteBatchRequest) ProtoMessage()

func (*DeleteBatchRequest) ProtoReflect 

func (x *DeleteBatchRequest) ProtoReflect() protoreflect.Message

func (*DeleteBatchRequest) Reset 

func (x *DeleteBatchRequest) Reset()

func (*DeleteBatchRequest) String 

func (x *DeleteBatchRequest) String() string

type DeleteBatchResponse 

type DeleteBatchResponse struct {
	Status     *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	FailedIds  []int64          `protobuf:"varint,2,rep,packed,name=failed_ids,json=failedIds,proto3" json:"failed_ids,omitempty"`
	MissingIds []int64          `protobuf:"varint,3,rep,packed,name=missing_ids,json=missingIds,proto3" json:"missing_ids,omitempty"`
	// contains filtered or unexported fields
}

DeleteBatchResponse returns failed/missing segment ids cannot just using common.Status to handle partial failure logic

func (*DeleteBatchResponse) Descriptor deprecated 

func (*DeleteBatchResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteBatchResponse.ProtoReflect.Descriptor instead.

func (*DeleteBatchResponse) GetFailedIds 

func (x *DeleteBatchResponse) GetFailedIds() []int64

func (*DeleteBatchResponse) GetMissingIds 

func (x *DeleteBatchResponse) GetMissingIds() []int64

func (*DeleteBatchResponse) GetStatus 

func (x *DeleteBatchResponse) GetStatus() *commonpb.Status

func (*DeleteBatchResponse) ProtoMessage 

func (*DeleteBatchResponse) ProtoMessage()

func (*DeleteBatchResponse) ProtoReflect 

func (x *DeleteBatchResponse) ProtoReflect() protoreflect.Message

func (*DeleteBatchResponse) Reset 

func (x *DeleteBatchResponse) Reset()

func (*DeleteBatchResponse) String 

func (x *DeleteBatchResponse) String() string

type DeleteRequest 

type DeleteRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CollectionId int64             `protobuf:"varint,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	PartitionId  int64             `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	VchannelName string            `protobuf:"bytes,4,opt,name=vchannel_name,json=vchannelName,proto3" json:"vchannel_name,omitempty"`
	SegmentId    int64             `protobuf:"varint,5,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	PrimaryKeys  *schemapb.IDs     `protobuf:"bytes,6,opt,name=primary_keys,json=primaryKeys,proto3" json:"primary_keys,omitempty"`
	Timestamps   []uint64          `protobuf:"varint,7,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	Scope        DataScope         `protobuf:"varint,8,opt,name=scope,proto3,enum=milvus.proto.query.DataScope" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

func (*DeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetBase 

func (x *DeleteRequest) GetBase() *commonpb.MsgBase

func (*DeleteRequest) GetCollectionId 

func (x *DeleteRequest) GetCollectionId() int64

func (*DeleteRequest) GetPartitionId 

func (x *DeleteRequest) GetPartitionId() int64

func (*DeleteRequest) GetPrimaryKeys 

func (x *DeleteRequest) GetPrimaryKeys() *schemapb.IDs

func (*DeleteRequest) GetScope 

func (x *DeleteRequest) GetScope() DataScope

func (*DeleteRequest) GetSegmentId 

func (x *DeleteRequest) GetSegmentId() int64

func (*DeleteRequest) GetTimestamps 

func (x *DeleteRequest) GetTimestamps() []uint64

func (*DeleteRequest) GetVchannelName 

func (x *DeleteRequest) GetVchannelName() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

func (x *DeleteRequest) ProtoReflect() protoreflect.Message

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DescribeResourceGroupRequest 

type DescribeResourceGroupRequest struct {
	Base          *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	ResourceGroup string            `protobuf:"bytes,2,opt,name=resource_group,json=resourceGroup,proto3" json:"resource_group,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeResourceGroupRequest) Descriptor deprecated 

func (*DescribeResourceGroupRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeResourceGroupRequest.ProtoReflect.Descriptor instead.

func (*DescribeResourceGroupRequest) GetBase 

func (x *DescribeResourceGroupRequest) GetBase() *commonpb.MsgBase

func (*DescribeResourceGroupRequest) GetResourceGroup 

func (x *DescribeResourceGroupRequest) GetResourceGroup() string

func (*DescribeResourceGroupRequest) ProtoMessage 

func (*DescribeResourceGroupRequest) ProtoMessage()

func (*DescribeResourceGroupRequest) ProtoReflect 

func (x *DescribeResourceGroupRequest) ProtoReflect() protoreflect.Message

func (*DescribeResourceGroupRequest) Reset 

func (x *DescribeResourceGroupRequest) Reset()

func (*DescribeResourceGroupRequest) String 

func (x *DescribeResourceGroupRequest) String() string

type DescribeResourceGroupResponse 

type DescribeResourceGroupResponse struct {
	Status        *commonpb.Status   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	ResourceGroup *ResourceGroupInfo `protobuf:"bytes,2,opt,name=resource_group,json=resourceGroup,proto3" json:"resource_group,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeResourceGroupResponse) Descriptor deprecated 

func (*DescribeResourceGroupResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeResourceGroupResponse.ProtoReflect.Descriptor instead.

func (*DescribeResourceGroupResponse) GetResourceGroup 

func (x *DescribeResourceGroupResponse) GetResourceGroup() *ResourceGroupInfo

func (*DescribeResourceGroupResponse) GetStatus 

func (x *DescribeResourceGroupResponse) GetStatus() *commonpb.Status

func (*DescribeResourceGroupResponse) ProtoMessage 

func (*DescribeResourceGroupResponse) ProtoMessage()

func (*DescribeResourceGroupResponse) ProtoReflect 

func (x *DescribeResourceGroupResponse) ProtoReflect() protoreflect.Message

func (*DescribeResourceGroupResponse) Reset 

func (x *DescribeResourceGroupResponse) Reset()

func (*DescribeResourceGroupResponse) String 

func (x *DescribeResourceGroupResponse) String() string

type DmChannelWatchInfo 

type DmChannelWatchInfo struct {
	CollectionID int64   `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	DmChannel    string  `protobuf:"bytes,2,opt,name=dmChannel,proto3" json:"dmChannel,omitempty"`
	NodeIDLoaded int64   `protobuf:"varint,3,opt,name=nodeID_loaded,json=nodeIDLoaded,proto3" json:"nodeID_loaded,omitempty"`
	ReplicaID    int64   `protobuf:"varint,4,opt,name=replicaID,proto3" json:"replicaID,omitempty"`
	NodeIds      []int64 `protobuf:"varint,5,rep,packed,name=node_ids,json=nodeIds,proto3" json:"node_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*DmChannelWatchInfo) Descriptor deprecated 

func (*DmChannelWatchInfo) Descriptor() ([]byte, []int)

Deprecated: Use DmChannelWatchInfo.ProtoReflect.Descriptor instead.

func (*DmChannelWatchInfo) GetCollectionID 

func (x *DmChannelWatchInfo) GetCollectionID() int64

func (*DmChannelWatchInfo) GetDmChannel 

func (x *DmChannelWatchInfo) GetDmChannel() string

func (*DmChannelWatchInfo) GetNodeIDLoaded 

func (x *DmChannelWatchInfo) GetNodeIDLoaded() int64

func (*DmChannelWatchInfo) GetNodeIds 

func (x *DmChannelWatchInfo) GetNodeIds() []int64

func (*DmChannelWatchInfo) GetReplicaID 

func (x *DmChannelWatchInfo) GetReplicaID() int64

func (*DmChannelWatchInfo) ProtoMessage 

func (*DmChannelWatchInfo) ProtoMessage()

func (*DmChannelWatchInfo) ProtoReflect 

func (x *DmChannelWatchInfo) ProtoReflect() protoreflect.Message

func (*DmChannelWatchInfo) Reset 

func (x *DmChannelWatchInfo) Reset()

func (*DmChannelWatchInfo) String 

func (x *DmChannelWatchInfo) String() string

type FieldIndexInfo 

type FieldIndexInfo struct {
	FieldID int64 `protobuf:"varint,1,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	// deprecated
	EnableIndex         bool                     `protobuf:"varint,2,opt,name=enable_index,json=enableIndex,proto3" json:"enable_index,omitempty"`
	IndexName           string                   `protobuf:"bytes,3,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	IndexID             int64                    `protobuf:"varint,4,opt,name=indexID,proto3" json:"indexID,omitempty"`
	BuildID             int64                    `protobuf:"varint,5,opt,name=buildID,proto3" json:"buildID,omitempty"`
	IndexParams         []*commonpb.KeyValuePair `protobuf:"bytes,6,rep,name=index_params,json=indexParams,proto3" json:"index_params,omitempty"`
	IndexFilePaths      []string                 `protobuf:"bytes,7,rep,name=index_file_paths,json=indexFilePaths,proto3" json:"index_file_paths,omitempty"`
	IndexSize           int64                    `protobuf:"varint,8,opt,name=index_size,json=indexSize,proto3" json:"index_size,omitempty"`
	IndexVersion        int64                    `protobuf:"varint,9,opt,name=index_version,json=indexVersion,proto3" json:"index_version,omitempty"`
	NumRows             int64                    `protobuf:"varint,10,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	CurrentIndexVersion int32                    `protobuf:"varint,11,opt,name=current_index_version,json=currentIndexVersion,proto3" json:"current_index_version,omitempty"`
	IndexStoreVersion   int64                    `protobuf:"varint,12,opt,name=index_store_version,json=indexStoreVersion,proto3" json:"index_store_version,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldIndexInfo) Descriptor deprecated 

func (*FieldIndexInfo) Descriptor() ([]byte, []int)

Deprecated: Use FieldIndexInfo.ProtoReflect.Descriptor instead.

func (*FieldIndexInfo) GetBuildID 

func (x *FieldIndexInfo) GetBuildID() int64

func (*FieldIndexInfo) GetCurrentIndexVersion 

func (x *FieldIndexInfo) GetCurrentIndexVersion() int32

func (*FieldIndexInfo) GetEnableIndex 

func (x *FieldIndexInfo) GetEnableIndex() bool

func (*FieldIndexInfo) GetFieldID 

func (x *FieldIndexInfo) GetFieldID() int64

func (*FieldIndexInfo) GetIndexFilePaths 

func (x *FieldIndexInfo) GetIndexFilePaths() []string

func (*FieldIndexInfo) GetIndexID 

func (x *FieldIndexInfo) GetIndexID() int64

func (*FieldIndexInfo) GetIndexName 

func (x *FieldIndexInfo) GetIndexName() string

func (*FieldIndexInfo) GetIndexParams 

func (x *FieldIndexInfo) GetIndexParams() []*commonpb.KeyValuePair

func (*FieldIndexInfo) GetIndexSize 

func (x *FieldIndexInfo) GetIndexSize() int64

func (*FieldIndexInfo) GetIndexStoreVersion 

func (x *FieldIndexInfo) GetIndexStoreVersion() int64

func (*FieldIndexInfo) GetIndexVersion 

func (x *FieldIndexInfo) GetIndexVersion() int64

func (*FieldIndexInfo) GetNumRows 

func (x *FieldIndexInfo) GetNumRows() int64

func (*FieldIndexInfo) ProtoMessage 

func (*FieldIndexInfo) ProtoMessage()

func (*FieldIndexInfo) ProtoReflect 

func (x *FieldIndexInfo) ProtoReflect() protoreflect.Message

func (*FieldIndexInfo) Reset 

func (x *FieldIndexInfo) Reset()

func (*FieldIndexInfo) String 

func (x *FieldIndexInfo) String() string

type GetDataDistributionRequest 

type GetDataDistributionRequest struct {
	Base         *commonpb.MsgBase             `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Checkpoints  map[string]*msgpb.MsgPosition `` /* 163-byte string literal not displayed */
	LastUpdateTs int64                         `protobuf:"varint,3,opt,name=lastUpdateTs,proto3" json:"lastUpdateTs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataDistributionRequest) Descriptor deprecated 

func (*GetDataDistributionRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetDataDistributionRequest.ProtoReflect.Descriptor instead.

func (*GetDataDistributionRequest) GetBase 

func (x *GetDataDistributionRequest) GetBase() *commonpb.MsgBase

func (*GetDataDistributionRequest) GetCheckpoints 

func (x *GetDataDistributionRequest) GetCheckpoints() map[string]*msgpb.MsgPosition

func (*GetDataDistributionRequest) GetLastUpdateTs 

func (x *GetDataDistributionRequest) GetLastUpdateTs() int64

func (*GetDataDistributionRequest) ProtoMessage 

func (*GetDataDistributionRequest) ProtoMessage()

func (*GetDataDistributionRequest) ProtoReflect 

func (x *GetDataDistributionRequest) ProtoReflect() protoreflect.Message

func (*GetDataDistributionRequest) Reset 

func (x *GetDataDistributionRequest) Reset()

func (*GetDataDistributionRequest) String 

func (x *GetDataDistributionRequest) String() string

type GetDataDistributionResponse 

type GetDataDistributionResponse struct {
	Status          *commonpb.Status      `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	NodeID          int64                 `protobuf:"varint,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	Segments        []*SegmentVersionInfo `protobuf:"bytes,3,rep,name=segments,proto3" json:"segments,omitempty"`
	Channels        []*ChannelVersionInfo `protobuf:"bytes,4,rep,name=channels,proto3" json:"channels,omitempty"`
	LeaderViews     []*LeaderView         `protobuf:"bytes,5,rep,name=leader_views,json=leaderViews,proto3" json:"leader_views,omitempty"`
	LastModifyTs    int64                 `protobuf:"varint,6,opt,name=lastModifyTs,proto3" json:"lastModifyTs,omitempty"`
	MemCapacityInMB float64               `protobuf:"fixed64,7,opt,name=memCapacityInMB,proto3" json:"memCapacityInMB,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataDistributionResponse) Descriptor deprecated 

func (*GetDataDistributionResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetDataDistributionResponse.ProtoReflect.Descriptor instead.

func (*GetDataDistributionResponse) GetChannels 

func (x *GetDataDistributionResponse) GetChannels() []*ChannelVersionInfo

func (*GetDataDistributionResponse) GetLastModifyTs 

func (x *GetDataDistributionResponse) GetLastModifyTs() int64

func (*GetDataDistributionResponse) GetLeaderViews 

func (x *GetDataDistributionResponse) GetLeaderViews() []*LeaderView

func (*GetDataDistributionResponse) GetMemCapacityInMB 

func (x *GetDataDistributionResponse) GetMemCapacityInMB() float64

func (*GetDataDistributionResponse) GetNodeID 

func (x *GetDataDistributionResponse) GetNodeID() int64

func (*GetDataDistributionResponse) GetSegments 

func (x *GetDataDistributionResponse) GetSegments() []*SegmentVersionInfo

func (*GetDataDistributionResponse) GetStatus 

func (x *GetDataDistributionResponse) GetStatus() *commonpb.Status

func (*GetDataDistributionResponse) ProtoMessage 

func (*GetDataDistributionResponse) ProtoMessage()

func (*GetDataDistributionResponse) ProtoReflect 

func (x *GetDataDistributionResponse) ProtoReflect() protoreflect.Message

func (*GetDataDistributionResponse) Reset 

func (x *GetDataDistributionResponse) Reset()

func (*GetDataDistributionResponse) String 

func (x *GetDataDistributionResponse) String() string

type GetLoadInfoRequest 

type GetLoadInfoRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CollectionId int64             `protobuf:"varint,2,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLoadInfoRequest) Descriptor deprecated 

func (*GetLoadInfoRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetLoadInfoRequest.ProtoReflect.Descriptor instead.

func (*GetLoadInfoRequest) GetBase 

func (x *GetLoadInfoRequest) GetBase() *commonpb.MsgBase

func (*GetLoadInfoRequest) GetCollectionId 

func (x *GetLoadInfoRequest) GetCollectionId() int64

func (*GetLoadInfoRequest) ProtoMessage 

func (*GetLoadInfoRequest) ProtoMessage()

func (*GetLoadInfoRequest) ProtoReflect 

func (x *GetLoadInfoRequest) ProtoReflect() protoreflect.Message

func (*GetLoadInfoRequest) Reset 

func (x *GetLoadInfoRequest) Reset()

func (*GetLoadInfoRequest) String 

func (x *GetLoadInfoRequest) String() string

type GetLoadInfoResponse 

type GetLoadInfoResponse struct {
	Status     *commonpb.Status           `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Schema     *schemapb.CollectionSchema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	LoadType   LoadType                   `protobuf:"varint,3,opt,name=load_type,json=loadType,proto3,enum=milvus.proto.query.LoadType" json:"load_type,omitempty"`
	Partitions []int64                    `protobuf:"varint,4,rep,packed,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLoadInfoResponse) Descriptor deprecated 

func (*GetLoadInfoResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetLoadInfoResponse.ProtoReflect.Descriptor instead.

func (*GetLoadInfoResponse) GetLoadType 

func (x *GetLoadInfoResponse) GetLoadType() LoadType

func (*GetLoadInfoResponse) GetPartitions 

func (x *GetLoadInfoResponse) GetPartitions() []int64

func (*GetLoadInfoResponse) GetSchema 

func (x *GetLoadInfoResponse) GetSchema() *schemapb.CollectionSchema

func (*GetLoadInfoResponse) GetStatus 

func (x *GetLoadInfoResponse) GetStatus() *commonpb.Status

func (*GetLoadInfoResponse) ProtoMessage 

func (*GetLoadInfoResponse) ProtoMessage()

func (*GetLoadInfoResponse) ProtoReflect 

func (x *GetLoadInfoResponse) ProtoReflect() protoreflect.Message

func (*GetLoadInfoResponse) Reset 

func (x *GetLoadInfoResponse) Reset()

func (*GetLoadInfoResponse) String 

func (x *GetLoadInfoResponse) String() string

type GetPartitionStatesRequest 

type GetPartitionStatesRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbID         int64             `protobuf:"varint,2,opt,name=dbID,proto3" json:"dbID,omitempty"`
	CollectionID int64             `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionIDs []int64           `protobuf:"varint,4,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPartitionStatesRequest) Descriptor deprecated 

func (*GetPartitionStatesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetPartitionStatesRequest.ProtoReflect.Descriptor instead.

func (*GetPartitionStatesRequest) GetBase 

func (x *GetPartitionStatesRequest) GetBase() *commonpb.MsgBase

func (*GetPartitionStatesRequest) GetCollectionID 

func (x *GetPartitionStatesRequest) GetCollectionID() int64

func (*GetPartitionStatesRequest) GetDbID 

func (x *GetPartitionStatesRequest) GetDbID() int64

func (*GetPartitionStatesRequest) GetPartitionIDs 

func (x *GetPartitionStatesRequest) GetPartitionIDs() []int64

func (*GetPartitionStatesRequest) ProtoMessage 

func (*GetPartitionStatesRequest) ProtoMessage()

func (*GetPartitionStatesRequest) ProtoReflect 

func (x *GetPartitionStatesRequest) ProtoReflect() protoreflect.Message

func (*GetPartitionStatesRequest) Reset 

func (x *GetPartitionStatesRequest) Reset()

func (*GetPartitionStatesRequest) String 

func (x *GetPartitionStatesRequest) String() string

type GetPartitionStatesResponse 

type GetPartitionStatesResponse struct {
	Status                *commonpb.Status   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	PartitionDescriptions []*PartitionStates `protobuf:"bytes,2,rep,name=partition_descriptions,json=partitionDescriptions,proto3" json:"partition_descriptions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPartitionStatesResponse) Descriptor deprecated 

func (*GetPartitionStatesResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetPartitionStatesResponse.ProtoReflect.Descriptor instead.

func (*GetPartitionStatesResponse) GetPartitionDescriptions 

func (x *GetPartitionStatesResponse) GetPartitionDescriptions() []*PartitionStates

func (*GetPartitionStatesResponse) GetStatus 

func (x *GetPartitionStatesResponse) GetStatus() *commonpb.Status

func (*GetPartitionStatesResponse) ProtoMessage 

func (*GetPartitionStatesResponse) ProtoMessage()

func (*GetPartitionStatesResponse) ProtoReflect 

func (x *GetPartitionStatesResponse) ProtoReflect() protoreflect.Message

func (*GetPartitionStatesResponse) Reset 

func (x *GetPartitionStatesResponse) Reset()

func (*GetPartitionStatesResponse) String 

func (x *GetPartitionStatesResponse) String() string

type GetQueryNodeDistributionRequest 

type GetQueryNodeDistributionRequest struct {
	Base   *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	NodeID int64             `protobuf:"varint,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetQueryNodeDistributionRequest) Descriptor deprecated 

func (*GetQueryNodeDistributionRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetQueryNodeDistributionRequest.ProtoReflect.Descriptor instead.

func (*GetQueryNodeDistributionRequest) GetBase 

func (x *GetQueryNodeDistributionRequest) GetBase() *commonpb.MsgBase

func (*GetQueryNodeDistributionRequest) GetNodeID 

func (x *GetQueryNodeDistributionRequest) GetNodeID() int64

func (*GetQueryNodeDistributionRequest) ProtoMessage 

func (*GetQueryNodeDistributionRequest) ProtoMessage()

func (*GetQueryNodeDistributionRequest) ProtoReflect 

func (x *GetQueryNodeDistributionRequest) ProtoReflect() protoreflect.Message

func (*GetQueryNodeDistributionRequest) Reset 

func (x *GetQueryNodeDistributionRequest) Reset()

func (*GetQueryNodeDistributionRequest) String 

func (x *GetQueryNodeDistributionRequest) String() string

type GetQueryNodeDistributionResponse 

type GetQueryNodeDistributionResponse struct {
	Status           *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	ID               int64            `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
	ChannelNames     []string         `protobuf:"bytes,3,rep,name=channel_names,json=channelNames,proto3" json:"channel_names,omitempty"`
	SealedSegmentIDs []int64          `protobuf:"varint,4,rep,packed,name=sealed_segmentIDs,json=sealedSegmentIDs,proto3" json:"sealed_segmentIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetQueryNodeDistributionResponse) Descriptor deprecated 

func (*GetQueryNodeDistributionResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetQueryNodeDistributionResponse.ProtoReflect.Descriptor instead.

func (*GetQueryNodeDistributionResponse) GetChannelNames 

func (x *GetQueryNodeDistributionResponse) GetChannelNames() []string

func (*GetQueryNodeDistributionResponse) GetID 

func (x *GetQueryNodeDistributionResponse) GetID() int64

func (*GetQueryNodeDistributionResponse) GetSealedSegmentIDs 

func (x *GetQueryNodeDistributionResponse) GetSealedSegmentIDs() []int64

func (*GetQueryNodeDistributionResponse) GetStatus 

func (x *GetQueryNodeDistributionResponse) GetStatus() *commonpb.Status

func (*GetQueryNodeDistributionResponse) ProtoMessage 

func (*GetQueryNodeDistributionResponse) ProtoMessage()

func (*GetQueryNodeDistributionResponse) ProtoReflect 

func (x *GetQueryNodeDistributionResponse) ProtoReflect() protoreflect.Message

func (*GetQueryNodeDistributionResponse) Reset 

func (x *GetQueryNodeDistributionResponse) Reset()

func (*GetQueryNodeDistributionResponse) String 

func (x *GetQueryNodeDistributionResponse) String() string

type GetSegmentInfoRequest 

type GetSegmentInfoRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	SegmentIDs   []int64           `protobuf:"varint,2,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"` // deprecated
	CollectionID int64             `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSegmentInfoRequest) Descriptor deprecated 

func (*GetSegmentInfoRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSegmentInfoRequest.ProtoReflect.Descriptor instead.

func (*GetSegmentInfoRequest) GetBase 

func (x *GetSegmentInfoRequest) GetBase() *commonpb.MsgBase

func (*GetSegmentInfoRequest) GetCollectionID 

func (x *GetSegmentInfoRequest) GetCollectionID() int64

func (*GetSegmentInfoRequest) GetSegmentIDs 

func (x *GetSegmentInfoRequest) GetSegmentIDs() []int64

func (*GetSegmentInfoRequest) ProtoMessage 

func (*GetSegmentInfoRequest) ProtoMessage()

func (*GetSegmentInfoRequest) ProtoReflect 

func (x *GetSegmentInfoRequest) ProtoReflect() protoreflect.Message

func (*GetSegmentInfoRequest) Reset 

func (x *GetSegmentInfoRequest) Reset()

func (*GetSegmentInfoRequest) String 

func (x *GetSegmentInfoRequest) String() string

type GetSegmentInfoResponse 

type GetSegmentInfoResponse struct {
	Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Infos  []*SegmentInfo   `protobuf:"bytes,2,rep,name=infos,proto3" json:"infos,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSegmentInfoResponse) Descriptor deprecated 

func (*GetSegmentInfoResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetSegmentInfoResponse.ProtoReflect.Descriptor instead.

func (*GetSegmentInfoResponse) GetInfos 

func (x *GetSegmentInfoResponse) GetInfos() []*SegmentInfo

func (*GetSegmentInfoResponse) GetStatus 

func (x *GetSegmentInfoResponse) GetStatus() *commonpb.Status

func (*GetSegmentInfoResponse) ProtoMessage 

func (*GetSegmentInfoResponse) ProtoMessage()

func (*GetSegmentInfoResponse) ProtoReflect 

func (x *GetSegmentInfoResponse) ProtoReflect() protoreflect.Message

func (*GetSegmentInfoResponse) Reset 

func (x *GetSegmentInfoResponse) Reset()

func (*GetSegmentInfoResponse) String 

func (x *GetSegmentInfoResponse) String() string

type GetShardLeadersRequest 

type GetShardLeadersRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CollectionID int64             `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetShardLeadersRequest) Descriptor deprecated 

func (*GetShardLeadersRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetShardLeadersRequest.ProtoReflect.Descriptor instead.

func (*GetShardLeadersRequest) GetBase 

func (x *GetShardLeadersRequest) GetBase() *commonpb.MsgBase

func (*GetShardLeadersRequest) GetCollectionID 

func (x *GetShardLeadersRequest) GetCollectionID() int64

func (*GetShardLeadersRequest) ProtoMessage 

func (*GetShardLeadersRequest) ProtoMessage()

func (*GetShardLeadersRequest) ProtoReflect 

func (x *GetShardLeadersRequest) ProtoReflect() protoreflect.Message

func (*GetShardLeadersRequest) Reset 

func (x *GetShardLeadersRequest) Reset()

func (*GetShardLeadersRequest) String 

func (x *GetShardLeadersRequest) String() string

type GetShardLeadersResponse 

type GetShardLeadersResponse struct {
	Status *commonpb.Status    `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Shards []*ShardLeadersList `protobuf:"bytes,2,rep,name=shards,proto3" json:"shards,omitempty"`
	// contains filtered or unexported fields
}

func (*GetShardLeadersResponse) Descriptor deprecated 

func (*GetShardLeadersResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetShardLeadersResponse.ProtoReflect.Descriptor instead.

func (*GetShardLeadersResponse) GetShards 

func (x *GetShardLeadersResponse) GetShards() []*ShardLeadersList

func (*GetShardLeadersResponse) GetStatus 

func (x *GetShardLeadersResponse) GetStatus() *commonpb.Status

func (*GetShardLeadersResponse) ProtoMessage 

func (*GetShardLeadersResponse) ProtoMessage()

func (*GetShardLeadersResponse) ProtoReflect 

func (x *GetShardLeadersResponse) ProtoReflect() protoreflect.Message

func (*GetShardLeadersResponse) Reset 

func (x *GetShardLeadersResponse) Reset()

func (*GetShardLeadersResponse) String 

func (x *GetShardLeadersResponse) String() string

type GetStatisticsRequest 

type GetStatisticsRequest struct {
	Req             *internalpb.GetStatisticsRequest `protobuf:"bytes,1,opt,name=req,proto3" json:"req,omitempty"`
	DmlChannels     []string                         `protobuf:"bytes,2,rep,name=dml_channels,json=dmlChannels,proto3" json:"dml_channels,omitempty"`
	SegmentIDs      []int64                          `protobuf:"varint,3,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	FromShardLeader bool                             `protobuf:"varint,4,opt,name=from_shard_leader,json=fromShardLeader,proto3" json:"from_shard_leader,omitempty"`
	Scope           DataScope                        `protobuf:"varint,5,opt,name=scope,proto3,enum=milvus.proto.query.DataScope" json:"scope,omitempty"` // All, Streaming, Historical
	// contains filtered or unexported fields
}

func (*GetStatisticsRequest) Descriptor deprecated 

func (*GetStatisticsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetStatisticsRequest.ProtoReflect.Descriptor instead.

func (*GetStatisticsRequest) GetDmlChannels 

func (x *GetStatisticsRequest) GetDmlChannels() []string

func (*GetStatisticsRequest) GetFromShardLeader 

func (x *GetStatisticsRequest) GetFromShardLeader() bool

func (*GetStatisticsRequest) GetReq 

func (x *GetStatisticsRequest) GetReq() *internalpb.GetStatisticsRequest

func (*GetStatisticsRequest) GetScope 

func (x *GetStatisticsRequest) GetScope() DataScope

func (*GetStatisticsRequest) GetSegmentIDs 

func (x *GetStatisticsRequest) GetSegmentIDs() []int64

func (*GetStatisticsRequest) ProtoMessage 

func (*GetStatisticsRequest) ProtoMessage()

func (*GetStatisticsRequest) ProtoReflect 

func (x *GetStatisticsRequest) ProtoReflect() protoreflect.Message

func (*GetStatisticsRequest) Reset 

func (x *GetStatisticsRequest) Reset()

func (*GetStatisticsRequest) String 

func (x *GetStatisticsRequest) String() string

type HandoffSegmentsRequest 

type HandoffSegmentsRequest struct {
	Base             *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	SegmentInfos     []*SegmentInfo    `protobuf:"bytes,2,rep,name=segmentInfos,proto3" json:"segmentInfos,omitempty"`
	ReleasedSegments []int64           `protobuf:"varint,3,rep,packed,name=released_segments,json=releasedSegments,proto3" json:"released_segments,omitempty"`
	// contains filtered or unexported fields
}

func (*HandoffSegmentsRequest) Descriptor deprecated 

func (*HandoffSegmentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use HandoffSegmentsRequest.ProtoReflect.Descriptor instead.

func (*HandoffSegmentsRequest) GetBase 

func (x *HandoffSegmentsRequest) GetBase() *commonpb.MsgBase

func (*HandoffSegmentsRequest) GetReleasedSegments 

func (x *HandoffSegmentsRequest) GetReleasedSegments() []int64

func (*HandoffSegmentsRequest) GetSegmentInfos 

func (x *HandoffSegmentsRequest) GetSegmentInfos() []*SegmentInfo

func (*HandoffSegmentsRequest) ProtoMessage 

func (*HandoffSegmentsRequest) ProtoMessage()

func (*HandoffSegmentsRequest) ProtoReflect 

func (x *HandoffSegmentsRequest) ProtoReflect() protoreflect.Message

func (*HandoffSegmentsRequest) Reset 

func (x *HandoffSegmentsRequest) Reset()

func (*HandoffSegmentsRequest) String 

func (x *HandoffSegmentsRequest) String() string

type LeaderView 

type LeaderView struct {
	Collection             int64                        `protobuf:"varint,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Channel                string                       `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	SegmentDist            map[int64]*SegmentDist       `` /* 183-byte string literal not displayed */
	GrowingSegmentIDs      []int64                      `protobuf:"varint,4,rep,packed,name=growing_segmentIDs,json=growingSegmentIDs,proto3" json:"growing_segmentIDs,omitempty"`
	GrowingSegments        map[int64]*msgpb.MsgPosition `` /* 195-byte string literal not displayed */
	TargetVersion          int64                        `protobuf:"varint,6,opt,name=TargetVersion,proto3" json:"TargetVersion,omitempty"`
	NumOfGrowingRows       int64                        `protobuf:"varint,7,opt,name=num_of_growing_rows,json=numOfGrowingRows,proto3" json:"num_of_growing_rows,omitempty"`
	PartitionStatsVersions map[int64]int64              `` /* 219-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LeaderView) Descriptor deprecated 

func (*LeaderView) Descriptor() ([]byte, []int)

Deprecated: Use LeaderView.ProtoReflect.Descriptor instead.

func (*LeaderView) GetChannel 

func (x *LeaderView) GetChannel() string

func (*LeaderView) GetCollection 

func (x *LeaderView) GetCollection() int64

func (*LeaderView) GetGrowingSegmentIDs 

func (x *LeaderView) GetGrowingSegmentIDs() []int64

func (*LeaderView) GetGrowingSegments 

func (x *LeaderView) GetGrowingSegments() map[int64]*msgpb.MsgPosition

func (*LeaderView) GetNumOfGrowingRows 

func (x *LeaderView) GetNumOfGrowingRows() int64

func (*LeaderView) GetPartitionStatsVersions 

func (x *LeaderView) GetPartitionStatsVersions() map[int64]int64

func (*LeaderView) GetSegmentDist 

func (x *LeaderView) GetSegmentDist() map[int64]*SegmentDist

func (*LeaderView) GetTargetVersion 

func (x *LeaderView) GetTargetVersion() int64

func (*LeaderView) ProtoMessage 

func (*LeaderView) ProtoMessage()

func (*LeaderView) ProtoReflect 

func (x *LeaderView) ProtoReflect() protoreflect.Message

func (*LeaderView) Reset 

func (x *LeaderView) Reset()

func (*LeaderView) String 

func (x *LeaderView) String() string

type ListCheckersRequest 

type ListCheckersRequest struct {
	Base       *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CheckerIDs []int32           `protobuf:"varint,2,rep,packed,name=checkerIDs,proto3" json:"checkerIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCheckersRequest) Descriptor deprecated 

func (*ListCheckersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListCheckersRequest.ProtoReflect.Descriptor instead.

func (*ListCheckersRequest) GetBase 

func (x *ListCheckersRequest) GetBase() *commonpb.MsgBase

func (*ListCheckersRequest) GetCheckerIDs 

func (x *ListCheckersRequest) GetCheckerIDs() []int32

func (*ListCheckersRequest) ProtoMessage 

func (*ListCheckersRequest) ProtoMessage()

func (*ListCheckersRequest) ProtoReflect 

func (x *ListCheckersRequest) ProtoReflect() protoreflect.Message

func (*ListCheckersRequest) Reset 

func (x *ListCheckersRequest) Reset()

func (*ListCheckersRequest) String 

func (x *ListCheckersRequest) String() string

type ListCheckersResponse 

type ListCheckersResponse struct {
	Status       *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	CheckerInfos []*CheckerInfo   `protobuf:"bytes,2,rep,name=checkerInfos,proto3" json:"checkerInfos,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCheckersResponse) Descriptor deprecated 

func (*ListCheckersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListCheckersResponse.ProtoReflect.Descriptor instead.

func (*ListCheckersResponse) GetCheckerInfos 

func (x *ListCheckersResponse) GetCheckerInfos() []*CheckerInfo

func (*ListCheckersResponse) GetStatus 

func (x *ListCheckersResponse) GetStatus() *commonpb.Status

func (*ListCheckersResponse) ProtoMessage 

func (*ListCheckersResponse) ProtoMessage()

func (*ListCheckersResponse) ProtoReflect 

func (x *ListCheckersResponse) ProtoReflect() protoreflect.Message

func (*ListCheckersResponse) Reset 

func (x *ListCheckersResponse) Reset()

func (*ListCheckersResponse) String 

func (x *ListCheckersResponse) String() string

type ListQueryNodeRequest 

type ListQueryNodeRequest struct {
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueryNodeRequest) Descriptor deprecated 

func (*ListQueryNodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListQueryNodeRequest.ProtoReflect.Descriptor instead.

func (*ListQueryNodeRequest) GetBase 

func (x *ListQueryNodeRequest) GetBase() *commonpb.MsgBase

func (*ListQueryNodeRequest) ProtoMessage 

func (*ListQueryNodeRequest) ProtoMessage()

func (*ListQueryNodeRequest) ProtoReflect 

func (x *ListQueryNodeRequest) ProtoReflect() protoreflect.Message

func (*ListQueryNodeRequest) Reset 

func (x *ListQueryNodeRequest) Reset()

func (*ListQueryNodeRequest) String 

func (x *ListQueryNodeRequest) String() string

type ListQueryNodeResponse 

type ListQueryNodeResponse struct {
	Status    *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	NodeInfos []*NodeInfo      `protobuf:"bytes,2,rep,name=nodeInfos,proto3" json:"nodeInfos,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueryNodeResponse) Descriptor deprecated 

func (*ListQueryNodeResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListQueryNodeResponse.ProtoReflect.Descriptor instead.

func (*ListQueryNodeResponse) GetNodeInfos 

func (x *ListQueryNodeResponse) GetNodeInfos() []*NodeInfo

func (*ListQueryNodeResponse) GetStatus 

func (x *ListQueryNodeResponse) GetStatus() *commonpb.Status

func (*ListQueryNodeResponse) ProtoMessage 

func (*ListQueryNodeResponse) ProtoMessage()

func (*ListQueryNodeResponse) ProtoReflect 

func (x *ListQueryNodeResponse) ProtoReflect() protoreflect.Message

func (*ListQueryNodeResponse) Reset 

func (x *ListQueryNodeResponse) Reset()

func (*ListQueryNodeResponse) String 

func (x *ListQueryNodeResponse) String() string

type LoadBalanceRequest 

type LoadBalanceRequest struct {
	Base             *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	SourceNodeIDs    []int64           `protobuf:"varint,2,rep,packed,name=source_nodeIDs,json=sourceNodeIDs,proto3" json:"source_nodeIDs,omitempty"`
	BalanceReason    TriggerCondition  `` /* 142-byte string literal not displayed */
	DstNodeIDs       []int64           `protobuf:"varint,4,rep,packed,name=dst_nodeIDs,json=dstNodeIDs,proto3" json:"dst_nodeIDs,omitempty"`
	SealedSegmentIDs []int64           `protobuf:"varint,5,rep,packed,name=sealed_segmentIDs,json=sealedSegmentIDs,proto3" json:"sealed_segmentIDs,omitempty"`
	CollectionID     int64             `protobuf:"varint,6,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadBalanceRequest) Descriptor deprecated 

func (*LoadBalanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoadBalanceRequest.ProtoReflect.Descriptor instead.

func (*LoadBalanceRequest) GetBalanceReason 

func (x *LoadBalanceRequest) GetBalanceReason() TriggerCondition

func (*LoadBalanceRequest) GetBase 

func (x *LoadBalanceRequest) GetBase() *commonpb.MsgBase

func (*LoadBalanceRequest) GetCollectionID 

func (x *LoadBalanceRequest) GetCollectionID() int64

func (*LoadBalanceRequest) GetDstNodeIDs 

func (x *LoadBalanceRequest) GetDstNodeIDs() []int64

func (*LoadBalanceRequest) GetSealedSegmentIDs 

func (x *LoadBalanceRequest) GetSealedSegmentIDs() []int64

func (*LoadBalanceRequest) GetSourceNodeIDs 

func (x *LoadBalanceRequest) GetSourceNodeIDs() []int64

func (*LoadBalanceRequest) ProtoMessage 

func (*LoadBalanceRequest) ProtoMessage()

func (*LoadBalanceRequest) ProtoReflect 

func (x *LoadBalanceRequest) ProtoReflect() protoreflect.Message

func (*LoadBalanceRequest) Reset 

func (x *LoadBalanceRequest) Reset()

func (*LoadBalanceRequest) String 

func (x *LoadBalanceRequest) String() string

type LoadCollectionRequest 

type LoadCollectionRequest struct {
	Base          *commonpb.MsgBase          `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbID          int64                      `protobuf:"varint,2,opt,name=dbID,proto3" json:"dbID,omitempty"`
	CollectionID  int64                      `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	Schema        *schemapb.CollectionSchema `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	ReplicaNumber int32                      `protobuf:"varint,5,opt,name=replica_number,json=replicaNumber,proto3" json:"replica_number,omitempty"`
	// fieldID -> indexID
	FieldIndexID map[int64]int64 `` /* 187-byte string literal not displayed */
	Refresh      bool            `protobuf:"varint,7,opt,name=refresh,proto3" json:"refresh,omitempty"`
	// resource group names
	ResourceGroups []string `protobuf:"bytes,8,rep,name=resource_groups,json=resourceGroups,proto3" json:"resource_groups,omitempty"`
	LoadFields     []int64  `protobuf:"varint,9,rep,packed,name=load_fields,json=loadFields,proto3" json:"load_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadCollectionRequest) Descriptor deprecated 

func (*LoadCollectionRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoadCollectionRequest.ProtoReflect.Descriptor instead.

func (*LoadCollectionRequest) GetBase 

func (x *LoadCollectionRequest) GetBase() *commonpb.MsgBase

func (*LoadCollectionRequest) GetCollectionID 

func (x *LoadCollectionRequest) GetCollectionID() int64

func (*LoadCollectionRequest) GetDbID 

func (x *LoadCollectionRequest) GetDbID() int64

func (*LoadCollectionRequest) GetFieldIndexID 

func (x *LoadCollectionRequest) GetFieldIndexID() map[int64]int64

func (*LoadCollectionRequest) GetLoadFields 

func (x *LoadCollectionRequest) GetLoadFields() []int64

func (*LoadCollectionRequest) GetRefresh 

func (x *LoadCollectionRequest) GetRefresh() bool

func (*LoadCollectionRequest) GetReplicaNumber 

func (x *LoadCollectionRequest) GetReplicaNumber() int32

func (*LoadCollectionRequest) GetResourceGroups 

func (x *LoadCollectionRequest) GetResourceGroups() []string

func (*LoadCollectionRequest) GetSchema 

func (x *LoadCollectionRequest) GetSchema() *schemapb.CollectionSchema

func (*LoadCollectionRequest) ProtoMessage 

func (*LoadCollectionRequest) ProtoMessage()

func (*LoadCollectionRequest) ProtoReflect 

func (x *LoadCollectionRequest) ProtoReflect() protoreflect.Message

func (*LoadCollectionRequest) Reset 

func (x *LoadCollectionRequest) Reset()

func (*LoadCollectionRequest) String 

func (x *LoadCollectionRequest) String() string

type LoadMetaInfo 

type LoadMetaInfo struct {
	LoadType     LoadType `protobuf:"varint,1,opt,name=load_type,json=loadType,proto3,enum=milvus.proto.query.LoadType" json:"load_type,omitempty"`
	CollectionID int64    `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionIDs []int64  `protobuf:"varint,3,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	// Deprecated: Marked as deprecated in query_coord.proto.
	MetricType    string                   `protobuf:"bytes,4,opt,name=metric_type,json=metricType,proto3" json:"metric_type,omitempty"`
	DbName        string                   `protobuf:"bytes,5,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`                      // Only used for metrics label.
	ResourceGroup string                   `protobuf:"bytes,6,opt,name=resource_group,json=resourceGroup,proto3" json:"resource_group,omitempty"` // Only used for metrics label.
	LoadFields    []int64                  `protobuf:"varint,7,rep,packed,name=load_fields,json=loadFields,proto3" json:"load_fields,omitempty"`
	DbProperties  []*commonpb.KeyValuePair `protobuf:"bytes,8,rep,name=db_properties,json=dbProperties,proto3" json:"db_properties,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadMetaInfo) Descriptor deprecated 

func (*LoadMetaInfo) Descriptor() ([]byte, []int)

Deprecated: Use LoadMetaInfo.ProtoReflect.Descriptor instead.

func (*LoadMetaInfo) GetCollectionID 

func (x *LoadMetaInfo) GetCollectionID() int64

func (*LoadMetaInfo) GetDbName 

func (x *LoadMetaInfo) GetDbName() string

func (*LoadMetaInfo) GetDbProperties 

func (x *LoadMetaInfo) GetDbProperties() []*commonpb.KeyValuePair

func (*LoadMetaInfo) GetLoadFields 

func (x *LoadMetaInfo) GetLoadFields() []int64

func (*LoadMetaInfo) GetLoadType 

func (x *LoadMetaInfo) GetLoadType() LoadType

func (*LoadMetaInfo) GetMetricType deprecated 

func (x *LoadMetaInfo) GetMetricType() string

Deprecated: Marked as deprecated in query_coord.proto.

func (*LoadMetaInfo) GetPartitionIDs 

func (x *LoadMetaInfo) GetPartitionIDs() []int64

func (*LoadMetaInfo) GetResourceGroup 

func (x *LoadMetaInfo) GetResourceGroup() string

func (*LoadMetaInfo) ProtoMessage 

func (*LoadMetaInfo) ProtoMessage()

func (*LoadMetaInfo) ProtoReflect 

func (x *LoadMetaInfo) ProtoReflect() protoreflect.Message

func (*LoadMetaInfo) Reset 

func (x *LoadMetaInfo) Reset()

func (*LoadMetaInfo) String 

func (x *LoadMetaInfo) String() string

type LoadPartitionsRequest 

type LoadPartitionsRequest struct {
	Base          *commonpb.MsgBase          `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbID          int64                      `protobuf:"varint,2,opt,name=dbID,proto3" json:"dbID,omitempty"`
	CollectionID  int64                      `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionIDs  []int64                    `protobuf:"varint,4,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	Schema        *schemapb.CollectionSchema `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	ReplicaNumber int32                      `protobuf:"varint,6,opt,name=replica_number,json=replicaNumber,proto3" json:"replica_number,omitempty"`
	// fieldID -> indexID
	FieldIndexID map[int64]int64 `` /* 187-byte string literal not displayed */
	Refresh      bool            `protobuf:"varint,8,opt,name=refresh,proto3" json:"refresh,omitempty"`
	// resource group names
	ResourceGroups []string             `protobuf:"bytes,9,rep,name=resource_groups,json=resourceGroups,proto3" json:"resource_groups,omitempty"`
	IndexInfoList  []*indexpb.IndexInfo `protobuf:"bytes,10,rep,name=index_info_list,json=indexInfoList,proto3" json:"index_info_list,omitempty"`
	LoadFields     []int64              `protobuf:"varint,11,rep,packed,name=load_fields,json=loadFields,proto3" json:"load_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadPartitionsRequest) Descriptor deprecated 

func (*LoadPartitionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoadPartitionsRequest.ProtoReflect.Descriptor instead.

func (*LoadPartitionsRequest) GetBase 

func (x *LoadPartitionsRequest) GetBase() *commonpb.MsgBase

func (*LoadPartitionsRequest) GetCollectionID 

func (x *LoadPartitionsRequest) GetCollectionID() int64

func (*LoadPartitionsRequest) GetDbID 

func (x *LoadPartitionsRequest) GetDbID() int64

func (*LoadPartitionsRequest) GetFieldIndexID 

func (x *LoadPartitionsRequest) GetFieldIndexID() map[int64]int64

func (*LoadPartitionsRequest) GetIndexInfoList 

func (x *LoadPartitionsRequest) GetIndexInfoList() []*indexpb.IndexInfo

func (*LoadPartitionsRequest) GetLoadFields 

func (x *LoadPartitionsRequest) GetLoadFields() []int64

func (*LoadPartitionsRequest) GetPartitionIDs 

func (x *LoadPartitionsRequest) GetPartitionIDs() []int64

func (*LoadPartitionsRequest) GetRefresh 

func (x *LoadPartitionsRequest) GetRefresh() bool

func (*LoadPartitionsRequest) GetReplicaNumber 

func (x *LoadPartitionsRequest) GetReplicaNumber() int32

func (*LoadPartitionsRequest) GetResourceGroups 

func (x *LoadPartitionsRequest) GetResourceGroups() []string

func (*LoadPartitionsRequest) GetSchema 

func (x *LoadPartitionsRequest) GetSchema() *schemapb.CollectionSchema

func (*LoadPartitionsRequest) ProtoMessage 

func (*LoadPartitionsRequest) ProtoMessage()

func (*LoadPartitionsRequest) ProtoReflect 

func (x *LoadPartitionsRequest) ProtoReflect() protoreflect.Message

func (*LoadPartitionsRequest) Reset 

func (x *LoadPartitionsRequest) Reset()

func (*LoadPartitionsRequest) String 

func (x *LoadPartitionsRequest) String() string

type LoadScope 

type LoadScope int32
const (
	LoadScope_Full  LoadScope = 0
	LoadScope_Delta LoadScope = 1
	LoadScope_Index LoadScope = 2
)

func (LoadScope) Descriptor 

func (LoadScope) Descriptor() protoreflect.EnumDescriptor

func (LoadScope) Enum 

func (x LoadScope) Enum() *LoadScope

func (LoadScope) EnumDescriptor deprecated 

func (LoadScope) EnumDescriptor() ([]byte, []int)

Deprecated: Use LoadScope.Descriptor instead.

func (LoadScope) Number 

func (x LoadScope) Number() protoreflect.EnumNumber

func (LoadScope) String 

func (x LoadScope) String() string

func (LoadScope) Type 

func (LoadScope) Type() protoreflect.EnumType

type LoadSegmentsRequest 

type LoadSegmentsRequest struct {
	Base           *commonpb.MsgBase          `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DstNodeID      int64                      `protobuf:"varint,2,opt,name=dst_nodeID,json=dstNodeID,proto3" json:"dst_nodeID,omitempty"`
	Infos          []*SegmentLoadInfo         `protobuf:"bytes,3,rep,name=infos,proto3" json:"infos,omitempty"`
	Schema         *schemapb.CollectionSchema `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	SourceNodeID   int64                      `protobuf:"varint,5,opt,name=source_nodeID,json=sourceNodeID,proto3" json:"source_nodeID,omitempty"`
	CollectionID   int64                      `protobuf:"varint,6,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	LoadMeta       *LoadMetaInfo              `protobuf:"bytes,7,opt,name=load_meta,json=loadMeta,proto3" json:"load_meta,omitempty"`
	ReplicaID      int64                      `protobuf:"varint,8,opt,name=replicaID,proto3" json:"replicaID,omitempty"`
	DeltaPositions []*msgpb.MsgPosition       `protobuf:"bytes,9,rep,name=delta_positions,json=deltaPositions,proto3" json:"delta_positions,omitempty"` // keep it for compatibility of rolling upgrade from 2.2.x to 2.3
	Version        int64                      `protobuf:"varint,10,opt,name=version,proto3" json:"version,omitempty"`
	NeedTransfer   bool                       `protobuf:"varint,11,opt,name=need_transfer,json=needTransfer,proto3" json:"need_transfer,omitempty"`
	LoadScope      LoadScope                  `protobuf:"varint,12,opt,name=load_scope,json=loadScope,proto3,enum=milvus.proto.query.LoadScope" json:"load_scope,omitempty"`
	IndexInfoList  []*indexpb.IndexInfo       `protobuf:"bytes,13,rep,name=index_info_list,json=indexInfoList,proto3" json:"index_info_list,omitempty"`
	LazyLoad       bool                       `protobuf:"varint,14,opt,name=lazy_load,json=lazyLoad,proto3" json:"lazy_load,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadSegmentsRequest) Descriptor deprecated 

func (*LoadSegmentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoadSegmentsRequest.ProtoReflect.Descriptor instead.

func (*LoadSegmentsRequest) GetBase 

func (x *LoadSegmentsRequest) GetBase() *commonpb.MsgBase

func (*LoadSegmentsRequest) GetCollectionID 

func (x *LoadSegmentsRequest) GetCollectionID() int64

func (*LoadSegmentsRequest) GetDeltaPositions 

func (x *LoadSegmentsRequest) GetDeltaPositions() []*msgpb.MsgPosition

func (*LoadSegmentsRequest) GetDstNodeID 

func (x *LoadSegmentsRequest) GetDstNodeID() int64

func (*LoadSegmentsRequest) GetIndexInfoList 

func (x *LoadSegmentsRequest) GetIndexInfoList() []*indexpb.IndexInfo

func (*LoadSegmentsRequest) GetInfos 

func (x *LoadSegmentsRequest) GetInfos() []*SegmentLoadInfo

func (*LoadSegmentsRequest) GetLazyLoad 

func (x *LoadSegmentsRequest) GetLazyLoad() bool

func (*LoadSegmentsRequest) GetLoadMeta 

func (x *LoadSegmentsRequest) GetLoadMeta() *LoadMetaInfo

func (*LoadSegmentsRequest) GetLoadScope 

func (x *LoadSegmentsRequest) GetLoadScope() LoadScope

func (*LoadSegmentsRequest) GetNeedTransfer 

func (x *LoadSegmentsRequest) GetNeedTransfer() bool

func (*LoadSegmentsRequest) GetReplicaID 

func (x *LoadSegmentsRequest) GetReplicaID() int64

func (*LoadSegmentsRequest) GetSchema 

func (x *LoadSegmentsRequest) GetSchema() *schemapb.CollectionSchema

func (*LoadSegmentsRequest) GetSourceNodeID 

func (x *LoadSegmentsRequest) GetSourceNodeID() int64

func (*LoadSegmentsRequest) GetVersion 

func (x *LoadSegmentsRequest) GetVersion() int64

func (*LoadSegmentsRequest) ProtoMessage 

func (*LoadSegmentsRequest) ProtoMessage()

func (*LoadSegmentsRequest) ProtoReflect 

func (x *LoadSegmentsRequest) ProtoReflect() protoreflect.Message

func (*LoadSegmentsRequest) Reset 

func (x *LoadSegmentsRequest) Reset()

func (*LoadSegmentsRequest) String 

func (x *LoadSegmentsRequest) String() string

type LoadStatus 

type LoadStatus int32
const (
	LoadStatus_Invalid LoadStatus = 0
	LoadStatus_Loading LoadStatus = 1
	LoadStatus_Loaded  LoadStatus = 2
)

func (LoadStatus) Descriptor 

func (LoadStatus) Descriptor() protoreflect.EnumDescriptor

func (LoadStatus) Enum 

func (x LoadStatus) Enum() *LoadStatus

func (LoadStatus) EnumDescriptor deprecated 

func (LoadStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use LoadStatus.Descriptor instead.

func (LoadStatus) Number 

func (x LoadStatus) Number() protoreflect.EnumNumber

func (LoadStatus) String 

func (x LoadStatus) String() string

func (LoadStatus) Type 

func (LoadStatus) Type() protoreflect.EnumType

type LoadType 

type LoadType int32
const (
	LoadType_UnKnownType    LoadType = 0
	LoadType_LoadPartition  LoadType = 1
	LoadType_LoadCollection LoadType = 2
)

func (LoadType) Descriptor 

func (LoadType) Descriptor() protoreflect.EnumDescriptor

func (LoadType) Enum 

func (x LoadType) Enum() *LoadType

func (LoadType) EnumDescriptor deprecated 

func (LoadType) EnumDescriptor() ([]byte, []int)

Deprecated: Use LoadType.Descriptor instead.

func (LoadType) Number 

func (x LoadType) Number() protoreflect.EnumNumber

func (LoadType) String 

func (x LoadType) String() string

func (LoadType) Type 

func (LoadType) Type() protoreflect.EnumType

type NodeInfo 

type NodeInfo struct {
	ID      int64  `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	State   string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

func (*NodeInfo) Descriptor() ([]byte, []int)

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetAddress 

func (x *NodeInfo) GetAddress() string

func (*NodeInfo) GetID 

func (x *NodeInfo) GetID() int64

func (*NodeInfo) GetState 

func (x *NodeInfo) GetState() string

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

func (x *NodeInfo) ProtoReflect() protoreflect.Message

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

type PartitionLoadInfo 

type PartitionLoadInfo struct {
	CollectionID  int64           `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionID   int64           `protobuf:"varint,2,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	ReplicaNumber int32           `protobuf:"varint,3,opt,name=replica_number,json=replicaNumber,proto3" json:"replica_number,omitempty"` // Deprecated: No longer used; kept for compatibility.
	Status        LoadStatus      `protobuf:"varint,4,opt,name=status,proto3,enum=milvus.proto.query.LoadStatus" json:"status,omitempty"`
	FieldIndexID  map[int64]int64 `` // Deprecated: No longer used; kept for compatibility.
	/* 187-byte string literal not displayed */
	RecoverTimes int32 `protobuf:"varint,7,opt,name=recover_times,json=recoverTimes,proto3" json:"recover_times,omitempty"`
	// contains filtered or unexported fields
}

func (*PartitionLoadInfo) Descriptor deprecated 

func (*PartitionLoadInfo) Descriptor() ([]byte, []int)

Deprecated: Use PartitionLoadInfo.ProtoReflect.Descriptor instead.

func (*PartitionLoadInfo) GetCollectionID 

func (x *PartitionLoadInfo) GetCollectionID() int64

func (*PartitionLoadInfo) GetFieldIndexID 

func (x *PartitionLoadInfo) GetFieldIndexID() map[int64]int64

func (*PartitionLoadInfo) GetPartitionID 

func (x *PartitionLoadInfo) GetPartitionID() int64

func (*PartitionLoadInfo) GetRecoverTimes 

func (x *PartitionLoadInfo) GetRecoverTimes() int32

func (*PartitionLoadInfo) GetReplicaNumber 

func (x *PartitionLoadInfo) GetReplicaNumber() int32

func (*PartitionLoadInfo) GetStatus 

func (x *PartitionLoadInfo) GetStatus() LoadStatus

func (*PartitionLoadInfo) ProtoMessage 

func (*PartitionLoadInfo) ProtoMessage()

func (*PartitionLoadInfo) ProtoReflect 

func (x *PartitionLoadInfo) ProtoReflect() protoreflect.Message

func (*PartitionLoadInfo) Reset 

func (x *PartitionLoadInfo) Reset()

func (*PartitionLoadInfo) String 

func (x *PartitionLoadInfo) String() string

type PartitionState 

type PartitionState int32
const (
	PartitionState_NotExist        PartitionState = 0
	PartitionState_NotPresent      PartitionState = 1
	PartitionState_OnDisk          PartitionState = 2
	PartitionState_PartialInMemory PartitionState = 3
	PartitionState_InMemory        PartitionState = 4
	PartitionState_PartialInGPU    PartitionState = 5
	PartitionState_InGPU           PartitionState = 6
)

func (PartitionState) Descriptor 

func (PartitionState) Descriptor() protoreflect.EnumDescriptor

func (PartitionState) Enum 

func (x PartitionState) Enum() *PartitionState

func (PartitionState) EnumDescriptor deprecated 

func (PartitionState) EnumDescriptor() ([]byte, []int)

Deprecated: Use PartitionState.Descriptor instead.

func (PartitionState) Number 

func (x PartitionState) Number() protoreflect.EnumNumber

func (PartitionState) String 

func (x PartitionState) String() string

func (PartitionState) Type 

func (PartitionState) Type() protoreflect.EnumType

type PartitionStates 

type PartitionStates struct {
	PartitionID        int64          `protobuf:"varint,1,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	State              PartitionState `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.query.PartitionState" json:"state,omitempty"`
	InMemoryPercentage int64          `protobuf:"varint,3,opt,name=inMemory_percentage,json=inMemoryPercentage,proto3" json:"inMemory_percentage,omitempty"`
	// contains filtered or unexported fields
}

func (*PartitionStates) Descriptor deprecated 

func (*PartitionStates) Descriptor() ([]byte, []int)

Deprecated: Use PartitionStates.ProtoReflect.Descriptor instead.

func (*PartitionStates) GetInMemoryPercentage 

func (x *PartitionStates) GetInMemoryPercentage() int64

func (*PartitionStates) GetPartitionID 

func (x *PartitionStates) GetPartitionID() int64

func (*PartitionStates) GetState 

func (x *PartitionStates) GetState() PartitionState

func (*PartitionStates) ProtoMessage 

func (*PartitionStates) ProtoMessage()

func (*PartitionStates) ProtoReflect 

func (x *PartitionStates) ProtoReflect() protoreflect.Message

func (*PartitionStates) Reset 

func (x *PartitionStates) Reset()

func (*PartitionStates) String 

func (x *PartitionStates) String() string

type PartitionTarget 

type PartitionTarget struct {
	PartitionID int64            `protobuf:"varint,1,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	Segments    []*SegmentTarget `protobuf:"bytes,2,rep,name=segments,proto3" json:"segments,omitempty"`
	// contains filtered or unexported fields
}

func (*PartitionTarget) Descriptor deprecated 

func (*PartitionTarget) Descriptor() ([]byte, []int)

Deprecated: Use PartitionTarget.ProtoReflect.Descriptor instead.

func (*PartitionTarget) GetPartitionID 

func (x *PartitionTarget) GetPartitionID() int64

func (*PartitionTarget) GetSegments 

func (x *PartitionTarget) GetSegments() []*SegmentTarget

func (*PartitionTarget) ProtoMessage 

func (*PartitionTarget) ProtoMessage()

func (*PartitionTarget) ProtoReflect 

func (x *PartitionTarget) ProtoReflect() protoreflect.Message

func (*PartitionTarget) Reset 

func (x *PartitionTarget) Reset()

func (*PartitionTarget) String 

func (x *PartitionTarget) String() string

type QueryChannelInfo 

type QueryChannelInfo struct {
	CollectionID         int64              `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	QueryChannel         string             `protobuf:"bytes,2,opt,name=query_channel,json=queryChannel,proto3" json:"query_channel,omitempty"`
	QueryResultChannel   string             `protobuf:"bytes,3,opt,name=query_result_channel,json=queryResultChannel,proto3" json:"query_result_channel,omitempty"`
	GlobalSealedSegments []*SegmentInfo     `protobuf:"bytes,4,rep,name=global_sealed_segments,json=globalSealedSegments,proto3" json:"global_sealed_segments,omitempty"`
	SeekPosition         *msgpb.MsgPosition `protobuf:"bytes,5,opt,name=seek_position,json=seekPosition,proto3" json:"seek_position,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryChannelInfo) Descriptor deprecated 

func (*QueryChannelInfo) Descriptor() ([]byte, []int)

Deprecated: Use QueryChannelInfo.ProtoReflect.Descriptor instead.

func (*QueryChannelInfo) GetCollectionID 

func (x *QueryChannelInfo) GetCollectionID() int64

func (*QueryChannelInfo) GetGlobalSealedSegments 

func (x *QueryChannelInfo) GetGlobalSealedSegments() []*SegmentInfo

func (*QueryChannelInfo) GetQueryChannel 

func (x *QueryChannelInfo) GetQueryChannel() string

func (*QueryChannelInfo) GetQueryResultChannel 

func (x *QueryChannelInfo) GetQueryResultChannel() string

func (*QueryChannelInfo) GetSeekPosition 

func (x *QueryChannelInfo) GetSeekPosition() *msgpb.MsgPosition

func (*QueryChannelInfo) ProtoMessage 

func (*QueryChannelInfo) ProtoMessage()

func (*QueryChannelInfo) ProtoReflect 

func (x *QueryChannelInfo) ProtoReflect() protoreflect.Message

func (*QueryChannelInfo) Reset 

func (x *QueryChannelInfo) Reset()

func (*QueryChannelInfo) String 

func (x *QueryChannelInfo) String() string

type QueryCoordClient 

type QueryCoordClient interface {
	GetComponentStates(ctx context.Context, in *milvuspb.GetComponentStatesRequest, opts ...grpc.CallOption) (*milvuspb.ComponentStates, error)
	GetTimeTickChannel(ctx context.Context, in *internalpb.GetTimeTickChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)
	GetStatisticsChannel(ctx context.Context, in *internalpb.GetStatisticsChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)
	ShowCollections(ctx context.Context, in *ShowCollectionsRequest, opts ...grpc.CallOption) (*ShowCollectionsResponse, error)
	ShowPartitions(ctx context.Context, in *ShowPartitionsRequest, opts ...grpc.CallOption) (*ShowPartitionsResponse, error)
	LoadPartitions(ctx context.Context, in *LoadPartitionsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ReleasePartitions(ctx context.Context, in *ReleasePartitionsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	LoadCollection(ctx context.Context, in *LoadCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ReleaseCollection(ctx context.Context, in *ReleaseCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	SyncNewCreatedPartition(ctx context.Context, in *SyncNewCreatedPartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	GetPartitionStates(ctx context.Context, in *GetPartitionStatesRequest, opts ...grpc.CallOption) (*GetPartitionStatesResponse, error)
	GetSegmentInfo(ctx context.Context, in *GetSegmentInfoRequest, opts ...grpc.CallOption) (*GetSegmentInfoResponse, error)
	LoadBalance(ctx context.Context, in *LoadBalanceRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ShowConfigurations(ctx context.Context, in *internalpb.ShowConfigurationsRequest, opts ...grpc.CallOption) (*internalpb.ShowConfigurationsResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+8+--+Add+metrics+for+proxy
	GetMetrics(ctx context.Context, in *milvuspb.GetMetricsRequest, opts ...grpc.CallOption) (*milvuspb.GetMetricsResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+23+--+Multiple+memory+replication+design
	GetReplicas(ctx context.Context, in *milvuspb.GetReplicasRequest, opts ...grpc.CallOption) (*milvuspb.GetReplicasResponse, error)
	GetShardLeaders(ctx context.Context, in *GetShardLeadersRequest, opts ...grpc.CallOption) (*GetShardLeadersResponse, error)
	CheckHealth(ctx context.Context, in *milvuspb.CheckHealthRequest, opts ...grpc.CallOption) (*milvuspb.CheckHealthResponse, error)
	CreateResourceGroup(ctx context.Context, in *milvuspb.CreateResourceGroupRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	UpdateResourceGroups(ctx context.Context, in *UpdateResourceGroupsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DropResourceGroup(ctx context.Context, in *milvuspb.DropResourceGroupRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	TransferNode(ctx context.Context, in *milvuspb.TransferNodeRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	TransferReplica(ctx context.Context, in *TransferReplicaRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ListResourceGroups(ctx context.Context, in *milvuspb.ListResourceGroupsRequest, opts ...grpc.CallOption) (*milvuspb.ListResourceGroupsResponse, error)
	DescribeResourceGroup(ctx context.Context, in *DescribeResourceGroupRequest, opts ...grpc.CallOption) (*DescribeResourceGroupResponse, error)
	// ops interfaces
	ListCheckers(ctx context.Context, in *ListCheckersRequest, opts ...grpc.CallOption) (*ListCheckersResponse, error)
	ActivateChecker(ctx context.Context, in *ActivateCheckerRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DeactivateChecker(ctx context.Context, in *DeactivateCheckerRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ListQueryNode(ctx context.Context, in *ListQueryNodeRequest, opts ...grpc.CallOption) (*ListQueryNodeResponse, error)
	GetQueryNodeDistribution(ctx context.Context, in *GetQueryNodeDistributionRequest, opts ...grpc.CallOption) (*GetQueryNodeDistributionResponse, error)
	SuspendBalance(ctx context.Context, in *SuspendBalanceRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ResumeBalance(ctx context.Context, in *ResumeBalanceRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	SuspendNode(ctx context.Context, in *SuspendNodeRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ResumeNode(ctx context.Context, in *ResumeNodeRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	TransferSegment(ctx context.Context, in *TransferSegmentRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	TransferChannel(ctx context.Context, in *TransferChannelRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	CheckQueryNodeDistribution(ctx context.Context, in *CheckQueryNodeDistributionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	UpdateLoadConfig(ctx context.Context, in *UpdateLoadConfigRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
}

QueryCoordClient is the client API for QueryCoord service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewQueryCoordClient 

func NewQueryCoordClient(cc grpc.ClientConnInterface) QueryCoordClient

type QueryCoordServer 

type QueryCoordServer interface {
	GetComponentStates(context.Context, *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)
	GetTimeTickChannel(context.Context, *internalpb.GetTimeTickChannelRequest) (*milvuspb.StringResponse, error)
	GetStatisticsChannel(context.Context, *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)
	ShowCollections(context.Context, *ShowCollectionsRequest) (*ShowCollectionsResponse, error)
	ShowPartitions(context.Context, *ShowPartitionsRequest) (*ShowPartitionsResponse, error)
	LoadPartitions(context.Context, *LoadPartitionsRequest) (*commonpb.Status, error)
	ReleasePartitions(context.Context, *ReleasePartitionsRequest) (*commonpb.Status, error)
	LoadCollection(context.Context, *LoadCollectionRequest) (*commonpb.Status, error)
	ReleaseCollection(context.Context, *ReleaseCollectionRequest) (*commonpb.Status, error)
	SyncNewCreatedPartition(context.Context, *SyncNewCreatedPartitionRequest) (*commonpb.Status, error)
	GetPartitionStates(context.Context, *GetPartitionStatesRequest) (*GetPartitionStatesResponse, error)
	GetSegmentInfo(context.Context, *GetSegmentInfoRequest) (*GetSegmentInfoResponse, error)
	LoadBalance(context.Context, *LoadBalanceRequest) (*commonpb.Status, error)
	ShowConfigurations(context.Context, *internalpb.ShowConfigurationsRequest) (*internalpb.ShowConfigurationsResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+8+--+Add+metrics+for+proxy
	GetMetrics(context.Context, *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+23+--+Multiple+memory+replication+design
	GetReplicas(context.Context, *milvuspb.GetReplicasRequest) (*milvuspb.GetReplicasResponse, error)
	GetShardLeaders(context.Context, *GetShardLeadersRequest) (*GetShardLeadersResponse, error)
	CheckHealth(context.Context, *milvuspb.CheckHealthRequest) (*milvuspb.CheckHealthResponse, error)
	CreateResourceGroup(context.Context, *milvuspb.CreateResourceGroupRequest) (*commonpb.Status, error)
	UpdateResourceGroups(context.Context, *UpdateResourceGroupsRequest) (*commonpb.Status, error)
	DropResourceGroup(context.Context, *milvuspb.DropResourceGroupRequest) (*commonpb.Status, error)
	TransferNode(context.Context, *milvuspb.TransferNodeRequest) (*commonpb.Status, error)
	TransferReplica(context.Context, *TransferReplicaRequest) (*commonpb.Status, error)
	ListResourceGroups(context.Context, *milvuspb.ListResourceGroupsRequest) (*milvuspb.ListResourceGroupsResponse, error)
	DescribeResourceGroup(context.Context, *DescribeResourceGroupRequest) (*DescribeResourceGroupResponse, error)
	// ops interfaces
	ListCheckers(context.Context, *ListCheckersRequest) (*ListCheckersResponse, error)
	ActivateChecker(context.Context, *ActivateCheckerRequest) (*commonpb.Status, error)
	DeactivateChecker(context.Context, *DeactivateCheckerRequest) (*commonpb.Status, error)
	ListQueryNode(context.Context, *ListQueryNodeRequest) (*ListQueryNodeResponse, error)
	GetQueryNodeDistribution(context.Context, *GetQueryNodeDistributionRequest) (*GetQueryNodeDistributionResponse, error)
	SuspendBalance(context.Context, *SuspendBalanceRequest) (*commonpb.Status, error)
	ResumeBalance(context.Context, *ResumeBalanceRequest) (*commonpb.Status, error)
	SuspendNode(context.Context, *SuspendNodeRequest) (*commonpb.Status, error)
	ResumeNode(context.Context, *ResumeNodeRequest) (*commonpb.Status, error)
	TransferSegment(context.Context, *TransferSegmentRequest) (*commonpb.Status, error)
	TransferChannel(context.Context, *TransferChannelRequest) (*commonpb.Status, error)
	CheckQueryNodeDistribution(context.Context, *CheckQueryNodeDistributionRequest) (*commonpb.Status, error)
	UpdateLoadConfig(context.Context, *UpdateLoadConfigRequest) (*commonpb.Status, error)
}

QueryCoordServer is the server API for QueryCoord service. All implementations should embed UnimplementedQueryCoordServer for forward compatibility

type QueryNodeClient 

type QueryNodeClient interface {
	GetComponentStates(ctx context.Context, in *milvuspb.GetComponentStatesRequest, opts ...grpc.CallOption) (*milvuspb.ComponentStates, error)
	GetTimeTickChannel(ctx context.Context, in *internalpb.GetTimeTickChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)
	GetStatisticsChannel(ctx context.Context, in *internalpb.GetStatisticsChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)
	WatchDmChannels(ctx context.Context, in *WatchDmChannelsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	UnsubDmChannel(ctx context.Context, in *UnsubDmChannelRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	LoadSegments(ctx context.Context, in *LoadSegmentsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ReleaseCollection(ctx context.Context, in *ReleaseCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	LoadPartitions(ctx context.Context, in *LoadPartitionsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ReleasePartitions(ctx context.Context, in *ReleasePartitionsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ReleaseSegments(ctx context.Context, in *ReleaseSegmentsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	GetSegmentInfo(ctx context.Context, in *GetSegmentInfoRequest, opts ...grpc.CallOption) (*GetSegmentInfoResponse, error)
	SyncReplicaSegments(ctx context.Context, in *SyncReplicaSegmentsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	GetStatistics(ctx context.Context, in *GetStatisticsRequest, opts ...grpc.CallOption) (*internalpb.GetStatisticsResponse, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*internalpb.SearchResults, error)
	SearchSegments(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*internalpb.SearchResults, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*internalpb.RetrieveResults, error)
	QueryStream(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (QueryNode_QueryStreamClient, error)
	QuerySegments(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*internalpb.RetrieveResults, error)
	QueryStreamSegments(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (QueryNode_QueryStreamSegmentsClient, error)
	ShowConfigurations(ctx context.Context, in *internalpb.ShowConfigurationsRequest, opts ...grpc.CallOption) (*internalpb.ShowConfigurationsResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+8+--+Add+metrics+for+proxy
	GetMetrics(ctx context.Context, in *milvuspb.GetMetricsRequest, opts ...grpc.CallOption) (*milvuspb.GetMetricsResponse, error)
	GetDataDistribution(ctx context.Context, in *GetDataDistributionRequest, opts ...grpc.CallOption) (*GetDataDistributionResponse, error)
	SyncDistribution(ctx context.Context, in *SyncDistributionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	// DeleteBatch is the API to apply same delete data into multiple segments.
	// it's basically same as `Delete` but cost less memory pressure.
	DeleteBatch(ctx context.Context, in *DeleteBatchRequest, opts ...grpc.CallOption) (*DeleteBatchResponse, error)
}

QueryNodeClient is the client API for QueryNode service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewQueryNodeClient 

func NewQueryNodeClient(cc grpc.ClientConnInterface) QueryNodeClient

type QueryNodeServer 

type QueryNodeServer interface {
	GetComponentStates(context.Context, *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)
	GetTimeTickChannel(context.Context, *internalpb.GetTimeTickChannelRequest) (*milvuspb.StringResponse, error)
	GetStatisticsChannel(context.Context, *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)
	WatchDmChannels(context.Context, *WatchDmChannelsRequest) (*commonpb.Status, error)
	UnsubDmChannel(context.Context, *UnsubDmChannelRequest) (*commonpb.Status, error)
	LoadSegments(context.Context, *LoadSegmentsRequest) (*commonpb.Status, error)
	ReleaseCollection(context.Context, *ReleaseCollectionRequest) (*commonpb.Status, error)
	LoadPartitions(context.Context, *LoadPartitionsRequest) (*commonpb.Status, error)
	ReleasePartitions(context.Context, *ReleasePartitionsRequest) (*commonpb.Status, error)
	ReleaseSegments(context.Context, *ReleaseSegmentsRequest) (*commonpb.Status, error)
	GetSegmentInfo(context.Context, *GetSegmentInfoRequest) (*GetSegmentInfoResponse, error)
	SyncReplicaSegments(context.Context, *SyncReplicaSegmentsRequest) (*commonpb.Status, error)
	GetStatistics(context.Context, *GetStatisticsRequest) (*internalpb.GetStatisticsResponse, error)
	Search(context.Context, *SearchRequest) (*internalpb.SearchResults, error)
	SearchSegments(context.Context, *SearchRequest) (*internalpb.SearchResults, error)
	Query(context.Context, *QueryRequest) (*internalpb.RetrieveResults, error)
	QueryStream(*QueryRequest, QueryNode_QueryStreamServer) error
	QuerySegments(context.Context, *QueryRequest) (*internalpb.RetrieveResults, error)
	QueryStreamSegments(*QueryRequest, QueryNode_QueryStreamSegmentsServer) error
	ShowConfigurations(context.Context, *internalpb.ShowConfigurationsRequest) (*internalpb.ShowConfigurationsResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+8+--+Add+metrics+for+proxy
	GetMetrics(context.Context, *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error)
	GetDataDistribution(context.Context, *GetDataDistributionRequest) (*GetDataDistributionResponse, error)
	SyncDistribution(context.Context, *SyncDistributionRequest) (*commonpb.Status, error)
	Delete(context.Context, *DeleteRequest) (*commonpb.Status, error)
	// DeleteBatch is the API to apply same delete data into multiple segments.
	// it's basically same as `Delete` but cost less memory pressure.
	DeleteBatch(context.Context, *DeleteBatchRequest) (*DeleteBatchResponse, error)
}

QueryNodeServer is the server API for QueryNode service. All implementations should embed UnimplementedQueryNodeServer for forward compatibility

type QueryNode_QueryStreamClient 

type QueryNode_QueryStreamClient interface {
	Recv() (*internalpb.RetrieveResults, error)
	grpc.ClientStream
}

type QueryNode_QueryStreamSegmentsClient 

type QueryNode_QueryStreamSegmentsClient interface {
	Recv() (*internalpb.RetrieveResults, error)
	grpc.ClientStream
}

type QueryNode_QueryStreamSegmentsServer 

type QueryNode_QueryStreamSegmentsServer interface {
	Send(*internalpb.RetrieveResults) error
	grpc.ServerStream
}

type QueryNode_QueryStreamServer 

type QueryNode_QueryStreamServer interface {
	Send(*internalpb.RetrieveResults) error
	grpc.ServerStream
}

type QueryRequest 

type QueryRequest struct {
	Req             *internalpb.RetrieveRequest `protobuf:"bytes,1,opt,name=req,proto3" json:"req,omitempty"`
	DmlChannels     []string                    `protobuf:"bytes,2,rep,name=dml_channels,json=dmlChannels,proto3" json:"dml_channels,omitempty"`
	SegmentIDs      []int64                     `protobuf:"varint,3,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	FromShardLeader bool                        `protobuf:"varint,4,opt,name=from_shard_leader,json=fromShardLeader,proto3" json:"from_shard_leader,omitempty"`
	Scope           DataScope                   `protobuf:"varint,5,opt,name=scope,proto3,enum=milvus.proto.query.DataScope" json:"scope,omitempty"` // All, Streaming, Historical
	// contains filtered or unexported fields
}

func (*QueryRequest) Descriptor deprecated 

func (*QueryRequest) Descriptor() ([]byte, []int)

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetDmlChannels 

func (x *QueryRequest) GetDmlChannels() []string

func (*QueryRequest) GetFromShardLeader 

func (x *QueryRequest) GetFromShardLeader() bool

func (*QueryRequest) GetReq 

func (x *QueryRequest) GetReq() *internalpb.RetrieveRequest

func (*QueryRequest) GetScope 

func (x *QueryRequest) GetScope() DataScope

func (*QueryRequest) GetSegmentIDs 

func (x *QueryRequest) GetSegmentIDs() []int64

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

func (x *QueryRequest) ProtoReflect() protoreflect.Message

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type ReleaseCollectionRequest 

type ReleaseCollectionRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbID         int64             `protobuf:"varint,2,opt,name=dbID,proto3" json:"dbID,omitempty"`
	CollectionID int64             `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	NodeID       int64             `protobuf:"varint,4,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseCollectionRequest) Descriptor deprecated 

func (*ReleaseCollectionRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReleaseCollectionRequest.ProtoReflect.Descriptor instead.

func (*ReleaseCollectionRequest) GetBase 

func (x *ReleaseCollectionRequest) GetBase() *commonpb.MsgBase

func (*ReleaseCollectionRequest) GetCollectionID 

func (x *ReleaseCollectionRequest) GetCollectionID() int64

func (*ReleaseCollectionRequest) GetDbID 

func (x *ReleaseCollectionRequest) GetDbID() int64

func (*ReleaseCollectionRequest) GetNodeID 

func (x *ReleaseCollectionRequest) GetNodeID() int64

func (*ReleaseCollectionRequest) ProtoMessage 

func (*ReleaseCollectionRequest) ProtoMessage()

func (*ReleaseCollectionRequest) ProtoReflect 

func (x *ReleaseCollectionRequest) ProtoReflect() protoreflect.Message

func (*ReleaseCollectionRequest) Reset 

func (x *ReleaseCollectionRequest) Reset()

func (*ReleaseCollectionRequest) String 

func (x *ReleaseCollectionRequest) String() string

type ReleasePartitionsRequest 

type ReleasePartitionsRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbID         int64             `protobuf:"varint,2,opt,name=dbID,proto3" json:"dbID,omitempty"`
	CollectionID int64             `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionIDs []int64           `protobuf:"varint,4,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	NodeID       int64             `protobuf:"varint,5,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleasePartitionsRequest) Descriptor deprecated 

func (*ReleasePartitionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReleasePartitionsRequest.ProtoReflect.Descriptor instead.

func (*ReleasePartitionsRequest) GetBase 

func (x *ReleasePartitionsRequest) GetBase() *commonpb.MsgBase

func (*ReleasePartitionsRequest) GetCollectionID 

func (x *ReleasePartitionsRequest) GetCollectionID() int64

func (*ReleasePartitionsRequest) GetDbID 

func (x *ReleasePartitionsRequest) GetDbID() int64

func (*ReleasePartitionsRequest) GetNodeID 

func (x *ReleasePartitionsRequest) GetNodeID() int64

func (*ReleasePartitionsRequest) GetPartitionIDs 

func (x *ReleasePartitionsRequest) GetPartitionIDs() []int64

func (*ReleasePartitionsRequest) ProtoMessage 

func (*ReleasePartitionsRequest) ProtoMessage()

func (*ReleasePartitionsRequest) ProtoReflect 

func (x *ReleasePartitionsRequest) ProtoReflect() protoreflect.Message

func (*ReleasePartitionsRequest) Reset 

func (x *ReleasePartitionsRequest) Reset()

func (*ReleasePartitionsRequest) String 

func (x *ReleasePartitionsRequest) String() string

type ReleaseSegmentsRequest 

type ReleaseSegmentsRequest struct {
	Base   *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	NodeID int64             `protobuf:"varint,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// Not useful for now
	DbID         int64              `protobuf:"varint,3,opt,name=dbID,proto3" json:"dbID,omitempty"`
	CollectionID int64              `protobuf:"varint,4,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionIDs []int64            `protobuf:"varint,5,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	SegmentIDs   []int64            `protobuf:"varint,6,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	Scope        DataScope          `protobuf:"varint,7,opt,name=scope,proto3,enum=milvus.proto.query.DataScope" json:"scope,omitempty"` // All, Streaming, Historical
	Shard        string             `protobuf:"bytes,8,opt,name=shard,proto3" json:"shard,omitempty"`
	NeedTransfer bool               `protobuf:"varint,11,opt,name=need_transfer,json=needTransfer,proto3" json:"need_transfer,omitempty"`
	Checkpoint   *msgpb.MsgPosition `protobuf:"bytes,12,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"` // channel's check point
	// contains filtered or unexported fields
}

func (*ReleaseSegmentsRequest) Descriptor deprecated 

func (*ReleaseSegmentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReleaseSegmentsRequest.ProtoReflect.Descriptor instead.

func (*ReleaseSegmentsRequest) GetBase 

func (x *ReleaseSegmentsRequest) GetBase() *commonpb.MsgBase

func (*ReleaseSegmentsRequest) GetCheckpoint 

func (x *ReleaseSegmentsRequest) GetCheckpoint() *msgpb.MsgPosition

func (*ReleaseSegmentsRequest) GetCollectionID 

func (x *ReleaseSegmentsRequest) GetCollectionID() int64

func (*ReleaseSegmentsRequest) GetDbID 

func (x *ReleaseSegmentsRequest) GetDbID() int64

func (*ReleaseSegmentsRequest) GetNeedTransfer 

func (x *ReleaseSegmentsRequest) GetNeedTransfer() bool

func (*ReleaseSegmentsRequest) GetNodeID 

func (x *ReleaseSegmentsRequest) GetNodeID() int64

func (*ReleaseSegmentsRequest) GetPartitionIDs 

func (x *ReleaseSegmentsRequest) GetPartitionIDs() []int64

func (*ReleaseSegmentsRequest) GetScope 

func (x *ReleaseSegmentsRequest) GetScope() DataScope

func (*ReleaseSegmentsRequest) GetSegmentIDs 

func (x *ReleaseSegmentsRequest) GetSegmentIDs() []int64

func (*ReleaseSegmentsRequest) GetShard 

func (x *ReleaseSegmentsRequest) GetShard() string

func (*ReleaseSegmentsRequest) ProtoMessage 

func (*ReleaseSegmentsRequest) ProtoMessage()

func (*ReleaseSegmentsRequest) ProtoReflect 

func (x *ReleaseSegmentsRequest) ProtoReflect() protoreflect.Message

func (*ReleaseSegmentsRequest) Reset 

func (x *ReleaseSegmentsRequest) Reset()

func (*ReleaseSegmentsRequest) String 

func (x *ReleaseSegmentsRequest) String() string

type Replica 

type Replica struct {
	ID           int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	CollectionID int64 `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	// nodes and ro_nodes can only load sealed segment.
	// only manage the legacy querynode that not embedded in the streamingnode.
	Nodes         []int64 `protobuf:"varint,3,rep,packed,name=nodes,proto3" json:"nodes,omitempty"` // all (read and write) nodes. mutual exclusive with ro_nodes.
	ResourceGroup string  `protobuf:"bytes,4,opt,name=resource_group,json=resourceGroup,proto3" json:"resource_group,omitempty"`
	RoNodes       []int64 `protobuf:"varint,5,rep,packed,name=ro_nodes,json=roNodes,proto3" json:"ro_nodes,omitempty"` // the in-using node but should not be assigned to these replica.
	// cannot load segment on it anymore.
	ChannelNodeInfos map[string]*ChannelNodeInfo `` /* 199-byte string literal not displayed */
	// rw_sq_nodes and ro_sq_nodes can only watch channel and assign segment, will be removed in 3.0.
	// only manage the querynode embedded in the streamingnode.
	RwSqNodes []int64 `protobuf:"varint,7,rep,packed,name=rw_sq_nodes,json=rwSqNodes,proto3" json:"rw_sq_nodes,omitempty"` // all (read and write) nodes. mutual exclusive with ro_sq_nodes.
	RoSqNodes []int64 `protobuf:"varint,8,rep,packed,name=ro_sq_nodes,json=roSqNodes,proto3" json:"ro_sq_nodes,omitempty"` // the in-using node but should not be assigned to these replica.
	// contains filtered or unexported fields
}

func (*Replica) Descriptor deprecated 

func (*Replica) Descriptor() ([]byte, []int)

Deprecated: Use Replica.ProtoReflect.Descriptor instead.

func (*Replica) GetChannelNodeInfos 

func (x *Replica) GetChannelNodeInfos() map[string]*ChannelNodeInfo

func (*Replica) GetCollectionID 

func (x *Replica) GetCollectionID() int64

func (*Replica) GetID 

func (x *Replica) GetID() int64

func (*Replica) GetNodes 

func (x *Replica) GetNodes() []int64

func (*Replica) GetResourceGroup 

func (x *Replica) GetResourceGroup() string

func (*Replica) GetRoNodes 

func (x *Replica) GetRoNodes() []int64

func (*Replica) GetRoSqNodes 

func (x *Replica) GetRoSqNodes() []int64

func (*Replica) GetRwSqNodes 

func (x *Replica) GetRwSqNodes() []int64

func (*Replica) ProtoMessage 

func (*Replica) ProtoMessage()

func (*Replica) ProtoReflect 

func (x *Replica) ProtoReflect() protoreflect.Message

func (*Replica) Reset 

func (x *Replica) Reset()

func (*Replica) String 

func (x *Replica) String() string

type ReplicaSegmentsInfo 

type ReplicaSegmentsInfo struct {
	NodeId      int64   `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	PartitionId int64   `protobuf:"varint,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	SegmentIds  []int64 `protobuf:"varint,3,rep,packed,name=segment_ids,json=segmentIds,proto3" json:"segment_ids,omitempty"`
	Versions    []int64 `protobuf:"varint,4,rep,packed,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaSegmentsInfo) Descriptor deprecated 

func (*ReplicaSegmentsInfo) Descriptor() ([]byte, []int)

Deprecated: Use ReplicaSegmentsInfo.ProtoReflect.Descriptor instead.

func (*ReplicaSegmentsInfo) GetNodeId 

func (x *ReplicaSegmentsInfo) GetNodeId() int64

func (*ReplicaSegmentsInfo) GetPartitionId 

func (x *ReplicaSegmentsInfo) GetPartitionId() int64

func (*ReplicaSegmentsInfo) GetSegmentIds 

func (x *ReplicaSegmentsInfo) GetSegmentIds() []int64

func (*ReplicaSegmentsInfo) GetVersions 

func (x *ReplicaSegmentsInfo) GetVersions() []int64

func (*ReplicaSegmentsInfo) ProtoMessage 

func (*ReplicaSegmentsInfo) ProtoMessage()

func (*ReplicaSegmentsInfo) ProtoReflect 

func (x *ReplicaSegmentsInfo) ProtoReflect() protoreflect.Message

func (*ReplicaSegmentsInfo) Reset 

func (x *ReplicaSegmentsInfo) Reset()

func (*ReplicaSegmentsInfo) String 

func (x *ReplicaSegmentsInfo) String() string

type ResourceGroup 

type ResourceGroup struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Deprecated: Marked as deprecated in query_coord.proto.
	Capacity int32                     `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"` // capacity can be found in config.requests.nodeNum and config.limits.nodeNum.
	Nodes    []int64                   `protobuf:"varint,3,rep,packed,name=nodes,proto3" json:"nodes,omitempty"`
	Config   *rgpb.ResourceGroupConfig `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceGroup) Descriptor deprecated 

func (*ResourceGroup) Descriptor() ([]byte, []int)

Deprecated: Use ResourceGroup.ProtoReflect.Descriptor instead.

func (*ResourceGroup) GetCapacity deprecated 

func (x *ResourceGroup) GetCapacity() int32

Deprecated: Marked as deprecated in query_coord.proto.

func (*ResourceGroup) GetConfig 

func (x *ResourceGroup) GetConfig() *rgpb.ResourceGroupConfig

func (*ResourceGroup) GetName 

func (x *ResourceGroup) GetName() string

func (*ResourceGroup) GetNodes 

func (x *ResourceGroup) GetNodes() []int64

func (*ResourceGroup) ProtoMessage 

func (*ResourceGroup) ProtoMessage()

func (*ResourceGroup) ProtoReflect 

func (x *ResourceGroup) ProtoReflect() protoreflect.Message

func (*ResourceGroup) Reset 

func (x *ResourceGroup) Reset()

func (*ResourceGroup) String 

func (x *ResourceGroup) String() string

type ResourceGroupInfo 

type ResourceGroupInfo struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Deprecated: Marked as deprecated in query_coord.proto.
	Capacity         int32 `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"` // capacity can be found in config.requests.nodeNum and config.limits.nodeNum.
	NumAvailableNode int32 `protobuf:"varint,3,opt,name=num_available_node,json=numAvailableNode,proto3" json:"num_available_node,omitempty"`
	// collection id -> loaded replica num
	NumLoadedReplica map[int64]int32 `` /* 201-byte string literal not displayed */
	// collection id -> accessed other rg's node num
	NumOutgoingNode map[int64]int32 `` /* 198-byte string literal not displayed */
	// collection id -> be accessed node num by other rg
	NumIncomingNode map[int64]int32 `` /* 198-byte string literal not displayed */
	// resource group configuration.
	Config *rgpb.ResourceGroupConfig `protobuf:"bytes,7,opt,name=config,proto3" json:"config,omitempty"`
	Nodes  []*commonpb.NodeInfo      `protobuf:"bytes,8,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceGroupInfo) Descriptor deprecated 

func (*ResourceGroupInfo) Descriptor() ([]byte, []int)

Deprecated: Use ResourceGroupInfo.ProtoReflect.Descriptor instead.

func (*ResourceGroupInfo) GetCapacity deprecated 

func (x *ResourceGroupInfo) GetCapacity() int32

Deprecated: Marked as deprecated in query_coord.proto.

func (*ResourceGroupInfo) GetConfig 

func (x *ResourceGroupInfo) GetConfig() *rgpb.ResourceGroupConfig

func (*ResourceGroupInfo) GetName 

func (x *ResourceGroupInfo) GetName() string

func (*ResourceGroupInfo) GetNodes 

func (x *ResourceGroupInfo) GetNodes() []*commonpb.NodeInfo

func (*ResourceGroupInfo) GetNumAvailableNode 

func (x *ResourceGroupInfo) GetNumAvailableNode() int32

func (*ResourceGroupInfo) GetNumIncomingNode 

func (x *ResourceGroupInfo) GetNumIncomingNode() map[int64]int32

func (*ResourceGroupInfo) GetNumLoadedReplica 

func (x *ResourceGroupInfo) GetNumLoadedReplica() map[int64]int32

func (*ResourceGroupInfo) GetNumOutgoingNode 

func (x *ResourceGroupInfo) GetNumOutgoingNode() map[int64]int32

func (*ResourceGroupInfo) ProtoMessage 

func (*ResourceGroupInfo) ProtoMessage()

func (*ResourceGroupInfo) ProtoReflect 

func (x *ResourceGroupInfo) ProtoReflect() protoreflect.Message

func (*ResourceGroupInfo) Reset 

func (x *ResourceGroupInfo) Reset()

func (*ResourceGroupInfo) String 

func (x *ResourceGroupInfo) String() string

type ResumeBalanceRequest 

type ResumeBalanceRequest struct {
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeBalanceRequest) Descriptor deprecated 

func (*ResumeBalanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ResumeBalanceRequest.ProtoReflect.Descriptor instead.

func (*ResumeBalanceRequest) GetBase 

func (x *ResumeBalanceRequest) GetBase() *commonpb.MsgBase

func (*ResumeBalanceRequest) ProtoMessage 

func (*ResumeBalanceRequest) ProtoMessage()

func (*ResumeBalanceRequest) ProtoReflect 

func (x *ResumeBalanceRequest) ProtoReflect() protoreflect.Message

func (*ResumeBalanceRequest) Reset 

func (x *ResumeBalanceRequest) Reset()

func (*ResumeBalanceRequest) String 

func (x *ResumeBalanceRequest) String() string

type ResumeNodeRequest 

type ResumeNodeRequest struct {
	Base   *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	NodeID int64             `protobuf:"varint,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeNodeRequest) Descriptor deprecated 

func (*ResumeNodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ResumeNodeRequest.ProtoReflect.Descriptor instead.

func (*ResumeNodeRequest) GetBase 

func (x *ResumeNodeRequest) GetBase() *commonpb.MsgBase

func (*ResumeNodeRequest) GetNodeID 

func (x *ResumeNodeRequest) GetNodeID() int64

func (*ResumeNodeRequest) ProtoMessage 

func (*ResumeNodeRequest) ProtoMessage()

func (*ResumeNodeRequest) ProtoReflect 

func (x *ResumeNodeRequest) ProtoReflect() protoreflect.Message

func (*ResumeNodeRequest) Reset 

func (x *ResumeNodeRequest) Reset()

func (*ResumeNodeRequest) String 

func (x *ResumeNodeRequest) String() string

type SealedSegmentsChangeInfo 

type SealedSegmentsChangeInfo struct {
	Base  *commonpb.MsgBase    `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Infos []*SegmentChangeInfo `protobuf:"bytes,2,rep,name=infos,proto3" json:"infos,omitempty"`
	// contains filtered or unexported fields
}

func (*SealedSegmentsChangeInfo) Descriptor deprecated 

func (*SealedSegmentsChangeInfo) Descriptor() ([]byte, []int)

Deprecated: Use SealedSegmentsChangeInfo.ProtoReflect.Descriptor instead.

func (*SealedSegmentsChangeInfo) GetBase 

func (x *SealedSegmentsChangeInfo) GetBase() *commonpb.MsgBase

func (*SealedSegmentsChangeInfo) GetInfos 

func (x *SealedSegmentsChangeInfo) GetInfos() []*SegmentChangeInfo

func (*SealedSegmentsChangeInfo) ProtoMessage 

func (*SealedSegmentsChangeInfo) ProtoMessage()

func (*SealedSegmentsChangeInfo) ProtoReflect 

func (x *SealedSegmentsChangeInfo) ProtoReflect() protoreflect.Message

func (*SealedSegmentsChangeInfo) Reset 

func (x *SealedSegmentsChangeInfo) Reset()

func (*SealedSegmentsChangeInfo) String 

func (x *SealedSegmentsChangeInfo) String() string

type SearchRequest 

type SearchRequest struct {
	Req             *internalpb.SearchRequest `protobuf:"bytes,1,opt,name=req,proto3" json:"req,omitempty"`
	DmlChannels     []string                  `protobuf:"bytes,2,rep,name=dml_channels,json=dmlChannels,proto3" json:"dml_channels,omitempty"`
	SegmentIDs      []int64                   `protobuf:"varint,3,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	FromShardLeader bool                      `protobuf:"varint,4,opt,name=from_shard_leader,json=fromShardLeader,proto3" json:"from_shard_leader,omitempty"`
	Scope           DataScope                 `protobuf:"varint,5,opt,name=scope,proto3,enum=milvus.proto.query.DataScope" json:"scope,omitempty"` // All, Streaming, Historical
	TotalChannelNum int32                     `protobuf:"varint,6,opt,name=total_channel_num,json=totalChannelNum,proto3" json:"total_channel_num,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchRequest) Descriptor deprecated 

func (*SearchRequest) Descriptor() ([]byte, []int)

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetDmlChannels 

func (x *SearchRequest) GetDmlChannels() []string

func (*SearchRequest) GetFromShardLeader 

func (x *SearchRequest) GetFromShardLeader() bool

func (*SearchRequest) GetReq 

func (x *SearchRequest) GetReq() *internalpb.SearchRequest

func (*SearchRequest) GetScope 

func (x *SearchRequest) GetScope() DataScope

func (*SearchRequest) GetSegmentIDs 

func (x *SearchRequest) GetSegmentIDs() []int64

func (*SearchRequest) GetTotalChannelNum 

func (x *SearchRequest) GetTotalChannelNum() int32

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

func (x *SearchRequest) ProtoReflect() protoreflect.Message

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) String 

func (x *SearchRequest) String() string

type SegmentChangeInfo 

type SegmentChangeInfo struct {
	OnlineNodeID    int64          `protobuf:"varint,1,opt,name=online_nodeID,json=onlineNodeID,proto3" json:"online_nodeID,omitempty"`
	OnlineSegments  []*SegmentInfo `protobuf:"bytes,2,rep,name=online_segments,json=onlineSegments,proto3" json:"online_segments,omitempty"`
	OfflineNodeID   int64          `protobuf:"varint,3,opt,name=offline_nodeID,json=offlineNodeID,proto3" json:"offline_nodeID,omitempty"`
	OfflineSegments []*SegmentInfo `protobuf:"bytes,4,rep,name=offline_segments,json=offlineSegments,proto3" json:"offline_segments,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentChangeInfo) Descriptor deprecated 

func (*SegmentChangeInfo) Descriptor() ([]byte, []int)

Deprecated: Use SegmentChangeInfo.ProtoReflect.Descriptor instead.

func (*SegmentChangeInfo) GetOfflineNodeID 

func (x *SegmentChangeInfo) GetOfflineNodeID() int64

func (*SegmentChangeInfo) GetOfflineSegments 

func (x *SegmentChangeInfo) GetOfflineSegments() []*SegmentInfo

func (*SegmentChangeInfo) GetOnlineNodeID 

func (x *SegmentChangeInfo) GetOnlineNodeID() int64

func (*SegmentChangeInfo) GetOnlineSegments 

func (x *SegmentChangeInfo) GetOnlineSegments() []*SegmentInfo

func (*SegmentChangeInfo) ProtoMessage 

func (*SegmentChangeInfo) ProtoMessage()

func (*SegmentChangeInfo) ProtoReflect 

func (x *SegmentChangeInfo) ProtoReflect() protoreflect.Message

func (*SegmentChangeInfo) Reset 

func (x *SegmentChangeInfo) Reset()

func (*SegmentChangeInfo) String 

func (x *SegmentChangeInfo) String() string

type SegmentDist 

type SegmentDist struct {
	NodeID  int64 `protobuf:"varint,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	Version int64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentDist) Descriptor deprecated 

func (*SegmentDist) Descriptor() ([]byte, []int)

Deprecated: Use SegmentDist.ProtoReflect.Descriptor instead.

func (*SegmentDist) GetNodeID 

func (x *SegmentDist) GetNodeID() int64

func (*SegmentDist) GetVersion 

func (x *SegmentDist) GetVersion() int64

func (*SegmentDist) ProtoMessage 

func (*SegmentDist) ProtoMessage()

func (*SegmentDist) ProtoReflect 

func (x *SegmentDist) ProtoReflect() protoreflect.Message

func (*SegmentDist) Reset 

func (x *SegmentDist) Reset()

func (*SegmentDist) String 

func (x *SegmentDist) String() string

type SegmentInfo 

type SegmentInfo struct {
	SegmentID    int64 `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	CollectionID int64 `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionID  int64 `protobuf:"varint,3,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	// deprecated, check node_ids(NodeIds) field
	NodeID              int64                 `protobuf:"varint,4,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	MemSize             int64                 `protobuf:"varint,5,opt,name=mem_size,json=memSize,proto3" json:"mem_size,omitempty"`
	NumRows             int64                 `protobuf:"varint,6,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	IndexName           string                `protobuf:"bytes,7,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	IndexID             int64                 `protobuf:"varint,8,opt,name=indexID,proto3" json:"indexID,omitempty"`
	DmChannel           string                `protobuf:"bytes,9,opt,name=dmChannel,proto3" json:"dmChannel,omitempty"`
	CompactionFrom      []int64               `protobuf:"varint,10,rep,packed,name=compactionFrom,proto3" json:"compactionFrom,omitempty"`
	CreatedByCompaction bool                  `protobuf:"varint,11,opt,name=createdByCompaction,proto3" json:"createdByCompaction,omitempty"`
	SegmentState        commonpb.SegmentState `` /* 137-byte string literal not displayed */
	IndexInfos          []*FieldIndexInfo     `protobuf:"bytes,13,rep,name=index_infos,json=indexInfos,proto3" json:"index_infos,omitempty"`
	ReplicaIds          []int64               `protobuf:"varint,14,rep,packed,name=replica_ids,json=replicaIds,proto3" json:"replica_ids,omitempty"`
	NodeIds             []int64               `protobuf:"varint,15,rep,packed,name=node_ids,json=nodeIds,proto3" json:"node_ids,omitempty"`
	EnableIndex         bool                  `protobuf:"varint,16,opt,name=enable_index,json=enableIndex,proto3" json:"enable_index,omitempty"`
	IsFake              bool                  `protobuf:"varint,17,opt,name=is_fake,json=isFake,proto3" json:"is_fake,omitempty"`
	Level               datapb.SegmentLevel   `protobuf:"varint,18,opt,name=level,proto3,enum=milvus.proto.data.SegmentLevel" json:"level,omitempty"`
	IsSorted            bool                  `protobuf:"varint,19,opt,name=is_sorted,json=isSorted,proto3" json:"is_sorted,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentInfo) Descriptor deprecated 

func (*SegmentInfo) Descriptor() ([]byte, []int)

Deprecated: Use SegmentInfo.ProtoReflect.Descriptor instead.

func (*SegmentInfo) GetCollectionID 

func (x *SegmentInfo) GetCollectionID() int64

func (*SegmentInfo) GetCompactionFrom 

func (x *SegmentInfo) GetCompactionFrom() []int64

func (*SegmentInfo) GetCreatedByCompaction 

func (x *SegmentInfo) GetCreatedByCompaction() bool

func (*SegmentInfo) GetDmChannel 

func (x *SegmentInfo) GetDmChannel() string

func (*SegmentInfo) GetEnableIndex 

func (x *SegmentInfo) GetEnableIndex() bool

func (*SegmentInfo) GetIndexID 

func (x *SegmentInfo) GetIndexID() int64

func (*SegmentInfo) GetIndexInfos 

func (x *SegmentInfo) GetIndexInfos() []*FieldIndexInfo

func (*SegmentInfo) GetIndexName 

func (x *SegmentInfo) GetIndexName() string

func (*SegmentInfo) GetIsFake 

func (x *SegmentInfo) GetIsFake() bool

func (*SegmentInfo) GetIsSorted 

func (x *SegmentInfo) GetIsSorted() bool

func (*SegmentInfo) GetLevel 

func (x *SegmentInfo) GetLevel() datapb.SegmentLevel

func (*SegmentInfo) GetMemSize 

func (x *SegmentInfo) GetMemSize() int64

func (*SegmentInfo) GetNodeID 

func (x *SegmentInfo) GetNodeID() int64

func (*SegmentInfo) GetNodeIds 

func (x *SegmentInfo) GetNodeIds() []int64

func (*SegmentInfo) GetNumRows 

func (x *SegmentInfo) GetNumRows() int64

func (*SegmentInfo) GetPartitionID 

func (x *SegmentInfo) GetPartitionID() int64

func (*SegmentInfo) GetReplicaIds 

func (x *SegmentInfo) GetReplicaIds() []int64

func (*SegmentInfo) GetSegmentID 

func (x *SegmentInfo) GetSegmentID() int64

func (*SegmentInfo) GetSegmentState 

func (x *SegmentInfo) GetSegmentState() commonpb.SegmentState

func (*SegmentInfo) ProtoMessage 

func (*SegmentInfo) ProtoMessage()

func (*SegmentInfo) ProtoReflect 

func (x *SegmentInfo) ProtoReflect() protoreflect.Message

func (*SegmentInfo) Reset 

func (x *SegmentInfo) Reset()

func (*SegmentInfo) String 

func (x *SegmentInfo) String() string

type SegmentLoadInfo 

type SegmentLoadInfo struct {
	SegmentID      int64                 `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	PartitionID    int64                 `protobuf:"varint,2,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	CollectionID   int64                 `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	DbID           int64                 `protobuf:"varint,4,opt,name=dbID,proto3" json:"dbID,omitempty"`
	FlushTime      int64                 `protobuf:"varint,5,opt,name=flush_time,json=flushTime,proto3" json:"flush_time,omitempty"`
	BinlogPaths    []*datapb.FieldBinlog `protobuf:"bytes,6,rep,name=binlog_paths,json=binlogPaths,proto3" json:"binlog_paths,omitempty"`
	NumOfRows      int64                 `protobuf:"varint,7,opt,name=num_of_rows,json=numOfRows,proto3" json:"num_of_rows,omitempty"`
	Statslogs      []*datapb.FieldBinlog `protobuf:"bytes,8,rep,name=statslogs,proto3" json:"statslogs,omitempty"`
	Deltalogs      []*datapb.FieldBinlog `protobuf:"bytes,9,rep,name=deltalogs,proto3" json:"deltalogs,omitempty"`
	CompactionFrom []int64               `protobuf:"varint,10,rep,packed,name=compactionFrom,proto3" json:"compactionFrom,omitempty"` // segmentIDs compacted from
	IndexInfos     []*FieldIndexInfo     `protobuf:"bytes,11,rep,name=index_infos,json=indexInfos,proto3" json:"index_infos,omitempty"`
	// Deprecated: Marked as deprecated in query_coord.proto.
	SegmentSize     int64                            `protobuf:"varint,12,opt,name=segment_size,json=segmentSize,proto3" json:"segment_size,omitempty"`
	InsertChannel   string                           `protobuf:"bytes,13,opt,name=insert_channel,json=insertChannel,proto3" json:"insert_channel,omitempty"`
	StartPosition   *msgpb.MsgPosition               `protobuf:"bytes,14,opt,name=start_position,json=startPosition,proto3" json:"start_position,omitempty"`
	DeltaPosition   *msgpb.MsgPosition               `protobuf:"bytes,15,opt,name=delta_position,json=deltaPosition,proto3" json:"delta_position,omitempty"`
	ReadableVersion int64                            `protobuf:"varint,16,opt,name=readableVersion,proto3" json:"readableVersion,omitempty"`
	Level           datapb.SegmentLevel              `protobuf:"varint,17,opt,name=level,proto3,enum=milvus.proto.data.SegmentLevel" json:"level,omitempty"`
	StorageVersion  int64                            `protobuf:"varint,18,opt,name=storageVersion,proto3" json:"storageVersion,omitempty"`
	IsSorted        bool                             `protobuf:"varint,19,opt,name=is_sorted,json=isSorted,proto3" json:"is_sorted,omitempty"`
	TextStatsLogs   map[int64]*datapb.TextIndexStats `` /* 169-byte string literal not displayed */
	Bm25Logs        []*datapb.FieldBinlog            `protobuf:"bytes,21,rep,name=bm25logs,proto3" json:"bm25logs,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentLoadInfo) Descriptor deprecated 

func (*SegmentLoadInfo) Descriptor() ([]byte, []int)

Deprecated: Use SegmentLoadInfo.ProtoReflect.Descriptor instead.

func (*SegmentLoadInfo) GetBinlogPaths 

func (x *SegmentLoadInfo) GetBinlogPaths() []*datapb.FieldBinlog

func (*SegmentLoadInfo) GetBm25Logs 

func (x *SegmentLoadInfo) GetBm25Logs() []*datapb.FieldBinlog

func (*SegmentLoadInfo) GetCollectionID 

func (x *SegmentLoadInfo) GetCollectionID() int64

func (*SegmentLoadInfo) GetCompactionFrom 

func (x *SegmentLoadInfo) GetCompactionFrom() []int64

func (*SegmentLoadInfo) GetDbID 

func (x *SegmentLoadInfo) GetDbID() int64

func (*SegmentLoadInfo) GetDeltaPosition 

func (x *SegmentLoadInfo) GetDeltaPosition() *msgpb.MsgPosition

func (*SegmentLoadInfo) GetDeltalogs 

func (x *SegmentLoadInfo) GetDeltalogs() []*datapb.FieldBinlog

func (*SegmentLoadInfo) GetFlushTime 

func (x *SegmentLoadInfo) GetFlushTime() int64

func (*SegmentLoadInfo) GetIndexInfos 

func (x *SegmentLoadInfo) GetIndexInfos() []*FieldIndexInfo

func (*SegmentLoadInfo) GetInsertChannel 

func (x *SegmentLoadInfo) GetInsertChannel() string

func (*SegmentLoadInfo) GetIsSorted 

func (x *SegmentLoadInfo) GetIsSorted() bool

func (*SegmentLoadInfo) GetLevel 

func (x *SegmentLoadInfo) GetLevel() datapb.SegmentLevel

func (*SegmentLoadInfo) GetNumOfRows 

func (x *SegmentLoadInfo) GetNumOfRows() int64

func (*SegmentLoadInfo) GetPartitionID 

func (x *SegmentLoadInfo) GetPartitionID() int64

func (*SegmentLoadInfo) GetReadableVersion 

func (x *SegmentLoadInfo) GetReadableVersion() int64

func (*SegmentLoadInfo) GetSegmentID 

func (x *SegmentLoadInfo) GetSegmentID() int64

func (*SegmentLoadInfo) GetSegmentSize deprecated 

func (x *SegmentLoadInfo) GetSegmentSize() int64

Deprecated: Marked as deprecated in query_coord.proto.

func (*SegmentLoadInfo) GetStartPosition 

func (x *SegmentLoadInfo) GetStartPosition() *msgpb.MsgPosition

func (*SegmentLoadInfo) GetStatslogs 

func (x *SegmentLoadInfo) GetStatslogs() []*datapb.FieldBinlog

func (*SegmentLoadInfo) GetStorageVersion 

func (x *SegmentLoadInfo) GetStorageVersion() int64

func (*SegmentLoadInfo) GetTextStatsLogs 

func (x *SegmentLoadInfo) GetTextStatsLogs() map[int64]*datapb.TextIndexStats

func (*SegmentLoadInfo) ProtoMessage 

func (*SegmentLoadInfo) ProtoMessage()

func (*SegmentLoadInfo) ProtoReflect 

func (x *SegmentLoadInfo) ProtoReflect() protoreflect.Message

func (*SegmentLoadInfo) Reset 

func (x *SegmentLoadInfo) Reset()

func (*SegmentLoadInfo) String 

func (x *SegmentLoadInfo) String() string

type SegmentTarget 

type SegmentTarget struct {
	ID        int64               `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Level     datapb.SegmentLevel `protobuf:"varint,2,opt,name=level,proto3,enum=milvus.proto.data.SegmentLevel" json:"level,omitempty"`
	NumOfRows int64               `protobuf:"varint,3,opt,name=num_of_rows,json=numOfRows,proto3" json:"num_of_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentTarget) Descriptor deprecated 

func (*SegmentTarget) Descriptor() ([]byte, []int)

Deprecated: Use SegmentTarget.ProtoReflect.Descriptor instead.

func (*SegmentTarget) GetID 

func (x *SegmentTarget) GetID() int64

func (*SegmentTarget) GetLevel 

func (x *SegmentTarget) GetLevel() datapb.SegmentLevel

func (*SegmentTarget) GetNumOfRows 

func (x *SegmentTarget) GetNumOfRows() int64

func (*SegmentTarget) ProtoMessage 

func (*SegmentTarget) ProtoMessage()

func (*SegmentTarget) ProtoReflect 

func (x *SegmentTarget) ProtoReflect() protoreflect.Message

func (*SegmentTarget) Reset 

func (x *SegmentTarget) Reset()

func (*SegmentTarget) String 

func (x *SegmentTarget) String() string

type SegmentVersionInfo 

type SegmentVersionInfo struct {
	ID                 int64                     `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Collection         int64                     `protobuf:"varint,2,opt,name=collection,proto3" json:"collection,omitempty"`
	Partition          int64                     `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	Channel            string                    `protobuf:"bytes,4,opt,name=channel,proto3" json:"channel,omitempty"`
	Version            int64                     `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	LastDeltaTimestamp uint64                    `protobuf:"varint,6,opt,name=last_delta_timestamp,json=lastDeltaTimestamp,proto3" json:"last_delta_timestamp,omitempty"`
	IndexInfo          map[int64]*FieldIndexInfo `` /* 177-byte string literal not displayed */
	Level              datapb.SegmentLevel       `protobuf:"varint,8,opt,name=level,proto3,enum=milvus.proto.data.SegmentLevel" json:"level,omitempty"`
	IsSorted           bool                      `protobuf:"varint,9,opt,name=is_sorted,json=isSorted,proto3" json:"is_sorted,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentVersionInfo) Descriptor deprecated 

func (*SegmentVersionInfo) Descriptor() ([]byte, []int)

Deprecated: Use SegmentVersionInfo.ProtoReflect.Descriptor instead.

func (*SegmentVersionInfo) GetChannel 

func (x *SegmentVersionInfo) GetChannel() string

func (*SegmentVersionInfo) GetCollection 

func (x *SegmentVersionInfo) GetCollection() int64

func (*SegmentVersionInfo) GetID 

func (x *SegmentVersionInfo) GetID() int64

func (*SegmentVersionInfo) GetIndexInfo 

func (x *SegmentVersionInfo) GetIndexInfo() map[int64]*FieldIndexInfo

func (*SegmentVersionInfo) GetIsSorted 

func (x *SegmentVersionInfo) GetIsSorted() bool

func (*SegmentVersionInfo) GetLastDeltaTimestamp 

func (x *SegmentVersionInfo) GetLastDeltaTimestamp() uint64

func (*SegmentVersionInfo) GetLevel 

func (x *SegmentVersionInfo) GetLevel() datapb.SegmentLevel

func (*SegmentVersionInfo) GetPartition 

func (x *SegmentVersionInfo) GetPartition() int64

func (*SegmentVersionInfo) GetVersion 

func (x *SegmentVersionInfo) GetVersion() int64

func (*SegmentVersionInfo) ProtoMessage 

func (*SegmentVersionInfo) ProtoMessage()

func (*SegmentVersionInfo) ProtoReflect 

func (x *SegmentVersionInfo) ProtoReflect() protoreflect.Message

func (*SegmentVersionInfo) Reset 

func (x *SegmentVersionInfo) Reset()

func (*SegmentVersionInfo) String 

func (x *SegmentVersionInfo) String() string

type ShardLeadersList 

type ShardLeadersList struct {
	ChannelName string   `protobuf:"bytes,1,opt,name=channel_name,json=channelName,proto3" json:"channel_name,omitempty"`
	NodeIds     []int64  `protobuf:"varint,2,rep,packed,name=node_ids,json=nodeIds,proto3" json:"node_ids,omitempty"`
	NodeAddrs   []string `protobuf:"bytes,3,rep,name=node_addrs,json=nodeAddrs,proto3" json:"node_addrs,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardLeadersList) Descriptor deprecated 

func (*ShardLeadersList) Descriptor() ([]byte, []int)

Deprecated: Use ShardLeadersList.ProtoReflect.Descriptor instead.

func (*ShardLeadersList) GetChannelName 

func (x *ShardLeadersList) GetChannelName() string

func (*ShardLeadersList) GetNodeAddrs 

func (x *ShardLeadersList) GetNodeAddrs() []string

func (*ShardLeadersList) GetNodeIds 

func (x *ShardLeadersList) GetNodeIds() []int64

func (*ShardLeadersList) ProtoMessage 

func (*ShardLeadersList) ProtoMessage()

func (*ShardLeadersList) ProtoReflect 

func (x *ShardLeadersList) ProtoReflect() protoreflect.Message

func (*ShardLeadersList) Reset 

func (x *ShardLeadersList) Reset()

func (*ShardLeadersList) String 

func (x *ShardLeadersList) String() string

type ShowCollectionsRequest 

type ShowCollectionsRequest struct {
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbID          int64   `protobuf:"varint,2,opt,name=dbID,proto3" json:"dbID,omitempty"`
	CollectionIDs []int64 `protobuf:"varint,3,rep,packed,name=collectionIDs,proto3" json:"collectionIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowCollectionsRequest) Descriptor deprecated 

func (*ShowCollectionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowCollectionsRequest.ProtoReflect.Descriptor instead.

func (*ShowCollectionsRequest) GetBase 

func (x *ShowCollectionsRequest) GetBase() *commonpb.MsgBase

func (*ShowCollectionsRequest) GetCollectionIDs 

func (x *ShowCollectionsRequest) GetCollectionIDs() []int64

func (*ShowCollectionsRequest) GetDbID 

func (x *ShowCollectionsRequest) GetDbID() int64

func (*ShowCollectionsRequest) ProtoMessage 

func (*ShowCollectionsRequest) ProtoMessage()

func (*ShowCollectionsRequest) ProtoReflect 

func (x *ShowCollectionsRequest) ProtoReflect() protoreflect.Message

func (*ShowCollectionsRequest) Reset 

func (x *ShowCollectionsRequest) Reset()

func (*ShowCollectionsRequest) String 

func (x *ShowCollectionsRequest) String() string

type ShowCollectionsResponse 

type ShowCollectionsResponse struct {
	Status                *commonpb.Status      `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	CollectionIDs         []int64               `protobuf:"varint,2,rep,packed,name=collectionIDs,proto3" json:"collectionIDs,omitempty"`
	InMemoryPercentages   []int64               `` /* 126-byte string literal not displayed */
	QueryServiceAvailable []bool                `` /* 134-byte string literal not displayed */
	RefreshProgress       []int64               `protobuf:"varint,5,rep,packed,name=refresh_progress,json=refreshProgress,proto3" json:"refresh_progress,omitempty"`
	LoadFields            []*schemapb.LongArray `protobuf:"bytes,6,rep,name=load_fields,json=loadFields,proto3" json:"load_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowCollectionsResponse) Descriptor deprecated 

func (*ShowCollectionsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowCollectionsResponse.ProtoReflect.Descriptor instead.

func (*ShowCollectionsResponse) GetCollectionIDs 

func (x *ShowCollectionsResponse) GetCollectionIDs() []int64

func (*ShowCollectionsResponse) GetInMemoryPercentages 

func (x *ShowCollectionsResponse) GetInMemoryPercentages() []int64

func (*ShowCollectionsResponse) GetLoadFields 

func (x *ShowCollectionsResponse) GetLoadFields() []*schemapb.LongArray

func (*ShowCollectionsResponse) GetQueryServiceAvailable 

func (x *ShowCollectionsResponse) GetQueryServiceAvailable() []bool

func (*ShowCollectionsResponse) GetRefreshProgress 

func (x *ShowCollectionsResponse) GetRefreshProgress() []int64

func (*ShowCollectionsResponse) GetStatus 

func (x *ShowCollectionsResponse) GetStatus() *commonpb.Status

func (*ShowCollectionsResponse) ProtoMessage 

func (*ShowCollectionsResponse) ProtoMessage()

func (*ShowCollectionsResponse) ProtoReflect 

func (x *ShowCollectionsResponse) ProtoReflect() protoreflect.Message

func (*ShowCollectionsResponse) Reset 

func (x *ShowCollectionsResponse) Reset()

func (*ShowCollectionsResponse) String 

func (x *ShowCollectionsResponse) String() string

type ShowPartitionsRequest 

type ShowPartitionsRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbID         int64             `protobuf:"varint,2,opt,name=dbID,proto3" json:"dbID,omitempty"`
	CollectionID int64             `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionIDs []int64           `protobuf:"varint,4,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowPartitionsRequest) Descriptor deprecated 

func (*ShowPartitionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowPartitionsRequest.ProtoReflect.Descriptor instead.

func (*ShowPartitionsRequest) GetBase 

func (x *ShowPartitionsRequest) GetBase() *commonpb.MsgBase

func (*ShowPartitionsRequest) GetCollectionID 

func (x *ShowPartitionsRequest) GetCollectionID() int64

func (*ShowPartitionsRequest) GetDbID 

func (x *ShowPartitionsRequest) GetDbID() int64

func (*ShowPartitionsRequest) GetPartitionIDs 

func (x *ShowPartitionsRequest) GetPartitionIDs() []int64

func (*ShowPartitionsRequest) ProtoMessage 

func (*ShowPartitionsRequest) ProtoMessage()

func (*ShowPartitionsRequest) ProtoReflect 

func (x *ShowPartitionsRequest) ProtoReflect() protoreflect.Message

func (*ShowPartitionsRequest) Reset 

func (x *ShowPartitionsRequest) Reset()

func (*ShowPartitionsRequest) String 

func (x *ShowPartitionsRequest) String() string

type ShowPartitionsResponse 

type ShowPartitionsResponse struct {
	Status              *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	PartitionIDs        []int64          `protobuf:"varint,2,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	InMemoryPercentages []int64          `` /* 126-byte string literal not displayed */
	RefreshProgress     []int64          `protobuf:"varint,4,rep,packed,name=refresh_progress,json=refreshProgress,proto3" json:"refresh_progress,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowPartitionsResponse) Descriptor deprecated 

func (*ShowPartitionsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowPartitionsResponse.ProtoReflect.Descriptor instead.

func (*ShowPartitionsResponse) GetInMemoryPercentages 

func (x *ShowPartitionsResponse) GetInMemoryPercentages() []int64

func (*ShowPartitionsResponse) GetPartitionIDs 

func (x *ShowPartitionsResponse) GetPartitionIDs() []int64

func (*ShowPartitionsResponse) GetRefreshProgress 

func (x *ShowPartitionsResponse) GetRefreshProgress() []int64

func (*ShowPartitionsResponse) GetStatus 

func (x *ShowPartitionsResponse) GetStatus() *commonpb.Status

func (*ShowPartitionsResponse) ProtoMessage 

func (*ShowPartitionsResponse) ProtoMessage()

func (*ShowPartitionsResponse) ProtoReflect 

func (x *ShowPartitionsResponse) ProtoReflect() protoreflect.Message

func (*ShowPartitionsResponse) Reset 

func (x *ShowPartitionsResponse) Reset()

func (*ShowPartitionsResponse) String 

func (x *ShowPartitionsResponse) String() string

type SuspendBalanceRequest 

type SuspendBalanceRequest struct {
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// contains filtered or unexported fields
}

func (*SuspendBalanceRequest) Descriptor deprecated 

func (*SuspendBalanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use SuspendBalanceRequest.ProtoReflect.Descriptor instead.

func (*SuspendBalanceRequest) GetBase 

func (x *SuspendBalanceRequest) GetBase() *commonpb.MsgBase

func (*SuspendBalanceRequest) ProtoMessage 

func (*SuspendBalanceRequest) ProtoMessage()

func (*SuspendBalanceRequest) ProtoReflect 

func (x *SuspendBalanceRequest) ProtoReflect() protoreflect.Message

func (*SuspendBalanceRequest) Reset 

func (x *SuspendBalanceRequest) Reset()

func (*SuspendBalanceRequest) String 

func (x *SuspendBalanceRequest) String() string

type SuspendNodeRequest 

type SuspendNodeRequest struct {
	Base   *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	NodeID int64             `protobuf:"varint,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// contains filtered or unexported fields
}

func (*SuspendNodeRequest) Descriptor deprecated 

func (*SuspendNodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use SuspendNodeRequest.ProtoReflect.Descriptor instead.

func (*SuspendNodeRequest) GetBase 

func (x *SuspendNodeRequest) GetBase() *commonpb.MsgBase

func (*SuspendNodeRequest) GetNodeID 

func (x *SuspendNodeRequest) GetNodeID() int64

func (*SuspendNodeRequest) ProtoMessage 

func (*SuspendNodeRequest) ProtoMessage()

func (*SuspendNodeRequest) ProtoReflect 

func (x *SuspendNodeRequest) ProtoReflect() protoreflect.Message

func (*SuspendNodeRequest) Reset 

func (x *SuspendNodeRequest) Reset()

func (*SuspendNodeRequest) String 

func (x *SuspendNodeRequest) String() string

type SyncAction 

type SyncAction struct {
	Type                   SyncType           `protobuf:"varint,1,opt,name=type,proto3,enum=milvus.proto.query.SyncType" json:"type,omitempty"`
	PartitionID            int64              `protobuf:"varint,2,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	SegmentID              int64              `protobuf:"varint,3,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	NodeID                 int64              `protobuf:"varint,4,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	Version                int64              `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Info                   *SegmentLoadInfo   `protobuf:"bytes,6,opt,name=info,proto3" json:"info,omitempty"`
	GrowingInTarget        []int64            `protobuf:"varint,7,rep,packed,name=growingInTarget,proto3" json:"growingInTarget,omitempty"`
	SealedInTarget         []int64            `protobuf:"varint,8,rep,packed,name=sealedInTarget,proto3" json:"sealedInTarget,omitempty"`
	TargetVersion          int64              `protobuf:"varint,9,opt,name=TargetVersion,proto3" json:"TargetVersion,omitempty"`
	DroppedInTarget        []int64            `protobuf:"varint,10,rep,packed,name=droppedInTarget,proto3" json:"droppedInTarget,omitempty"`
	Checkpoint             *msgpb.MsgPosition `protobuf:"bytes,11,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	PartitionStatsVersions map[int64]int64    `` /* 220-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SyncAction) Descriptor deprecated 

func (*SyncAction) Descriptor() ([]byte, []int)

Deprecated: Use SyncAction.ProtoReflect.Descriptor instead.

func (*SyncAction) GetCheckpoint 

func (x *SyncAction) GetCheckpoint() *msgpb.MsgPosition

func (*SyncAction) GetDroppedInTarget 

func (x *SyncAction) GetDroppedInTarget() []int64

func (*SyncAction) GetGrowingInTarget 

func (x *SyncAction) GetGrowingInTarget() []int64

func (*SyncAction) GetInfo 

func (x *SyncAction) GetInfo() *SegmentLoadInfo

func (*SyncAction) GetNodeID 

func (x *SyncAction) GetNodeID() int64

func (*SyncAction) GetPartitionID 

func (x *SyncAction) GetPartitionID() int64

func (*SyncAction) GetPartitionStatsVersions 

func (x *SyncAction) GetPartitionStatsVersions() map[int64]int64

func (*SyncAction) GetSealedInTarget 

func (x *SyncAction) GetSealedInTarget() []int64

func (*SyncAction) GetSegmentID 

func (x *SyncAction) GetSegmentID() int64

func (*SyncAction) GetTargetVersion 

func (x *SyncAction) GetTargetVersion() int64

func (*SyncAction) GetType 

func (x *SyncAction) GetType() SyncType

func (*SyncAction) GetVersion 

func (x *SyncAction) GetVersion() int64

func (*SyncAction) ProtoMessage 

func (*SyncAction) ProtoMessage()

func (*SyncAction) ProtoReflect 

func (x *SyncAction) ProtoReflect() protoreflect.Message

func (*SyncAction) Reset 

func (x *SyncAction) Reset()

func (*SyncAction) String 

func (x *SyncAction) String() string

type SyncDistributionRequest 

type SyncDistributionRequest struct {
	Base          *commonpb.MsgBase          `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CollectionID  int64                      `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	Channel       string                     `protobuf:"bytes,3,opt,name=channel,proto3" json:"channel,omitempty"`
	Actions       []*SyncAction              `protobuf:"bytes,4,rep,name=actions,proto3" json:"actions,omitempty"`
	Schema        *schemapb.CollectionSchema `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	LoadMeta      *LoadMetaInfo              `protobuf:"bytes,6,opt,name=load_meta,json=loadMeta,proto3" json:"load_meta,omitempty"`
	ReplicaID     int64                      `protobuf:"varint,7,opt,name=replicaID,proto3" json:"replicaID,omitempty"`
	Version       int64                      `protobuf:"varint,8,opt,name=version,proto3" json:"version,omitempty"`
	IndexInfoList []*indexpb.IndexInfo       `protobuf:"bytes,9,rep,name=index_info_list,json=indexInfoList,proto3" json:"index_info_list,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncDistributionRequest) Descriptor deprecated 

func (*SyncDistributionRequest) Descriptor() ([]byte, []int)

Deprecated: Use SyncDistributionRequest.ProtoReflect.Descriptor instead.

func (*SyncDistributionRequest) GetActions 

func (x *SyncDistributionRequest) GetActions() []*SyncAction

func (*SyncDistributionRequest) GetBase 

func (x *SyncDistributionRequest) GetBase() *commonpb.MsgBase

func (*SyncDistributionRequest) GetChannel 

func (x *SyncDistributionRequest) GetChannel() string

func (*SyncDistributionRequest) GetCollectionID 

func (x *SyncDistributionRequest) GetCollectionID() int64

func (*SyncDistributionRequest) GetIndexInfoList 

func (x *SyncDistributionRequest) GetIndexInfoList() []*indexpb.IndexInfo

func (*SyncDistributionRequest) GetLoadMeta 

func (x *SyncDistributionRequest) GetLoadMeta() *LoadMetaInfo

func (*SyncDistributionRequest) GetReplicaID 

func (x *SyncDistributionRequest) GetReplicaID() int64

func (*SyncDistributionRequest) GetSchema 

func (x *SyncDistributionRequest) GetSchema() *schemapb.CollectionSchema

func (*SyncDistributionRequest) GetVersion 

func (x *SyncDistributionRequest) GetVersion() int64

func (*SyncDistributionRequest) ProtoMessage 

func (*SyncDistributionRequest) ProtoMessage()

func (*SyncDistributionRequest) ProtoReflect 

func (x *SyncDistributionRequest) ProtoReflect() protoreflect.Message

func (*SyncDistributionRequest) Reset 

func (x *SyncDistributionRequest) Reset()

func (*SyncDistributionRequest) String 

func (x *SyncDistributionRequest) String() string

type SyncNewCreatedPartitionRequest 

type SyncNewCreatedPartitionRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CollectionID int64             `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionID  int64             `protobuf:"varint,3,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncNewCreatedPartitionRequest) Descriptor deprecated 

func (*SyncNewCreatedPartitionRequest) Descriptor() ([]byte, []int)

Deprecated: Use SyncNewCreatedPartitionRequest.ProtoReflect.Descriptor instead.

func (*SyncNewCreatedPartitionRequest) GetBase 

func (x *SyncNewCreatedPartitionRequest) GetBase() *commonpb.MsgBase

func (*SyncNewCreatedPartitionRequest) GetCollectionID 

func (x *SyncNewCreatedPartitionRequest) GetCollectionID() int64

func (*SyncNewCreatedPartitionRequest) GetPartitionID 

func (x *SyncNewCreatedPartitionRequest) GetPartitionID() int64

func (*SyncNewCreatedPartitionRequest) ProtoMessage 

func (*SyncNewCreatedPartitionRequest) ProtoMessage()

func (*SyncNewCreatedPartitionRequest) ProtoReflect 

func (x *SyncNewCreatedPartitionRequest) ProtoReflect() protoreflect.Message

func (*SyncNewCreatedPartitionRequest) Reset 

func (x *SyncNewCreatedPartitionRequest) Reset()

func (*SyncNewCreatedPartitionRequest) String 

func (x *SyncNewCreatedPartitionRequest) String() string

type SyncReplicaSegmentsRequest 

type SyncReplicaSegmentsRequest struct {
	Base            *commonpb.MsgBase      `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	VchannelName    string                 `protobuf:"bytes,2,opt,name=vchannel_name,json=vchannelName,proto3" json:"vchannel_name,omitempty"`
	ReplicaSegments []*ReplicaSegmentsInfo `protobuf:"bytes,3,rep,name=replica_segments,json=replicaSegments,proto3" json:"replica_segments,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncReplicaSegmentsRequest) Descriptor deprecated 

func (*SyncReplicaSegmentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use SyncReplicaSegmentsRequest.ProtoReflect.Descriptor instead.

func (*SyncReplicaSegmentsRequest) GetBase 

func (x *SyncReplicaSegmentsRequest) GetBase() *commonpb.MsgBase

func (*SyncReplicaSegmentsRequest) GetReplicaSegments 

func (x *SyncReplicaSegmentsRequest) GetReplicaSegments() []*ReplicaSegmentsInfo

func (*SyncReplicaSegmentsRequest) GetVchannelName 

func (x *SyncReplicaSegmentsRequest) GetVchannelName() string

func (*SyncReplicaSegmentsRequest) ProtoMessage 

func (*SyncReplicaSegmentsRequest) ProtoMessage()

func (*SyncReplicaSegmentsRequest) ProtoReflect 

func (x *SyncReplicaSegmentsRequest) ProtoReflect() protoreflect.Message

func (*SyncReplicaSegmentsRequest) Reset 

func (x *SyncReplicaSegmentsRequest) Reset()

func (*SyncReplicaSegmentsRequest) String 

func (x *SyncReplicaSegmentsRequest) String() string

type SyncType 

type SyncType int32
const (
	SyncType_Remove               SyncType = 0
	SyncType_Set                  SyncType = 1
	SyncType_Amend                SyncType = 2
	SyncType_UpdateVersion        SyncType = 3
	SyncType_UpdatePartitionStats SyncType = 4
)

func (SyncType) Descriptor 

func (SyncType) Descriptor() protoreflect.EnumDescriptor

func (SyncType) Enum 

func (x SyncType) Enum() *SyncType

func (SyncType) EnumDescriptor deprecated 

func (SyncType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SyncType.Descriptor instead.

func (SyncType) Number 

func (x SyncType) Number() protoreflect.EnumNumber

func (SyncType) String 

func (x SyncType) String() string

func (SyncType) Type 

func (SyncType) Type() protoreflect.EnumType

type TransferChannelRequest 

type TransferChannelRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	ChannelName  string            `protobuf:"bytes,2,opt,name=channel_name,json=channelName,proto3" json:"channel_name,omitempty"`
	SourceNodeID int64             `protobuf:"varint,3,opt,name=source_nodeID,json=sourceNodeID,proto3" json:"source_nodeID,omitempty"`
	TargetNodeID int64             `protobuf:"varint,4,opt,name=target_nodeID,json=targetNodeID,proto3" json:"target_nodeID,omitempty"`
	TransferAll  bool              `protobuf:"varint,5,opt,name=transfer_all,json=transferAll,proto3" json:"transfer_all,omitempty"`
	ToAllNodes   bool              `protobuf:"varint,6,opt,name=to_all_nodes,json=toAllNodes,proto3" json:"to_all_nodes,omitempty"`
	CopyMode     bool              `protobuf:"varint,7,opt,name=copy_mode,json=copyMode,proto3" json:"copy_mode,omitempty"`
	// contains filtered or unexported fields
}

func (*TransferChannelRequest) Descriptor deprecated 

func (*TransferChannelRequest) Descriptor() ([]byte, []int)

Deprecated: Use TransferChannelRequest.ProtoReflect.Descriptor instead.

func (*TransferChannelRequest) GetBase 

func (x *TransferChannelRequest) GetBase() *commonpb.MsgBase

func (*TransferChannelRequest) GetChannelName 

func (x *TransferChannelRequest) GetChannelName() string

func (*TransferChannelRequest) GetCopyMode 

func (x *TransferChannelRequest) GetCopyMode() bool

func (*TransferChannelRequest) GetSourceNodeID 

func (x *TransferChannelRequest) GetSourceNodeID() int64

func (*TransferChannelRequest) GetTargetNodeID 

func (x *TransferChannelRequest) GetTargetNodeID() int64

func (*TransferChannelRequest) GetToAllNodes 

func (x *TransferChannelRequest) GetToAllNodes() bool

func (*TransferChannelRequest) GetTransferAll 

func (x *TransferChannelRequest) GetTransferAll() bool

func (*TransferChannelRequest) ProtoMessage 

func (*TransferChannelRequest) ProtoMessage()

func (*TransferChannelRequest) ProtoReflect 

func (x *TransferChannelRequest) ProtoReflect() protoreflect.Message

func (*TransferChannelRequest) Reset 

func (x *TransferChannelRequest) Reset()

func (*TransferChannelRequest) String 

func (x *TransferChannelRequest) String() string

type TransferReplicaRequest 

type TransferReplicaRequest struct {
	Base                *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	SourceResourceGroup string            `protobuf:"bytes,2,opt,name=source_resource_group,json=sourceResourceGroup,proto3" json:"source_resource_group,omitempty"`
	TargetResourceGroup string            `protobuf:"bytes,3,opt,name=target_resource_group,json=targetResourceGroup,proto3" json:"target_resource_group,omitempty"`
	CollectionID        int64             `protobuf:"varint,4,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	NumReplica          int64             `protobuf:"varint,5,opt,name=num_replica,json=numReplica,proto3" json:"num_replica,omitempty"`
	// contains filtered or unexported fields
}

transfer `replicaNum` replicas in `collectionID` from `source_resource_group` to `target_resource_groups`

func (*TransferReplicaRequest) Descriptor deprecated 

func (*TransferReplicaRequest) Descriptor() ([]byte, []int)

Deprecated: Use TransferReplicaRequest.ProtoReflect.Descriptor instead.

func (*TransferReplicaRequest) GetBase 

func (x *TransferReplicaRequest) GetBase() *commonpb.MsgBase

func (*TransferReplicaRequest) GetCollectionID 

func (x *TransferReplicaRequest) GetCollectionID() int64

func (*TransferReplicaRequest) GetNumReplica 

func (x *TransferReplicaRequest) GetNumReplica() int64

func (*TransferReplicaRequest) GetSourceResourceGroup 

func (x *TransferReplicaRequest) GetSourceResourceGroup() string

func (*TransferReplicaRequest) GetTargetResourceGroup 

func (x *TransferReplicaRequest) GetTargetResourceGroup() string

func (*TransferReplicaRequest) ProtoMessage 

func (*TransferReplicaRequest) ProtoMessage()

func (*TransferReplicaRequest) ProtoReflect 

func (x *TransferReplicaRequest) ProtoReflect() protoreflect.Message

func (*TransferReplicaRequest) Reset 

func (x *TransferReplicaRequest) Reset()

func (*TransferReplicaRequest) String 

func (x *TransferReplicaRequest) String() string

type TransferSegmentRequest 

type TransferSegmentRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	SegmentID    int64             `protobuf:"varint,2,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	SourceNodeID int64             `protobuf:"varint,3,opt,name=source_nodeID,json=sourceNodeID,proto3" json:"source_nodeID,omitempty"`
	TargetNodeID int64             `protobuf:"varint,4,opt,name=target_nodeID,json=targetNodeID,proto3" json:"target_nodeID,omitempty"`
	TransferAll  bool              `protobuf:"varint,5,opt,name=transfer_all,json=transferAll,proto3" json:"transfer_all,omitempty"`
	ToAllNodes   bool              `protobuf:"varint,6,opt,name=to_all_nodes,json=toAllNodes,proto3" json:"to_all_nodes,omitempty"`
	CopyMode     bool              `protobuf:"varint,7,opt,name=copy_mode,json=copyMode,proto3" json:"copy_mode,omitempty"`
	// contains filtered or unexported fields
}

func (*TransferSegmentRequest) Descriptor deprecated 

func (*TransferSegmentRequest) Descriptor() ([]byte, []int)

Deprecated: Use TransferSegmentRequest.ProtoReflect.Descriptor instead.

func (*TransferSegmentRequest) GetBase 

func (x *TransferSegmentRequest) GetBase() *commonpb.MsgBase

func (*TransferSegmentRequest) GetCopyMode 

func (x *TransferSegmentRequest) GetCopyMode() bool

func (*TransferSegmentRequest) GetSegmentID 

func (x *TransferSegmentRequest) GetSegmentID() int64

func (*TransferSegmentRequest) GetSourceNodeID 

func (x *TransferSegmentRequest) GetSourceNodeID() int64

func (*TransferSegmentRequest) GetTargetNodeID 

func (x *TransferSegmentRequest) GetTargetNodeID() int64

func (*TransferSegmentRequest) GetToAllNodes 

func (x *TransferSegmentRequest) GetToAllNodes() bool

func (*TransferSegmentRequest) GetTransferAll 

func (x *TransferSegmentRequest) GetTransferAll() bool

func (*TransferSegmentRequest) ProtoMessage 

func (*TransferSegmentRequest) ProtoMessage()

func (*TransferSegmentRequest) ProtoReflect 

func (x *TransferSegmentRequest) ProtoReflect() protoreflect.Message

func (*TransferSegmentRequest) Reset 

func (x *TransferSegmentRequest) Reset()

func (*TransferSegmentRequest) String 

func (x *TransferSegmentRequest) String() string

type TriggerCondition 

type TriggerCondition int32
const (
	TriggerCondition_UnKnowCondition TriggerCondition = 0
	TriggerCondition_Handoff         TriggerCondition = 1
	TriggerCondition_LoadBalance     TriggerCondition = 2
	TriggerCondition_GrpcRequest     TriggerCondition = 3
	TriggerCondition_NodeDown        TriggerCondition = 4
)

func (TriggerCondition) Descriptor 

func (TriggerCondition) Descriptor() protoreflect.EnumDescriptor

func (TriggerCondition) Enum 

func (x TriggerCondition) Enum() *TriggerCondition

func (TriggerCondition) EnumDescriptor deprecated 

func (TriggerCondition) EnumDescriptor() ([]byte, []int)

Deprecated: Use TriggerCondition.Descriptor instead.

func (TriggerCondition) Number 

func (x TriggerCondition) Number() protoreflect.EnumNumber

func (TriggerCondition) String 

func (x TriggerCondition) String() string

func (TriggerCondition) Type 

func (TriggerCondition) Type() protoreflect.EnumType

type UnimplementedQueryCoordServer 

type UnimplementedQueryCoordServer struct {
}

UnimplementedQueryCoordServer should be embedded to have forward compatible implementations.

func (UnimplementedQueryCoordServer) ActivateChecker 

func (UnimplementedQueryCoordServer) ActivateChecker(context.Context, *ActivateCheckerRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) CheckHealth 

func (UnimplementedQueryCoordServer) CheckHealth(context.Context, *milvuspb.CheckHealthRequest) (*milvuspb.CheckHealthResponse, error)

func (UnimplementedQueryCoordServer) CheckQueryNodeDistribution 

func (UnimplementedQueryCoordServer) CheckQueryNodeDistribution(context.Context, *CheckQueryNodeDistributionRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) CreateResourceGroup 

func (UnimplementedQueryCoordServer) CreateResourceGroup(context.Context, *milvuspb.CreateResourceGroupRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) DeactivateChecker 

func (UnimplementedQueryCoordServer) DeactivateChecker(context.Context, *DeactivateCheckerRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) DescribeResourceGroup 

func (UnimplementedQueryCoordServer) DescribeResourceGroup(context.Context, *DescribeResourceGroupRequest) (*DescribeResourceGroupResponse, error)

func (UnimplementedQueryCoordServer) DropResourceGroup 

func (UnimplementedQueryCoordServer) DropResourceGroup(context.Context, *milvuspb.DropResourceGroupRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) GetComponentStates 

func (UnimplementedQueryCoordServer) GetComponentStates(context.Context, *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)

func (UnimplementedQueryCoordServer) GetMetrics 

func (UnimplementedQueryCoordServer) GetMetrics(context.Context, *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error)

func (UnimplementedQueryCoordServer) GetPartitionStates 

func (UnimplementedQueryCoordServer) GetPartitionStates(context.Context, *GetPartitionStatesRequest) (*GetPartitionStatesResponse, error)

func (UnimplementedQueryCoordServer) GetQueryNodeDistribution 

func (UnimplementedQueryCoordServer) GetQueryNodeDistribution(context.Context, *GetQueryNodeDistributionRequest) (*GetQueryNodeDistributionResponse, error)

func (UnimplementedQueryCoordServer) GetReplicas 

func (UnimplementedQueryCoordServer) GetReplicas(context.Context, *milvuspb.GetReplicasRequest) (*milvuspb.GetReplicasResponse, error)

func (UnimplementedQueryCoordServer) GetSegmentInfo 

func (UnimplementedQueryCoordServer) GetSegmentInfo(context.Context, *GetSegmentInfoRequest) (*GetSegmentInfoResponse, error)

func (UnimplementedQueryCoordServer) GetShardLeaders 

func (UnimplementedQueryCoordServer) GetShardLeaders(context.Context, *GetShardLeadersRequest) (*GetShardLeadersResponse, error)

func (UnimplementedQueryCoordServer) GetStatisticsChannel 

func (UnimplementedQueryCoordServer) GetStatisticsChannel(context.Context, *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)

func (UnimplementedQueryCoordServer) GetTimeTickChannel 

func (UnimplementedQueryCoordServer) GetTimeTickChannel(context.Context, *internalpb.GetTimeTickChannelRequest) (*milvuspb.StringResponse, error)

func (UnimplementedQueryCoordServer) ListCheckers 

func (UnimplementedQueryCoordServer) ListCheckers(context.Context, *ListCheckersRequest) (*ListCheckersResponse, error)

func (UnimplementedQueryCoordServer) ListQueryNode 

func (UnimplementedQueryCoordServer) ListQueryNode(context.Context, *ListQueryNodeRequest) (*ListQueryNodeResponse, error)

func (UnimplementedQueryCoordServer) ListResourceGroups 

func (UnimplementedQueryCoordServer) ListResourceGroups(context.Context, *milvuspb.ListResourceGroupsRequest) (*milvuspb.ListResourceGroupsResponse, error)

func (UnimplementedQueryCoordServer) LoadBalance 

func (UnimplementedQueryCoordServer) LoadBalance(context.Context, *LoadBalanceRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) LoadCollection 

func (UnimplementedQueryCoordServer) LoadCollection(context.Context, *LoadCollectionRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) LoadPartitions 

func (UnimplementedQueryCoordServer) LoadPartitions(context.Context, *LoadPartitionsRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) ReleaseCollection 

func (UnimplementedQueryCoordServer) ReleaseCollection(context.Context, *ReleaseCollectionRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) ReleasePartitions 

func (UnimplementedQueryCoordServer) ReleasePartitions(context.Context, *ReleasePartitionsRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) ResumeBalance 

func (UnimplementedQueryCoordServer) ResumeBalance(context.Context, *ResumeBalanceRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) ResumeNode 

func (UnimplementedQueryCoordServer) ResumeNode(context.Context, *ResumeNodeRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) ShowCollections 

func (UnimplementedQueryCoordServer) ShowCollections(context.Context, *ShowCollectionsRequest) (*ShowCollectionsResponse, error)

func (UnimplementedQueryCoordServer) ShowConfigurations 

func (UnimplementedQueryCoordServer) ShowConfigurations(context.Context, *internalpb.ShowConfigurationsRequest) (*internalpb.ShowConfigurationsResponse, error)

func (UnimplementedQueryCoordServer) ShowPartitions 

func (UnimplementedQueryCoordServer) ShowPartitions(context.Context, *ShowPartitionsRequest) (*ShowPartitionsResponse, error)

func (UnimplementedQueryCoordServer) SuspendBalance 

func (UnimplementedQueryCoordServer) SuspendBalance(context.Context, *SuspendBalanceRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) SuspendNode 

func (UnimplementedQueryCoordServer) SuspendNode(context.Context, *SuspendNodeRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) SyncNewCreatedPartition 

func (UnimplementedQueryCoordServer) SyncNewCreatedPartition(context.Context, *SyncNewCreatedPartitionRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) TransferChannel 

func (UnimplementedQueryCoordServer) TransferChannel(context.Context, *TransferChannelRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) TransferNode 

func (UnimplementedQueryCoordServer) TransferNode(context.Context, *milvuspb.TransferNodeRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) TransferReplica 

func (UnimplementedQueryCoordServer) TransferReplica(context.Context, *TransferReplicaRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) TransferSegment 

func (UnimplementedQueryCoordServer) TransferSegment(context.Context, *TransferSegmentRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) UpdateLoadConfig 

func (UnimplementedQueryCoordServer) UpdateLoadConfig(context.Context, *UpdateLoadConfigRequest) (*commonpb.Status, error)

func (UnimplementedQueryCoordServer) UpdateResourceGroups 

func (UnimplementedQueryCoordServer) UpdateResourceGroups(context.Context, *UpdateResourceGroupsRequest) (*commonpb.Status, error)

type UnimplementedQueryNodeServer 

type UnimplementedQueryNodeServer struct {
}

UnimplementedQueryNodeServer should be embedded to have forward compatible implementations.

func (UnimplementedQueryNodeServer) Delete 

func (UnimplementedQueryNodeServer) Delete(context.Context, *DeleteRequest) (*commonpb.Status, error)

func (UnimplementedQueryNodeServer) DeleteBatch 

func (UnimplementedQueryNodeServer) DeleteBatch(context.Context, *DeleteBatchRequest) (*DeleteBatchResponse, error)

func (UnimplementedQueryNodeServer) GetComponentStates 

func (UnimplementedQueryNodeServer) GetComponentStates(context.Context, *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)

func (UnimplementedQueryNodeServer) GetDataDistribution 

func (UnimplementedQueryNodeServer) GetDataDistribution(context.Context, *GetDataDistributionRequest) (*GetDataDistributionResponse, error)

func (UnimplementedQueryNodeServer) GetMetrics 

func (UnimplementedQueryNodeServer) GetMetrics(context.Context, *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error)

func (UnimplementedQueryNodeServer) GetSegmentInfo 

func (UnimplementedQueryNodeServer) GetSegmentInfo(context.Context, *GetSegmentInfoRequest) (*GetSegmentInfoResponse, error)

func (UnimplementedQueryNodeServer) GetStatistics 

func (UnimplementedQueryNodeServer) GetStatistics(context.Context, *GetStatisticsRequest) (*internalpb.GetStatisticsResponse, error)

func (UnimplementedQueryNodeServer) GetStatisticsChannel 

func (UnimplementedQueryNodeServer) GetStatisticsChannel(context.Context, *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)

func (UnimplementedQueryNodeServer) GetTimeTickChannel 

func (UnimplementedQueryNodeServer) GetTimeTickChannel(context.Context, *internalpb.GetTimeTickChannelRequest) (*milvuspb.StringResponse, error)

func (UnimplementedQueryNodeServer) LoadPartitions 

func (UnimplementedQueryNodeServer) LoadPartitions(context.Context, *LoadPartitionsRequest) (*commonpb.Status, error)

func (UnimplementedQueryNodeServer) LoadSegments 

func (UnimplementedQueryNodeServer) LoadSegments(context.Context, *LoadSegmentsRequest) (*commonpb.Status, error)

func (UnimplementedQueryNodeServer) Query 

func (UnimplementedQueryNodeServer) Query(context.Context, *QueryRequest) (*internalpb.RetrieveResults, error)

func (UnimplementedQueryNodeServer) QuerySegments 

func (UnimplementedQueryNodeServer) QuerySegments(context.Context, *QueryRequest) (*internalpb.RetrieveResults, error)

func (UnimplementedQueryNodeServer) QueryStream 

func (UnimplementedQueryNodeServer) QueryStream(*QueryRequest, QueryNode_QueryStreamServer) error

func (UnimplementedQueryNodeServer) QueryStreamSegments 

func (UnimplementedQueryNodeServer) QueryStreamSegments(*QueryRequest, QueryNode_QueryStreamSegmentsServer) error

func (UnimplementedQueryNodeServer) ReleaseCollection 

func (UnimplementedQueryNodeServer) ReleaseCollection(context.Context, *ReleaseCollectionRequest) (*commonpb.Status, error)

func (UnimplementedQueryNodeServer) ReleasePartitions 

func (UnimplementedQueryNodeServer) ReleasePartitions(context.Context, *ReleasePartitionsRequest) (*commonpb.Status, error)

func (UnimplementedQueryNodeServer) ReleaseSegments 

func (UnimplementedQueryNodeServer) ReleaseSegments(context.Context, *ReleaseSegmentsRequest) (*commonpb.Status, error)

func (UnimplementedQueryNodeServer) Search 

func (UnimplementedQueryNodeServer) Search(context.Context, *SearchRequest) (*internalpb.SearchResults, error)

func (UnimplementedQueryNodeServer) SearchSegments 

func (UnimplementedQueryNodeServer) SearchSegments(context.Context, *SearchRequest) (*internalpb.SearchResults, error)

func (UnimplementedQueryNodeServer) ShowConfigurations 

func (UnimplementedQueryNodeServer) ShowConfigurations(context.Context, *internalpb.ShowConfigurationsRequest) (*internalpb.ShowConfigurationsResponse, error)

func (UnimplementedQueryNodeServer) SyncDistribution 

func (UnimplementedQueryNodeServer) SyncDistribution(context.Context, *SyncDistributionRequest) (*commonpb.Status, error)

func (UnimplementedQueryNodeServer) SyncReplicaSegments 

func (UnimplementedQueryNodeServer) SyncReplicaSegments(context.Context, *SyncReplicaSegmentsRequest) (*commonpb.Status, error)

func (UnimplementedQueryNodeServer) UnsubDmChannel 

func (UnimplementedQueryNodeServer) UnsubDmChannel(context.Context, *UnsubDmChannelRequest) (*commonpb.Status, error)

func (UnimplementedQueryNodeServer) WatchDmChannels 

func (UnimplementedQueryNodeServer) WatchDmChannels(context.Context, *WatchDmChannelsRequest) (*commonpb.Status, error)

type UnsafeQueryCoordServer 

type UnsafeQueryCoordServer interface {
	// contains filtered or unexported methods
}

UnsafeQueryCoordServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryCoordServer will result in compilation errors.

type UnsafeQueryNodeServer 

type UnsafeQueryNodeServer interface {
	// contains filtered or unexported methods
}

UnsafeQueryNodeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryNodeServer will result in compilation errors.

type UnsubDmChannelRequest 

type UnsubDmChannelRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	NodeID       int64             `protobuf:"varint,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	CollectionID int64             `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	ChannelName  string            `protobuf:"bytes,4,opt,name=channel_name,json=channelName,proto3" json:"channel_name,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubDmChannelRequest) Descriptor deprecated 

func (*UnsubDmChannelRequest) Descriptor() ([]byte, []int)

Deprecated: Use UnsubDmChannelRequest.ProtoReflect.Descriptor instead.

func (*UnsubDmChannelRequest) GetBase 

func (x *UnsubDmChannelRequest) GetBase() *commonpb.MsgBase

func (*UnsubDmChannelRequest) GetChannelName 

func (x *UnsubDmChannelRequest) GetChannelName() string

func (*UnsubDmChannelRequest) GetCollectionID 

func (x *UnsubDmChannelRequest) GetCollectionID() int64

func (*UnsubDmChannelRequest) GetNodeID 

func (x *UnsubDmChannelRequest) GetNodeID() int64

func (*UnsubDmChannelRequest) ProtoMessage 

func (*UnsubDmChannelRequest) ProtoMessage()

func (*UnsubDmChannelRequest) ProtoReflect 

func (x *UnsubDmChannelRequest) ProtoReflect() protoreflect.Message

func (*UnsubDmChannelRequest) Reset 

func (x *UnsubDmChannelRequest) Reset()

func (*UnsubDmChannelRequest) String 

func (x *UnsubDmChannelRequest) String() string

type UnsubscribeChannelInfo 

type UnsubscribeChannelInfo struct {
	NodeID             int64                  `protobuf:"varint,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	CollectionChannels []*UnsubscribeChannels `protobuf:"bytes,2,rep,name=collection_channels,json=collectionChannels,proto3" json:"collection_channels,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubscribeChannelInfo) Descriptor deprecated 

func (*UnsubscribeChannelInfo) Descriptor() ([]byte, []int)

Deprecated: Use UnsubscribeChannelInfo.ProtoReflect.Descriptor instead.

func (*UnsubscribeChannelInfo) GetCollectionChannels 

func (x *UnsubscribeChannelInfo) GetCollectionChannels() []*UnsubscribeChannels

func (*UnsubscribeChannelInfo) GetNodeID 

func (x *UnsubscribeChannelInfo) GetNodeID() int64

func (*UnsubscribeChannelInfo) ProtoMessage 

func (*UnsubscribeChannelInfo) ProtoMessage()

func (*UnsubscribeChannelInfo) ProtoReflect 

func (x *UnsubscribeChannelInfo) ProtoReflect() protoreflect.Message

func (*UnsubscribeChannelInfo) Reset 

func (x *UnsubscribeChannelInfo) Reset()

func (*UnsubscribeChannelInfo) String 

func (x *UnsubscribeChannelInfo) String() string

type UnsubscribeChannels 

type UnsubscribeChannels struct {
	CollectionID int64    `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	Channels     []string `protobuf:"bytes,2,rep,name=channels,proto3" json:"channels,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubscribeChannels) Descriptor deprecated 

func (*UnsubscribeChannels) Descriptor() ([]byte, []int)

Deprecated: Use UnsubscribeChannels.ProtoReflect.Descriptor instead.

func (*UnsubscribeChannels) GetChannels 

func (x *UnsubscribeChannels) GetChannels() []string

func (*UnsubscribeChannels) GetCollectionID 

func (x *UnsubscribeChannels) GetCollectionID() int64

func (*UnsubscribeChannels) ProtoMessage 

func (*UnsubscribeChannels) ProtoMessage()

func (*UnsubscribeChannels) ProtoReflect 

func (x *UnsubscribeChannels) ProtoReflect() protoreflect.Message

func (*UnsubscribeChannels) Reset 

func (x *UnsubscribeChannels) Reset()

func (*UnsubscribeChannels) String 

func (x *UnsubscribeChannels) String() string

type UpdateLoadConfigRequest 

type UpdateLoadConfigRequest struct {
	Base           *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbID           int64             `protobuf:"varint,2,opt,name=dbID,proto3" json:"dbID,omitempty"`
	CollectionIDs  []int64           `protobuf:"varint,3,rep,packed,name=collectionIDs,proto3" json:"collectionIDs,omitempty"`
	ReplicaNumber  int32             `protobuf:"varint,4,opt,name=replica_number,json=replicaNumber,proto3" json:"replica_number,omitempty"`
	ResourceGroups []string          `protobuf:"bytes,5,rep,name=resource_groups,json=resourceGroups,proto3" json:"resource_groups,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateLoadConfigRequest) Descriptor deprecated 

func (*UpdateLoadConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateLoadConfigRequest.ProtoReflect.Descriptor instead.

func (*UpdateLoadConfigRequest) GetBase 

func (x *UpdateLoadConfigRequest) GetBase() *commonpb.MsgBase

func (*UpdateLoadConfigRequest) GetCollectionIDs 

func (x *UpdateLoadConfigRequest) GetCollectionIDs() []int64

func (*UpdateLoadConfigRequest) GetDbID 

func (x *UpdateLoadConfigRequest) GetDbID() int64

func (*UpdateLoadConfigRequest) GetReplicaNumber 

func (x *UpdateLoadConfigRequest) GetReplicaNumber() int32

func (*UpdateLoadConfigRequest) GetResourceGroups 

func (x *UpdateLoadConfigRequest) GetResourceGroups() []string

func (*UpdateLoadConfigRequest) ProtoMessage 

func (*UpdateLoadConfigRequest) ProtoMessage()

func (*UpdateLoadConfigRequest) ProtoReflect 

func (x *UpdateLoadConfigRequest) ProtoReflect() protoreflect.Message

func (*UpdateLoadConfigRequest) Reset 

func (x *UpdateLoadConfigRequest) Reset()

func (*UpdateLoadConfigRequest) String 

func (x *UpdateLoadConfigRequest) String() string

type UpdateResourceGroupsRequest 

type UpdateResourceGroupsRequest struct {
	Base           *commonpb.MsgBase                    `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	ResourceGroups map[string]*rgpb.ResourceGroupConfig `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateResourceGroupsRequest) Descriptor deprecated 

func (*UpdateResourceGroupsRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateResourceGroupsRequest.ProtoReflect.Descriptor instead.

func (*UpdateResourceGroupsRequest) GetBase 

func (x *UpdateResourceGroupsRequest) GetBase() *commonpb.MsgBase

func (*UpdateResourceGroupsRequest) GetResourceGroups 

func (x *UpdateResourceGroupsRequest) GetResourceGroups() map[string]*rgpb.ResourceGroupConfig

func (*UpdateResourceGroupsRequest) ProtoMessage 

func (*UpdateResourceGroupsRequest) ProtoMessage()

func (*UpdateResourceGroupsRequest) ProtoReflect 

func (x *UpdateResourceGroupsRequest) ProtoReflect() protoreflect.Message

func (*UpdateResourceGroupsRequest) Reset 

func (x *UpdateResourceGroupsRequest) Reset()

func (*UpdateResourceGroupsRequest) String 

func (x *UpdateResourceGroupsRequest) String() string

type WatchDmChannelsRequest 

type WatchDmChannelsRequest struct {
	Base         *commonpb.MsgBase             `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	NodeID       int64                         `protobuf:"varint,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	CollectionID int64                         `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionIDs []int64                       `protobuf:"varint,4,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	Infos        []*datapb.VchannelInfo        `protobuf:"bytes,5,rep,name=infos,proto3" json:"infos,omitempty"`
	Schema       *schemapb.CollectionSchema    `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"`
	ExcludeInfos []*datapb.SegmentInfo         `protobuf:"bytes,7,rep,name=exclude_infos,json=excludeInfos,proto3" json:"exclude_infos,omitempty"`
	LoadMeta     *LoadMetaInfo                 `protobuf:"bytes,8,opt,name=load_meta,json=loadMeta,proto3" json:"load_meta,omitempty"`
	ReplicaID    int64                         `protobuf:"varint,9,opt,name=replicaID,proto3" json:"replicaID,omitempty"`
	SegmentInfos map[int64]*datapb.SegmentInfo `` /* 187-byte string literal not displayed */
	// Deprecated
	// for node down load balance, need to remove offline node in time after every watchDmChannel finish.
	OfflineNodeID int64                `protobuf:"varint,11,opt,name=offlineNodeID,proto3" json:"offlineNodeID,omitempty"`
	Version       int64                `protobuf:"varint,12,opt,name=version,proto3" json:"version,omitempty"`
	IndexInfoList []*indexpb.IndexInfo `protobuf:"bytes,13,rep,name=index_info_list,json=indexInfoList,proto3" json:"index_info_list,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchDmChannelsRequest) Descriptor deprecated 

func (*WatchDmChannelsRequest) Descriptor() ([]byte, []int)

Deprecated: Use WatchDmChannelsRequest.ProtoReflect.Descriptor instead.

func (*WatchDmChannelsRequest) GetBase 

func (x *WatchDmChannelsRequest) GetBase() *commonpb.MsgBase

func (*WatchDmChannelsRequest) GetCollectionID 

func (x *WatchDmChannelsRequest) GetCollectionID() int64

func (*WatchDmChannelsRequest) GetExcludeInfos 

func (x *WatchDmChannelsRequest) GetExcludeInfos() []*datapb.SegmentInfo

func (*WatchDmChannelsRequest) GetIndexInfoList 

func (x *WatchDmChannelsRequest) GetIndexInfoList() []*indexpb.IndexInfo

func (*WatchDmChannelsRequest) GetInfos 

func (x *WatchDmChannelsRequest) GetInfos() []*datapb.VchannelInfo

func (*WatchDmChannelsRequest) GetLoadMeta 

func (x *WatchDmChannelsRequest) GetLoadMeta() *LoadMetaInfo

func (*WatchDmChannelsRequest) GetNodeID 

func (x *WatchDmChannelsRequest) GetNodeID() int64

func (*WatchDmChannelsRequest) GetOfflineNodeID 

func (x *WatchDmChannelsRequest) GetOfflineNodeID() int64

func (*WatchDmChannelsRequest) GetPartitionIDs 

func (x *WatchDmChannelsRequest) GetPartitionIDs() []int64

func (*WatchDmChannelsRequest) GetReplicaID 

func (x *WatchDmChannelsRequest) GetReplicaID() int64

func (*WatchDmChannelsRequest) GetSchema 

func (x *WatchDmChannelsRequest) GetSchema() *schemapb.CollectionSchema

func (*WatchDmChannelsRequest) GetSegmentInfos 

func (x *WatchDmChannelsRequest) GetSegmentInfos() map[int64]*datapb.SegmentInfo

func (*WatchDmChannelsRequest) GetVersion 

func (x *WatchDmChannelsRequest) GetVersion() int64

func (*WatchDmChannelsRequest) ProtoMessage 

func (*WatchDmChannelsRequest) ProtoMessage()

func (*WatchDmChannelsRequest) ProtoReflect 

func (x *WatchDmChannelsRequest) ProtoReflect() protoreflect.Message

func (*WatchDmChannelsRequest) Reset 

func (x *WatchDmChannelsRequest) Reset()

func (*WatchDmChannelsRequest) String 

func (x *WatchDmChannelsRequest) String() string

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.