datapb

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: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DataCoord_GetComponentStates_FullMethodName          = "/milvus.proto.data.DataCoord/GetComponentStates"
	DataCoord_GetTimeTickChannel_FullMethodName          = "/milvus.proto.data.DataCoord/GetTimeTickChannel"
	DataCoord_GetStatisticsChannel_FullMethodName        = "/milvus.proto.data.DataCoord/GetStatisticsChannel"
	DataCoord_Flush_FullMethodName                       = "/milvus.proto.data.DataCoord/Flush"
	DataCoord_AllocSegment_FullMethodName                = "/milvus.proto.data.DataCoord/AllocSegment"
	DataCoord_AssignSegmentID_FullMethodName             = "/milvus.proto.data.DataCoord/AssignSegmentID"
	DataCoord_GetSegmentInfo_FullMethodName              = "/milvus.proto.data.DataCoord/GetSegmentInfo"
	DataCoord_GetSegmentStates_FullMethodName            = "/milvus.proto.data.DataCoord/GetSegmentStates"
	DataCoord_GetInsertBinlogPaths_FullMethodName        = "/milvus.proto.data.DataCoord/GetInsertBinlogPaths"
	DataCoord_GetCollectionStatistics_FullMethodName     = "/milvus.proto.data.DataCoord/GetCollectionStatistics"
	DataCoord_GetPartitionStatistics_FullMethodName      = "/milvus.proto.data.DataCoord/GetPartitionStatistics"
	DataCoord_GetSegmentInfoChannel_FullMethodName       = "/milvus.proto.data.DataCoord/GetSegmentInfoChannel"
	DataCoord_SaveBinlogPaths_FullMethodName             = "/milvus.proto.data.DataCoord/SaveBinlogPaths"
	DataCoord_GetRecoveryInfo_FullMethodName             = "/milvus.proto.data.DataCoord/GetRecoveryInfo"
	DataCoord_GetRecoveryInfoV2_FullMethodName           = "/milvus.proto.data.DataCoord/GetRecoveryInfoV2"
	DataCoord_GetChannelRecoveryInfo_FullMethodName      = "/milvus.proto.data.DataCoord/GetChannelRecoveryInfo"
	DataCoord_GetFlushedSegments_FullMethodName          = "/milvus.proto.data.DataCoord/GetFlushedSegments"
	DataCoord_GetSegmentsByStates_FullMethodName         = "/milvus.proto.data.DataCoord/GetSegmentsByStates"
	DataCoord_GetFlushAllState_FullMethodName            = "/milvus.proto.data.DataCoord/GetFlushAllState"
	DataCoord_ShowConfigurations_FullMethodName          = "/milvus.proto.data.DataCoord/ShowConfigurations"
	DataCoord_GetMetrics_FullMethodName                  = "/milvus.proto.data.DataCoord/GetMetrics"
	DataCoord_ManualCompaction_FullMethodName            = "/milvus.proto.data.DataCoord/ManualCompaction"
	DataCoord_GetCompactionState_FullMethodName          = "/milvus.proto.data.DataCoord/GetCompactionState"
	DataCoord_GetCompactionStateWithPlans_FullMethodName = "/milvus.proto.data.DataCoord/GetCompactionStateWithPlans"
	DataCoord_WatchChannels_FullMethodName               = "/milvus.proto.data.DataCoord/WatchChannels"
	DataCoord_GetFlushState_FullMethodName               = "/milvus.proto.data.DataCoord/GetFlushState"
	DataCoord_DropVirtualChannel_FullMethodName          = "/milvus.proto.data.DataCoord/DropVirtualChannel"
	DataCoord_SetSegmentState_FullMethodName             = "/milvus.proto.data.DataCoord/SetSegmentState"
	DataCoord_UpdateSegmentStatistics_FullMethodName     = "/milvus.proto.data.DataCoord/UpdateSegmentStatistics"
	DataCoord_UpdateChannelCheckpoint_FullMethodName     = "/milvus.proto.data.DataCoord/UpdateChannelCheckpoint"
	DataCoord_MarkSegmentsDropped_FullMethodName         = "/milvus.proto.data.DataCoord/MarkSegmentsDropped"
	DataCoord_BroadcastAlteredCollection_FullMethodName  = "/milvus.proto.data.DataCoord/BroadcastAlteredCollection"
	DataCoord_CheckHealth_FullMethodName                 = "/milvus.proto.data.DataCoord/CheckHealth"
	DataCoord_CreateIndex_FullMethodName                 = "/milvus.proto.data.DataCoord/CreateIndex"
	DataCoord_AlterIndex_FullMethodName                  = "/milvus.proto.data.DataCoord/AlterIndex"
	DataCoord_GetIndexState_FullMethodName               = "/milvus.proto.data.DataCoord/GetIndexState"
	DataCoord_GetSegmentIndexState_FullMethodName        = "/milvus.proto.data.DataCoord/GetSegmentIndexState"
	DataCoord_GetIndexInfos_FullMethodName               = "/milvus.proto.data.DataCoord/GetIndexInfos"
	DataCoord_DropIndex_FullMethodName                   = "/milvus.proto.data.DataCoord/DropIndex"
	DataCoord_DescribeIndex_FullMethodName               = "/milvus.proto.data.DataCoord/DescribeIndex"
	DataCoord_GetIndexStatistics_FullMethodName          = "/milvus.proto.data.DataCoord/GetIndexStatistics"
	DataCoord_GetIndexBuildProgress_FullMethodName       = "/milvus.proto.data.DataCoord/GetIndexBuildProgress"
	DataCoord_ListIndexes_FullMethodName                 = "/milvus.proto.data.DataCoord/ListIndexes"
	DataCoord_GcConfirm_FullMethodName                   = "/milvus.proto.data.DataCoord/GcConfirm"
	DataCoord_ReportDataNodeTtMsgs_FullMethodName        = "/milvus.proto.data.DataCoord/ReportDataNodeTtMsgs"
	DataCoord_GcControl_FullMethodName                   = "/milvus.proto.data.DataCoord/GcControl"
	DataCoord_ImportV2_FullMethodName                    = "/milvus.proto.data.DataCoord/ImportV2"
	DataCoord_GetImportProgress_FullMethodName           = "/milvus.proto.data.DataCoord/GetImportProgress"
	DataCoord_ListImports_FullMethodName                 = "/milvus.proto.data.DataCoord/ListImports"
)
View Source 
const (
	DataNode_GetComponentStates_FullMethodName            = "/milvus.proto.data.DataNode/GetComponentStates"
	DataNode_GetStatisticsChannel_FullMethodName          = "/milvus.proto.data.DataNode/GetStatisticsChannel"
	DataNode_WatchDmChannels_FullMethodName               = "/milvus.proto.data.DataNode/WatchDmChannels"
	DataNode_FlushSegments_FullMethodName                 = "/milvus.proto.data.DataNode/FlushSegments"
	DataNode_ShowConfigurations_FullMethodName            = "/milvus.proto.data.DataNode/ShowConfigurations"
	DataNode_GetMetrics_FullMethodName                    = "/milvus.proto.data.DataNode/GetMetrics"
	DataNode_CompactionV2_FullMethodName                  = "/milvus.proto.data.DataNode/CompactionV2"
	DataNode_GetCompactionState_FullMethodName            = "/milvus.proto.data.DataNode/GetCompactionState"
	DataNode_SyncSegments_FullMethodName                  = "/milvus.proto.data.DataNode/SyncSegments"
	DataNode_ResendSegmentStats_FullMethodName            = "/milvus.proto.data.DataNode/ResendSegmentStats"
	DataNode_FlushChannels_FullMethodName                 = "/milvus.proto.data.DataNode/FlushChannels"
	DataNode_NotifyChannelOperation_FullMethodName        = "/milvus.proto.data.DataNode/NotifyChannelOperation"
	DataNode_CheckChannelOperationProgress_FullMethodName = "/milvus.proto.data.DataNode/CheckChannelOperationProgress"
	DataNode_PreImport_FullMethodName                     = "/milvus.proto.data.DataNode/PreImport"
	DataNode_ImportV2_FullMethodName                      = "/milvus.proto.data.DataNode/ImportV2"
	DataNode_QueryPreImport_FullMethodName                = "/milvus.proto.data.DataNode/QueryPreImport"
	DataNode_QueryImport_FullMethodName                   = "/milvus.proto.data.DataNode/QueryImport"
	DataNode_DropImport_FullMethodName                    = "/milvus.proto.data.DataNode/DropImport"
	DataNode_QuerySlot_FullMethodName                     = "/milvus.proto.data.DataNode/QuerySlot"
	DataNode_DropCompactionPlan_FullMethodName            = "/milvus.proto.data.DataNode/DropCompactionPlan"
)

Variables

View Source 
var (
	SegmentType_name = map[int32]string{
		0: "New",
		1: "Normal",
		2: "Flushed",
		3: "Compacted",
	}
	SegmentType_value = map[string]int32{
		"New":       0,
		"Normal":    1,
		"Flushed":   2,
		"Compacted": 3,
	}
)

Enum value maps for SegmentType.

View Source 
var (
	SegmentLevel_name = map[int32]string{
		0: "Legacy",
		1: "L0",
		2: "L1",
		3: "L2",
	}
	SegmentLevel_value = map[string]int32{
		"Legacy": 0,
		"L0":     1,
		"L1":     2,
		"L2":     3,
	}
)

Enum value maps for SegmentLevel.

View Source 
var (
	ChannelWatchState_name = map[int32]string{
		0: "Uncomplete",
		1: "Complete",
		2: "ToWatch",
		3: "WatchSuccess",
		4: "WatchFailure",
		5: "ToRelease",
		6: "ReleaseSuccess",
		7: "ReleaseFailure",
	}
	ChannelWatchState_value = map[string]int32{
		"Uncomplete":     0,
		"Complete":       1,
		"ToWatch":        2,
		"WatchSuccess":   3,
		"WatchFailure":   4,
		"ToRelease":      5,
		"ReleaseSuccess": 6,
		"ReleaseFailure": 7,
	}
)

Enum value maps for ChannelWatchState.

View Source 
var (
	CompactionType_name = map[int32]string{
		0: "UndefinedCompaction",
		2: "MergeCompaction",
		3: "MixCompaction",
		4: "SingleCompaction",
		5: "MinorCompaction",
		6: "MajorCompaction",
		7: "Level0DeleteCompaction",
		8: "ClusteringCompaction",
	}
	CompactionType_value = map[string]int32{
		"UndefinedCompaction":    0,
		"MergeCompaction":        2,
		"MixCompaction":          3,
		"SingleCompaction":       4,
		"MinorCompaction":        5,
		"MajorCompaction":        6,
		"Level0DeleteCompaction": 7,
		"ClusteringCompaction":   8,
	}
)

Enum value maps for CompactionType.

View Source 
var (
	ImportTaskStateV2_name = map[int32]string{
		0: "None",
		1: "Pending",
		2: "InProgress",
		3: "Failed",
		4: "Completed",
	}
	ImportTaskStateV2_value = map[string]int32{
		"None":       0,
		"Pending":    1,
		"InProgress": 2,
		"Failed":     3,
		"Completed":  4,
	}
)

Enum value maps for ImportTaskStateV2.

View Source 
var (
	GcCommand_name = map[int32]string{
		0: "_",
		1: "Pause",
		2: "Resume",
	}
	GcCommand_value = map[string]int32{
		"_":      0,
		"Pause":  1,
		"Resume": 2,
	}
)

Enum value maps for GcCommand.

View Source 
var (
	CompactionTaskState_name = map[int32]string{
		0:  "unknown",
		1:  "executing",
		2:  "pipelining",
		3:  "completed",
		4:  "failed",
		5:  "timeout",
		6:  "analyzing",
		7:  "indexing",
		8:  "cleaned",
		9:  "meta_saved",
		10: "statistic",
	}
	CompactionTaskState_value = map[string]int32{
		"unknown":    0,
		"executing":  1,
		"pipelining": 2,
		"completed":  3,
		"failed":     4,
		"timeout":    5,
		"analyzing":  6,
		"indexing":   7,
		"cleaned":    8,
		"meta_saved": 9,
		"statistic":  10,
	}
)

Enum value maps for CompactionTaskState.

View Source 
var DataCoord_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "milvus.proto.data.DataCoord",
	HandlerType: (*DataCoordServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetComponentStates",
			Handler:    _DataCoord_GetComponentStates_Handler,
		},
		{
			MethodName: "GetTimeTickChannel",
			Handler:    _DataCoord_GetTimeTickChannel_Handler,
		},
		{
			MethodName: "GetStatisticsChannel",
			Handler:    _DataCoord_GetStatisticsChannel_Handler,
		},
		{
			MethodName: "Flush",
			Handler:    _DataCoord_Flush_Handler,
		},
		{
			MethodName: "AllocSegment",
			Handler:    _DataCoord_AllocSegment_Handler,
		},
		{
			MethodName: "AssignSegmentID",
			Handler:    _DataCoord_AssignSegmentID_Handler,
		},
		{
			MethodName: "GetSegmentInfo",
			Handler:    _DataCoord_GetSegmentInfo_Handler,
		},
		{
			MethodName: "GetSegmentStates",
			Handler:    _DataCoord_GetSegmentStates_Handler,
		},
		{
			MethodName: "GetInsertBinlogPaths",
			Handler:    _DataCoord_GetInsertBinlogPaths_Handler,
		},
		{
			MethodName: "GetCollectionStatistics",
			Handler:    _DataCoord_GetCollectionStatistics_Handler,
		},
		{
			MethodName: "GetPartitionStatistics",
			Handler:    _DataCoord_GetPartitionStatistics_Handler,
		},
		{
			MethodName: "GetSegmentInfoChannel",
			Handler:    _DataCoord_GetSegmentInfoChannel_Handler,
		},
		{
			MethodName: "SaveBinlogPaths",
			Handler:    _DataCoord_SaveBinlogPaths_Handler,
		},
		{
			MethodName: "GetRecoveryInfo",
			Handler:    _DataCoord_GetRecoveryInfo_Handler,
		},
		{
			MethodName: "GetRecoveryInfoV2",
			Handler:    _DataCoord_GetRecoveryInfoV2_Handler,
		},
		{
			MethodName: "GetChannelRecoveryInfo",
			Handler:    _DataCoord_GetChannelRecoveryInfo_Handler,
		},
		{
			MethodName: "GetFlushedSegments",
			Handler:    _DataCoord_GetFlushedSegments_Handler,
		},
		{
			MethodName: "GetSegmentsByStates",
			Handler:    _DataCoord_GetSegmentsByStates_Handler,
		},
		{
			MethodName: "GetFlushAllState",
			Handler:    _DataCoord_GetFlushAllState_Handler,
		},
		{
			MethodName: "ShowConfigurations",
			Handler:    _DataCoord_ShowConfigurations_Handler,
		},
		{
			MethodName: "GetMetrics",
			Handler:    _DataCoord_GetMetrics_Handler,
		},
		{
			MethodName: "ManualCompaction",
			Handler:    _DataCoord_ManualCompaction_Handler,
		},
		{
			MethodName: "GetCompactionState",
			Handler:    _DataCoord_GetCompactionState_Handler,
		},
		{
			MethodName: "GetCompactionStateWithPlans",
			Handler:    _DataCoord_GetCompactionStateWithPlans_Handler,
		},
		{
			MethodName: "WatchChannels",
			Handler:    _DataCoord_WatchChannels_Handler,
		},
		{
			MethodName: "GetFlushState",
			Handler:    _DataCoord_GetFlushState_Handler,
		},
		{
			MethodName: "DropVirtualChannel",
			Handler:    _DataCoord_DropVirtualChannel_Handler,
		},
		{
			MethodName: "SetSegmentState",
			Handler:    _DataCoord_SetSegmentState_Handler,
		},
		{
			MethodName: "UpdateSegmentStatistics",
			Handler:    _DataCoord_UpdateSegmentStatistics_Handler,
		},
		{
			MethodName: "UpdateChannelCheckpoint",
			Handler:    _DataCoord_UpdateChannelCheckpoint_Handler,
		},
		{
			MethodName: "MarkSegmentsDropped",
			Handler:    _DataCoord_MarkSegmentsDropped_Handler,
		},
		{
			MethodName: "BroadcastAlteredCollection",
			Handler:    _DataCoord_BroadcastAlteredCollection_Handler,
		},
		{
			MethodName: "CheckHealth",
			Handler:    _DataCoord_CheckHealth_Handler,
		},
		{
			MethodName: "CreateIndex",
			Handler:    _DataCoord_CreateIndex_Handler,
		},
		{
			MethodName: "AlterIndex",
			Handler:    _DataCoord_AlterIndex_Handler,
		},
		{
			MethodName: "GetIndexState",
			Handler:    _DataCoord_GetIndexState_Handler,
		},
		{
			MethodName: "GetSegmentIndexState",
			Handler:    _DataCoord_GetSegmentIndexState_Handler,
		},
		{
			MethodName: "GetIndexInfos",
			Handler:    _DataCoord_GetIndexInfos_Handler,
		},
		{
			MethodName: "DropIndex",
			Handler:    _DataCoord_DropIndex_Handler,
		},
		{
			MethodName: "DescribeIndex",
			Handler:    _DataCoord_DescribeIndex_Handler,
		},
		{
			MethodName: "GetIndexStatistics",
			Handler:    _DataCoord_GetIndexStatistics_Handler,
		},
		{
			MethodName: "GetIndexBuildProgress",
			Handler:    _DataCoord_GetIndexBuildProgress_Handler,
		},
		{
			MethodName: "ListIndexes",
			Handler:    _DataCoord_ListIndexes_Handler,
		},
		{
			MethodName: "GcConfirm",
			Handler:    _DataCoord_GcConfirm_Handler,
		},
		{
			MethodName: "ReportDataNodeTtMsgs",
			Handler:    _DataCoord_ReportDataNodeTtMsgs_Handler,
		},
		{
			MethodName: "GcControl",
			Handler:    _DataCoord_GcControl_Handler,
		},
		{
			MethodName: "ImportV2",
			Handler:    _DataCoord_ImportV2_Handler,
		},
		{
			MethodName: "GetImportProgress",
			Handler:    _DataCoord_GetImportProgress_Handler,
		},
		{
			MethodName: "ListImports",
			Handler:    _DataCoord_ListImports_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "data_coord.proto",
}

DataCoord_ServiceDesc is the grpc.ServiceDesc for DataCoord 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 DataNode_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "milvus.proto.data.DataNode",
	HandlerType: (*DataNodeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetComponentStates",
			Handler:    _DataNode_GetComponentStates_Handler,
		},
		{
			MethodName: "GetStatisticsChannel",
			Handler:    _DataNode_GetStatisticsChannel_Handler,
		},
		{
			MethodName: "WatchDmChannels",
			Handler:    _DataNode_WatchDmChannels_Handler,
		},
		{
			MethodName: "FlushSegments",
			Handler:    _DataNode_FlushSegments_Handler,
		},
		{
			MethodName: "ShowConfigurations",
			Handler:    _DataNode_ShowConfigurations_Handler,
		},
		{
			MethodName: "GetMetrics",
			Handler:    _DataNode_GetMetrics_Handler,
		},
		{
			MethodName: "CompactionV2",
			Handler:    _DataNode_CompactionV2_Handler,
		},
		{
			MethodName: "GetCompactionState",
			Handler:    _DataNode_GetCompactionState_Handler,
		},
		{
			MethodName: "SyncSegments",
			Handler:    _DataNode_SyncSegments_Handler,
		},
		{
			MethodName: "ResendSegmentStats",
			Handler:    _DataNode_ResendSegmentStats_Handler,
		},
		{
			MethodName: "FlushChannels",
			Handler:    _DataNode_FlushChannels_Handler,
		},
		{
			MethodName: "NotifyChannelOperation",
			Handler:    _DataNode_NotifyChannelOperation_Handler,
		},
		{
			MethodName: "CheckChannelOperationProgress",
			Handler:    _DataNode_CheckChannelOperationProgress_Handler,
		},
		{
			MethodName: "PreImport",
			Handler:    _DataNode_PreImport_Handler,
		},
		{
			MethodName: "ImportV2",
			Handler:    _DataNode_ImportV2_Handler,
		},
		{
			MethodName: "QueryPreImport",
			Handler:    _DataNode_QueryPreImport_Handler,
		},
		{
			MethodName: "QueryImport",
			Handler:    _DataNode_QueryImport_Handler,
		},
		{
			MethodName: "DropImport",
			Handler:    _DataNode_DropImport_Handler,
		},
		{
			MethodName: "QuerySlot",
			Handler:    _DataNode_QuerySlot_Handler,
		},
		{
			MethodName: "DropCompactionPlan",
			Handler:    _DataNode_DropCompactionPlan_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "data_coord.proto",
}

DataNode_ServiceDesc is the grpc.ServiceDesc for DataNode 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 File_data_coord_proto protoreflect.FileDescriptor

Functions

func RegisterDataCoordServer 

func RegisterDataCoordServer(s grpc.ServiceRegistrar, srv DataCoordServer)

func RegisterDataNodeServer 

func RegisterDataNodeServer(s grpc.ServiceRegistrar, srv DataNodeServer)

Types

type AllocSegmentRequest 

type AllocSegmentRequest struct {
	CollectionId int64  `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	PartitionId  int64  `protobuf:"varint,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	SegmentId    int64  `protobuf:"varint,3,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"` // segment id must be allocate from rootcoord idalloc service.
	Vchannel     string `protobuf:"bytes,4,opt,name=vchannel,proto3" json:"vchannel,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocSegmentRequest) Descriptor deprecated 

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

Deprecated: Use AllocSegmentRequest.ProtoReflect.Descriptor instead.

func (*AllocSegmentRequest) GetCollectionId 

func (x *AllocSegmentRequest) GetCollectionId() int64

func (*AllocSegmentRequest) GetPartitionId 

func (x *AllocSegmentRequest) GetPartitionId() int64

func (*AllocSegmentRequest) GetSegmentId 

func (x *AllocSegmentRequest) GetSegmentId() int64

func (*AllocSegmentRequest) GetVchannel 

func (x *AllocSegmentRequest) GetVchannel() string

func (*AllocSegmentRequest) ProtoMessage 

func (*AllocSegmentRequest) ProtoMessage()

func (*AllocSegmentRequest) ProtoReflect 

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

func (*AllocSegmentRequest) Reset 

func (x *AllocSegmentRequest) Reset()

func (*AllocSegmentRequest) String 

func (x *AllocSegmentRequest) String() string

type AllocSegmentResponse 

type AllocSegmentResponse struct {
	SegmentInfo *SegmentInfo     `protobuf:"bytes,1,opt,name=segment_info,json=segmentInfo,proto3" json:"segment_info,omitempty"`
	Status      *commonpb.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocSegmentResponse) Descriptor deprecated 

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

Deprecated: Use AllocSegmentResponse.ProtoReflect.Descriptor instead.

func (*AllocSegmentResponse) GetSegmentInfo 

func (x *AllocSegmentResponse) GetSegmentInfo() *SegmentInfo

func (*AllocSegmentResponse) GetStatus 

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

func (*AllocSegmentResponse) ProtoMessage 

func (*AllocSegmentResponse) ProtoMessage()

func (*AllocSegmentResponse) ProtoReflect 

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

func (*AllocSegmentResponse) Reset 

func (x *AllocSegmentResponse) Reset()

func (*AllocSegmentResponse) String 

func (x *AllocSegmentResponse) String() string

type AlterCollectionRequest 

type AlterCollectionRequest struct {
	CollectionID   int64                      `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	Schema         *schemapb.CollectionSchema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	PartitionIDs   []int64                    `protobuf:"varint,3,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	StartPositions []*commonpb.KeyDataPair    `protobuf:"bytes,4,rep,name=start_positions,json=startPositions,proto3" json:"start_positions,omitempty"`
	Properties     []*commonpb.KeyValuePair   `protobuf:"bytes,5,rep,name=properties,proto3" json:"properties,omitempty"`
	DbID           int64                      `protobuf:"varint,6,opt,name=dbID,proto3" json:"dbID,omitempty"`
	VChannels      []string                   `protobuf:"bytes,7,rep,name=vChannels,proto3" json:"vChannels,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterCollectionRequest) Descriptor deprecated 

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

Deprecated: Use AlterCollectionRequest.ProtoReflect.Descriptor instead.

func (*AlterCollectionRequest) GetCollectionID 

func (x *AlterCollectionRequest) GetCollectionID() int64

func (*AlterCollectionRequest) GetDbID 

func (x *AlterCollectionRequest) GetDbID() int64

func (*AlterCollectionRequest) GetPartitionIDs 

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

func (*AlterCollectionRequest) GetProperties 

func (x *AlterCollectionRequest) GetProperties() []*commonpb.KeyValuePair

func (*AlterCollectionRequest) GetSchema 

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

func (*AlterCollectionRequest) GetStartPositions 

func (x *AlterCollectionRequest) GetStartPositions() []*commonpb.KeyDataPair

func (*AlterCollectionRequest) GetVChannels 

func (x *AlterCollectionRequest) GetVChannels() []string

func (*AlterCollectionRequest) ProtoMessage 

func (*AlterCollectionRequest) ProtoMessage()

func (*AlterCollectionRequest) ProtoReflect 

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

func (*AlterCollectionRequest) Reset 

func (x *AlterCollectionRequest) Reset()

func (*AlterCollectionRequest) String 

func (x *AlterCollectionRequest) String() string

type AssignSegmentIDRequest 

type AssignSegmentIDRequest struct {
	NodeID            int64               `protobuf:"varint,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	PeerRole          string              `protobuf:"bytes,2,opt,name=peer_role,json=peerRole,proto3" json:"peer_role,omitempty"`
	SegmentIDRequests []*SegmentIDRequest `protobuf:"bytes,3,rep,name=segmentIDRequests,proto3" json:"segmentIDRequests,omitempty"`
	// contains filtered or unexported fields
}

func (*AssignSegmentIDRequest) Descriptor deprecated 

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

Deprecated: Use AssignSegmentIDRequest.ProtoReflect.Descriptor instead.

func (*AssignSegmentIDRequest) GetNodeID 

func (x *AssignSegmentIDRequest) GetNodeID() int64

func (*AssignSegmentIDRequest) GetPeerRole 

func (x *AssignSegmentIDRequest) GetPeerRole() string

func (*AssignSegmentIDRequest) GetSegmentIDRequests 

func (x *AssignSegmentIDRequest) GetSegmentIDRequests() []*SegmentIDRequest

func (*AssignSegmentIDRequest) ProtoMessage 

func (*AssignSegmentIDRequest) ProtoMessage()

func (*AssignSegmentIDRequest) ProtoReflect 

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

func (*AssignSegmentIDRequest) Reset 

func (x *AssignSegmentIDRequest) Reset()

func (*AssignSegmentIDRequest) String 

func (x *AssignSegmentIDRequest) String() string

type AssignSegmentIDResponse 

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

func (*AssignSegmentIDResponse) Descriptor deprecated 

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

Deprecated: Use AssignSegmentIDResponse.ProtoReflect.Descriptor instead.

func (*AssignSegmentIDResponse) GetSegIDAssignments 

func (x *AssignSegmentIDResponse) GetSegIDAssignments() []*SegmentIDAssignment

func (*AssignSegmentIDResponse) GetStatus 

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

func (*AssignSegmentIDResponse) ProtoMessage 

func (*AssignSegmentIDResponse) ProtoMessage()

func (*AssignSegmentIDResponse) ProtoReflect 

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

func (*AssignSegmentIDResponse) Reset 

func (x *AssignSegmentIDResponse) Reset()

func (*AssignSegmentIDResponse) String 

func (x *AssignSegmentIDResponse) String() string

type Binlog 

type Binlog struct {
	EntriesNum    int64  `protobuf:"varint,1,opt,name=entries_num,json=entriesNum,proto3" json:"entries_num,omitempty"`
	TimestampFrom uint64 `protobuf:"varint,2,opt,name=timestamp_from,json=timestampFrom,proto3" json:"timestamp_from,omitempty"`
	TimestampTo   uint64 `protobuf:"varint,3,opt,name=timestamp_to,json=timestampTo,proto3" json:"timestamp_to,omitempty"`
	// deprecated
	LogPath string `protobuf:"bytes,4,opt,name=log_path,json=logPath,proto3" json:"log_path,omitempty"`
	LogSize int64  `protobuf:"varint,5,opt,name=log_size,json=logSize,proto3" json:"log_size,omitempty"`
	LogID   int64  `protobuf:"varint,6,opt,name=logID,proto3" json:"logID,omitempty"`
	// memory_size represents the size occupied by loading data into memory.
	// log_size represents the size after data serialized.
	// for stats_log, the memory_size always equal log_size.
	MemorySize int64 `protobuf:"varint,7,opt,name=memory_size,json=memorySize,proto3" json:"memory_size,omitempty"`
	// contains filtered or unexported fields
}

func (*Binlog) Descriptor deprecated 

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

Deprecated: Use Binlog.ProtoReflect.Descriptor instead.

func (*Binlog) GetEntriesNum 

func (x *Binlog) GetEntriesNum() int64

func (*Binlog) GetLogID 

func (x *Binlog) GetLogID() int64

func (*Binlog) GetLogPath 

func (x *Binlog) GetLogPath() string

func (*Binlog) GetLogSize 

func (x *Binlog) GetLogSize() int64

func (*Binlog) GetMemorySize 

func (x *Binlog) GetMemorySize() int64

func (*Binlog) GetTimestampFrom 

func (x *Binlog) GetTimestampFrom() uint64

func (*Binlog) GetTimestampTo 

func (x *Binlog) GetTimestampTo() uint64

func (*Binlog) ProtoMessage 

func (*Binlog) ProtoMessage()

func (*Binlog) ProtoReflect 

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

func (*Binlog) Reset 

func (x *Binlog) Reset()

func (*Binlog) String 

func (x *Binlog) String() string

type ChannelOperationProgressResponse 

type ChannelOperationProgressResponse struct {
	Status   *commonpb.Status  `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	OpID     int64             `protobuf:"varint,2,opt,name=opID,proto3" json:"opID,omitempty"`
	State    ChannelWatchState `protobuf:"varint,3,opt,name=state,proto3,enum=milvus.proto.data.ChannelWatchState" json:"state,omitempty"`
	Progress int32             `protobuf:"varint,4,opt,name=progress,proto3" json:"progress,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelOperationProgressResponse) Descriptor deprecated 

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

Deprecated: Use ChannelOperationProgressResponse.ProtoReflect.Descriptor instead.

func (*ChannelOperationProgressResponse) GetOpID 

func (x *ChannelOperationProgressResponse) GetOpID() int64

func (*ChannelOperationProgressResponse) GetProgress 

func (x *ChannelOperationProgressResponse) GetProgress() int32

func (*ChannelOperationProgressResponse) GetState 

func (x *ChannelOperationProgressResponse) GetState() ChannelWatchState

func (*ChannelOperationProgressResponse) GetStatus 

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

func (*ChannelOperationProgressResponse) ProtoMessage 

func (*ChannelOperationProgressResponse) ProtoMessage()

func (*ChannelOperationProgressResponse) ProtoReflect 

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

func (*ChannelOperationProgressResponse) Reset 

func (x *ChannelOperationProgressResponse) Reset()

func (*ChannelOperationProgressResponse) String 

func (x *ChannelOperationProgressResponse) String() string

type ChannelOperationsRequest 

type ChannelOperationsRequest struct {
	Infos []*ChannelWatchInfo `protobuf:"bytes,1,rep,name=infos,proto3" json:"infos,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelOperationsRequest) Descriptor deprecated 

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

Deprecated: Use ChannelOperationsRequest.ProtoReflect.Descriptor instead.

func (*ChannelOperationsRequest) GetInfos 

func (x *ChannelOperationsRequest) GetInfos() []*ChannelWatchInfo

func (*ChannelOperationsRequest) ProtoMessage 

func (*ChannelOperationsRequest) ProtoMessage()

func (*ChannelOperationsRequest) ProtoReflect 

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

func (*ChannelOperationsRequest) Reset 

func (x *ChannelOperationsRequest) Reset()

func (*ChannelOperationsRequest) String 

func (x *ChannelOperationsRequest) String() string

type ChannelStatus 

type ChannelStatus struct {
	Name         string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	State        ChannelWatchState `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.data.ChannelWatchState" json:"state,omitempty"`
	CollectionID int64             `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelStatus) Descriptor deprecated 

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

Deprecated: Use ChannelStatus.ProtoReflect.Descriptor instead.

func (*ChannelStatus) GetCollectionID 

func (x *ChannelStatus) GetCollectionID() int64

func (*ChannelStatus) GetName 

func (x *ChannelStatus) GetName() string

func (*ChannelStatus) GetState 

func (x *ChannelStatus) GetState() ChannelWatchState

func (*ChannelStatus) ProtoMessage 

func (*ChannelStatus) ProtoMessage()

func (*ChannelStatus) ProtoReflect 

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

func (*ChannelStatus) Reset 

func (x *ChannelStatus) Reset()

func (*ChannelStatus) String 

func (x *ChannelStatus) String() string

type ChannelWatchInfo 

type ChannelWatchInfo struct {
	Vchan   *VchannelInfo     `protobuf:"bytes,1,opt,name=vchan,proto3" json:"vchan,omitempty"`
	StartTs int64             `protobuf:"varint,2,opt,name=startTs,proto3" json:"startTs,omitempty"`
	State   ChannelWatchState `protobuf:"varint,3,opt,name=state,proto3,enum=milvus.proto.data.ChannelWatchState" json:"state,omitempty"`
	// the timeout ts, datanode shall do nothing after it
	// NOT USED.
	TimeoutTs int64 `protobuf:"varint,4,opt,name=timeoutTs,proto3" json:"timeoutTs,omitempty"`
	// the schema of the collection to watch, to avoid get schema rpc issues.
	Schema *schemapb.CollectionSchema `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	// watch progress, deprecated
	Progress     int32                    `protobuf:"varint,6,opt,name=progress,proto3" json:"progress,omitempty"`
	OpID         int64                    `protobuf:"varint,7,opt,name=opID,proto3" json:"opID,omitempty"`
	DbProperties []*commonpb.KeyValuePair `protobuf:"bytes,8,rep,name=dbProperties,proto3" json:"dbProperties,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelWatchInfo) Descriptor deprecated 

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

Deprecated: Use ChannelWatchInfo.ProtoReflect.Descriptor instead.

func (*ChannelWatchInfo) GetDbProperties 

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

func (*ChannelWatchInfo) GetOpID 

func (x *ChannelWatchInfo) GetOpID() int64

func (*ChannelWatchInfo) GetProgress 

func (x *ChannelWatchInfo) GetProgress() int32

func (*ChannelWatchInfo) GetSchema 

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

func (*ChannelWatchInfo) GetStartTs 

func (x *ChannelWatchInfo) GetStartTs() int64

func (*ChannelWatchInfo) GetState 

func (x *ChannelWatchInfo) GetState() ChannelWatchState

func (*ChannelWatchInfo) GetTimeoutTs 

func (x *ChannelWatchInfo) GetTimeoutTs() int64

func (*ChannelWatchInfo) GetVchan 

func (x *ChannelWatchInfo) GetVchan() *VchannelInfo

func (*ChannelWatchInfo) ProtoMessage 

func (*ChannelWatchInfo) ProtoMessage()

func (*ChannelWatchInfo) ProtoReflect 

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

func (*ChannelWatchInfo) Reset 

func (x *ChannelWatchInfo) Reset()

func (*ChannelWatchInfo) String 

func (x *ChannelWatchInfo) String() string

type ChannelWatchState 

type ChannelWatchState int32
const (
	ChannelWatchState_Uncomplete     ChannelWatchState = 0 // deprecated, keep it for compatibility
	ChannelWatchState_Complete       ChannelWatchState = 1 // deprecated, keep it for compatibility
	ChannelWatchState_ToWatch        ChannelWatchState = 2
	ChannelWatchState_WatchSuccess   ChannelWatchState = 3
	ChannelWatchState_WatchFailure   ChannelWatchState = 4
	ChannelWatchState_ToRelease      ChannelWatchState = 5
	ChannelWatchState_ReleaseSuccess ChannelWatchState = 6
	ChannelWatchState_ReleaseFailure ChannelWatchState = 7
)

func (ChannelWatchState) Descriptor 

func (ChannelWatchState) Descriptor() protoreflect.EnumDescriptor

func (ChannelWatchState) Enum 

func (x ChannelWatchState) Enum() *ChannelWatchState

func (ChannelWatchState) EnumDescriptor deprecated 

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

Deprecated: Use ChannelWatchState.Descriptor instead.

func (ChannelWatchState) Number 

func (x ChannelWatchState) Number() protoreflect.EnumNumber

func (ChannelWatchState) String 

func (x ChannelWatchState) String() string

func (ChannelWatchState) Type 

func (ChannelWatchState) Type() protoreflect.EnumType

type CheckPoint 

type CheckPoint struct {
	SegmentID int64              `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	Position  *msgpb.MsgPosition `protobuf:"bytes,2,opt,name=position,proto3" json:"position,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 (*CheckPoint) Descriptor deprecated 

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

Deprecated: Use CheckPoint.ProtoReflect.Descriptor instead.

func (*CheckPoint) GetNumOfRows 

func (x *CheckPoint) GetNumOfRows() int64

func (*CheckPoint) GetPosition 

func (x *CheckPoint) GetPosition() *msgpb.MsgPosition

func (*CheckPoint) GetSegmentID 

func (x *CheckPoint) GetSegmentID() int64

func (*CheckPoint) ProtoMessage 

func (*CheckPoint) ProtoMessage()

func (*CheckPoint) ProtoReflect 

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

func (*CheckPoint) Reset 

func (x *CheckPoint) Reset()

func (*CheckPoint) String 

func (x *CheckPoint) String() string

type CompactionPlan 

type CompactionPlan struct {
	PlanID                 int64                       `protobuf:"varint,1,opt,name=planID,proto3" json:"planID,omitempty"`
	SegmentBinlogs         []*CompactionSegmentBinlogs `protobuf:"bytes,2,rep,name=segmentBinlogs,proto3" json:"segmentBinlogs,omitempty"`
	StartTime              int64                       `protobuf:"varint,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	TimeoutInSeconds       int32                       `protobuf:"varint,4,opt,name=timeout_in_seconds,json=timeoutInSeconds,proto3" json:"timeout_in_seconds,omitempty"`
	Type                   CompactionType              `protobuf:"varint,5,opt,name=type,proto3,enum=milvus.proto.data.CompactionType" json:"type,omitempty"`
	Timetravel             uint64                      `protobuf:"varint,6,opt,name=timetravel,proto3" json:"timetravel,omitempty"`
	Channel                string                      `protobuf:"bytes,7,opt,name=channel,proto3" json:"channel,omitempty"`
	CollectionTtl          int64                       `protobuf:"varint,8,opt,name=collection_ttl,json=collectionTtl,proto3" json:"collection_ttl,omitempty"` // nanoseconds
	TotalRows              int64                       `protobuf:"varint,9,opt,name=total_rows,json=totalRows,proto3" json:"total_rows,omitempty"`
	Schema                 *schemapb.CollectionSchema  `protobuf:"bytes,10,opt,name=schema,proto3" json:"schema,omitempty"`
	ClusteringKeyField     int64                       `protobuf:"varint,11,opt,name=clustering_key_field,json=clusteringKeyField,proto3" json:"clustering_key_field,omitempty"`
	MaxSegmentRows         int64                       `protobuf:"varint,12,opt,name=max_segment_rows,json=maxSegmentRows,proto3" json:"max_segment_rows,omitempty"`
	PreferSegmentRows      int64                       `protobuf:"varint,13,opt,name=prefer_segment_rows,json=preferSegmentRows,proto3" json:"prefer_segment_rows,omitempty"`
	AnalyzeResultPath      string                      `protobuf:"bytes,14,opt,name=analyze_result_path,json=analyzeResultPath,proto3" json:"analyze_result_path,omitempty"`
	AnalyzeSegmentIds      []int64                     `protobuf:"varint,15,rep,packed,name=analyze_segment_ids,json=analyzeSegmentIds,proto3" json:"analyze_segment_ids,omitempty"`
	State                  int32                       `protobuf:"varint,16,opt,name=state,proto3" json:"state,omitempty"`
	BeginLogID             int64                       `protobuf:"varint,17,opt,name=begin_logID,json=beginLogID,proto3" json:"begin_logID,omitempty"`
	PreAllocatedSegmentIDs *IDRange                    `` /* 130-byte string literal not displayed */
	SlotUsage              int64                       `protobuf:"varint,19,opt,name=slot_usage,json=slotUsage,proto3" json:"slot_usage,omitempty"`
	MaxSize                int64                       `protobuf:"varint,20,opt,name=max_size,json=maxSize,proto3" json:"max_size,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactionPlan) Descriptor deprecated 

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

Deprecated: Use CompactionPlan.ProtoReflect.Descriptor instead.

func (*CompactionPlan) GetAnalyzeResultPath 

func (x *CompactionPlan) GetAnalyzeResultPath() string

func (*CompactionPlan) GetAnalyzeSegmentIds 

func (x *CompactionPlan) GetAnalyzeSegmentIds() []int64

func (*CompactionPlan) GetBeginLogID 

func (x *CompactionPlan) GetBeginLogID() int64

func (*CompactionPlan) GetChannel 

func (x *CompactionPlan) GetChannel() string

func (*CompactionPlan) GetClusteringKeyField 

func (x *CompactionPlan) GetClusteringKeyField() int64

func (*CompactionPlan) GetCollectionTtl 

func (x *CompactionPlan) GetCollectionTtl() int64

func (*CompactionPlan) GetMaxSegmentRows 

func (x *CompactionPlan) GetMaxSegmentRows() int64

func (*CompactionPlan) GetMaxSize 

func (x *CompactionPlan) GetMaxSize() int64

func (*CompactionPlan) GetPlanID 

func (x *CompactionPlan) GetPlanID() int64

func (*CompactionPlan) GetPreAllocatedSegmentIDs 

func (x *CompactionPlan) GetPreAllocatedSegmentIDs() *IDRange

func (*CompactionPlan) GetPreferSegmentRows 

func (x *CompactionPlan) GetPreferSegmentRows() int64

func (*CompactionPlan) GetSchema 

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

func (*CompactionPlan) GetSegmentBinlogs 

func (x *CompactionPlan) GetSegmentBinlogs() []*CompactionSegmentBinlogs

func (*CompactionPlan) GetSlotUsage 

func (x *CompactionPlan) GetSlotUsage() int64

func (*CompactionPlan) GetStartTime 

func (x *CompactionPlan) GetStartTime() int64

func (*CompactionPlan) GetState 

func (x *CompactionPlan) GetState() int32

func (*CompactionPlan) GetTimeoutInSeconds 

func (x *CompactionPlan) GetTimeoutInSeconds() int32

func (*CompactionPlan) GetTimetravel 

func (x *CompactionPlan) GetTimetravel() uint64

func (*CompactionPlan) GetTotalRows 

func (x *CompactionPlan) GetTotalRows() int64

func (*CompactionPlan) GetType 

func (x *CompactionPlan) GetType() CompactionType

func (*CompactionPlan) ProtoMessage 

func (*CompactionPlan) ProtoMessage()

func (*CompactionPlan) ProtoReflect 

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

func (*CompactionPlan) Reset 

func (x *CompactionPlan) Reset()

func (*CompactionPlan) String 

func (x *CompactionPlan) String() string

type CompactionPlanResult 

type CompactionPlanResult struct {
	PlanID   int64                `protobuf:"varint,1,opt,name=planID,proto3" json:"planID,omitempty"`
	State    CompactionTaskState  `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.data.CompactionTaskState" json:"state,omitempty"`
	Segments []*CompactionSegment `protobuf:"bytes,3,rep,name=segments,proto3" json:"segments,omitempty"`
	Channel  string               `protobuf:"bytes,4,opt,name=channel,proto3" json:"channel,omitempty"`
	Type     CompactionType       `protobuf:"varint,5,opt,name=type,proto3,enum=milvus.proto.data.CompactionType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactionPlanResult) Descriptor deprecated 

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

Deprecated: Use CompactionPlanResult.ProtoReflect.Descriptor instead.

func (*CompactionPlanResult) GetChannel 

func (x *CompactionPlanResult) GetChannel() string

func (*CompactionPlanResult) GetPlanID 

func (x *CompactionPlanResult) GetPlanID() int64

func (*CompactionPlanResult) GetSegments 

func (x *CompactionPlanResult) GetSegments() []*CompactionSegment

func (*CompactionPlanResult) GetState 

func (x *CompactionPlanResult) GetState() CompactionTaskState

func (*CompactionPlanResult) GetType 

func (x *CompactionPlanResult) GetType() CompactionType

func (*CompactionPlanResult) ProtoMessage 

func (*CompactionPlanResult) ProtoMessage()

func (*CompactionPlanResult) ProtoReflect 

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

func (*CompactionPlanResult) Reset 

func (x *CompactionPlanResult) Reset()

func (*CompactionPlanResult) String 

func (x *CompactionPlanResult) String() string

type CompactionSegment 

type CompactionSegment struct {
	PlanID              int64          `protobuf:"varint,1,opt,name=planID,proto3" json:"planID,omitempty"` // deprecated after 2.3.4
	SegmentID           int64          `protobuf:"varint,2,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	NumOfRows           int64          `protobuf:"varint,3,opt,name=num_of_rows,json=numOfRows,proto3" json:"num_of_rows,omitempty"`
	InsertLogs          []*FieldBinlog `protobuf:"bytes,4,rep,name=insert_logs,json=insertLogs,proto3" json:"insert_logs,omitempty"`
	Field2StatslogPaths []*FieldBinlog `protobuf:"bytes,5,rep,name=field2StatslogPaths,proto3" json:"field2StatslogPaths,omitempty"`
	Deltalogs           []*FieldBinlog `protobuf:"bytes,6,rep,name=deltalogs,proto3" json:"deltalogs,omitempty"`
	Channel             string         `protobuf:"bytes,7,opt,name=channel,proto3" json:"channel,omitempty"`
	IsSorted            bool           `protobuf:"varint,8,opt,name=is_sorted,json=isSorted,proto3" json:"is_sorted,omitempty"`
	Bm25Logs            []*FieldBinlog `protobuf:"bytes,9,rep,name=bm25logs,proto3" json:"bm25logs,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactionSegment) Descriptor deprecated 

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

Deprecated: Use CompactionSegment.ProtoReflect.Descriptor instead.

func (*CompactionSegment) GetBm25Logs 

func (x *CompactionSegment) GetBm25Logs() []*FieldBinlog

func (*CompactionSegment) GetChannel 

func (x *CompactionSegment) GetChannel() string

func (*CompactionSegment) GetDeltalogs 

func (x *CompactionSegment) GetDeltalogs() []*FieldBinlog

func (*CompactionSegment) GetField2StatslogPaths 

func (x *CompactionSegment) GetField2StatslogPaths() []*FieldBinlog

func (*CompactionSegment) GetInsertLogs 

func (x *CompactionSegment) GetInsertLogs() []*FieldBinlog

func (*CompactionSegment) GetIsSorted 

func (x *CompactionSegment) GetIsSorted() bool

func (*CompactionSegment) GetNumOfRows 

func (x *CompactionSegment) GetNumOfRows() int64

func (*CompactionSegment) GetPlanID 

func (x *CompactionSegment) GetPlanID() int64

func (*CompactionSegment) GetSegmentID 

func (x *CompactionSegment) GetSegmentID() int64

func (*CompactionSegment) ProtoMessage 

func (*CompactionSegment) ProtoMessage()

func (*CompactionSegment) ProtoReflect 

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

func (*CompactionSegment) Reset 

func (x *CompactionSegment) Reset()

func (*CompactionSegment) String 

func (x *CompactionSegment) String() string

type CompactionSegmentBinlogs 

type CompactionSegmentBinlogs struct {
	SegmentID           int64          `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	FieldBinlogs        []*FieldBinlog `protobuf:"bytes,2,rep,name=fieldBinlogs,proto3" json:"fieldBinlogs,omitempty"`
	Field2StatslogPaths []*FieldBinlog `protobuf:"bytes,3,rep,name=field2StatslogPaths,proto3" json:"field2StatslogPaths,omitempty"`
	Deltalogs           []*FieldBinlog `protobuf:"bytes,4,rep,name=deltalogs,proto3" json:"deltalogs,omitempty"`
	InsertChannel       string         `protobuf:"bytes,5,opt,name=insert_channel,json=insertChannel,proto3" json:"insert_channel,omitempty"`
	Level               SegmentLevel   `protobuf:"varint,6,opt,name=level,proto3,enum=milvus.proto.data.SegmentLevel" json:"level,omitempty"`
	CollectionID        int64          `protobuf:"varint,7,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionID         int64          `protobuf:"varint,8,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	IsSorted            bool           `protobuf:"varint,9,opt,name=is_sorted,json=isSorted,proto3" json:"is_sorted,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactionSegmentBinlogs) Descriptor deprecated 

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

Deprecated: Use CompactionSegmentBinlogs.ProtoReflect.Descriptor instead.

func (*CompactionSegmentBinlogs) GetCollectionID 

func (x *CompactionSegmentBinlogs) GetCollectionID() int64

func (*CompactionSegmentBinlogs) GetDeltalogs 

func (x *CompactionSegmentBinlogs) GetDeltalogs() []*FieldBinlog

func (*CompactionSegmentBinlogs) GetField2StatslogPaths 

func (x *CompactionSegmentBinlogs) GetField2StatslogPaths() []*FieldBinlog

func (*CompactionSegmentBinlogs) GetFieldBinlogs 

func (x *CompactionSegmentBinlogs) GetFieldBinlogs() []*FieldBinlog

func (*CompactionSegmentBinlogs) GetInsertChannel 

func (x *CompactionSegmentBinlogs) GetInsertChannel() string

func (*CompactionSegmentBinlogs) GetIsSorted 

func (x *CompactionSegmentBinlogs) GetIsSorted() bool

func (*CompactionSegmentBinlogs) GetLevel 

func (x *CompactionSegmentBinlogs) GetLevel() SegmentLevel

func (*CompactionSegmentBinlogs) GetPartitionID 

func (x *CompactionSegmentBinlogs) GetPartitionID() int64

func (*CompactionSegmentBinlogs) GetSegmentID 

func (x *CompactionSegmentBinlogs) GetSegmentID() int64

func (*CompactionSegmentBinlogs) ProtoMessage 

func (*CompactionSegmentBinlogs) ProtoMessage()

func (*CompactionSegmentBinlogs) ProtoReflect 

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

func (*CompactionSegmentBinlogs) Reset 

func (x *CompactionSegmentBinlogs) Reset()

func (*CompactionSegmentBinlogs) String 

func (x *CompactionSegmentBinlogs) String() string

type CompactionStateRequest 

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

func (*CompactionStateRequest) Descriptor deprecated 

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

Deprecated: Use CompactionStateRequest.ProtoReflect.Descriptor instead.

func (*CompactionStateRequest) GetBase 

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

func (*CompactionStateRequest) GetPlanID 

func (x *CompactionStateRequest) GetPlanID() int64

func (*CompactionStateRequest) ProtoMessage 

func (*CompactionStateRequest) ProtoMessage()

func (*CompactionStateRequest) ProtoReflect 

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

func (*CompactionStateRequest) Reset 

func (x *CompactionStateRequest) Reset()

func (*CompactionStateRequest) String 

func (x *CompactionStateRequest) String() string

type CompactionStateResponse 

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

func (*CompactionStateResponse) Descriptor deprecated 

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

Deprecated: Use CompactionStateResponse.ProtoReflect.Descriptor instead.

func (*CompactionStateResponse) GetResults 

func (x *CompactionStateResponse) GetResults() []*CompactionPlanResult

func (*CompactionStateResponse) GetStatus 

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

func (*CompactionStateResponse) ProtoMessage 

func (*CompactionStateResponse) ProtoMessage()

func (*CompactionStateResponse) ProtoReflect 

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

func (*CompactionStateResponse) Reset 

func (x *CompactionStateResponse) Reset()

func (*CompactionStateResponse) String 

func (x *CompactionStateResponse) String() string

type CompactionTask 

type CompactionTask struct {
	PlanID                 int64                      `protobuf:"varint,1,opt,name=planID,proto3" json:"planID,omitempty"`
	TriggerID              int64                      `protobuf:"varint,2,opt,name=triggerID,proto3" json:"triggerID,omitempty"`
	CollectionID           int64                      `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionID            int64                      `protobuf:"varint,4,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	Channel                string                     `protobuf:"bytes,5,opt,name=channel,proto3" json:"channel,omitempty"`
	Type                   CompactionType             `protobuf:"varint,6,opt,name=type,proto3,enum=milvus.proto.data.CompactionType" json:"type,omitempty"`
	State                  CompactionTaskState        `protobuf:"varint,7,opt,name=state,proto3,enum=milvus.proto.data.CompactionTaskState" json:"state,omitempty"`
	FailReason             string                     `protobuf:"bytes,8,opt,name=fail_reason,json=failReason,proto3" json:"fail_reason,omitempty"`
	StartTime              int64                      `protobuf:"varint,9,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime                int64                      `protobuf:"varint,10,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	TimeoutInSeconds       int32                      `protobuf:"varint,11,opt,name=timeout_in_seconds,json=timeoutInSeconds,proto3" json:"timeout_in_seconds,omitempty"`
	RetryTimes             int32                      `protobuf:"varint,12,opt,name=retry_times,json=retryTimes,proto3" json:"retry_times,omitempty"`
	CollectionTtl          int64                      `protobuf:"varint,13,opt,name=collection_ttl,json=collectionTtl,proto3" json:"collection_ttl,omitempty"`
	TotalRows              int64                      `protobuf:"varint,14,opt,name=total_rows,json=totalRows,proto3" json:"total_rows,omitempty"`
	InputSegments          []int64                    `protobuf:"varint,15,rep,packed,name=inputSegments,proto3" json:"inputSegments,omitempty"`
	ResultSegments         []int64                    `protobuf:"varint,16,rep,packed,name=resultSegments,proto3" json:"resultSegments,omitempty"`
	Pos                    *msgpb.MsgPosition         `protobuf:"bytes,17,opt,name=pos,proto3" json:"pos,omitempty"`
	NodeID                 int64                      `protobuf:"varint,18,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	Schema                 *schemapb.CollectionSchema `protobuf:"bytes,19,opt,name=schema,proto3" json:"schema,omitempty"`
	ClusteringKeyField     *schemapb.FieldSchema      `protobuf:"bytes,20,opt,name=clustering_key_field,json=clusteringKeyField,proto3" json:"clustering_key_field,omitempty"`
	MaxSegmentRows         int64                      `protobuf:"varint,21,opt,name=max_segment_rows,json=maxSegmentRows,proto3" json:"max_segment_rows,omitempty"`
	PreferSegmentRows      int64                      `protobuf:"varint,22,opt,name=prefer_segment_rows,json=preferSegmentRows,proto3" json:"prefer_segment_rows,omitempty"`
	AnalyzeTaskID          int64                      `protobuf:"varint,23,opt,name=analyzeTaskID,proto3" json:"analyzeTaskID,omitempty"`
	AnalyzeVersion         int64                      `protobuf:"varint,24,opt,name=analyzeVersion,proto3" json:"analyzeVersion,omitempty"`
	LastStateStartTime     int64                      `protobuf:"varint,25,opt,name=lastStateStartTime,proto3" json:"lastStateStartTime,omitempty"`
	MaxSize                int64                      `protobuf:"varint,26,opt,name=max_size,json=maxSize,proto3" json:"max_size,omitempty"`
	TmpSegments            []int64                    `protobuf:"varint,27,rep,packed,name=tmpSegments,proto3" json:"tmpSegments,omitempty"`
	PreAllocatedSegmentIDs *IDRange                   `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CompactionTask) Descriptor deprecated 

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

Deprecated: Use CompactionTask.ProtoReflect.Descriptor instead.

func (*CompactionTask) GetAnalyzeTaskID 

func (x *CompactionTask) GetAnalyzeTaskID() int64

func (*CompactionTask) GetAnalyzeVersion 

func (x *CompactionTask) GetAnalyzeVersion() int64

func (*CompactionTask) GetChannel 

func (x *CompactionTask) GetChannel() string

func (*CompactionTask) GetClusteringKeyField 

func (x *CompactionTask) GetClusteringKeyField() *schemapb.FieldSchema

func (*CompactionTask) GetCollectionID 

func (x *CompactionTask) GetCollectionID() int64

func (*CompactionTask) GetCollectionTtl 

func (x *CompactionTask) GetCollectionTtl() int64

func (*CompactionTask) GetEndTime 

func (x *CompactionTask) GetEndTime() int64

func (*CompactionTask) GetFailReason 

func (x *CompactionTask) GetFailReason() string

func (*CompactionTask) GetInputSegments 

func (x *CompactionTask) GetInputSegments() []int64

func (*CompactionTask) GetLastStateStartTime 

func (x *CompactionTask) GetLastStateStartTime() int64

func (*CompactionTask) GetMaxSegmentRows 

func (x *CompactionTask) GetMaxSegmentRows() int64

func (*CompactionTask) GetMaxSize 

func (x *CompactionTask) GetMaxSize() int64

func (*CompactionTask) GetNodeID 

func (x *CompactionTask) GetNodeID() int64

func (*CompactionTask) GetPartitionID 

func (x *CompactionTask) GetPartitionID() int64

func (*CompactionTask) GetPlanID 

func (x *CompactionTask) GetPlanID() int64

func (*CompactionTask) GetPos 

func (x *CompactionTask) GetPos() *msgpb.MsgPosition

func (*CompactionTask) GetPreAllocatedSegmentIDs 

func (x *CompactionTask) GetPreAllocatedSegmentIDs() *IDRange

func (*CompactionTask) GetPreferSegmentRows 

func (x *CompactionTask) GetPreferSegmentRows() int64

func (*CompactionTask) GetResultSegments 

func (x *CompactionTask) GetResultSegments() []int64

func (*CompactionTask) GetRetryTimes 

func (x *CompactionTask) GetRetryTimes() int32

func (*CompactionTask) GetSchema 

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

func (*CompactionTask) GetStartTime 

func (x *CompactionTask) GetStartTime() int64

func (*CompactionTask) GetState 

func (x *CompactionTask) GetState() CompactionTaskState

func (*CompactionTask) GetTimeoutInSeconds 

func (x *CompactionTask) GetTimeoutInSeconds() int32

func (*CompactionTask) GetTmpSegments 

func (x *CompactionTask) GetTmpSegments() []int64

func (*CompactionTask) GetTotalRows 

func (x *CompactionTask) GetTotalRows() int64

func (*CompactionTask) GetTriggerID 

func (x *CompactionTask) GetTriggerID() int64

func (*CompactionTask) GetType 

func (x *CompactionTask) GetType() CompactionType

func (*CompactionTask) ProtoMessage 

func (*CompactionTask) ProtoMessage()

func (*CompactionTask) ProtoReflect 

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

func (*CompactionTask) Reset 

func (x *CompactionTask) Reset()

func (*CompactionTask) String 

func (x *CompactionTask) String() string

type CompactionTaskState 

type CompactionTaskState int32
const (
	CompactionTaskState_unknown    CompactionTaskState = 0
	CompactionTaskState_executing  CompactionTaskState = 1
	CompactionTaskState_pipelining CompactionTaskState = 2
	CompactionTaskState_completed  CompactionTaskState = 3
	CompactionTaskState_failed     CompactionTaskState = 4
	CompactionTaskState_timeout    CompactionTaskState = 5
	CompactionTaskState_analyzing  CompactionTaskState = 6
	CompactionTaskState_indexing   CompactionTaskState = 7
	CompactionTaskState_cleaned    CompactionTaskState = 8
	CompactionTaskState_meta_saved CompactionTaskState = 9
	CompactionTaskState_statistic  CompactionTaskState = 10
)

func (CompactionTaskState) Descriptor 

func (CompactionTaskState) Descriptor() protoreflect.EnumDescriptor

func (CompactionTaskState) Enum 

func (x CompactionTaskState) Enum() *CompactionTaskState

func (CompactionTaskState) EnumDescriptor deprecated 

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

Deprecated: Use CompactionTaskState.Descriptor instead.

func (CompactionTaskState) Number 

func (x CompactionTaskState) Number() protoreflect.EnumNumber

func (CompactionTaskState) String 

func (x CompactionTaskState) String() string

func (CompactionTaskState) Type 

func (CompactionTaskState) Type() protoreflect.EnumType

type CompactionType 

type CompactionType int32
const (
	CompactionType_UndefinedCompaction CompactionType = 0
	CompactionType_MergeCompaction     CompactionType = 2
	CompactionType_MixCompaction       CompactionType = 3
	// compactionV2
	CompactionType_SingleCompaction       CompactionType = 4
	CompactionType_MinorCompaction        CompactionType = 5
	CompactionType_MajorCompaction        CompactionType = 6
	CompactionType_Level0DeleteCompaction CompactionType = 7
	CompactionType_ClusteringCompaction   CompactionType = 8
)

func (CompactionType) Descriptor 

func (CompactionType) Descriptor() protoreflect.EnumDescriptor

func (CompactionType) Enum 

func (x CompactionType) Enum() *CompactionType

func (CompactionType) EnumDescriptor deprecated 

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

Deprecated: Use CompactionType.Descriptor instead.

func (CompactionType) Number 

func (x CompactionType) Number() protoreflect.EnumNumber

func (CompactionType) String 

func (x CompactionType) String() string

func (CompactionType) Type 

func (CompactionType) Type() protoreflect.EnumType

type DataCoordClient 

type DataCoordClient 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)
	Flush(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*FlushResponse, error)
	// AllocSegment alloc a new growing segment, add it into segment meta.
	AllocSegment(ctx context.Context, in *AllocSegmentRequest, opts ...grpc.CallOption) (*AllocSegmentResponse, error)
	// Deprecated: Do not use.
	AssignSegmentID(ctx context.Context, in *AssignSegmentIDRequest, opts ...grpc.CallOption) (*AssignSegmentIDResponse, error)
	GetSegmentInfo(ctx context.Context, in *GetSegmentInfoRequest, opts ...grpc.CallOption) (*GetSegmentInfoResponse, error)
	GetSegmentStates(ctx context.Context, in *GetSegmentStatesRequest, opts ...grpc.CallOption) (*GetSegmentStatesResponse, error)
	GetInsertBinlogPaths(ctx context.Context, in *GetInsertBinlogPathsRequest, opts ...grpc.CallOption) (*GetInsertBinlogPathsResponse, error)
	GetCollectionStatistics(ctx context.Context, in *GetCollectionStatisticsRequest, opts ...grpc.CallOption) (*GetCollectionStatisticsResponse, error)
	GetPartitionStatistics(ctx context.Context, in *GetPartitionStatisticsRequest, opts ...grpc.CallOption) (*GetPartitionStatisticsResponse, error)
	GetSegmentInfoChannel(ctx context.Context, in *GetSegmentInfoChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)
	SaveBinlogPaths(ctx context.Context, in *SaveBinlogPathsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	GetRecoveryInfo(ctx context.Context, in *GetRecoveryInfoRequest, opts ...grpc.CallOption) (*GetRecoveryInfoResponse, error)
	GetRecoveryInfoV2(ctx context.Context, in *GetRecoveryInfoRequestV2, opts ...grpc.CallOption) (*GetRecoveryInfoResponseV2, error)
	GetChannelRecoveryInfo(ctx context.Context, in *GetChannelRecoveryInfoRequest, opts ...grpc.CallOption) (*GetChannelRecoveryInfoResponse, error)
	GetFlushedSegments(ctx context.Context, in *GetFlushedSegmentsRequest, opts ...grpc.CallOption) (*GetFlushedSegmentsResponse, error)
	GetSegmentsByStates(ctx context.Context, in *GetSegmentsByStatesRequest, opts ...grpc.CallOption) (*GetSegmentsByStatesResponse, error)
	GetFlushAllState(ctx context.Context, in *milvuspb.GetFlushAllStateRequest, opts ...grpc.CallOption) (*milvuspb.GetFlushAllStateResponse, 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)
	ManualCompaction(ctx context.Context, in *milvuspb.ManualCompactionRequest, opts ...grpc.CallOption) (*milvuspb.ManualCompactionResponse, error)
	GetCompactionState(ctx context.Context, in *milvuspb.GetCompactionStateRequest, opts ...grpc.CallOption) (*milvuspb.GetCompactionStateResponse, error)
	GetCompactionStateWithPlans(ctx context.Context, in *milvuspb.GetCompactionPlansRequest, opts ...grpc.CallOption) (*milvuspb.GetCompactionPlansResponse, error)
	WatchChannels(ctx context.Context, in *WatchChannelsRequest, opts ...grpc.CallOption) (*WatchChannelsResponse, error)
	GetFlushState(ctx context.Context, in *GetFlushStateRequest, opts ...grpc.CallOption) (*milvuspb.GetFlushStateResponse, error)
	DropVirtualChannel(ctx context.Context, in *DropVirtualChannelRequest, opts ...grpc.CallOption) (*DropVirtualChannelResponse, error)
	SetSegmentState(ctx context.Context, in *SetSegmentStateRequest, opts ...grpc.CallOption) (*SetSegmentStateResponse, error)
	UpdateSegmentStatistics(ctx context.Context, in *UpdateSegmentStatisticsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	UpdateChannelCheckpoint(ctx context.Context, in *UpdateChannelCheckpointRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	MarkSegmentsDropped(ctx context.Context, in *MarkSegmentsDroppedRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	BroadcastAlteredCollection(ctx context.Context, in *AlterCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	CheckHealth(ctx context.Context, in *milvuspb.CheckHealthRequest, opts ...grpc.CallOption) (*milvuspb.CheckHealthResponse, error)
	CreateIndex(ctx context.Context, in *indexpb.CreateIndexRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	AlterIndex(ctx context.Context, in *indexpb.AlterIndexRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	// Deprecated: use DescribeIndex instead
	GetIndexState(ctx context.Context, in *indexpb.GetIndexStateRequest, opts ...grpc.CallOption) (*indexpb.GetIndexStateResponse, error)
	GetSegmentIndexState(ctx context.Context, in *indexpb.GetSegmentIndexStateRequest, opts ...grpc.CallOption) (*indexpb.GetSegmentIndexStateResponse, error)
	GetIndexInfos(ctx context.Context, in *indexpb.GetIndexInfoRequest, opts ...grpc.CallOption) (*indexpb.GetIndexInfoResponse, error)
	DropIndex(ctx context.Context, in *indexpb.DropIndexRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DescribeIndex(ctx context.Context, in *indexpb.DescribeIndexRequest, opts ...grpc.CallOption) (*indexpb.DescribeIndexResponse, error)
	GetIndexStatistics(ctx context.Context, in *indexpb.GetIndexStatisticsRequest, opts ...grpc.CallOption) (*indexpb.GetIndexStatisticsResponse, error)
	// Deprecated: use DescribeIndex instead
	GetIndexBuildProgress(ctx context.Context, in *indexpb.GetIndexBuildProgressRequest, opts ...grpc.CallOption) (*indexpb.GetIndexBuildProgressResponse, error)
	ListIndexes(ctx context.Context, in *indexpb.ListIndexesRequest, opts ...grpc.CallOption) (*indexpb.ListIndexesResponse, error)
	GcConfirm(ctx context.Context, in *GcConfirmRequest, opts ...grpc.CallOption) (*GcConfirmResponse, error)
	ReportDataNodeTtMsgs(ctx context.Context, in *ReportDataNodeTtMsgsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	GcControl(ctx context.Context, in *GcControlRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	// importV2
	ImportV2(ctx context.Context, in *internalpb.ImportRequestInternal, opts ...grpc.CallOption) (*internalpb.ImportResponse, error)
	GetImportProgress(ctx context.Context, in *internalpb.GetImportProgressRequest, opts ...grpc.CallOption) (*internalpb.GetImportProgressResponse, error)
	ListImports(ctx context.Context, in *internalpb.ListImportsRequestInternal, opts ...grpc.CallOption) (*internalpb.ListImportsResponse, error)
}

DataCoordClient is the client API for DataCoord 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 NewDataCoordClient 

func NewDataCoordClient(cc grpc.ClientConnInterface) DataCoordClient

type DataCoordServer 

type DataCoordServer 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)
	Flush(context.Context, *FlushRequest) (*FlushResponse, error)
	// AllocSegment alloc a new growing segment, add it into segment meta.
	AllocSegment(context.Context, *AllocSegmentRequest) (*AllocSegmentResponse, error)
	// Deprecated: Do not use.
	AssignSegmentID(context.Context, *AssignSegmentIDRequest) (*AssignSegmentIDResponse, error)
	GetSegmentInfo(context.Context, *GetSegmentInfoRequest) (*GetSegmentInfoResponse, error)
	GetSegmentStates(context.Context, *GetSegmentStatesRequest) (*GetSegmentStatesResponse, error)
	GetInsertBinlogPaths(context.Context, *GetInsertBinlogPathsRequest) (*GetInsertBinlogPathsResponse, error)
	GetCollectionStatistics(context.Context, *GetCollectionStatisticsRequest) (*GetCollectionStatisticsResponse, error)
	GetPartitionStatistics(context.Context, *GetPartitionStatisticsRequest) (*GetPartitionStatisticsResponse, error)
	GetSegmentInfoChannel(context.Context, *GetSegmentInfoChannelRequest) (*milvuspb.StringResponse, error)
	SaveBinlogPaths(context.Context, *SaveBinlogPathsRequest) (*commonpb.Status, error)
	GetRecoveryInfo(context.Context, *GetRecoveryInfoRequest) (*GetRecoveryInfoResponse, error)
	GetRecoveryInfoV2(context.Context, *GetRecoveryInfoRequestV2) (*GetRecoveryInfoResponseV2, error)
	GetChannelRecoveryInfo(context.Context, *GetChannelRecoveryInfoRequest) (*GetChannelRecoveryInfoResponse, error)
	GetFlushedSegments(context.Context, *GetFlushedSegmentsRequest) (*GetFlushedSegmentsResponse, error)
	GetSegmentsByStates(context.Context, *GetSegmentsByStatesRequest) (*GetSegmentsByStatesResponse, error)
	GetFlushAllState(context.Context, *milvuspb.GetFlushAllStateRequest) (*milvuspb.GetFlushAllStateResponse, 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)
	ManualCompaction(context.Context, *milvuspb.ManualCompactionRequest) (*milvuspb.ManualCompactionResponse, error)
	GetCompactionState(context.Context, *milvuspb.GetCompactionStateRequest) (*milvuspb.GetCompactionStateResponse, error)
	GetCompactionStateWithPlans(context.Context, *milvuspb.GetCompactionPlansRequest) (*milvuspb.GetCompactionPlansResponse, error)
	WatchChannels(context.Context, *WatchChannelsRequest) (*WatchChannelsResponse, error)
	GetFlushState(context.Context, *GetFlushStateRequest) (*milvuspb.GetFlushStateResponse, error)
	DropVirtualChannel(context.Context, *DropVirtualChannelRequest) (*DropVirtualChannelResponse, error)
	SetSegmentState(context.Context, *SetSegmentStateRequest) (*SetSegmentStateResponse, error)
	UpdateSegmentStatistics(context.Context, *UpdateSegmentStatisticsRequest) (*commonpb.Status, error)
	UpdateChannelCheckpoint(context.Context, *UpdateChannelCheckpointRequest) (*commonpb.Status, error)
	MarkSegmentsDropped(context.Context, *MarkSegmentsDroppedRequest) (*commonpb.Status, error)
	BroadcastAlteredCollection(context.Context, *AlterCollectionRequest) (*commonpb.Status, error)
	CheckHealth(context.Context, *milvuspb.CheckHealthRequest) (*milvuspb.CheckHealthResponse, error)
	CreateIndex(context.Context, *indexpb.CreateIndexRequest) (*commonpb.Status, error)
	AlterIndex(context.Context, *indexpb.AlterIndexRequest) (*commonpb.Status, error)
	// Deprecated: use DescribeIndex instead
	GetIndexState(context.Context, *indexpb.GetIndexStateRequest) (*indexpb.GetIndexStateResponse, error)
	GetSegmentIndexState(context.Context, *indexpb.GetSegmentIndexStateRequest) (*indexpb.GetSegmentIndexStateResponse, error)
	GetIndexInfos(context.Context, *indexpb.GetIndexInfoRequest) (*indexpb.GetIndexInfoResponse, error)
	DropIndex(context.Context, *indexpb.DropIndexRequest) (*commonpb.Status, error)
	DescribeIndex(context.Context, *indexpb.DescribeIndexRequest) (*indexpb.DescribeIndexResponse, error)
	GetIndexStatistics(context.Context, *indexpb.GetIndexStatisticsRequest) (*indexpb.GetIndexStatisticsResponse, error)
	// Deprecated: use DescribeIndex instead
	GetIndexBuildProgress(context.Context, *indexpb.GetIndexBuildProgressRequest) (*indexpb.GetIndexBuildProgressResponse, error)
	ListIndexes(context.Context, *indexpb.ListIndexesRequest) (*indexpb.ListIndexesResponse, error)
	GcConfirm(context.Context, *GcConfirmRequest) (*GcConfirmResponse, error)
	ReportDataNodeTtMsgs(context.Context, *ReportDataNodeTtMsgsRequest) (*commonpb.Status, error)
	GcControl(context.Context, *GcControlRequest) (*commonpb.Status, error)
	// importV2
	ImportV2(context.Context, *internalpb.ImportRequestInternal) (*internalpb.ImportResponse, error)
	GetImportProgress(context.Context, *internalpb.GetImportProgressRequest) (*internalpb.GetImportProgressResponse, error)
	ListImports(context.Context, *internalpb.ListImportsRequestInternal) (*internalpb.ListImportsResponse, error)
}

DataCoordServer is the server API for DataCoord service. All implementations should embed UnimplementedDataCoordServer for forward compatibility

type DataNodeClient 

type DataNodeClient interface {
	GetComponentStates(ctx context.Context, in *milvuspb.GetComponentStatesRequest, opts ...grpc.CallOption) (*milvuspb.ComponentStates, 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)
	FlushSegments(ctx context.Context, in *FlushSegmentsRequest, 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)
	CompactionV2(ctx context.Context, in *CompactionPlan, opts ...grpc.CallOption) (*commonpb.Status, error)
	GetCompactionState(ctx context.Context, in *CompactionStateRequest, opts ...grpc.CallOption) (*CompactionStateResponse, error)
	SyncSegments(ctx context.Context, in *SyncSegmentsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	// Deprecated
	ResendSegmentStats(ctx context.Context, in *ResendSegmentStatsRequest, opts ...grpc.CallOption) (*ResendSegmentStatsResponse, error)
	FlushChannels(ctx context.Context, in *FlushChannelsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	NotifyChannelOperation(ctx context.Context, in *ChannelOperationsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	CheckChannelOperationProgress(ctx context.Context, in *ChannelWatchInfo, opts ...grpc.CallOption) (*ChannelOperationProgressResponse, error)
	// import v2
	PreImport(ctx context.Context, in *PreImportRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ImportV2(ctx context.Context, in *ImportRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	QueryPreImport(ctx context.Context, in *QueryPreImportRequest, opts ...grpc.CallOption) (*QueryPreImportResponse, error)
	QueryImport(ctx context.Context, in *QueryImportRequest, opts ...grpc.CallOption) (*QueryImportResponse, error)
	DropImport(ctx context.Context, in *DropImportRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	QuerySlot(ctx context.Context, in *QuerySlotRequest, opts ...grpc.CallOption) (*QuerySlotResponse, error)
	DropCompactionPlan(ctx context.Context, in *DropCompactionPlanRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
}

DataNodeClient is the client API for DataNode 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 NewDataNodeClient 

func NewDataNodeClient(cc grpc.ClientConnInterface) DataNodeClient

type DataNodeInfo 

type DataNodeInfo struct {
	Address  string           `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Version  int64            `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Channels []*ChannelStatus `protobuf:"bytes,3,rep,name=channels,proto3" json:"channels,omitempty"`
	// contains filtered or unexported fields
}

func (*DataNodeInfo) Descriptor deprecated 

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

Deprecated: Use DataNodeInfo.ProtoReflect.Descriptor instead.

func (*DataNodeInfo) GetAddress 

func (x *DataNodeInfo) GetAddress() string

func (*DataNodeInfo) GetChannels 

func (x *DataNodeInfo) GetChannels() []*ChannelStatus

func (*DataNodeInfo) GetVersion 

func (x *DataNodeInfo) GetVersion() int64

func (*DataNodeInfo) ProtoMessage 

func (*DataNodeInfo) ProtoMessage()

func (*DataNodeInfo) ProtoReflect 

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

func (*DataNodeInfo) Reset 

func (x *DataNodeInfo) Reset()

func (*DataNodeInfo) String 

func (x *DataNodeInfo) String() string

type DataNodeServer 

type DataNodeServer interface {
	GetComponentStates(context.Context, *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)
	GetStatisticsChannel(context.Context, *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)
	WatchDmChannels(context.Context, *WatchDmChannelsRequest) (*commonpb.Status, error)
	FlushSegments(context.Context, *FlushSegmentsRequest) (*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)
	CompactionV2(context.Context, *CompactionPlan) (*commonpb.Status, error)
	GetCompactionState(context.Context, *CompactionStateRequest) (*CompactionStateResponse, error)
	SyncSegments(context.Context, *SyncSegmentsRequest) (*commonpb.Status, error)
	// Deprecated
	ResendSegmentStats(context.Context, *ResendSegmentStatsRequest) (*ResendSegmentStatsResponse, error)
	FlushChannels(context.Context, *FlushChannelsRequest) (*commonpb.Status, error)
	NotifyChannelOperation(context.Context, *ChannelOperationsRequest) (*commonpb.Status, error)
	CheckChannelOperationProgress(context.Context, *ChannelWatchInfo) (*ChannelOperationProgressResponse, error)
	// import v2
	PreImport(context.Context, *PreImportRequest) (*commonpb.Status, error)
	ImportV2(context.Context, *ImportRequest) (*commonpb.Status, error)
	QueryPreImport(context.Context, *QueryPreImportRequest) (*QueryPreImportResponse, error)
	QueryImport(context.Context, *QueryImportRequest) (*QueryImportResponse, error)
	DropImport(context.Context, *DropImportRequest) (*commonpb.Status, error)
	QuerySlot(context.Context, *QuerySlotRequest) (*QuerySlotResponse, error)
	DropCompactionPlan(context.Context, *DropCompactionPlanRequest) (*commonpb.Status, error)
}

DataNodeServer is the server API for DataNode service. All implementations should embed UnimplementedDataNodeServer for forward compatibility

type DeltaLogInfo 

type DeltaLogInfo struct {
	RecordEntries uint64 `protobuf:"varint,1,opt,name=record_entries,json=recordEntries,proto3" json:"record_entries,omitempty"`
	TimestampFrom uint64 `protobuf:"varint,2,opt,name=timestamp_from,json=timestampFrom,proto3" json:"timestamp_from,omitempty"`
	TimestampTo   uint64 `protobuf:"varint,3,opt,name=timestamp_to,json=timestampTo,proto3" json:"timestamp_to,omitempty"`
	DeltaLogPath  string `protobuf:"bytes,4,opt,name=delta_log_path,json=deltaLogPath,proto3" json:"delta_log_path,omitempty"`
	DeltaLogSize  int64  `protobuf:"varint,5,opt,name=delta_log_size,json=deltaLogSize,proto3" json:"delta_log_size,omitempty"`
	// contains filtered or unexported fields
}

func (*DeltaLogInfo) Descriptor deprecated 

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

Deprecated: Use DeltaLogInfo.ProtoReflect.Descriptor instead.

func (*DeltaLogInfo) GetDeltaLogPath 

func (x *DeltaLogInfo) GetDeltaLogPath() string

func (*DeltaLogInfo) GetDeltaLogSize 

func (x *DeltaLogInfo) GetDeltaLogSize() int64

func (*DeltaLogInfo) GetRecordEntries 

func (x *DeltaLogInfo) GetRecordEntries() uint64

func (*DeltaLogInfo) GetTimestampFrom 

func (x *DeltaLogInfo) GetTimestampFrom() uint64

func (*DeltaLogInfo) GetTimestampTo 

func (x *DeltaLogInfo) GetTimestampTo() uint64

func (*DeltaLogInfo) ProtoMessage 

func (*DeltaLogInfo) ProtoMessage()

func (*DeltaLogInfo) ProtoReflect 

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

func (*DeltaLogInfo) Reset 

func (x *DeltaLogInfo) Reset()

func (*DeltaLogInfo) String 

func (x *DeltaLogInfo) String() string

type DropCompactionPlanRequest 

type DropCompactionPlanRequest struct {
	PlanID int64 `protobuf:"varint,1,opt,name=planID,proto3" json:"planID,omitempty"`
	// contains filtered or unexported fields
}

func (*DropCompactionPlanRequest) Descriptor deprecated 

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

Deprecated: Use DropCompactionPlanRequest.ProtoReflect.Descriptor instead.

func (*DropCompactionPlanRequest) GetPlanID 

func (x *DropCompactionPlanRequest) GetPlanID() int64

func (*DropCompactionPlanRequest) ProtoMessage 

func (*DropCompactionPlanRequest) ProtoMessage()

func (*DropCompactionPlanRequest) ProtoReflect 

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

func (*DropCompactionPlanRequest) Reset 

func (x *DropCompactionPlanRequest) Reset()

func (*DropCompactionPlanRequest) String 

func (x *DropCompactionPlanRequest) String() string

type DropImportRequest 

type DropImportRequest struct {
	ClusterID string `protobuf:"bytes,1,opt,name=clusterID,proto3" json:"clusterID,omitempty"`
	JobID     int64  `protobuf:"varint,2,opt,name=jobID,proto3" json:"jobID,omitempty"`
	TaskID    int64  `protobuf:"varint,3,opt,name=taskID,proto3" json:"taskID,omitempty"`
	// contains filtered or unexported fields
}

func (*DropImportRequest) Descriptor deprecated 

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

Deprecated: Use DropImportRequest.ProtoReflect.Descriptor instead.

func (*DropImportRequest) GetClusterID 

func (x *DropImportRequest) GetClusterID() string

func (*DropImportRequest) GetJobID 

func (x *DropImportRequest) GetJobID() int64

func (*DropImportRequest) GetTaskID 

func (x *DropImportRequest) GetTaskID() int64

func (*DropImportRequest) ProtoMessage 

func (*DropImportRequest) ProtoMessage()

func (*DropImportRequest) ProtoReflect 

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

func (*DropImportRequest) Reset 

func (x *DropImportRequest) Reset()

func (*DropImportRequest) String 

func (x *DropImportRequest) String() string

type DropVirtualChannelRequest 

type DropVirtualChannelRequest 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"`
	Segments    []*DropVirtualChannelSegment `protobuf:"bytes,3,rep,name=segments,proto3" json:"segments,omitempty"`
	// contains filtered or unexported fields
}

func (*DropVirtualChannelRequest) Descriptor deprecated 

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

Deprecated: Use DropVirtualChannelRequest.ProtoReflect.Descriptor instead.

func (*DropVirtualChannelRequest) GetBase 

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

func (*DropVirtualChannelRequest) GetChannelName 

func (x *DropVirtualChannelRequest) GetChannelName() string

func (*DropVirtualChannelRequest) GetSegments 

func (x *DropVirtualChannelRequest) GetSegments() []*DropVirtualChannelSegment

func (*DropVirtualChannelRequest) ProtoMessage 

func (*DropVirtualChannelRequest) ProtoMessage()

func (*DropVirtualChannelRequest) ProtoReflect 

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

func (*DropVirtualChannelRequest) Reset 

func (x *DropVirtualChannelRequest) Reset()

func (*DropVirtualChannelRequest) String 

func (x *DropVirtualChannelRequest) String() string

type DropVirtualChannelResponse 

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

func (*DropVirtualChannelResponse) Descriptor deprecated 

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

Deprecated: Use DropVirtualChannelResponse.ProtoReflect.Descriptor instead.

func (*DropVirtualChannelResponse) GetStatus 

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

func (*DropVirtualChannelResponse) ProtoMessage 

func (*DropVirtualChannelResponse) ProtoMessage()

func (*DropVirtualChannelResponse) ProtoReflect 

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

func (*DropVirtualChannelResponse) Reset 

func (x *DropVirtualChannelResponse) Reset()

func (*DropVirtualChannelResponse) String 

func (x *DropVirtualChannelResponse) String() string

type DropVirtualChannelSegment 

type DropVirtualChannelSegment 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"`
	Field2BinlogPaths   []*FieldBinlog     `protobuf:"bytes,3,rep,name=field2BinlogPaths,proto3" json:"field2BinlogPaths,omitempty"`
	Field2StatslogPaths []*FieldBinlog     `protobuf:"bytes,4,rep,name=field2StatslogPaths,proto3" json:"field2StatslogPaths,omitempty"`
	Deltalogs           []*FieldBinlog     `protobuf:"bytes,5,rep,name=deltalogs,proto3" json:"deltalogs,omitempty"`
	StartPosition       *msgpb.MsgPosition `protobuf:"bytes,6,opt,name=startPosition,proto3" json:"startPosition,omitempty"`
	CheckPoint          *msgpb.MsgPosition `protobuf:"bytes,7,opt,name=checkPoint,proto3" json:"checkPoint,omitempty"`
	NumOfRows           int64              `protobuf:"varint,8,opt,name=numOfRows,proto3" json:"numOfRows,omitempty"`
	// contains filtered or unexported fields
}

func (*DropVirtualChannelSegment) Descriptor deprecated 

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

Deprecated: Use DropVirtualChannelSegment.ProtoReflect.Descriptor instead.

func (*DropVirtualChannelSegment) GetCheckPoint 

func (x *DropVirtualChannelSegment) GetCheckPoint() *msgpb.MsgPosition

func (*DropVirtualChannelSegment) GetCollectionID 

func (x *DropVirtualChannelSegment) GetCollectionID() int64

func (*DropVirtualChannelSegment) GetDeltalogs 

func (x *DropVirtualChannelSegment) GetDeltalogs() []*FieldBinlog

func (*DropVirtualChannelSegment) GetField2BinlogPaths 

func (x *DropVirtualChannelSegment) GetField2BinlogPaths() []*FieldBinlog

func (*DropVirtualChannelSegment) GetField2StatslogPaths 

func (x *DropVirtualChannelSegment) GetField2StatslogPaths() []*FieldBinlog

func (*DropVirtualChannelSegment) GetNumOfRows 

func (x *DropVirtualChannelSegment) GetNumOfRows() int64

func (*DropVirtualChannelSegment) GetSegmentID 

func (x *DropVirtualChannelSegment) GetSegmentID() int64

func (*DropVirtualChannelSegment) GetStartPosition 

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

func (*DropVirtualChannelSegment) ProtoMessage 

func (*DropVirtualChannelSegment) ProtoMessage()

func (*DropVirtualChannelSegment) ProtoReflect 

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

func (*DropVirtualChannelSegment) Reset 

func (x *DropVirtualChannelSegment) Reset()

func (*DropVirtualChannelSegment) String 

func (x *DropVirtualChannelSegment) String() string

type Empty 

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

TODO: import google/protobuf/empty.proto

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type FieldBinlog 

type FieldBinlog struct {
	FieldID int64     `protobuf:"varint,1,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	Binlogs []*Binlog `protobuf:"bytes,2,rep,name=binlogs,proto3" json:"binlogs,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldBinlog) Descriptor deprecated 

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

Deprecated: Use FieldBinlog.ProtoReflect.Descriptor instead.

func (*FieldBinlog) GetBinlogs 

func (x *FieldBinlog) GetBinlogs() []*Binlog

func (*FieldBinlog) GetFieldID 

func (x *FieldBinlog) GetFieldID() int64

func (*FieldBinlog) ProtoMessage 

func (*FieldBinlog) ProtoMessage()

func (*FieldBinlog) ProtoReflect 

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

func (*FieldBinlog) Reset 

func (x *FieldBinlog) Reset()

func (*FieldBinlog) String 

func (x *FieldBinlog) String() string

type FlushChannelsRequest 

type FlushChannelsRequest struct {
	Base     *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	FlushTs  uint64            `protobuf:"varint,2,opt,name=flush_ts,json=flushTs,proto3" json:"flush_ts,omitempty"`
	Channels []string          `protobuf:"bytes,3,rep,name=channels,proto3" json:"channels,omitempty"`
	// contains filtered or unexported fields
}

func (*FlushChannelsRequest) Descriptor deprecated 

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

Deprecated: Use FlushChannelsRequest.ProtoReflect.Descriptor instead.

func (*FlushChannelsRequest) GetBase 

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

func (*FlushChannelsRequest) GetChannels 

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

func (*FlushChannelsRequest) GetFlushTs 

func (x *FlushChannelsRequest) GetFlushTs() uint64

func (*FlushChannelsRequest) ProtoMessage 

func (*FlushChannelsRequest) ProtoMessage()

func (*FlushChannelsRequest) ProtoReflect 

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

func (*FlushChannelsRequest) Reset 

func (x *FlushChannelsRequest) Reset()

func (*FlushChannelsRequest) String 

func (x *FlushChannelsRequest) String() string

type FlushRequest 

type FlushRequest 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"`
	SegmentIDs   []int64           `protobuf:"varint,3,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	CollectionID int64             `protobuf:"varint,4,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	IsImport     bool              `protobuf:"varint,5,opt,name=isImport,proto3" json:"isImport,omitempty"` // deprecated
	// contains filtered or unexported fields
}

func (*FlushRequest) Descriptor deprecated 

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

Deprecated: Use FlushRequest.ProtoReflect.Descriptor instead.

func (*FlushRequest) GetBase 

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

func (*FlushRequest) GetCollectionID 

func (x *FlushRequest) GetCollectionID() int64

func (*FlushRequest) GetDbID 

func (x *FlushRequest) GetDbID() int64

func (*FlushRequest) GetIsImport 

func (x *FlushRequest) GetIsImport() bool

func (*FlushRequest) GetSegmentIDs 

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

func (*FlushRequest) ProtoMessage 

func (*FlushRequest) ProtoMessage()

func (*FlushRequest) ProtoReflect 

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

func (*FlushRequest) Reset 

func (x *FlushRequest) Reset()

func (*FlushRequest) String 

func (x *FlushRequest) String() string

type FlushResponse 

type FlushResponse struct {
	Status          *commonpb.Status              `protobuf:"bytes,1,opt,name=status,proto3" json:"status,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"`
	SegmentIDs      []int64                       `protobuf:"varint,4,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`           // newly sealed segments
	FlushSegmentIDs []int64                       `protobuf:"varint,5,rep,packed,name=flushSegmentIDs,proto3" json:"flushSegmentIDs,omitempty"` // old flushed segment
	TimeOfSeal      int64                         `protobuf:"varint,6,opt,name=timeOfSeal,proto3" json:"timeOfSeal,omitempty"`
	FlushTs         uint64                        `protobuf:"varint,7,opt,name=flush_ts,json=flushTs,proto3" json:"flush_ts,omitempty"`
	ChannelCps      map[string]*msgpb.MsgPosition `` /* 179-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FlushResponse) Descriptor deprecated 

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

Deprecated: Use FlushResponse.ProtoReflect.Descriptor instead.

func (*FlushResponse) GetChannelCps 

func (x *FlushResponse) GetChannelCps() map[string]*msgpb.MsgPosition

func (*FlushResponse) GetCollectionID 

func (x *FlushResponse) GetCollectionID() int64

func (*FlushResponse) GetDbID 

func (x *FlushResponse) GetDbID() int64

func (*FlushResponse) GetFlushSegmentIDs 

func (x *FlushResponse) GetFlushSegmentIDs() []int64

func (*FlushResponse) GetFlushTs 

func (x *FlushResponse) GetFlushTs() uint64

func (*FlushResponse) GetSegmentIDs 

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

func (*FlushResponse) GetStatus 

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

func (*FlushResponse) GetTimeOfSeal 

func (x *FlushResponse) GetTimeOfSeal() int64

func (*FlushResponse) ProtoMessage 

func (*FlushResponse) ProtoMessage()

func (*FlushResponse) ProtoReflect 

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

func (*FlushResponse) Reset 

func (x *FlushResponse) Reset()

func (*FlushResponse) String 

func (x *FlushResponse) String() string

type FlushSegmentsRequest 

type FlushSegmentsRequest 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"`
	SegmentIDs   []int64           `protobuf:"varint,4,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"` // segments to flush
	ChannelName  string            `protobuf:"bytes,5,opt,name=channelName,proto3" json:"channelName,omitempty"`       // vchannel name to flush
	// contains filtered or unexported fields
}

func (*FlushSegmentsRequest) Descriptor deprecated 

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

Deprecated: Use FlushSegmentsRequest.ProtoReflect.Descriptor instead.

func (*FlushSegmentsRequest) GetBase 

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

func (*FlushSegmentsRequest) GetChannelName 

func (x *FlushSegmentsRequest) GetChannelName() string

func (*FlushSegmentsRequest) GetCollectionID 

func (x *FlushSegmentsRequest) GetCollectionID() int64

func (*FlushSegmentsRequest) GetDbID 

func (x *FlushSegmentsRequest) GetDbID() int64

func (*FlushSegmentsRequest) GetSegmentIDs 

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

func (*FlushSegmentsRequest) ProtoMessage 

func (*FlushSegmentsRequest) ProtoMessage()

func (*FlushSegmentsRequest) ProtoReflect 

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

func (*FlushSegmentsRequest) Reset 

func (x *FlushSegmentsRequest) Reset()

func (*FlushSegmentsRequest) String 

func (x *FlushSegmentsRequest) String() string

type GcCommand 

type GcCommand int32
const (
	GcCommand__      GcCommand = 0
	GcCommand_Pause  GcCommand = 1
	GcCommand_Resume GcCommand = 2
)

func (GcCommand) Descriptor 

func (GcCommand) Descriptor() protoreflect.EnumDescriptor

func (GcCommand) Enum 

func (x GcCommand) Enum() *GcCommand

func (GcCommand) EnumDescriptor deprecated 

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

Deprecated: Use GcCommand.Descriptor instead.

func (GcCommand) Number 

func (x GcCommand) Number() protoreflect.EnumNumber

func (GcCommand) String 

func (x GcCommand) String() string

func (GcCommand) Type 

func (GcCommand) Type() protoreflect.EnumType

type GcConfirmRequest 

type GcConfirmRequest struct {
	CollectionId int64 `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	PartitionId  int64 `protobuf:"varint,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"` // -1 means whole collection.
	// contains filtered or unexported fields
}

func (*GcConfirmRequest) Descriptor deprecated 

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

Deprecated: Use GcConfirmRequest.ProtoReflect.Descriptor instead.

func (*GcConfirmRequest) GetCollectionId 

func (x *GcConfirmRequest) GetCollectionId() int64

func (*GcConfirmRequest) GetPartitionId 

func (x *GcConfirmRequest) GetPartitionId() int64

func (*GcConfirmRequest) ProtoMessage 

func (*GcConfirmRequest) ProtoMessage()

func (*GcConfirmRequest) ProtoReflect 

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

func (*GcConfirmRequest) Reset 

func (x *GcConfirmRequest) Reset()

func (*GcConfirmRequest) String 

func (x *GcConfirmRequest) String() string

type GcConfirmResponse 

type GcConfirmResponse struct {
	Status     *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	GcFinished bool             `protobuf:"varint,2,opt,name=gc_finished,json=gcFinished,proto3" json:"gc_finished,omitempty"`
	// contains filtered or unexported fields
}

func (*GcConfirmResponse) Descriptor deprecated 

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

Deprecated: Use GcConfirmResponse.ProtoReflect.Descriptor instead.

func (*GcConfirmResponse) GetGcFinished 

func (x *GcConfirmResponse) GetGcFinished() bool

func (*GcConfirmResponse) GetStatus 

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

func (*GcConfirmResponse) ProtoMessage 

func (*GcConfirmResponse) ProtoMessage()

func (*GcConfirmResponse) ProtoReflect 

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

func (*GcConfirmResponse) Reset 

func (x *GcConfirmResponse) Reset()

func (*GcConfirmResponse) String 

func (x *GcConfirmResponse) String() string

type GcControlRequest 

type GcControlRequest struct {
	Base    *commonpb.MsgBase        `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Command GcCommand                `protobuf:"varint,2,opt,name=command,proto3,enum=milvus.proto.data.GcCommand" json:"command,omitempty"`
	Params  []*commonpb.KeyValuePair `protobuf:"bytes,3,rep,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*GcControlRequest) Descriptor deprecated 

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

Deprecated: Use GcControlRequest.ProtoReflect.Descriptor instead.

func (*GcControlRequest) GetBase 

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

func (*GcControlRequest) GetCommand 

func (x *GcControlRequest) GetCommand() GcCommand

func (*GcControlRequest) GetParams 

func (x *GcControlRequest) GetParams() []*commonpb.KeyValuePair

func (*GcControlRequest) ProtoMessage 

func (*GcControlRequest) ProtoMessage()

func (*GcControlRequest) ProtoReflect 

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

func (*GcControlRequest) Reset 

func (x *GcControlRequest) Reset()

func (*GcControlRequest) String 

func (x *GcControlRequest) String() string

type GetChannelRecoveryInfoRequest 

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

func (*GetChannelRecoveryInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetChannelRecoveryInfoRequest.ProtoReflect.Descriptor instead.

func (*GetChannelRecoveryInfoRequest) GetBase 

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

func (*GetChannelRecoveryInfoRequest) GetVchannel 

func (x *GetChannelRecoveryInfoRequest) GetVchannel() string

func (*GetChannelRecoveryInfoRequest) ProtoMessage 

func (*GetChannelRecoveryInfoRequest) ProtoMessage()

func (*GetChannelRecoveryInfoRequest) ProtoReflect 

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

func (*GetChannelRecoveryInfoRequest) Reset 

func (x *GetChannelRecoveryInfoRequest) Reset()

func (*GetChannelRecoveryInfoRequest) String 

func (x *GetChannelRecoveryInfoRequest) String() string

type GetChannelRecoveryInfoResponse 

type GetChannelRecoveryInfoResponse struct {
	Status *commonpb.Status           `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Info   *VchannelInfo              `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	Schema *schemapb.CollectionSchema `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*GetChannelRecoveryInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetChannelRecoveryInfoResponse.ProtoReflect.Descriptor instead.

func (*GetChannelRecoveryInfoResponse) GetInfo 

func (x *GetChannelRecoveryInfoResponse) GetInfo() *VchannelInfo

func (*GetChannelRecoveryInfoResponse) GetSchema 

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

func (*GetChannelRecoveryInfoResponse) GetStatus 

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

func (*GetChannelRecoveryInfoResponse) ProtoMessage 

func (*GetChannelRecoveryInfoResponse) ProtoMessage()

func (*GetChannelRecoveryInfoResponse) ProtoReflect 

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

func (*GetChannelRecoveryInfoResponse) Reset 

func (x *GetChannelRecoveryInfoResponse) Reset()

func (*GetChannelRecoveryInfoResponse) String 

func (x *GetChannelRecoveryInfoResponse) String() string

type GetCollectionStatisticsRequest 

type GetCollectionStatisticsRequest 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"`
	// contains filtered or unexported fields
}

func (*GetCollectionStatisticsRequest) Descriptor deprecated 

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

Deprecated: Use GetCollectionStatisticsRequest.ProtoReflect.Descriptor instead.

func (*GetCollectionStatisticsRequest) GetBase 

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

func (*GetCollectionStatisticsRequest) GetCollectionID 

func (x *GetCollectionStatisticsRequest) GetCollectionID() int64

func (*GetCollectionStatisticsRequest) GetDbID 

func (x *GetCollectionStatisticsRequest) GetDbID() int64

func (*GetCollectionStatisticsRequest) ProtoMessage 

func (*GetCollectionStatisticsRequest) ProtoMessage()

func (*GetCollectionStatisticsRequest) ProtoReflect 

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

func (*GetCollectionStatisticsRequest) Reset 

func (x *GetCollectionStatisticsRequest) Reset()

func (*GetCollectionStatisticsRequest) String 

func (x *GetCollectionStatisticsRequest) String() string

type GetCollectionStatisticsResponse 

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

func (*GetCollectionStatisticsResponse) Descriptor deprecated 

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

Deprecated: Use GetCollectionStatisticsResponse.ProtoReflect.Descriptor instead.

func (*GetCollectionStatisticsResponse) GetStats 

func (x *GetCollectionStatisticsResponse) GetStats() []*commonpb.KeyValuePair

func (*GetCollectionStatisticsResponse) GetStatus 

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

func (*GetCollectionStatisticsResponse) ProtoMessage 

func (*GetCollectionStatisticsResponse) ProtoMessage()

func (*GetCollectionStatisticsResponse) ProtoReflect 

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

func (*GetCollectionStatisticsResponse) Reset 

func (x *GetCollectionStatisticsResponse) Reset()

func (*GetCollectionStatisticsResponse) String 

func (x *GetCollectionStatisticsResponse) String() string

type GetFlushStateRequest 

type GetFlushStateRequest struct {
	SegmentIDs     []int64 `protobuf:"varint,1,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	FlushTs        uint64  `protobuf:"varint,2,opt,name=flush_ts,json=flushTs,proto3" json:"flush_ts,omitempty"`
	DbName         string  `protobuf:"bytes,3,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName string  `protobuf:"bytes,4,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	CollectionID   int64   `protobuf:"varint,5,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFlushStateRequest) Descriptor deprecated 

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

Deprecated: Use GetFlushStateRequest.ProtoReflect.Descriptor instead.

func (*GetFlushStateRequest) GetCollectionID 

func (x *GetFlushStateRequest) GetCollectionID() int64

func (*GetFlushStateRequest) GetCollectionName 

func (x *GetFlushStateRequest) GetCollectionName() string

func (*GetFlushStateRequest) GetDbName 

func (x *GetFlushStateRequest) GetDbName() string

func (*GetFlushStateRequest) GetFlushTs 

func (x *GetFlushStateRequest) GetFlushTs() uint64

func (*GetFlushStateRequest) GetSegmentIDs 

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

func (*GetFlushStateRequest) ProtoMessage 

func (*GetFlushStateRequest) ProtoMessage()

func (*GetFlushStateRequest) ProtoReflect 

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

func (*GetFlushStateRequest) Reset 

func (x *GetFlushStateRequest) Reset()

func (*GetFlushStateRequest) String 

func (x *GetFlushStateRequest) String() string

type GetFlushedSegmentsRequest 

type GetFlushedSegmentsRequest 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"`
	IncludeUnhealthy bool              `protobuf:"varint,4,opt,name=includeUnhealthy,proto3" json:"includeUnhealthy,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFlushedSegmentsRequest) Descriptor deprecated 

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

Deprecated: Use GetFlushedSegmentsRequest.ProtoReflect.Descriptor instead.

func (*GetFlushedSegmentsRequest) GetBase 

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

func (*GetFlushedSegmentsRequest) GetCollectionID 

func (x *GetFlushedSegmentsRequest) GetCollectionID() int64

func (*GetFlushedSegmentsRequest) GetIncludeUnhealthy 

func (x *GetFlushedSegmentsRequest) GetIncludeUnhealthy() bool

func (*GetFlushedSegmentsRequest) GetPartitionID 

func (x *GetFlushedSegmentsRequest) GetPartitionID() int64

func (*GetFlushedSegmentsRequest) ProtoMessage 

func (*GetFlushedSegmentsRequest) ProtoMessage()

func (*GetFlushedSegmentsRequest) ProtoReflect 

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

func (*GetFlushedSegmentsRequest) Reset 

func (x *GetFlushedSegmentsRequest) Reset()

func (*GetFlushedSegmentsRequest) String 

func (x *GetFlushedSegmentsRequest) String() string

type GetFlushedSegmentsResponse 

type GetFlushedSegmentsResponse struct {
	Status   *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Segments []int64          `protobuf:"varint,2,rep,packed,name=segments,proto3" json:"segments,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFlushedSegmentsResponse) Descriptor deprecated 

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

Deprecated: Use GetFlushedSegmentsResponse.ProtoReflect.Descriptor instead.

func (*GetFlushedSegmentsResponse) GetSegments 

func (x *GetFlushedSegmentsResponse) GetSegments() []int64

func (*GetFlushedSegmentsResponse) GetStatus 

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

func (*GetFlushedSegmentsResponse) ProtoMessage 

func (*GetFlushedSegmentsResponse) ProtoMessage()

func (*GetFlushedSegmentsResponse) ProtoReflect 

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

func (*GetFlushedSegmentsResponse) Reset 

func (x *GetFlushedSegmentsResponse) Reset()

func (*GetFlushedSegmentsResponse) String 

func (x *GetFlushedSegmentsResponse) String() string

type GetInsertBinlogPathsRequest 

type GetInsertBinlogPathsRequest 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"`
	// contains filtered or unexported fields
}

func (*GetInsertBinlogPathsRequest) Descriptor deprecated 

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

Deprecated: Use GetInsertBinlogPathsRequest.ProtoReflect.Descriptor instead.

func (*GetInsertBinlogPathsRequest) GetBase 

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

func (*GetInsertBinlogPathsRequest) GetSegmentID 

func (x *GetInsertBinlogPathsRequest) GetSegmentID() int64

func (*GetInsertBinlogPathsRequest) ProtoMessage 

func (*GetInsertBinlogPathsRequest) ProtoMessage()

func (*GetInsertBinlogPathsRequest) ProtoReflect 

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

func (*GetInsertBinlogPathsRequest) Reset 

func (x *GetInsertBinlogPathsRequest) Reset()

func (*GetInsertBinlogPathsRequest) String 

func (x *GetInsertBinlogPathsRequest) String() string

type GetInsertBinlogPathsResponse 

type GetInsertBinlogPathsResponse struct {
	FieldIDs []int64                  `protobuf:"varint,1,rep,packed,name=fieldIDs,proto3" json:"fieldIDs,omitempty"`
	Paths    []*internalpb.StringList `protobuf:"bytes,2,rep,name=paths,proto3" json:"paths,omitempty"`
	Status   *commonpb.Status         `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInsertBinlogPathsResponse) Descriptor deprecated 

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

Deprecated: Use GetInsertBinlogPathsResponse.ProtoReflect.Descriptor instead.

func (*GetInsertBinlogPathsResponse) GetFieldIDs 

func (x *GetInsertBinlogPathsResponse) GetFieldIDs() []int64

func (*GetInsertBinlogPathsResponse) GetPaths 

func (x *GetInsertBinlogPathsResponse) GetPaths() []*internalpb.StringList

func (*GetInsertBinlogPathsResponse) GetStatus 

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

func (*GetInsertBinlogPathsResponse) ProtoMessage 

func (*GetInsertBinlogPathsResponse) ProtoMessage()

func (*GetInsertBinlogPathsResponse) ProtoReflect 

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

func (*GetInsertBinlogPathsResponse) Reset 

func (x *GetInsertBinlogPathsResponse) Reset()

func (*GetInsertBinlogPathsResponse) String 

func (x *GetInsertBinlogPathsResponse) String() string

type GetPartitionStatisticsRequest 

type GetPartitionStatisticsRequest 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 (*GetPartitionStatisticsRequest) Descriptor deprecated 

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

Deprecated: Use GetPartitionStatisticsRequest.ProtoReflect.Descriptor instead.

func (*GetPartitionStatisticsRequest) GetBase 

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

func (*GetPartitionStatisticsRequest) GetCollectionID 

func (x *GetPartitionStatisticsRequest) GetCollectionID() int64

func (*GetPartitionStatisticsRequest) GetDbID 

func (x *GetPartitionStatisticsRequest) GetDbID() int64

func (*GetPartitionStatisticsRequest) GetPartitionIDs 

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

func (*GetPartitionStatisticsRequest) ProtoMessage 

func (*GetPartitionStatisticsRequest) ProtoMessage()

func (*GetPartitionStatisticsRequest) ProtoReflect 

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

func (*GetPartitionStatisticsRequest) Reset 

func (x *GetPartitionStatisticsRequest) Reset()

func (*GetPartitionStatisticsRequest) String 

func (x *GetPartitionStatisticsRequest) String() string

type GetPartitionStatisticsResponse 

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

func (*GetPartitionStatisticsResponse) Descriptor deprecated 

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

Deprecated: Use GetPartitionStatisticsResponse.ProtoReflect.Descriptor instead.

func (*GetPartitionStatisticsResponse) GetStats 

func (x *GetPartitionStatisticsResponse) GetStats() []*commonpb.KeyValuePair

func (*GetPartitionStatisticsResponse) GetStatus 

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

func (*GetPartitionStatisticsResponse) ProtoMessage 

func (*GetPartitionStatisticsResponse) ProtoMessage()

func (*GetPartitionStatisticsResponse) ProtoReflect 

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

func (*GetPartitionStatisticsResponse) Reset 

func (x *GetPartitionStatisticsResponse) Reset()

func (*GetPartitionStatisticsResponse) String 

func (x *GetPartitionStatisticsResponse) String() string

type GetRecoveryInfoRequest 

type GetRecoveryInfoRequest 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 (*GetRecoveryInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetRecoveryInfoRequest.ProtoReflect.Descriptor instead.

func (*GetRecoveryInfoRequest) GetBase 

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

func (*GetRecoveryInfoRequest) GetCollectionID 

func (x *GetRecoveryInfoRequest) GetCollectionID() int64

func (*GetRecoveryInfoRequest) GetPartitionID 

func (x *GetRecoveryInfoRequest) GetPartitionID() int64

func (*GetRecoveryInfoRequest) ProtoMessage 

func (*GetRecoveryInfoRequest) ProtoMessage()

func (*GetRecoveryInfoRequest) ProtoReflect 

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

func (*GetRecoveryInfoRequest) Reset 

func (x *GetRecoveryInfoRequest) Reset()

func (*GetRecoveryInfoRequest) String 

func (x *GetRecoveryInfoRequest) String() string

type GetRecoveryInfoRequestV2 

type GetRecoveryInfoRequestV2 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"`
	PartitionIDs []int64           `protobuf:"varint,3,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecoveryInfoRequestV2) Descriptor deprecated 

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

Deprecated: Use GetRecoveryInfoRequestV2.ProtoReflect.Descriptor instead.

func (*GetRecoveryInfoRequestV2) GetBase 

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

func (*GetRecoveryInfoRequestV2) GetCollectionID 

func (x *GetRecoveryInfoRequestV2) GetCollectionID() int64

func (*GetRecoveryInfoRequestV2) GetPartitionIDs 

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

func (*GetRecoveryInfoRequestV2) ProtoMessage 

func (*GetRecoveryInfoRequestV2) ProtoMessage()

func (*GetRecoveryInfoRequestV2) ProtoReflect 

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

func (*GetRecoveryInfoRequestV2) Reset 

func (x *GetRecoveryInfoRequestV2) Reset()

func (*GetRecoveryInfoRequestV2) String 

func (x *GetRecoveryInfoRequestV2) String() string

type GetRecoveryInfoResponse 

type GetRecoveryInfoResponse struct {
	Status   *commonpb.Status  `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Channels []*VchannelInfo   `protobuf:"bytes,2,rep,name=channels,proto3" json:"channels,omitempty"`
	Binlogs  []*SegmentBinlogs `protobuf:"bytes,3,rep,name=binlogs,proto3" json:"binlogs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecoveryInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetRecoveryInfoResponse.ProtoReflect.Descriptor instead.

func (*GetRecoveryInfoResponse) GetBinlogs 

func (x *GetRecoveryInfoResponse) GetBinlogs() []*SegmentBinlogs

func (*GetRecoveryInfoResponse) GetChannels 

func (x *GetRecoveryInfoResponse) GetChannels() []*VchannelInfo

func (*GetRecoveryInfoResponse) GetStatus 

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

func (*GetRecoveryInfoResponse) ProtoMessage 

func (*GetRecoveryInfoResponse) ProtoMessage()

func (*GetRecoveryInfoResponse) ProtoReflect 

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

func (*GetRecoveryInfoResponse) Reset 

func (x *GetRecoveryInfoResponse) Reset()

func (*GetRecoveryInfoResponse) String 

func (x *GetRecoveryInfoResponse) String() string

type GetRecoveryInfoResponseV2 

type GetRecoveryInfoResponseV2 struct {
	Status   *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Channels []*VchannelInfo  `protobuf:"bytes,2,rep,name=channels,proto3" json:"channels,omitempty"`
	Segments []*SegmentInfo   `protobuf:"bytes,3,rep,name=segments,proto3" json:"segments,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecoveryInfoResponseV2) Descriptor deprecated 

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

Deprecated: Use GetRecoveryInfoResponseV2.ProtoReflect.Descriptor instead.

func (*GetRecoveryInfoResponseV2) GetChannels 

func (x *GetRecoveryInfoResponseV2) GetChannels() []*VchannelInfo

func (*GetRecoveryInfoResponseV2) GetSegments 

func (x *GetRecoveryInfoResponseV2) GetSegments() []*SegmentInfo

func (*GetRecoveryInfoResponseV2) GetStatus 

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

func (*GetRecoveryInfoResponseV2) ProtoMessage 

func (*GetRecoveryInfoResponseV2) ProtoMessage()

func (*GetRecoveryInfoResponseV2) ProtoReflect 

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

func (*GetRecoveryInfoResponseV2) Reset 

func (x *GetRecoveryInfoResponseV2) Reset()

func (*GetRecoveryInfoResponseV2) String 

func (x *GetRecoveryInfoResponseV2) String() string

type GetSegmentInfoChannelRequest 

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

func (*GetSegmentInfoChannelRequest) Descriptor deprecated 

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

Deprecated: Use GetSegmentInfoChannelRequest.ProtoReflect.Descriptor instead.

func (*GetSegmentInfoChannelRequest) ProtoMessage 

func (*GetSegmentInfoChannelRequest) ProtoMessage()

func (*GetSegmentInfoChannelRequest) ProtoReflect 

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

func (*GetSegmentInfoChannelRequest) Reset 

func (x *GetSegmentInfoChannelRequest) Reset()

func (*GetSegmentInfoChannelRequest) String 

func (x *GetSegmentInfoChannelRequest) 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"`
	IncludeUnHealthy bool              `protobuf:"varint,3,opt,name=includeUnHealthy,proto3" json:"includeUnHealthy,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) GetIncludeUnHealthy 

func (x *GetSegmentInfoRequest) GetIncludeUnHealthy() bool

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"`
	ChannelCheckpoint map[string]*msgpb.MsgPosition `` /* 200-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetSegmentInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetSegmentInfoResponse.ProtoReflect.Descriptor instead.

func (*GetSegmentInfoResponse) GetChannelCheckpoint 

func (x *GetSegmentInfoResponse) GetChannelCheckpoint() map[string]*msgpb.MsgPosition

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 GetSegmentStatesRequest 

type GetSegmentStatesRequest 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"`
	// contains filtered or unexported fields
}

func (*GetSegmentStatesRequest) Descriptor deprecated 

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

Deprecated: Use GetSegmentStatesRequest.ProtoReflect.Descriptor instead.

func (*GetSegmentStatesRequest) GetBase 

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

func (*GetSegmentStatesRequest) GetSegmentIDs 

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

func (*GetSegmentStatesRequest) ProtoMessage 

func (*GetSegmentStatesRequest) ProtoMessage()

func (*GetSegmentStatesRequest) ProtoReflect 

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

func (*GetSegmentStatesRequest) Reset 

func (x *GetSegmentStatesRequest) Reset()

func (*GetSegmentStatesRequest) String 

func (x *GetSegmentStatesRequest) String() string

type GetSegmentStatesResponse 

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

func (*GetSegmentStatesResponse) Descriptor deprecated 

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

Deprecated: Use GetSegmentStatesResponse.ProtoReflect.Descriptor instead.

func (*GetSegmentStatesResponse) GetStates 

func (x *GetSegmentStatesResponse) GetStates() []*SegmentStateInfo

func (*GetSegmentStatesResponse) GetStatus 

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

func (*GetSegmentStatesResponse) ProtoMessage 

func (*GetSegmentStatesResponse) ProtoMessage()

func (*GetSegmentStatesResponse) ProtoReflect 

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

func (*GetSegmentStatesResponse) Reset 

func (x *GetSegmentStatesResponse) Reset()

func (*GetSegmentStatesResponse) String 

func (x *GetSegmentStatesResponse) String() string

type GetSegmentsByStatesRequest 

type GetSegmentsByStatesRequest 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"`
	States       []commonpb.SegmentState `protobuf:"varint,4,rep,packed,name=states,proto3,enum=milvus.proto.common.SegmentState" json:"states,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSegmentsByStatesRequest) Descriptor deprecated 

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

Deprecated: Use GetSegmentsByStatesRequest.ProtoReflect.Descriptor instead.

func (*GetSegmentsByStatesRequest) GetBase 

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

func (*GetSegmentsByStatesRequest) GetCollectionID 

func (x *GetSegmentsByStatesRequest) GetCollectionID() int64

func (*GetSegmentsByStatesRequest) GetPartitionID 

func (x *GetSegmentsByStatesRequest) GetPartitionID() int64

func (*GetSegmentsByStatesRequest) GetStates 

func (x *GetSegmentsByStatesRequest) GetStates() []commonpb.SegmentState

func (*GetSegmentsByStatesRequest) ProtoMessage 

func (*GetSegmentsByStatesRequest) ProtoMessage()

func (*GetSegmentsByStatesRequest) ProtoReflect 

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

func (*GetSegmentsByStatesRequest) Reset 

func (x *GetSegmentsByStatesRequest) Reset()

func (*GetSegmentsByStatesRequest) String 

func (x *GetSegmentsByStatesRequest) String() string

type GetSegmentsByStatesResponse 

type GetSegmentsByStatesResponse struct {
	Status   *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Segments []int64          `protobuf:"varint,2,rep,packed,name=segments,proto3" json:"segments,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSegmentsByStatesResponse) Descriptor deprecated 

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

Deprecated: Use GetSegmentsByStatesResponse.ProtoReflect.Descriptor instead.

func (*GetSegmentsByStatesResponse) GetSegments 

func (x *GetSegmentsByStatesResponse) GetSegments() []int64

func (*GetSegmentsByStatesResponse) GetStatus 

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

func (*GetSegmentsByStatesResponse) ProtoMessage 

func (*GetSegmentsByStatesResponse) ProtoMessage()

func (*GetSegmentsByStatesResponse) ProtoReflect 

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

func (*GetSegmentsByStatesResponse) Reset 

func (x *GetSegmentsByStatesResponse) Reset()

func (*GetSegmentsByStatesResponse) String 

func (x *GetSegmentsByStatesResponse) String() string

type IDRange 

type IDRange struct {
	Begin int64 `protobuf:"varint,1,opt,name=begin,proto3" json:"begin,omitempty"`
	End   int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*IDRange) Descriptor deprecated 

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

Deprecated: Use IDRange.ProtoReflect.Descriptor instead.

func (*IDRange) GetBegin 

func (x *IDRange) GetBegin() int64

func (*IDRange) GetEnd 

func (x *IDRange) GetEnd() int64

func (*IDRange) ProtoMessage 

func (*IDRange) ProtoMessage()

func (*IDRange) ProtoReflect 

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

func (*IDRange) Reset 

func (x *IDRange) Reset()

func (*IDRange) String 

func (x *IDRange) String() string

type ImportFileStats 

type ImportFileStats struct {
	ImportFile      *internalpb.ImportFile           `protobuf:"bytes,1,opt,name=import_file,json=importFile,proto3" json:"import_file,omitempty"`
	FileSize        int64                            `protobuf:"varint,2,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	TotalRows       int64                            `protobuf:"varint,3,opt,name=total_rows,json=totalRows,proto3" json:"total_rows,omitempty"`
	TotalMemorySize int64                            `protobuf:"varint,4,opt,name=total_memory_size,json=totalMemorySize,proto3" json:"total_memory_size,omitempty"`
	HashedStats     map[string]*PartitionImportStats `` // channel -> PartitionImportStats
	/* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ImportFileStats) Descriptor deprecated 

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

Deprecated: Use ImportFileStats.ProtoReflect.Descriptor instead.

func (*ImportFileStats) GetFileSize 

func (x *ImportFileStats) GetFileSize() int64

func (*ImportFileStats) GetHashedStats 

func (x *ImportFileStats) GetHashedStats() map[string]*PartitionImportStats

func (*ImportFileStats) GetImportFile 

func (x *ImportFileStats) GetImportFile() *internalpb.ImportFile

func (*ImportFileStats) GetTotalMemorySize 

func (x *ImportFileStats) GetTotalMemorySize() int64

func (*ImportFileStats) GetTotalRows 

func (x *ImportFileStats) GetTotalRows() int64

func (*ImportFileStats) ProtoMessage 

func (*ImportFileStats) ProtoMessage()

func (*ImportFileStats) ProtoReflect 

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

func (*ImportFileStats) Reset 

func (x *ImportFileStats) Reset()

func (*ImportFileStats) String 

func (x *ImportFileStats) String() string

type ImportJob 

type ImportJob struct {
	JobID             int64                      `protobuf:"varint,1,opt,name=jobID,proto3" json:"jobID,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"`
	CollectionName    string                     `protobuf:"bytes,4,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionIDs      []int64                    `protobuf:"varint,5,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	Vchannels         []string                   `protobuf:"bytes,6,rep,name=vchannels,proto3" json:"vchannels,omitempty"`
	Schema            *schemapb.CollectionSchema `protobuf:"bytes,7,opt,name=schema,proto3" json:"schema,omitempty"`
	TimeoutTs         uint64                     `protobuf:"varint,8,opt,name=timeout_ts,json=timeoutTs,proto3" json:"timeout_ts,omitempty"`
	CleanupTs         uint64                     `protobuf:"varint,9,opt,name=cleanup_ts,json=cleanupTs,proto3" json:"cleanup_ts,omitempty"`
	RequestedDiskSize int64                      `protobuf:"varint,10,opt,name=requestedDiskSize,proto3" json:"requestedDiskSize,omitempty"`
	State             internalpb.ImportJobState  `protobuf:"varint,11,opt,name=state,proto3,enum=milvus.proto.internal.ImportJobState" json:"state,omitempty"`
	Reason            string                     `protobuf:"bytes,12,opt,name=reason,proto3" json:"reason,omitempty"`
	CompleteTime      string                     `protobuf:"bytes,13,opt,name=complete_time,json=completeTime,proto3" json:"complete_time,omitempty"`
	Files             []*internalpb.ImportFile   `protobuf:"bytes,14,rep,name=files,proto3" json:"files,omitempty"`
	Options           []*commonpb.KeyValuePair   `protobuf:"bytes,15,rep,name=options,proto3" json:"options,omitempty"`
	StartTime         string                     `protobuf:"bytes,16,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportJob) Descriptor deprecated 

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

Deprecated: Use ImportJob.ProtoReflect.Descriptor instead.

func (*ImportJob) GetCleanupTs 

func (x *ImportJob) GetCleanupTs() uint64

func (*ImportJob) GetCollectionID 

func (x *ImportJob) GetCollectionID() int64

func (*ImportJob) GetCollectionName 

func (x *ImportJob) GetCollectionName() string

func (*ImportJob) GetCompleteTime 

func (x *ImportJob) GetCompleteTime() string

func (*ImportJob) GetDbID 

func (x *ImportJob) GetDbID() int64

func (*ImportJob) GetFiles 

func (x *ImportJob) GetFiles() []*internalpb.ImportFile

func (*ImportJob) GetJobID 

func (x *ImportJob) GetJobID() int64

func (*ImportJob) GetOptions 

func (x *ImportJob) GetOptions() []*commonpb.KeyValuePair

func (*ImportJob) GetPartitionIDs 

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

func (*ImportJob) GetReason 

func (x *ImportJob) GetReason() string

func (*ImportJob) GetRequestedDiskSize 

func (x *ImportJob) GetRequestedDiskSize() int64

func (*ImportJob) GetSchema 

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

func (*ImportJob) GetStartTime 

func (x *ImportJob) GetStartTime() string

func (*ImportJob) GetState 

func (x *ImportJob) GetState() internalpb.ImportJobState

func (*ImportJob) GetTimeoutTs 

func (x *ImportJob) GetTimeoutTs() uint64

func (*ImportJob) GetVchannels 

func (x *ImportJob) GetVchannels() []string

func (*ImportJob) ProtoMessage 

func (*ImportJob) ProtoMessage()

func (*ImportJob) ProtoReflect 

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

func (*ImportJob) Reset 

func (x *ImportJob) Reset()

func (*ImportJob) String 

func (x *ImportJob) String() string

type ImportRequest 

type ImportRequest struct {
	ClusterID       string                     `protobuf:"bytes,1,opt,name=clusterID,proto3" json:"clusterID,omitempty"`
	JobID           int64                      `protobuf:"varint,2,opt,name=jobID,proto3" json:"jobID,omitempty"`
	TaskID          int64                      `protobuf:"varint,3,opt,name=taskID,proto3" json:"taskID,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"`
	Vchannels       []string                   `protobuf:"bytes,6,rep,name=vchannels,proto3" json:"vchannels,omitempty"`
	Schema          *schemapb.CollectionSchema `protobuf:"bytes,7,opt,name=schema,proto3" json:"schema,omitempty"`
	Files           []*internalpb.ImportFile   `protobuf:"bytes,8,rep,name=files,proto3" json:"files,omitempty"`
	Options         []*commonpb.KeyValuePair   `protobuf:"bytes,9,rep,name=options,proto3" json:"options,omitempty"`
	Ts              uint64                     `protobuf:"varint,10,opt,name=ts,proto3" json:"ts,omitempty"`
	IDRange         *IDRange                   `protobuf:"bytes,11,opt,name=ID_range,json=IDRange,proto3" json:"ID_range,omitempty"`
	RequestSegments []*ImportRequestSegment    `protobuf:"bytes,12,rep,name=request_segments,json=requestSegments,proto3" json:"request_segments,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportRequest) Descriptor deprecated 

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

Deprecated: Use ImportRequest.ProtoReflect.Descriptor instead.

func (*ImportRequest) GetClusterID 

func (x *ImportRequest) GetClusterID() string

func (*ImportRequest) GetCollectionID 

func (x *ImportRequest) GetCollectionID() int64

func (*ImportRequest) GetFiles 

func (x *ImportRequest) GetFiles() []*internalpb.ImportFile

func (*ImportRequest) GetIDRange 

func (x *ImportRequest) GetIDRange() *IDRange

func (*ImportRequest) GetJobID 

func (x *ImportRequest) GetJobID() int64

func (*ImportRequest) GetOptions 

func (x *ImportRequest) GetOptions() []*commonpb.KeyValuePair

func (*ImportRequest) GetPartitionIDs 

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

func (*ImportRequest) GetRequestSegments 

func (x *ImportRequest) GetRequestSegments() []*ImportRequestSegment

func (*ImportRequest) GetSchema 

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

func (*ImportRequest) GetTaskID 

func (x *ImportRequest) GetTaskID() int64

func (*ImportRequest) GetTs 

func (x *ImportRequest) GetTs() uint64

func (*ImportRequest) GetVchannels 

func (x *ImportRequest) GetVchannels() []string

func (*ImportRequest) ProtoMessage 

func (*ImportRequest) ProtoMessage()

func (*ImportRequest) ProtoReflect 

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

func (*ImportRequest) Reset 

func (x *ImportRequest) Reset()

func (*ImportRequest) String 

func (x *ImportRequest) String() string

type ImportRequestSegment 

type ImportRequestSegment 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"`
	Vchannel    string `protobuf:"bytes,3,opt,name=vchannel,proto3" json:"vchannel,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportRequestSegment) Descriptor deprecated 

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

Deprecated: Use ImportRequestSegment.ProtoReflect.Descriptor instead.

func (*ImportRequestSegment) GetPartitionID 

func (x *ImportRequestSegment) GetPartitionID() int64

func (*ImportRequestSegment) GetSegmentID 

func (x *ImportRequestSegment) GetSegmentID() int64

func (*ImportRequestSegment) GetVchannel 

func (x *ImportRequestSegment) GetVchannel() string

func (*ImportRequestSegment) ProtoMessage 

func (*ImportRequestSegment) ProtoMessage()

func (*ImportRequestSegment) ProtoReflect 

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

func (*ImportRequestSegment) Reset 

func (x *ImportRequestSegment) Reset()

func (*ImportRequestSegment) String 

func (x *ImportRequestSegment) String() string

type ImportSegmentInfo 

type ImportSegmentInfo struct {
	SegmentID    int64          `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	ImportedRows int64          `protobuf:"varint,2,opt,name=imported_rows,json=importedRows,proto3" json:"imported_rows,omitempty"`
	Binlogs      []*FieldBinlog `protobuf:"bytes,3,rep,name=binlogs,proto3" json:"binlogs,omitempty"`
	Statslogs    []*FieldBinlog `protobuf:"bytes,4,rep,name=statslogs,proto3" json:"statslogs,omitempty"`
	Deltalogs    []*FieldBinlog `protobuf:"bytes,5,rep,name=deltalogs,proto3" json:"deltalogs,omitempty"`
	Bm25Logs     []*FieldBinlog `protobuf:"bytes,6,rep,name=bm25logs,proto3" json:"bm25logs,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportSegmentInfo) Descriptor deprecated 

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

Deprecated: Use ImportSegmentInfo.ProtoReflect.Descriptor instead.

func (*ImportSegmentInfo) GetBinlogs 

func (x *ImportSegmentInfo) GetBinlogs() []*FieldBinlog

func (*ImportSegmentInfo) GetBm25Logs 

func (x *ImportSegmentInfo) GetBm25Logs() []*FieldBinlog

func (*ImportSegmentInfo) GetDeltalogs 

func (x *ImportSegmentInfo) GetDeltalogs() []*FieldBinlog

func (*ImportSegmentInfo) GetImportedRows 

func (x *ImportSegmentInfo) GetImportedRows() int64

func (*ImportSegmentInfo) GetSegmentID 

func (x *ImportSegmentInfo) GetSegmentID() int64

func (*ImportSegmentInfo) GetStatslogs 

func (x *ImportSegmentInfo) GetStatslogs() []*FieldBinlog

func (*ImportSegmentInfo) ProtoMessage 

func (*ImportSegmentInfo) ProtoMessage()

func (*ImportSegmentInfo) ProtoReflect 

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

func (*ImportSegmentInfo) Reset 

func (x *ImportSegmentInfo) Reset()

func (*ImportSegmentInfo) String 

func (x *ImportSegmentInfo) String() string

type ImportTaskStateV2 

type ImportTaskStateV2 int32
const (
	ImportTaskStateV2_None       ImportTaskStateV2 = 0
	ImportTaskStateV2_Pending    ImportTaskStateV2 = 1
	ImportTaskStateV2_InProgress ImportTaskStateV2 = 2
	ImportTaskStateV2_Failed     ImportTaskStateV2 = 3
	ImportTaskStateV2_Completed  ImportTaskStateV2 = 4
)

func (ImportTaskStateV2) Descriptor 

func (ImportTaskStateV2) Descriptor() protoreflect.EnumDescriptor

func (ImportTaskStateV2) Enum 

func (x ImportTaskStateV2) Enum() *ImportTaskStateV2

func (ImportTaskStateV2) EnumDescriptor deprecated 

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

Deprecated: Use ImportTaskStateV2.Descriptor instead.

func (ImportTaskStateV2) Number 

func (x ImportTaskStateV2) Number() protoreflect.EnumNumber

func (ImportTaskStateV2) String 

func (x ImportTaskStateV2) String() string

func (ImportTaskStateV2) Type 

func (ImportTaskStateV2) Type() protoreflect.EnumType

type ImportTaskV2 

type ImportTaskV2 struct {
	JobID           int64              `protobuf:"varint,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	TaskID          int64              `protobuf:"varint,2,opt,name=taskID,proto3" json:"taskID,omitempty"`
	CollectionID    int64              `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	SegmentIDs      []int64            `protobuf:"varint,4,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	NodeID          int64              `protobuf:"varint,5,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	State           ImportTaskStateV2  `protobuf:"varint,6,opt,name=state,proto3,enum=milvus.proto.data.ImportTaskStateV2" json:"state,omitempty"`
	Reason          string             `protobuf:"bytes,7,opt,name=reason,proto3" json:"reason,omitempty"`
	CompleteTime    string             `protobuf:"bytes,8,opt,name=complete_time,json=completeTime,proto3" json:"complete_time,omitempty"`
	FileStats       []*ImportFileStats `protobuf:"bytes,9,rep,name=file_stats,json=fileStats,proto3" json:"file_stats,omitempty"`
	StatsSegmentIDs []int64            `protobuf:"varint,10,rep,packed,name=stats_segmentIDs,json=statsSegmentIDs,proto3" json:"stats_segmentIDs,omitempty"`
	CreatedTime     string             `protobuf:"bytes,11,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportTaskV2) Descriptor deprecated 

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

Deprecated: Use ImportTaskV2.ProtoReflect.Descriptor instead.

func (*ImportTaskV2) GetCollectionID 

func (x *ImportTaskV2) GetCollectionID() int64

func (*ImportTaskV2) GetCompleteTime 

func (x *ImportTaskV2) GetCompleteTime() string

func (*ImportTaskV2) GetCreatedTime 

func (x *ImportTaskV2) GetCreatedTime() string

func (*ImportTaskV2) GetFileStats 

func (x *ImportTaskV2) GetFileStats() []*ImportFileStats

func (*ImportTaskV2) GetJobID 

func (x *ImportTaskV2) GetJobID() int64

func (*ImportTaskV2) GetNodeID 

func (x *ImportTaskV2) GetNodeID() int64

func (*ImportTaskV2) GetReason 

func (x *ImportTaskV2) GetReason() string

func (*ImportTaskV2) GetSegmentIDs 

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

func (*ImportTaskV2) GetState 

func (x *ImportTaskV2) GetState() ImportTaskStateV2

func (*ImportTaskV2) GetStatsSegmentIDs 

func (x *ImportTaskV2) GetStatsSegmentIDs() []int64

func (*ImportTaskV2) GetTaskID 

func (x *ImportTaskV2) GetTaskID() int64

func (*ImportTaskV2) ProtoMessage 

func (*ImportTaskV2) ProtoMessage()

func (*ImportTaskV2) ProtoReflect 

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

func (*ImportTaskV2) Reset 

func (x *ImportTaskV2) Reset()

func (*ImportTaskV2) String 

func (x *ImportTaskV2) String() string

type MarkSegmentsDroppedRequest 

type MarkSegmentsDroppedRequest struct {
	Base       *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	SegmentIds []int64           `protobuf:"varint,2,rep,packed,name=segment_ids,json=segmentIds,proto3" json:"segment_ids,omitempty"` // IDs of segments that needs to be marked as `dropped`.
	// contains filtered or unexported fields
}

func (*MarkSegmentsDroppedRequest) Descriptor deprecated 

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

Deprecated: Use MarkSegmentsDroppedRequest.ProtoReflect.Descriptor instead.

func (*MarkSegmentsDroppedRequest) GetBase 

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

func (*MarkSegmentsDroppedRequest) GetSegmentIds 

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

func (*MarkSegmentsDroppedRequest) ProtoMessage 

func (*MarkSegmentsDroppedRequest) ProtoMessage()

func (*MarkSegmentsDroppedRequest) ProtoReflect 

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

func (*MarkSegmentsDroppedRequest) Reset 

func (x *MarkSegmentsDroppedRequest) Reset()

func (*MarkSegmentsDroppedRequest) String 

func (x *MarkSegmentsDroppedRequest) String() string

type PartitionImportStats 

type PartitionImportStats struct {
	PartitionRows map[int64]int64 `` // partitionID -> numRows
	/* 190-byte string literal not displayed */
	PartitionDataSize map[int64]int64 `` // partitionID -> dataSize
	/* 204-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PartitionImportStats) Descriptor deprecated 

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

Deprecated: Use PartitionImportStats.ProtoReflect.Descriptor instead.

func (*PartitionImportStats) GetPartitionDataSize 

func (x *PartitionImportStats) GetPartitionDataSize() map[int64]int64

func (*PartitionImportStats) GetPartitionRows 

func (x *PartitionImportStats) GetPartitionRows() map[int64]int64

func (*PartitionImportStats) ProtoMessage 

func (*PartitionImportStats) ProtoMessage()

func (*PartitionImportStats) ProtoReflect 

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

func (*PartitionImportStats) Reset 

func (x *PartitionImportStats) Reset()

func (*PartitionImportStats) String 

func (x *PartitionImportStats) String() string

type PartitionStatsInfo 

type PartitionStatsInfo 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"`
	VChannel      string  `protobuf:"bytes,3,opt,name=vChannel,proto3" json:"vChannel,omitempty"`
	Version       int64   `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	SegmentIDs    []int64 `protobuf:"varint,5,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	AnalyzeTaskID int64   `protobuf:"varint,6,opt,name=analyzeTaskID,proto3" json:"analyzeTaskID,omitempty"`
	CommitTime    int64   `protobuf:"varint,7,opt,name=commitTime,proto3" json:"commitTime,omitempty"`
	// contains filtered or unexported fields
}

func (*PartitionStatsInfo) Descriptor deprecated 

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

Deprecated: Use PartitionStatsInfo.ProtoReflect.Descriptor instead.

func (*PartitionStatsInfo) GetAnalyzeTaskID 

func (x *PartitionStatsInfo) GetAnalyzeTaskID() int64

func (*PartitionStatsInfo) GetCollectionID 

func (x *PartitionStatsInfo) GetCollectionID() int64

func (*PartitionStatsInfo) GetCommitTime 

func (x *PartitionStatsInfo) GetCommitTime() int64

func (*PartitionStatsInfo) GetPartitionID 

func (x *PartitionStatsInfo) GetPartitionID() int64

func (*PartitionStatsInfo) GetSegmentIDs 

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

func (*PartitionStatsInfo) GetVChannel 

func (x *PartitionStatsInfo) GetVChannel() string

func (*PartitionStatsInfo) GetVersion 

func (x *PartitionStatsInfo) GetVersion() int64

func (*PartitionStatsInfo) ProtoMessage 

func (*PartitionStatsInfo) ProtoMessage()

func (*PartitionStatsInfo) ProtoReflect 

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

func (*PartitionStatsInfo) Reset 

func (x *PartitionStatsInfo) Reset()

func (*PartitionStatsInfo) String 

func (x *PartitionStatsInfo) String() string

type PreImportRequest 

type PreImportRequest struct {
	ClusterID    string                     `protobuf:"bytes,1,opt,name=clusterID,proto3" json:"clusterID,omitempty"`
	JobID        int64                      `protobuf:"varint,2,opt,name=jobID,proto3" json:"jobID,omitempty"`
	TaskID       int64                      `protobuf:"varint,3,opt,name=taskID,proto3" json:"taskID,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"`
	Vchannels    []string                   `protobuf:"bytes,6,rep,name=vchannels,proto3" json:"vchannels,omitempty"`
	Schema       *schemapb.CollectionSchema `protobuf:"bytes,7,opt,name=schema,proto3" json:"schema,omitempty"`
	ImportFiles  []*internalpb.ImportFile   `protobuf:"bytes,8,rep,name=import_files,json=importFiles,proto3" json:"import_files,omitempty"`
	Options      []*commonpb.KeyValuePair   `protobuf:"bytes,9,rep,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*PreImportRequest) Descriptor deprecated 

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

Deprecated: Use PreImportRequest.ProtoReflect.Descriptor instead.

func (*PreImportRequest) GetClusterID 

func (x *PreImportRequest) GetClusterID() string

func (*PreImportRequest) GetCollectionID 

func (x *PreImportRequest) GetCollectionID() int64

func (*PreImportRequest) GetImportFiles 

func (x *PreImportRequest) GetImportFiles() []*internalpb.ImportFile

func (*PreImportRequest) GetJobID 

func (x *PreImportRequest) GetJobID() int64

func (*PreImportRequest) GetOptions 

func (x *PreImportRequest) GetOptions() []*commonpb.KeyValuePair

func (*PreImportRequest) GetPartitionIDs 

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

func (*PreImportRequest) GetSchema 

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

func (*PreImportRequest) GetTaskID 

func (x *PreImportRequest) GetTaskID() int64

func (*PreImportRequest) GetVchannels 

func (x *PreImportRequest) GetVchannels() []string

func (*PreImportRequest) ProtoMessage 

func (*PreImportRequest) ProtoMessage()

func (*PreImportRequest) ProtoReflect 

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

func (*PreImportRequest) Reset 

func (x *PreImportRequest) Reset()

func (*PreImportRequest) String 

func (x *PreImportRequest) String() string

type PreImportTask 

type PreImportTask struct {
	JobID        int64              `protobuf:"varint,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	TaskID       int64              `protobuf:"varint,2,opt,name=taskID,proto3" json:"taskID,omitempty"`
	CollectionID int64              `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	NodeID       int64              `protobuf:"varint,6,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	State        ImportTaskStateV2  `protobuf:"varint,7,opt,name=state,proto3,enum=milvus.proto.data.ImportTaskStateV2" json:"state,omitempty"`
	Reason       string             `protobuf:"bytes,8,opt,name=reason,proto3" json:"reason,omitempty"`
	FileStats    []*ImportFileStats `protobuf:"bytes,10,rep,name=file_stats,json=fileStats,proto3" json:"file_stats,omitempty"`
	CreatedTime  string             `protobuf:"bytes,11,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	CompleteTime string             `protobuf:"bytes,12,opt,name=complete_time,json=completeTime,proto3" json:"complete_time,omitempty"`
	// contains filtered or unexported fields
}

func (*PreImportTask) Descriptor deprecated 

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

Deprecated: Use PreImportTask.ProtoReflect.Descriptor instead.

func (*PreImportTask) GetCollectionID 

func (x *PreImportTask) GetCollectionID() int64

func (*PreImportTask) GetCompleteTime 

func (x *PreImportTask) GetCompleteTime() string

func (*PreImportTask) GetCreatedTime 

func (x *PreImportTask) GetCreatedTime() string

func (*PreImportTask) GetFileStats 

func (x *PreImportTask) GetFileStats() []*ImportFileStats

func (*PreImportTask) GetJobID 

func (x *PreImportTask) GetJobID() int64

func (*PreImportTask) GetNodeID 

func (x *PreImportTask) GetNodeID() int64

func (*PreImportTask) GetReason 

func (x *PreImportTask) GetReason() string

func (*PreImportTask) GetState 

func (x *PreImportTask) GetState() ImportTaskStateV2

func (*PreImportTask) GetTaskID 

func (x *PreImportTask) GetTaskID() int64

func (*PreImportTask) ProtoMessage 

func (*PreImportTask) ProtoMessage()

func (*PreImportTask) ProtoReflect 

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

func (*PreImportTask) Reset 

func (x *PreImportTask) Reset()

func (*PreImportTask) String 

func (x *PreImportTask) String() string

type QueryImportRequest 

type QueryImportRequest struct {
	ClusterID string `protobuf:"bytes,1,opt,name=clusterID,proto3" json:"clusterID,omitempty"`
	JobID     int64  `protobuf:"varint,2,opt,name=jobID,proto3" json:"jobID,omitempty"`
	TaskID    int64  `protobuf:"varint,3,opt,name=taskID,proto3" json:"taskID,omitempty"`
	QuerySlot bool   `protobuf:"varint,4,opt,name=querySlot,proto3" json:"querySlot,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryImportRequest) Descriptor deprecated 

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

Deprecated: Use QueryImportRequest.ProtoReflect.Descriptor instead.

func (*QueryImportRequest) GetClusterID 

func (x *QueryImportRequest) GetClusterID() string

func (*QueryImportRequest) GetJobID 

func (x *QueryImportRequest) GetJobID() int64

func (*QueryImportRequest) GetQuerySlot 

func (x *QueryImportRequest) GetQuerySlot() bool

func (*QueryImportRequest) GetTaskID 

func (x *QueryImportRequest) GetTaskID() int64

func (*QueryImportRequest) ProtoMessage 

func (*QueryImportRequest) ProtoMessage()

func (*QueryImportRequest) ProtoReflect 

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

func (*QueryImportRequest) Reset 

func (x *QueryImportRequest) Reset()

func (*QueryImportRequest) String 

func (x *QueryImportRequest) String() string

type QueryImportResponse 

type QueryImportResponse struct {
	Status             *commonpb.Status     `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	TaskID             int64                `protobuf:"varint,2,opt,name=taskID,proto3" json:"taskID,omitempty"`
	State              ImportTaskStateV2    `protobuf:"varint,3,opt,name=state,proto3,enum=milvus.proto.data.ImportTaskStateV2" json:"state,omitempty"`
	Reason             string               `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	Slots              int64                `protobuf:"varint,5,opt,name=slots,proto3" json:"slots,omitempty"`
	ImportSegmentsInfo []*ImportSegmentInfo `protobuf:"bytes,6,rep,name=import_segments_info,json=importSegmentsInfo,proto3" json:"import_segments_info,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryImportResponse) Descriptor deprecated 

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

Deprecated: Use QueryImportResponse.ProtoReflect.Descriptor instead.

func (*QueryImportResponse) GetImportSegmentsInfo 

func (x *QueryImportResponse) GetImportSegmentsInfo() []*ImportSegmentInfo

func (*QueryImportResponse) GetReason 

func (x *QueryImportResponse) GetReason() string

func (*QueryImportResponse) GetSlots 

func (x *QueryImportResponse) GetSlots() int64

func (*QueryImportResponse) GetState 

func (x *QueryImportResponse) GetState() ImportTaskStateV2

func (*QueryImportResponse) GetStatus 

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

func (*QueryImportResponse) GetTaskID 

func (x *QueryImportResponse) GetTaskID() int64

func (*QueryImportResponse) ProtoMessage 

func (*QueryImportResponse) ProtoMessage()

func (*QueryImportResponse) ProtoReflect 

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

func (*QueryImportResponse) Reset 

func (x *QueryImportResponse) Reset()

func (*QueryImportResponse) String 

func (x *QueryImportResponse) String() string

type QueryPreImportRequest 

type QueryPreImportRequest struct {
	ClusterID string `protobuf:"bytes,1,opt,name=clusterID,proto3" json:"clusterID,omitempty"`
	JobID     int64  `protobuf:"varint,2,opt,name=jobID,proto3" json:"jobID,omitempty"`
	TaskID    int64  `protobuf:"varint,3,opt,name=taskID,proto3" json:"taskID,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryPreImportRequest) Descriptor deprecated 

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

Deprecated: Use QueryPreImportRequest.ProtoReflect.Descriptor instead.

func (*QueryPreImportRequest) GetClusterID 

func (x *QueryPreImportRequest) GetClusterID() string

func (*QueryPreImportRequest) GetJobID 

func (x *QueryPreImportRequest) GetJobID() int64

func (*QueryPreImportRequest) GetTaskID 

func (x *QueryPreImportRequest) GetTaskID() int64

func (*QueryPreImportRequest) ProtoMessage 

func (*QueryPreImportRequest) ProtoMessage()

func (*QueryPreImportRequest) ProtoReflect 

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

func (*QueryPreImportRequest) Reset 

func (x *QueryPreImportRequest) Reset()

func (*QueryPreImportRequest) String 

func (x *QueryPreImportRequest) String() string

type QueryPreImportResponse 

type QueryPreImportResponse struct {
	Status    *commonpb.Status   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	TaskID    int64              `protobuf:"varint,2,opt,name=taskID,proto3" json:"taskID,omitempty"`
	State     ImportTaskStateV2  `protobuf:"varint,3,opt,name=state,proto3,enum=milvus.proto.data.ImportTaskStateV2" json:"state,omitempty"`
	Reason    string             `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	Slots     int64              `protobuf:"varint,5,opt,name=slots,proto3" json:"slots,omitempty"`
	FileStats []*ImportFileStats `protobuf:"bytes,6,rep,name=file_stats,json=fileStats,proto3" json:"file_stats,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryPreImportResponse) Descriptor deprecated 

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

Deprecated: Use QueryPreImportResponse.ProtoReflect.Descriptor instead.

func (*QueryPreImportResponse) GetFileStats 

func (x *QueryPreImportResponse) GetFileStats() []*ImportFileStats

func (*QueryPreImportResponse) GetReason 

func (x *QueryPreImportResponse) GetReason() string

func (*QueryPreImportResponse) GetSlots 

func (x *QueryPreImportResponse) GetSlots() int64

func (*QueryPreImportResponse) GetState 

func (x *QueryPreImportResponse) GetState() ImportTaskStateV2

func (*QueryPreImportResponse) GetStatus 

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

func (*QueryPreImportResponse) GetTaskID 

func (x *QueryPreImportResponse) GetTaskID() int64

func (*QueryPreImportResponse) ProtoMessage 

func (*QueryPreImportResponse) ProtoMessage()

func (*QueryPreImportResponse) ProtoReflect 

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

func (*QueryPreImportResponse) Reset 

func (x *QueryPreImportResponse) Reset()

func (*QueryPreImportResponse) String 

func (x *QueryPreImportResponse) String() string

type QuerySlotRequest 

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

func (*QuerySlotRequest) Descriptor deprecated 

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

Deprecated: Use QuerySlotRequest.ProtoReflect.Descriptor instead.

func (*QuerySlotRequest) ProtoMessage 

func (*QuerySlotRequest) ProtoMessage()

func (*QuerySlotRequest) ProtoReflect 

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

func (*QuerySlotRequest) Reset 

func (x *QuerySlotRequest) Reset()

func (*QuerySlotRequest) String 

func (x *QuerySlotRequest) String() string

type QuerySlotResponse 

type QuerySlotResponse struct {
	Status   *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	NumSlots int64            `protobuf:"varint,2,opt,name=num_slots,json=numSlots,proto3" json:"num_slots,omitempty"`
	// contains filtered or unexported fields
}

func (*QuerySlotResponse) Descriptor deprecated 

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

Deprecated: Use QuerySlotResponse.ProtoReflect.Descriptor instead.

func (*QuerySlotResponse) GetNumSlots 

func (x *QuerySlotResponse) GetNumSlots() int64

func (*QuerySlotResponse) GetStatus 

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

func (*QuerySlotResponse) ProtoMessage 

func (*QuerySlotResponse) ProtoMessage()

func (*QuerySlotResponse) ProtoReflect 

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

func (*QuerySlotResponse) Reset 

func (x *QuerySlotResponse) Reset()

func (*QuerySlotResponse) String 

func (x *QuerySlotResponse) String() string

type ReportDataNodeTtMsgsRequest 

type ReportDataNodeTtMsgsRequest struct {
	Base *commonpb.MsgBase      `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Msgs []*msgpb.DataNodeTtMsg `protobuf:"bytes,2,rep,name=msgs,proto3" json:"msgs,omitempty"` // -1 means whole collection.
	// contains filtered or unexported fields
}

func (*ReportDataNodeTtMsgsRequest) Descriptor deprecated 

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

Deprecated: Use ReportDataNodeTtMsgsRequest.ProtoReflect.Descriptor instead.

func (*ReportDataNodeTtMsgsRequest) GetBase 

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

func (*ReportDataNodeTtMsgsRequest) GetMsgs 

func (x *ReportDataNodeTtMsgsRequest) GetMsgs() []*msgpb.DataNodeTtMsg

func (*ReportDataNodeTtMsgsRequest) ProtoMessage 

func (*ReportDataNodeTtMsgsRequest) ProtoMessage()

func (*ReportDataNodeTtMsgsRequest) ProtoReflect 

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

func (*ReportDataNodeTtMsgsRequest) Reset 

func (x *ReportDataNodeTtMsgsRequest) Reset()

func (*ReportDataNodeTtMsgsRequest) String 

func (x *ReportDataNodeTtMsgsRequest) String() string

type ResendSegmentStatsRequest 

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

func (*ResendSegmentStatsRequest) Descriptor deprecated 

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

Deprecated: Use ResendSegmentStatsRequest.ProtoReflect.Descriptor instead.

func (*ResendSegmentStatsRequest) GetBase 

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

func (*ResendSegmentStatsRequest) ProtoMessage 

func (*ResendSegmentStatsRequest) ProtoMessage()

func (*ResendSegmentStatsRequest) ProtoReflect 

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

func (*ResendSegmentStatsRequest) Reset 

func (x *ResendSegmentStatsRequest) Reset()

func (*ResendSegmentStatsRequest) String 

func (x *ResendSegmentStatsRequest) String() string

type ResendSegmentStatsResponse 

type ResendSegmentStatsResponse struct {
	Status    *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	SegResent []int64          `protobuf:"varint,2,rep,packed,name=seg_resent,json=segResent,proto3" json:"seg_resent,omitempty"`
	// contains filtered or unexported fields
}

func (*ResendSegmentStatsResponse) Descriptor deprecated 

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

Deprecated: Use ResendSegmentStatsResponse.ProtoReflect.Descriptor instead.

func (*ResendSegmentStatsResponse) GetSegResent 

func (x *ResendSegmentStatsResponse) GetSegResent() []int64

func (*ResendSegmentStatsResponse) GetStatus 

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

func (*ResendSegmentStatsResponse) ProtoMessage 

func (*ResendSegmentStatsResponse) ProtoMessage()

func (*ResendSegmentStatsResponse) ProtoReflect 

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

func (*ResendSegmentStatsResponse) Reset 

func (x *ResendSegmentStatsResponse) Reset()

func (*ResendSegmentStatsResponse) String 

func (x *ResendSegmentStatsResponse) String() string

type SaveBinlogPathsRequest 

type SaveBinlogPathsRequest 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"`
	CollectionID        int64                   `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	Field2BinlogPaths   []*FieldBinlog          `protobuf:"bytes,4,rep,name=field2BinlogPaths,proto3" json:"field2BinlogPaths,omitempty"`
	CheckPoints         []*CheckPoint           `protobuf:"bytes,5,rep,name=checkPoints,proto3" json:"checkPoints,omitempty"`
	StartPositions      []*SegmentStartPosition `protobuf:"bytes,6,rep,name=start_positions,json=startPositions,proto3" json:"start_positions,omitempty"`
	Flushed             bool                    `protobuf:"varint,7,opt,name=flushed,proto3" json:"flushed,omitempty"`
	Field2StatslogPaths []*FieldBinlog          `protobuf:"bytes,8,rep,name=field2StatslogPaths,proto3" json:"field2StatslogPaths,omitempty"`
	Deltalogs           []*FieldBinlog          `protobuf:"bytes,9,rep,name=deltalogs,proto3" json:"deltalogs,omitempty"`
	Dropped             bool                    `protobuf:"varint,10,opt,name=dropped,proto3" json:"dropped,omitempty"`
	Importing           bool                    `protobuf:"varint,11,opt,name=importing,proto3" json:"importing,omitempty"` // deprecated
	Channel             string                  `protobuf:"bytes,12,opt,name=channel,proto3" json:"channel,omitempty"`      // report channel name for verification
	SegLevel            SegmentLevel            `protobuf:"varint,13,opt,name=seg_level,json=segLevel,proto3,enum=milvus.proto.data.SegmentLevel" json:"seg_level,omitempty"`
	PartitionID         int64                   `protobuf:"varint,14,opt,name=partitionID,proto3" json:"partitionID,omitempty"` // report partitionID for create L0 segment
	StorageVersion      int64                   `protobuf:"varint,15,opt,name=storageVersion,proto3" json:"storageVersion,omitempty"`
	Field2Bm25LogPaths  []*FieldBinlog          `protobuf:"bytes,16,rep,name=field2Bm25logPaths,proto3" json:"field2Bm25logPaths,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveBinlogPathsRequest) Descriptor deprecated 

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

Deprecated: Use SaveBinlogPathsRequest.ProtoReflect.Descriptor instead.

func (*SaveBinlogPathsRequest) GetBase 

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

func (*SaveBinlogPathsRequest) GetChannel 

func (x *SaveBinlogPathsRequest) GetChannel() string

func (*SaveBinlogPathsRequest) GetCheckPoints 

func (x *SaveBinlogPathsRequest) GetCheckPoints() []*CheckPoint

func (*SaveBinlogPathsRequest) GetCollectionID 

func (x *SaveBinlogPathsRequest) GetCollectionID() int64

func (*SaveBinlogPathsRequest) GetDeltalogs 

func (x *SaveBinlogPathsRequest) GetDeltalogs() []*FieldBinlog

func (*SaveBinlogPathsRequest) GetDropped 

func (x *SaveBinlogPathsRequest) GetDropped() bool

func (*SaveBinlogPathsRequest) GetField2BinlogPaths 

func (x *SaveBinlogPathsRequest) GetField2BinlogPaths() []*FieldBinlog

func (*SaveBinlogPathsRequest) GetField2Bm25LogPaths 

func (x *SaveBinlogPathsRequest) GetField2Bm25LogPaths() []*FieldBinlog

func (*SaveBinlogPathsRequest) GetField2StatslogPaths 

func (x *SaveBinlogPathsRequest) GetField2StatslogPaths() []*FieldBinlog

func (*SaveBinlogPathsRequest) GetFlushed 

func (x *SaveBinlogPathsRequest) GetFlushed() bool

func (*SaveBinlogPathsRequest) GetImporting 

func (x *SaveBinlogPathsRequest) GetImporting() bool

func (*SaveBinlogPathsRequest) GetPartitionID 

func (x *SaveBinlogPathsRequest) GetPartitionID() int64

func (*SaveBinlogPathsRequest) GetSegLevel 

func (x *SaveBinlogPathsRequest) GetSegLevel() SegmentLevel

func (*SaveBinlogPathsRequest) GetSegmentID 

func (x *SaveBinlogPathsRequest) GetSegmentID() int64

func (*SaveBinlogPathsRequest) GetStartPositions 

func (x *SaveBinlogPathsRequest) GetStartPositions() []*SegmentStartPosition

func (*SaveBinlogPathsRequest) GetStorageVersion 

func (x *SaveBinlogPathsRequest) GetStorageVersion() int64

func (*SaveBinlogPathsRequest) ProtoMessage 

func (*SaveBinlogPathsRequest) ProtoMessage()

func (*SaveBinlogPathsRequest) ProtoReflect 

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

func (*SaveBinlogPathsRequest) Reset 

func (x *SaveBinlogPathsRequest) Reset()

func (*SaveBinlogPathsRequest) String 

func (x *SaveBinlogPathsRequest) String() string

type SegmentBinlogs 

type SegmentBinlogs struct {
	SegmentID     int64                     `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	FieldBinlogs  []*FieldBinlog            `protobuf:"bytes,2,rep,name=fieldBinlogs,proto3" json:"fieldBinlogs,omitempty"`
	NumOfRows     int64                     `protobuf:"varint,3,opt,name=num_of_rows,json=numOfRows,proto3" json:"num_of_rows,omitempty"`
	Statslogs     []*FieldBinlog            `protobuf:"bytes,4,rep,name=statslogs,proto3" json:"statslogs,omitempty"`
	Deltalogs     []*FieldBinlog            `protobuf:"bytes,5,rep,name=deltalogs,proto3" json:"deltalogs,omitempty"`
	InsertChannel string                    `protobuf:"bytes,6,opt,name=insert_channel,json=insertChannel,proto3" json:"insert_channel,omitempty"`
	TextStatsLogs map[int64]*TextIndexStats `` /* 168-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SegmentBinlogs) Descriptor deprecated 

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

Deprecated: Use SegmentBinlogs.ProtoReflect.Descriptor instead.

func (*SegmentBinlogs) GetDeltalogs 

func (x *SegmentBinlogs) GetDeltalogs() []*FieldBinlog

func (*SegmentBinlogs) GetFieldBinlogs 

func (x *SegmentBinlogs) GetFieldBinlogs() []*FieldBinlog

func (*SegmentBinlogs) GetInsertChannel 

func (x *SegmentBinlogs) GetInsertChannel() string

func (*SegmentBinlogs) GetNumOfRows 

func (x *SegmentBinlogs) GetNumOfRows() int64

func (*SegmentBinlogs) GetSegmentID 

func (x *SegmentBinlogs) GetSegmentID() int64

func (*SegmentBinlogs) GetStatslogs 

func (x *SegmentBinlogs) GetStatslogs() []*FieldBinlog

func (*SegmentBinlogs) GetTextStatsLogs 

func (x *SegmentBinlogs) GetTextStatsLogs() map[int64]*TextIndexStats

func (*SegmentBinlogs) ProtoMessage 

func (*SegmentBinlogs) ProtoMessage()

func (*SegmentBinlogs) ProtoReflect 

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

func (*SegmentBinlogs) Reset 

func (x *SegmentBinlogs) Reset()

func (*SegmentBinlogs) String 

func (x *SegmentBinlogs) String() string

type SegmentFieldBinlogMeta 

type SegmentFieldBinlogMeta struct {
	FieldID    int64  `protobuf:"varint,1,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	BinlogPath string `protobuf:"bytes,2,opt,name=binlog_path,json=binlogPath,proto3" json:"binlog_path,omitempty"`
	// contains filtered or unexported fields
}

Deprecated

func (*SegmentFieldBinlogMeta) Descriptor deprecated 

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

Deprecated: Use SegmentFieldBinlogMeta.ProtoReflect.Descriptor instead.

func (*SegmentFieldBinlogMeta) GetBinlogPath 

func (x *SegmentFieldBinlogMeta) GetBinlogPath() string

func (*SegmentFieldBinlogMeta) GetFieldID 

func (x *SegmentFieldBinlogMeta) GetFieldID() int64

func (*SegmentFieldBinlogMeta) ProtoMessage 

func (*SegmentFieldBinlogMeta) ProtoMessage()

func (*SegmentFieldBinlogMeta) ProtoReflect 

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

func (*SegmentFieldBinlogMeta) Reset 

func (x *SegmentFieldBinlogMeta) Reset()

func (*SegmentFieldBinlogMeta) String 

func (x *SegmentFieldBinlogMeta) String() string

type SegmentFlushCompletedMsg 

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

func (*SegmentFlushCompletedMsg) Descriptor deprecated 

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

Deprecated: Use SegmentFlushCompletedMsg.ProtoReflect.Descriptor instead.

func (*SegmentFlushCompletedMsg) GetBase 

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

func (*SegmentFlushCompletedMsg) GetSegment 

func (x *SegmentFlushCompletedMsg) GetSegment() *SegmentInfo

func (*SegmentFlushCompletedMsg) ProtoMessage 

func (*SegmentFlushCompletedMsg) ProtoMessage()

func (*SegmentFlushCompletedMsg) ProtoReflect 

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

func (*SegmentFlushCompletedMsg) Reset 

func (x *SegmentFlushCompletedMsg) Reset()

func (*SegmentFlushCompletedMsg) String 

func (x *SegmentFlushCompletedMsg) String() string

type SegmentIDAssignment 

type SegmentIDAssignment struct {
	SegID        int64            `protobuf:"varint,1,opt,name=segID,proto3" json:"segID,omitempty"`
	ChannelName  string           `protobuf:"bytes,2,opt,name=channel_name,json=channelName,proto3" json:"channel_name,omitempty"`
	Count        uint32           `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	CollectionID int64            `protobuf:"varint,4,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionID  int64            `protobuf:"varint,5,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	ExpireTime   uint64           `protobuf:"varint,6,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	Status       *commonpb.Status `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentIDAssignment) Descriptor deprecated 

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

Deprecated: Use SegmentIDAssignment.ProtoReflect.Descriptor instead.

func (*SegmentIDAssignment) GetChannelName 

func (x *SegmentIDAssignment) GetChannelName() string

func (*SegmentIDAssignment) GetCollectionID 

func (x *SegmentIDAssignment) GetCollectionID() int64

func (*SegmentIDAssignment) GetCount 

func (x *SegmentIDAssignment) GetCount() uint32

func (*SegmentIDAssignment) GetExpireTime 

func (x *SegmentIDAssignment) GetExpireTime() uint64

func (*SegmentIDAssignment) GetPartitionID 

func (x *SegmentIDAssignment) GetPartitionID() int64

func (*SegmentIDAssignment) GetSegID 

func (x *SegmentIDAssignment) GetSegID() int64

func (*SegmentIDAssignment) GetStatus 

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

func (*SegmentIDAssignment) ProtoMessage 

func (*SegmentIDAssignment) ProtoMessage()

func (*SegmentIDAssignment) ProtoReflect 

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

func (*SegmentIDAssignment) Reset 

func (x *SegmentIDAssignment) Reset()

func (*SegmentIDAssignment) String 

func (x *SegmentIDAssignment) String() string

type SegmentIDRequest 

type SegmentIDRequest struct {
	Count        uint32       `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	ChannelName  string       `protobuf:"bytes,2,opt,name=channel_name,json=channelName,proto3" json:"channel_name,omitempty"`
	CollectionID int64        `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionID  int64        `protobuf:"varint,4,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	IsImport     bool         `protobuf:"varint,5,opt,name=isImport,proto3" json:"isImport,omitempty"`                               // deprecated
	ImportTaskID int64        `protobuf:"varint,6,opt,name=importTaskID,proto3" json:"importTaskID,omitempty"`                       // deprecated
	Level        SegmentLevel `protobuf:"varint,7,opt,name=level,proto3,enum=milvus.proto.data.SegmentLevel" json:"level,omitempty"` // deprecated
	// contains filtered or unexported fields
}

func (*SegmentIDRequest) Descriptor deprecated 

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

Deprecated: Use SegmentIDRequest.ProtoReflect.Descriptor instead.

func (*SegmentIDRequest) GetChannelName 

func (x *SegmentIDRequest) GetChannelName() string

func (*SegmentIDRequest) GetCollectionID 

func (x *SegmentIDRequest) GetCollectionID() int64

func (*SegmentIDRequest) GetCount 

func (x *SegmentIDRequest) GetCount() uint32

func (*SegmentIDRequest) GetImportTaskID 

func (x *SegmentIDRequest) GetImportTaskID() int64

func (*SegmentIDRequest) GetIsImport 

func (x *SegmentIDRequest) GetIsImport() bool

func (*SegmentIDRequest) GetLevel 

func (x *SegmentIDRequest) GetLevel() SegmentLevel

func (*SegmentIDRequest) GetPartitionID 

func (x *SegmentIDRequest) GetPartitionID() int64

func (*SegmentIDRequest) ProtoMessage 

func (*SegmentIDRequest) ProtoMessage()

func (*SegmentIDRequest) ProtoReflect 

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

func (*SegmentIDRequest) Reset 

func (x *SegmentIDRequest) Reset()

func (*SegmentIDRequest) String 

func (x *SegmentIDRequest) String() string

type SegmentInfo 

type SegmentInfo 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"`
	PartitionID    int64                 `protobuf:"varint,3,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	InsertChannel  string                `protobuf:"bytes,4,opt,name=insert_channel,json=insertChannel,proto3" json:"insert_channel,omitempty"`
	NumOfRows      int64                 `protobuf:"varint,5,opt,name=num_of_rows,json=numOfRows,proto3" json:"num_of_rows,omitempty"`
	State          commonpb.SegmentState `protobuf:"varint,6,opt,name=state,proto3,enum=milvus.proto.common.SegmentState" json:"state,omitempty"`
	MaxRowNum      int64                 `protobuf:"varint,7,opt,name=max_row_num,json=maxRowNum,proto3" json:"max_row_num,omitempty"`
	LastExpireTime uint64                `protobuf:"varint,8,opt,name=last_expire_time,json=lastExpireTime,proto3" json:"last_expire_time,omitempty"`
	StartPosition  *msgpb.MsgPosition    `protobuf:"bytes,9,opt,name=start_position,json=startPosition,proto3" json:"start_position,omitempty"`
	DmlPosition    *msgpb.MsgPosition    `protobuf:"bytes,10,opt,name=dml_position,json=dmlPosition,proto3" json:"dml_position,omitempty"`
	// binlogs consist of insert binlogs
	Binlogs   []*FieldBinlog `protobuf:"bytes,11,rep,name=binlogs,proto3" json:"binlogs,omitempty"`
	Statslogs []*FieldBinlog `protobuf:"bytes,12,rep,name=statslogs,proto3" json:"statslogs,omitempty"`
	// deltalogs consists of delete binlogs. FieldID is not used yet since delete is always applied on primary key
	Deltalogs           []*FieldBinlog `protobuf:"bytes,13,rep,name=deltalogs,proto3" json:"deltalogs,omitempty"`
	CreatedByCompaction bool           `protobuf:"varint,14,opt,name=createdByCompaction,proto3" json:"createdByCompaction,omitempty"`
	CompactionFrom      []int64        `protobuf:"varint,15,rep,packed,name=compactionFrom,proto3" json:"compactionFrom,omitempty"`
	DroppedAt           uint64         `protobuf:"varint,16,opt,name=dropped_at,json=droppedAt,proto3" json:"dropped_at,omitempty"` // timestamp when segment marked drop
	// A flag indicating if:
	// (1) this segment is created by bulk insert, and
	// (2) the bulk insert task that creates this segment has not yet reached `ImportCompleted` state.
	IsImporting bool `protobuf:"varint,17,opt,name=is_importing,json=isImporting,proto3" json:"is_importing,omitempty"`
	IsFake      bool `protobuf:"varint,18,opt,name=is_fake,json=isFake,proto3" json:"is_fake,omitempty"`
	// denote if this segment is compacted to other segment.
	// For compatibility reasons, this flag of an old compacted segment may still be False.
	// As for new fields added in the message, they will be populated with their respective field types' default values.
	Compacted bool `protobuf:"varint,19,opt,name=compacted,proto3" json:"compacted,omitempty"`
	// Segment level, indicating compaction segment level
	// Available value: Legacy, L0, L1, L2
	// For legacy level, it represent old segment before segment level introduced
	// so segments with Legacy level shall be treated as L1 segment
	Level                 SegmentLevel `protobuf:"varint,20,opt,name=level,proto3,enum=milvus.proto.data.SegmentLevel" json:"level,omitempty"`
	StorageVersion        int64        `protobuf:"varint,21,opt,name=storage_version,json=storageVersion,proto3" json:"storage_version,omitempty"`
	PartitionStatsVersion int64        `` /* 128-byte string literal not displayed */
	// use in major compaction, if compaction fail, should revert segment level to last value
	LastLevel SegmentLevel `` /* 126-byte string literal not displayed */
	// use in major compaction, if compaction fail, should revert partition stats version to last value
	LastPartitionStatsVersion int64 `` /* 142-byte string literal not displayed */
	// used to indicate whether the segment is sorted by primary key.
	IsSorted bool `protobuf:"varint,25,opt,name=is_sorted,json=isSorted,proto3" json:"is_sorted,omitempty"`
	// textStatsLogs is used to record tokenization index for fields.
	TextStatsLogs map[int64]*TextIndexStats `` /* 169-byte string literal not displayed */
	Bm25Statslogs []*FieldBinlog            `protobuf:"bytes,27,rep,name=bm25statslogs,proto3" json:"bm25statslogs,omitempty"`
	// This field is used to indicate that some intermediate state segments should not be loaded.
	// For example, segments that have been clustered but haven't undergone stats yet.
	IsInvisible bool `protobuf:"varint,28,opt,name=is_invisible,json=isInvisible,proto3" json:"is_invisible,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentInfo) Descriptor deprecated 

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

Deprecated: Use SegmentInfo.ProtoReflect.Descriptor instead.

func (*SegmentInfo) GetBinlogs 

func (x *SegmentInfo) GetBinlogs() []*FieldBinlog

func (*SegmentInfo) GetBm25Statslogs 

func (x *SegmentInfo) GetBm25Statslogs() []*FieldBinlog

func (*SegmentInfo) GetCollectionID 

func (x *SegmentInfo) GetCollectionID() int64

func (*SegmentInfo) GetCompacted 

func (x *SegmentInfo) GetCompacted() bool

func (*SegmentInfo) GetCompactionFrom 

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

func (*SegmentInfo) GetCreatedByCompaction 

func (x *SegmentInfo) GetCreatedByCompaction() bool

func (*SegmentInfo) GetDeltalogs 

func (x *SegmentInfo) GetDeltalogs() []*FieldBinlog

func (*SegmentInfo) GetDmlPosition 

func (x *SegmentInfo) GetDmlPosition() *msgpb.MsgPosition

func (*SegmentInfo) GetDroppedAt 

func (x *SegmentInfo) GetDroppedAt() uint64

func (*SegmentInfo) GetID 

func (x *SegmentInfo) GetID() int64

func (*SegmentInfo) GetInsertChannel 

func (x *SegmentInfo) GetInsertChannel() string

func (*SegmentInfo) GetIsFake 

func (x *SegmentInfo) GetIsFake() bool

func (*SegmentInfo) GetIsImporting 

func (x *SegmentInfo) GetIsImporting() bool

func (*SegmentInfo) GetIsInvisible 

func (x *SegmentInfo) GetIsInvisible() bool

func (*SegmentInfo) GetIsSorted 

func (x *SegmentInfo) GetIsSorted() bool

func (*SegmentInfo) GetLastExpireTime 

func (x *SegmentInfo) GetLastExpireTime() uint64

func (*SegmentInfo) GetLastLevel 

func (x *SegmentInfo) GetLastLevel() SegmentLevel

func (*SegmentInfo) GetLastPartitionStatsVersion 

func (x *SegmentInfo) GetLastPartitionStatsVersion() int64

func (*SegmentInfo) GetLevel 

func (x *SegmentInfo) GetLevel() SegmentLevel

func (*SegmentInfo) GetMaxRowNum 

func (x *SegmentInfo) GetMaxRowNum() int64

func (*SegmentInfo) GetNumOfRows 

func (x *SegmentInfo) GetNumOfRows() int64

func (*SegmentInfo) GetPartitionID 

func (x *SegmentInfo) GetPartitionID() int64

func (*SegmentInfo) GetPartitionStatsVersion 

func (x *SegmentInfo) GetPartitionStatsVersion() int64

func (*SegmentInfo) GetStartPosition 

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

func (*SegmentInfo) GetState 

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

func (*SegmentInfo) GetStatslogs 

func (x *SegmentInfo) GetStatslogs() []*FieldBinlog

func (*SegmentInfo) GetStorageVersion 

func (x *SegmentInfo) GetStorageVersion() int64

func (*SegmentInfo) GetTextStatsLogs 

func (x *SegmentInfo) GetTextStatsLogs() map[int64]*TextIndexStats

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 SegmentLevel 

type SegmentLevel int32
const (
	SegmentLevel_Legacy SegmentLevel = 0 // zero value for legacy logic
	SegmentLevel_L0     SegmentLevel = 1 // L0 segment, contains delta data for current channel
	SegmentLevel_L1     SegmentLevel = 2 // L1 segment, normal segment, with no extra compaction attribute
	SegmentLevel_L2     SegmentLevel = 3 // L2 segment, segment with extra data distribution info
)

func (SegmentLevel) Descriptor 

func (SegmentLevel) Descriptor() protoreflect.EnumDescriptor

func (SegmentLevel) Enum 

func (x SegmentLevel) Enum() *SegmentLevel

func (SegmentLevel) EnumDescriptor deprecated 

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

Deprecated: Use SegmentLevel.Descriptor instead.

func (SegmentLevel) Number 

func (x SegmentLevel) Number() protoreflect.EnumNumber

func (SegmentLevel) String 

func (x SegmentLevel) String() string

func (SegmentLevel) Type 

func (SegmentLevel) Type() protoreflect.EnumType

type SegmentMsg 

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

func (*SegmentMsg) Descriptor deprecated 

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

Deprecated: Use SegmentMsg.ProtoReflect.Descriptor instead.

func (*SegmentMsg) GetBase 

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

func (*SegmentMsg) GetSegment 

func (x *SegmentMsg) GetSegment() *SegmentInfo

func (*SegmentMsg) ProtoMessage 

func (*SegmentMsg) ProtoMessage()

func (*SegmentMsg) ProtoReflect 

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

func (*SegmentMsg) Reset 

func (x *SegmentMsg) Reset()

func (*SegmentMsg) String 

func (x *SegmentMsg) String() string

type SegmentReferenceLock 

type SegmentReferenceLock struct {
	TaskID     int64   `protobuf:"varint,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	NodeID     int64   `protobuf:"varint,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	SegmentIDs []int64 `protobuf:"varint,3,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentReferenceLock) Descriptor deprecated 

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

Deprecated: Use SegmentReferenceLock.ProtoReflect.Descriptor instead.

func (*SegmentReferenceLock) GetNodeID 

func (x *SegmentReferenceLock) GetNodeID() int64

func (*SegmentReferenceLock) GetSegmentIDs 

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

func (*SegmentReferenceLock) GetTaskID 

func (x *SegmentReferenceLock) GetTaskID() int64

func (*SegmentReferenceLock) ProtoMessage 

func (*SegmentReferenceLock) ProtoMessage()

func (*SegmentReferenceLock) ProtoReflect 

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

func (*SegmentReferenceLock) Reset 

func (x *SegmentReferenceLock) Reset()

func (*SegmentReferenceLock) String 

func (x *SegmentReferenceLock) String() string

type SegmentStartPosition 

type SegmentStartPosition struct {
	StartPosition *msgpb.MsgPosition `protobuf:"bytes,1,opt,name=start_position,json=startPosition,proto3" json:"start_position,omitempty"`
	SegmentID     int64              `protobuf:"varint,2,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentStartPosition) Descriptor deprecated 

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

Deprecated: Use SegmentStartPosition.ProtoReflect.Descriptor instead.

func (*SegmentStartPosition) GetSegmentID 

func (x *SegmentStartPosition) GetSegmentID() int64

func (*SegmentStartPosition) GetStartPosition 

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

func (*SegmentStartPosition) ProtoMessage 

func (*SegmentStartPosition) ProtoMessage()

func (*SegmentStartPosition) ProtoReflect 

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

func (*SegmentStartPosition) Reset 

func (x *SegmentStartPosition) Reset()

func (*SegmentStartPosition) String 

func (x *SegmentStartPosition) String() string

type SegmentStateInfo 

type SegmentStateInfo struct {
	SegmentID     int64                 `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	State         commonpb.SegmentState `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.common.SegmentState" json:"state,omitempty"`
	StartPosition *msgpb.MsgPosition    `protobuf:"bytes,3,opt,name=start_position,json=startPosition,proto3" json:"start_position,omitempty"`
	EndPosition   *msgpb.MsgPosition    `protobuf:"bytes,4,opt,name=end_position,json=endPosition,proto3" json:"end_position,omitempty"`
	Status        *commonpb.Status      `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentStateInfo) Descriptor deprecated 

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

Deprecated: Use SegmentStateInfo.ProtoReflect.Descriptor instead.

func (*SegmentStateInfo) GetEndPosition 

func (x *SegmentStateInfo) GetEndPosition() *msgpb.MsgPosition

func (*SegmentStateInfo) GetSegmentID 

func (x *SegmentStateInfo) GetSegmentID() int64

func (*SegmentStateInfo) GetStartPosition 

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

func (*SegmentStateInfo) GetState 

func (x *SegmentStateInfo) GetState() commonpb.SegmentState

func (*SegmentStateInfo) GetStatus 

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

func (*SegmentStateInfo) ProtoMessage 

func (*SegmentStateInfo) ProtoMessage()

func (*SegmentStateInfo) ProtoReflect 

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

func (*SegmentStateInfo) Reset 

func (x *SegmentStateInfo) Reset()

func (*SegmentStateInfo) String 

func (x *SegmentStateInfo) String() string

type SegmentType 

type SegmentType int32
const (
	SegmentType_New       SegmentType = 0
	SegmentType_Normal    SegmentType = 1
	SegmentType_Flushed   SegmentType = 2
	SegmentType_Compacted SegmentType = 3
)

func (SegmentType) Descriptor 

func (SegmentType) Descriptor() protoreflect.EnumDescriptor

func (SegmentType) Enum 

func (x SegmentType) Enum() *SegmentType

func (SegmentType) EnumDescriptor deprecated 

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

Deprecated: Use SegmentType.Descriptor instead.

func (SegmentType) Number 

func (x SegmentType) Number() protoreflect.EnumNumber

func (SegmentType) String 

func (x SegmentType) String() string

func (SegmentType) Type 

func (SegmentType) Type() protoreflect.EnumType

type SetSegmentStateRequest 

type SetSegmentStateRequest struct {
	Base      *commonpb.MsgBase     `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	SegmentId int64                 `protobuf:"varint,2,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	NewState  commonpb.SegmentState `protobuf:"varint,3,opt,name=new_state,json=newState,proto3,enum=milvus.proto.common.SegmentState" json:"new_state,omitempty"`
	// contains filtered or unexported fields
}

func (*SetSegmentStateRequest) Descriptor deprecated 

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

Deprecated: Use SetSegmentStateRequest.ProtoReflect.Descriptor instead.

func (*SetSegmentStateRequest) GetBase 

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

func (*SetSegmentStateRequest) GetNewState 

func (x *SetSegmentStateRequest) GetNewState() commonpb.SegmentState

func (*SetSegmentStateRequest) GetSegmentId 

func (x *SetSegmentStateRequest) GetSegmentId() int64

func (*SetSegmentStateRequest) ProtoMessage 

func (*SetSegmentStateRequest) ProtoMessage()

func (*SetSegmentStateRequest) ProtoReflect 

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

func (*SetSegmentStateRequest) Reset 

func (x *SetSegmentStateRequest) Reset()

func (*SetSegmentStateRequest) String 

func (x *SetSegmentStateRequest) String() string

type SetSegmentStateResponse 

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

func (*SetSegmentStateResponse) Descriptor deprecated 

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

Deprecated: Use SetSegmentStateResponse.ProtoReflect.Descriptor instead.

func (*SetSegmentStateResponse) GetStatus 

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

func (*SetSegmentStateResponse) ProtoMessage 

func (*SetSegmentStateResponse) ProtoMessage()

func (*SetSegmentStateResponse) ProtoReflect 

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

func (*SetSegmentStateResponse) Reset 

func (x *SetSegmentStateResponse) Reset()

func (*SetSegmentStateResponse) String 

func (x *SetSegmentStateResponse) String() string

type SyncSegmentInfo 

type SyncSegmentInfo struct {
	SegmentId  int64                 `protobuf:"varint,1,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	PkStatsLog *FieldBinlog          `protobuf:"bytes,2,opt,name=pk_stats_log,json=pkStatsLog,proto3" json:"pk_stats_log,omitempty"`
	State      commonpb.SegmentState `protobuf:"varint,3,opt,name=state,proto3,enum=milvus.proto.common.SegmentState" json:"state,omitempty"`
	Level      SegmentLevel          `protobuf:"varint,4,opt,name=level,proto3,enum=milvus.proto.data.SegmentLevel" json:"level,omitempty"`
	NumOfRows  int64                 `protobuf:"varint,5,opt,name=num_of_rows,json=numOfRows,proto3" json:"num_of_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncSegmentInfo) Descriptor deprecated 

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

Deprecated: Use SyncSegmentInfo.ProtoReflect.Descriptor instead.

func (*SyncSegmentInfo) GetLevel 

func (x *SyncSegmentInfo) GetLevel() SegmentLevel

func (*SyncSegmentInfo) GetNumOfRows 

func (x *SyncSegmentInfo) GetNumOfRows() int64

func (*SyncSegmentInfo) GetPkStatsLog 

func (x *SyncSegmentInfo) GetPkStatsLog() *FieldBinlog

func (*SyncSegmentInfo) GetSegmentId 

func (x *SyncSegmentInfo) GetSegmentId() int64

func (*SyncSegmentInfo) GetState 

func (x *SyncSegmentInfo) GetState() commonpb.SegmentState

func (*SyncSegmentInfo) ProtoMessage 

func (*SyncSegmentInfo) ProtoMessage()

func (*SyncSegmentInfo) ProtoReflect 

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

func (*SyncSegmentInfo) Reset 

func (x *SyncSegmentInfo) Reset()

func (*SyncSegmentInfo) String 

func (x *SyncSegmentInfo) String() string

type SyncSegmentsRequest 

type SyncSegmentsRequest struct {

	// Deprecated, after v2.4.3
	PlanID int64 `protobuf:"varint,1,opt,name=planID,proto3" json:"planID,omitempty"`
	// Deprecated, after v2.4.3
	CompactedTo int64 `protobuf:"varint,2,opt,name=compacted_to,json=compactedTo,proto3" json:"compacted_to,omitempty"`
	// Deprecated, after v2.4.3
	NumOfRows int64 `protobuf:"varint,3,opt,name=num_of_rows,json=numOfRows,proto3" json:"num_of_rows,omitempty"`
	// Deprecated, after v2.4.3
	CompactedFrom []int64 `protobuf:"varint,4,rep,packed,name=compacted_from,json=compactedFrom,proto3" json:"compacted_from,omitempty"`
	// Deprecated, after v2.4.3
	StatsLogs    []*FieldBinlog             `protobuf:"bytes,5,rep,name=stats_logs,json=statsLogs,proto3" json:"stats_logs,omitempty"`
	ChannelName  string                     `protobuf:"bytes,6,opt,name=channel_name,json=channelName,proto3" json:"channel_name,omitempty"`
	PartitionId  int64                      `protobuf:"varint,7,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	CollectionId int64                      `protobuf:"varint,8,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	SegmentInfos map[int64]*SyncSegmentInfo `` /* 186-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SyncSegmentsRequest) Descriptor deprecated 

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

Deprecated: Use SyncSegmentsRequest.ProtoReflect.Descriptor instead.

func (*SyncSegmentsRequest) GetChannelName 

func (x *SyncSegmentsRequest) GetChannelName() string

func (*SyncSegmentsRequest) GetCollectionId 

func (x *SyncSegmentsRequest) GetCollectionId() int64

func (*SyncSegmentsRequest) GetCompactedFrom 

func (x *SyncSegmentsRequest) GetCompactedFrom() []int64

func (*SyncSegmentsRequest) GetCompactedTo 

func (x *SyncSegmentsRequest) GetCompactedTo() int64

func (*SyncSegmentsRequest) GetNumOfRows 

func (x *SyncSegmentsRequest) GetNumOfRows() int64

func (*SyncSegmentsRequest) GetPartitionId 

func (x *SyncSegmentsRequest) GetPartitionId() int64

func (*SyncSegmentsRequest) GetPlanID 

func (x *SyncSegmentsRequest) GetPlanID() int64

func (*SyncSegmentsRequest) GetSegmentInfos 

func (x *SyncSegmentsRequest) GetSegmentInfos() map[int64]*SyncSegmentInfo

func (*SyncSegmentsRequest) GetStatsLogs 

func (x *SyncSegmentsRequest) GetStatsLogs() []*FieldBinlog

func (*SyncSegmentsRequest) ProtoMessage 

func (*SyncSegmentsRequest) ProtoMessage()

func (*SyncSegmentsRequest) ProtoReflect 

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

func (*SyncSegmentsRequest) Reset 

func (x *SyncSegmentsRequest) Reset()

func (*SyncSegmentsRequest) String 

func (x *SyncSegmentsRequest) String() string

type TextIndexStats 

type TextIndexStats struct {
	FieldID    int64    `protobuf:"varint,1,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	Version    int64    `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Files      []string `protobuf:"bytes,3,rep,name=files,proto3" json:"files,omitempty"`
	LogSize    int64    `protobuf:"varint,4,opt,name=log_size,json=logSize,proto3" json:"log_size,omitempty"`
	MemorySize int64    `protobuf:"varint,5,opt,name=memory_size,json=memorySize,proto3" json:"memory_size,omitempty"`
	BuildID    int64    `protobuf:"varint,6,opt,name=buildID,proto3" json:"buildID,omitempty"`
	// contains filtered or unexported fields
}

func (*TextIndexStats) Descriptor deprecated 

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

Deprecated: Use TextIndexStats.ProtoReflect.Descriptor instead.

func (*TextIndexStats) GetBuildID 

func (x *TextIndexStats) GetBuildID() int64

func (*TextIndexStats) GetFieldID 

func (x *TextIndexStats) GetFieldID() int64

func (*TextIndexStats) GetFiles 

func (x *TextIndexStats) GetFiles() []string

func (*TextIndexStats) GetLogSize 

func (x *TextIndexStats) GetLogSize() int64

func (*TextIndexStats) GetMemorySize 

func (x *TextIndexStats) GetMemorySize() int64

func (*TextIndexStats) GetVersion 

func (x *TextIndexStats) GetVersion() int64

func (*TextIndexStats) ProtoMessage 

func (*TextIndexStats) ProtoMessage()

func (*TextIndexStats) ProtoReflect 

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

func (*TextIndexStats) Reset 

func (x *TextIndexStats) Reset()

func (*TextIndexStats) String 

func (x *TextIndexStats) String() string

type UnimplementedDataCoordServer 

type UnimplementedDataCoordServer struct {
}

UnimplementedDataCoordServer should be embedded to have forward compatible implementations.

func (UnimplementedDataCoordServer) AllocSegment 

func (UnimplementedDataCoordServer) AllocSegment(context.Context, *AllocSegmentRequest) (*AllocSegmentResponse, error)

func (UnimplementedDataCoordServer) AlterIndex 

func (UnimplementedDataCoordServer) AlterIndex(context.Context, *indexpb.AlterIndexRequest) (*commonpb.Status, error)

func (UnimplementedDataCoordServer) AssignSegmentID 

func (UnimplementedDataCoordServer) AssignSegmentID(context.Context, *AssignSegmentIDRequest) (*AssignSegmentIDResponse, error)

func (UnimplementedDataCoordServer) BroadcastAlteredCollection 

func (UnimplementedDataCoordServer) BroadcastAlteredCollection(context.Context, *AlterCollectionRequest) (*commonpb.Status, error)

func (UnimplementedDataCoordServer) CheckHealth 

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

func (UnimplementedDataCoordServer) CreateIndex 

func (UnimplementedDataCoordServer) CreateIndex(context.Context, *indexpb.CreateIndexRequest) (*commonpb.Status, error)

func (UnimplementedDataCoordServer) DescribeIndex 

func (UnimplementedDataCoordServer) DescribeIndex(context.Context, *indexpb.DescribeIndexRequest) (*indexpb.DescribeIndexResponse, error)

func (UnimplementedDataCoordServer) DropIndex 

func (UnimplementedDataCoordServer) DropIndex(context.Context, *indexpb.DropIndexRequest) (*commonpb.Status, error)

func (UnimplementedDataCoordServer) DropVirtualChannel 

func (UnimplementedDataCoordServer) DropVirtualChannel(context.Context, *DropVirtualChannelRequest) (*DropVirtualChannelResponse, error)

func (UnimplementedDataCoordServer) Flush 

func (UnimplementedDataCoordServer) Flush(context.Context, *FlushRequest) (*FlushResponse, error)

func (UnimplementedDataCoordServer) GcConfirm 

func (UnimplementedDataCoordServer) GcConfirm(context.Context, *GcConfirmRequest) (*GcConfirmResponse, error)

func (UnimplementedDataCoordServer) GcControl 

func (UnimplementedDataCoordServer) GcControl(context.Context, *GcControlRequest) (*commonpb.Status, error)

func (UnimplementedDataCoordServer) GetChannelRecoveryInfo 

func (UnimplementedDataCoordServer) GetChannelRecoveryInfo(context.Context, *GetChannelRecoveryInfoRequest) (*GetChannelRecoveryInfoResponse, error)

func (UnimplementedDataCoordServer) GetCollectionStatistics 

func (UnimplementedDataCoordServer) GetCollectionStatistics(context.Context, *GetCollectionStatisticsRequest) (*GetCollectionStatisticsResponse, error)

func (UnimplementedDataCoordServer) GetCompactionState 

func (UnimplementedDataCoordServer) GetCompactionState(context.Context, *milvuspb.GetCompactionStateRequest) (*milvuspb.GetCompactionStateResponse, error)

func (UnimplementedDataCoordServer) GetCompactionStateWithPlans 

func (UnimplementedDataCoordServer) GetCompactionStateWithPlans(context.Context, *milvuspb.GetCompactionPlansRequest) (*milvuspb.GetCompactionPlansResponse, error)

func (UnimplementedDataCoordServer) GetComponentStates 

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

func (UnimplementedDataCoordServer) GetFlushAllState 

func (UnimplementedDataCoordServer) GetFlushAllState(context.Context, *milvuspb.GetFlushAllStateRequest) (*milvuspb.GetFlushAllStateResponse, error)

func (UnimplementedDataCoordServer) GetFlushState 

func (UnimplementedDataCoordServer) GetFlushState(context.Context, *GetFlushStateRequest) (*milvuspb.GetFlushStateResponse, error)

func (UnimplementedDataCoordServer) GetFlushedSegments 

func (UnimplementedDataCoordServer) GetFlushedSegments(context.Context, *GetFlushedSegmentsRequest) (*GetFlushedSegmentsResponse, error)

func (UnimplementedDataCoordServer) GetImportProgress 

func (UnimplementedDataCoordServer) GetImportProgress(context.Context, *internalpb.GetImportProgressRequest) (*internalpb.GetImportProgressResponse, error)

func (UnimplementedDataCoordServer) GetIndexBuildProgress 

func (UnimplementedDataCoordServer) GetIndexBuildProgress(context.Context, *indexpb.GetIndexBuildProgressRequest) (*indexpb.GetIndexBuildProgressResponse, error)

func (UnimplementedDataCoordServer) GetIndexInfos 

func (UnimplementedDataCoordServer) GetIndexInfos(context.Context, *indexpb.GetIndexInfoRequest) (*indexpb.GetIndexInfoResponse, error)

func (UnimplementedDataCoordServer) GetIndexState 

func (UnimplementedDataCoordServer) GetIndexState(context.Context, *indexpb.GetIndexStateRequest) (*indexpb.GetIndexStateResponse, error)

func (UnimplementedDataCoordServer) GetIndexStatistics 

func (UnimplementedDataCoordServer) GetIndexStatistics(context.Context, *indexpb.GetIndexStatisticsRequest) (*indexpb.GetIndexStatisticsResponse, error)

func (UnimplementedDataCoordServer) GetInsertBinlogPaths 

func (UnimplementedDataCoordServer) GetInsertBinlogPaths(context.Context, *GetInsertBinlogPathsRequest) (*GetInsertBinlogPathsResponse, error)

func (UnimplementedDataCoordServer) GetMetrics 

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

func (UnimplementedDataCoordServer) GetPartitionStatistics 

func (UnimplementedDataCoordServer) GetPartitionStatistics(context.Context, *GetPartitionStatisticsRequest) (*GetPartitionStatisticsResponse, error)

func (UnimplementedDataCoordServer) GetRecoveryInfo 

func (UnimplementedDataCoordServer) GetRecoveryInfo(context.Context, *GetRecoveryInfoRequest) (*GetRecoveryInfoResponse, error)

func (UnimplementedDataCoordServer) GetRecoveryInfoV2 

func (UnimplementedDataCoordServer) GetRecoveryInfoV2(context.Context, *GetRecoveryInfoRequestV2) (*GetRecoveryInfoResponseV2, error)

func (UnimplementedDataCoordServer) GetSegmentIndexState 

func (UnimplementedDataCoordServer) GetSegmentIndexState(context.Context, *indexpb.GetSegmentIndexStateRequest) (*indexpb.GetSegmentIndexStateResponse, error)

func (UnimplementedDataCoordServer) GetSegmentInfo 

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

func (UnimplementedDataCoordServer) GetSegmentInfoChannel 

func (UnimplementedDataCoordServer) GetSegmentInfoChannel(context.Context, *GetSegmentInfoChannelRequest) (*milvuspb.StringResponse, error)

func (UnimplementedDataCoordServer) GetSegmentStates 

func (UnimplementedDataCoordServer) GetSegmentStates(context.Context, *GetSegmentStatesRequest) (*GetSegmentStatesResponse, error)

func (UnimplementedDataCoordServer) GetSegmentsByStates 

func (UnimplementedDataCoordServer) GetSegmentsByStates(context.Context, *GetSegmentsByStatesRequest) (*GetSegmentsByStatesResponse, error)

func (UnimplementedDataCoordServer) GetStatisticsChannel 

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

func (UnimplementedDataCoordServer) GetTimeTickChannel 

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

func (UnimplementedDataCoordServer) ImportV2 

func (UnimplementedDataCoordServer) ImportV2(context.Context, *internalpb.ImportRequestInternal) (*internalpb.ImportResponse, error)

func (UnimplementedDataCoordServer) ListImports 

func (UnimplementedDataCoordServer) ListImports(context.Context, *internalpb.ListImportsRequestInternal) (*internalpb.ListImportsResponse, error)

func (UnimplementedDataCoordServer) ListIndexes 

func (UnimplementedDataCoordServer) ListIndexes(context.Context, *indexpb.ListIndexesRequest) (*indexpb.ListIndexesResponse, error)

func (UnimplementedDataCoordServer) ManualCompaction 

func (UnimplementedDataCoordServer) ManualCompaction(context.Context, *milvuspb.ManualCompactionRequest) (*milvuspb.ManualCompactionResponse, error)

func (UnimplementedDataCoordServer) MarkSegmentsDropped 

func (UnimplementedDataCoordServer) MarkSegmentsDropped(context.Context, *MarkSegmentsDroppedRequest) (*commonpb.Status, error)

func (UnimplementedDataCoordServer) ReportDataNodeTtMsgs 

func (UnimplementedDataCoordServer) ReportDataNodeTtMsgs(context.Context, *ReportDataNodeTtMsgsRequest) (*commonpb.Status, error)

func (UnimplementedDataCoordServer) SaveBinlogPaths 

func (UnimplementedDataCoordServer) SaveBinlogPaths(context.Context, *SaveBinlogPathsRequest) (*commonpb.Status, error)

func (UnimplementedDataCoordServer) SetSegmentState 

func (UnimplementedDataCoordServer) SetSegmentState(context.Context, *SetSegmentStateRequest) (*SetSegmentStateResponse, error)

func (UnimplementedDataCoordServer) ShowConfigurations 

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

func (UnimplementedDataCoordServer) UpdateChannelCheckpoint 

func (UnimplementedDataCoordServer) UpdateChannelCheckpoint(context.Context, *UpdateChannelCheckpointRequest) (*commonpb.Status, error)

func (UnimplementedDataCoordServer) UpdateSegmentStatistics 

func (UnimplementedDataCoordServer) UpdateSegmentStatistics(context.Context, *UpdateSegmentStatisticsRequest) (*commonpb.Status, error)

func (UnimplementedDataCoordServer) WatchChannels 

func (UnimplementedDataCoordServer) WatchChannels(context.Context, *WatchChannelsRequest) (*WatchChannelsResponse, error)

type UnimplementedDataNodeServer 

type UnimplementedDataNodeServer struct {
}

UnimplementedDataNodeServer should be embedded to have forward compatible implementations.

func (UnimplementedDataNodeServer) CheckChannelOperationProgress 

func (UnimplementedDataNodeServer) CheckChannelOperationProgress(context.Context, *ChannelWatchInfo) (*ChannelOperationProgressResponse, error)

func (UnimplementedDataNodeServer) CompactionV2 

func (UnimplementedDataNodeServer) CompactionV2(context.Context, *CompactionPlan) (*commonpb.Status, error)

func (UnimplementedDataNodeServer) DropCompactionPlan 

func (UnimplementedDataNodeServer) DropCompactionPlan(context.Context, *DropCompactionPlanRequest) (*commonpb.Status, error)

func (UnimplementedDataNodeServer) DropImport 

func (UnimplementedDataNodeServer) DropImport(context.Context, *DropImportRequest) (*commonpb.Status, error)

func (UnimplementedDataNodeServer) FlushChannels 

func (UnimplementedDataNodeServer) FlushChannels(context.Context, *FlushChannelsRequest) (*commonpb.Status, error)

func (UnimplementedDataNodeServer) FlushSegments 

func (UnimplementedDataNodeServer) FlushSegments(context.Context, *FlushSegmentsRequest) (*commonpb.Status, error)

func (UnimplementedDataNodeServer) GetCompactionState 

func (UnimplementedDataNodeServer) GetCompactionState(context.Context, *CompactionStateRequest) (*CompactionStateResponse, error)

func (UnimplementedDataNodeServer) GetComponentStates 

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

func (UnimplementedDataNodeServer) GetMetrics 

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

func (UnimplementedDataNodeServer) GetStatisticsChannel 

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

func (UnimplementedDataNodeServer) ImportV2 

func (UnimplementedDataNodeServer) ImportV2(context.Context, *ImportRequest) (*commonpb.Status, error)

func (UnimplementedDataNodeServer) NotifyChannelOperation 

func (UnimplementedDataNodeServer) NotifyChannelOperation(context.Context, *ChannelOperationsRequest) (*commonpb.Status, error)

func (UnimplementedDataNodeServer) PreImport 

func (UnimplementedDataNodeServer) PreImport(context.Context, *PreImportRequest) (*commonpb.Status, error)

func (UnimplementedDataNodeServer) QueryImport 

func (UnimplementedDataNodeServer) QueryImport(context.Context, *QueryImportRequest) (*QueryImportResponse, error)

func (UnimplementedDataNodeServer) QueryPreImport 

func (UnimplementedDataNodeServer) QueryPreImport(context.Context, *QueryPreImportRequest) (*QueryPreImportResponse, error)

func (UnimplementedDataNodeServer) QuerySlot 

func (UnimplementedDataNodeServer) QuerySlot(context.Context, *QuerySlotRequest) (*QuerySlotResponse, error)

func (UnimplementedDataNodeServer) ResendSegmentStats 

func (UnimplementedDataNodeServer) ResendSegmentStats(context.Context, *ResendSegmentStatsRequest) (*ResendSegmentStatsResponse, error)

func (UnimplementedDataNodeServer) ShowConfigurations 

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

func (UnimplementedDataNodeServer) SyncSegments 

func (UnimplementedDataNodeServer) SyncSegments(context.Context, *SyncSegmentsRequest) (*commonpb.Status, error)

func (UnimplementedDataNodeServer) WatchDmChannels 

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

type UnsafeDataCoordServer 

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

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

type UnsafeDataNodeServer 

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

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

type UpdateChannelCheckpointRequest 

type UpdateChannelCheckpointRequest struct {
	Base               *commonpb.MsgBase    `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	VChannel           string               `protobuf:"bytes,2,opt,name=vChannel,proto3" json:"vChannel,omitempty"` // deprecated, keep it for compatibility
	Position           *msgpb.MsgPosition   `protobuf:"bytes,3,opt,name=position,proto3" json:"position,omitempty"` // deprecated, keep it for compatibility
	ChannelCheckpoints []*msgpb.MsgPosition `protobuf:"bytes,4,rep,name=channel_checkpoints,json=channelCheckpoints,proto3" json:"channel_checkpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateChannelCheckpointRequest) Descriptor deprecated 

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

Deprecated: Use UpdateChannelCheckpointRequest.ProtoReflect.Descriptor instead.

func (*UpdateChannelCheckpointRequest) GetBase 

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

func (*UpdateChannelCheckpointRequest) GetChannelCheckpoints 

func (x *UpdateChannelCheckpointRequest) GetChannelCheckpoints() []*msgpb.MsgPosition

func (*UpdateChannelCheckpointRequest) GetPosition 

func (x *UpdateChannelCheckpointRequest) GetPosition() *msgpb.MsgPosition

func (*UpdateChannelCheckpointRequest) GetVChannel 

func (x *UpdateChannelCheckpointRequest) GetVChannel() string

func (*UpdateChannelCheckpointRequest) ProtoMessage 

func (*UpdateChannelCheckpointRequest) ProtoMessage()

func (*UpdateChannelCheckpointRequest) ProtoReflect 

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

func (*UpdateChannelCheckpointRequest) Reset 

func (x *UpdateChannelCheckpointRequest) Reset()

func (*UpdateChannelCheckpointRequest) String 

func (x *UpdateChannelCheckpointRequest) String() string

type UpdateSegmentStatisticsRequest 

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

func (*UpdateSegmentStatisticsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateSegmentStatisticsRequest.ProtoReflect.Descriptor instead.

func (*UpdateSegmentStatisticsRequest) GetBase 

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

func (*UpdateSegmentStatisticsRequest) GetStats 

func (x *UpdateSegmentStatisticsRequest) GetStats() []*commonpb.SegmentStats

func (*UpdateSegmentStatisticsRequest) ProtoMessage 

func (*UpdateSegmentStatisticsRequest) ProtoMessage()

func (*UpdateSegmentStatisticsRequest) ProtoReflect 

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

func (*UpdateSegmentStatisticsRequest) Reset 

func (x *UpdateSegmentStatisticsRequest) Reset()

func (*UpdateSegmentStatisticsRequest) String 

func (x *UpdateSegmentStatisticsRequest) String() string

type VchannelInfo 

type VchannelInfo struct {
	CollectionID           int64              `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	ChannelName            string             `protobuf:"bytes,2,opt,name=channelName,proto3" json:"channelName,omitempty"`
	SeekPosition           *msgpb.MsgPosition `protobuf:"bytes,3,opt,name=seek_position,json=seekPosition,proto3" json:"seek_position,omitempty"`
	UnflushedSegments      []*SegmentInfo     `protobuf:"bytes,4,rep,name=unflushedSegments,proto3" json:"unflushedSegments,omitempty"`                    // deprecated, keep it for compatibility
	FlushedSegments        []*SegmentInfo     `protobuf:"bytes,5,rep,name=flushedSegments,proto3" json:"flushedSegments,omitempty"`                        // deprecated, keep it for compatibility
	DroppedSegments        []*SegmentInfo     `protobuf:"bytes,6,rep,name=dropped_segments,json=droppedSegments,proto3" json:"dropped_segments,omitempty"` // deprecated, keep it for compatibility
	UnflushedSegmentIds    []int64            `protobuf:"varint,7,rep,packed,name=unflushedSegmentIds,proto3" json:"unflushedSegmentIds,omitempty"`
	FlushedSegmentIds      []int64            `protobuf:"varint,8,rep,packed,name=flushedSegmentIds,proto3" json:"flushedSegmentIds,omitempty"`
	DroppedSegmentIds      []int64            `protobuf:"varint,9,rep,packed,name=dropped_segmentIds,json=droppedSegmentIds,proto3" json:"dropped_segmentIds,omitempty"`
	IndexedSegmentIds      []int64            `protobuf:"varint,10,rep,packed,name=indexed_segmentIds,json=indexedSegmentIds,proto3" json:"indexed_segmentIds,omitempty"` // deprecated, keep it for compatibility
	IndexedSegments        []*SegmentInfo     `protobuf:"bytes,11,rep,name=indexed_segments,json=indexedSegments,proto3" json:"indexed_segments,omitempty"`               // deprecated, keep it for compatibility
	LevelZeroSegmentIds    []int64            ``                                                                                                                          /* 131-byte string literal not displayed */
	PartitionStatsVersions map[int64]int64    ``                                                                                                                          /* 220-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*VchannelInfo) Descriptor deprecated 

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

Deprecated: Use VchannelInfo.ProtoReflect.Descriptor instead.

func (*VchannelInfo) GetChannelName 

func (x *VchannelInfo) GetChannelName() string

func (*VchannelInfo) GetCollectionID 

func (x *VchannelInfo) GetCollectionID() int64

func (*VchannelInfo) GetDroppedSegmentIds 

func (x *VchannelInfo) GetDroppedSegmentIds() []int64

func (*VchannelInfo) GetDroppedSegments 

func (x *VchannelInfo) GetDroppedSegments() []*SegmentInfo

func (*VchannelInfo) GetFlushedSegmentIds 

func (x *VchannelInfo) GetFlushedSegmentIds() []int64

func (*VchannelInfo) GetFlushedSegments 

func (x *VchannelInfo) GetFlushedSegments() []*SegmentInfo

func (*VchannelInfo) GetIndexedSegmentIds 

func (x *VchannelInfo) GetIndexedSegmentIds() []int64

func (*VchannelInfo) GetIndexedSegments 

func (x *VchannelInfo) GetIndexedSegments() []*SegmentInfo

func (*VchannelInfo) GetLevelZeroSegmentIds 

func (x *VchannelInfo) GetLevelZeroSegmentIds() []int64

func (*VchannelInfo) GetPartitionStatsVersions 

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

func (*VchannelInfo) GetSeekPosition 

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

func (*VchannelInfo) GetUnflushedSegmentIds 

func (x *VchannelInfo) GetUnflushedSegmentIds() []int64

func (*VchannelInfo) GetUnflushedSegments 

func (x *VchannelInfo) GetUnflushedSegments() []*SegmentInfo

func (*VchannelInfo) ProtoMessage 

func (*VchannelInfo) ProtoMessage()

func (*VchannelInfo) ProtoReflect 

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

func (*VchannelInfo) Reset 

func (x *VchannelInfo) Reset()

func (*VchannelInfo) String 

func (x *VchannelInfo) String() string

type WatchChannelsRequest 

type WatchChannelsRequest struct {
	CollectionID    int64                      `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	ChannelNames    []string                   `protobuf:"bytes,2,rep,name=channelNames,proto3" json:"channelNames,omitempty"`
	StartPositions  []*commonpb.KeyDataPair    `protobuf:"bytes,3,rep,name=start_positions,json=startPositions,proto3" json:"start_positions,omitempty"`
	Schema          *schemapb.CollectionSchema `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	CreateTimestamp uint64                     `protobuf:"varint,5,opt,name=create_timestamp,json=createTimestamp,proto3" json:"create_timestamp,omitempty"`
	DbProperties    []*commonpb.KeyValuePair   `protobuf:"bytes,6,rep,name=db_properties,json=dbProperties,proto3" json:"db_properties,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchChannelsRequest) Descriptor deprecated 

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

Deprecated: Use WatchChannelsRequest.ProtoReflect.Descriptor instead.

func (*WatchChannelsRequest) GetChannelNames 

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

func (*WatchChannelsRequest) GetCollectionID 

func (x *WatchChannelsRequest) GetCollectionID() int64

func (*WatchChannelsRequest) GetCreateTimestamp 

func (x *WatchChannelsRequest) GetCreateTimestamp() uint64

func (*WatchChannelsRequest) GetDbProperties 

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

func (*WatchChannelsRequest) GetSchema 

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

func (*WatchChannelsRequest) GetStartPositions 

func (x *WatchChannelsRequest) GetStartPositions() []*commonpb.KeyDataPair

func (*WatchChannelsRequest) ProtoMessage 

func (*WatchChannelsRequest) ProtoMessage()

func (*WatchChannelsRequest) ProtoReflect 

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

func (*WatchChannelsRequest) Reset 

func (x *WatchChannelsRequest) Reset()

func (*WatchChannelsRequest) String 

func (x *WatchChannelsRequest) String() string

type WatchChannelsResponse 

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

func (*WatchChannelsResponse) Descriptor deprecated 

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

Deprecated: Use WatchChannelsResponse.ProtoReflect.Descriptor instead.

func (*WatchChannelsResponse) GetStatus 

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

func (*WatchChannelsResponse) ProtoMessage 

func (*WatchChannelsResponse) ProtoMessage()

func (*WatchChannelsResponse) ProtoReflect 

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

func (*WatchChannelsResponse) Reset 

func (x *WatchChannelsResponse) Reset()

func (*WatchChannelsResponse) String 

func (x *WatchChannelsResponse) String() string

type WatchDmChannelsRequest 

type WatchDmChannelsRequest struct {
	Base      *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Vchannels []*VchannelInfo   `protobuf:"bytes,2,rep,name=vchannels,proto3" json:"vchannels,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) GetVchannels 

func (x *WatchDmChannelsRequest) GetVchannels() []*VchannelInfo

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.