indexpb

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

Documentation

Index

Constants

View Source 
const (
	IndexCoord_GetComponentStates_FullMethodName    = "/milvus.proto.index.IndexCoord/GetComponentStates"
	IndexCoord_GetStatisticsChannel_FullMethodName  = "/milvus.proto.index.IndexCoord/GetStatisticsChannel"
	IndexCoord_CreateIndex_FullMethodName           = "/milvus.proto.index.IndexCoord/CreateIndex"
	IndexCoord_AlterIndex_FullMethodName            = "/milvus.proto.index.IndexCoord/AlterIndex"
	IndexCoord_GetIndexState_FullMethodName         = "/milvus.proto.index.IndexCoord/GetIndexState"
	IndexCoord_GetSegmentIndexState_FullMethodName  = "/milvus.proto.index.IndexCoord/GetSegmentIndexState"
	IndexCoord_GetIndexInfos_FullMethodName         = "/milvus.proto.index.IndexCoord/GetIndexInfos"
	IndexCoord_DropIndex_FullMethodName             = "/milvus.proto.index.IndexCoord/DropIndex"
	IndexCoord_DescribeIndex_FullMethodName         = "/milvus.proto.index.IndexCoord/DescribeIndex"
	IndexCoord_GetIndexStatistics_FullMethodName    = "/milvus.proto.index.IndexCoord/GetIndexStatistics"
	IndexCoord_GetIndexBuildProgress_FullMethodName = "/milvus.proto.index.IndexCoord/GetIndexBuildProgress"
	IndexCoord_ShowConfigurations_FullMethodName    = "/milvus.proto.index.IndexCoord/ShowConfigurations"
	IndexCoord_GetMetrics_FullMethodName            = "/milvus.proto.index.IndexCoord/GetMetrics"
	IndexCoord_CheckHealth_FullMethodName           = "/milvus.proto.index.IndexCoord/CheckHealth"
)

Variables

View Source 
var (
	JobType_name = map[int32]string{
		0: "JobTypeNone",
		1: "JobTypeIndexJob",
		2: "JobTypeAnalyzeJob",
		3: "JobTypeStatsJob",
	}
	JobType_value = map[string]int32{
		"JobTypeNone":       0,
		"JobTypeIndexJob":   1,
		"JobTypeAnalyzeJob": 2,
		"JobTypeStatsJob":   3,
	}
)

Enum value maps for JobType.

View Source 
var (
	JobState_name = map[int32]string{
		0: "JobStateNone",
		1: "JobStateInit",
		2: "JobStateInProgress",
		3: "JobStateFinished",
		4: "JobStateFailed",
		5: "JobStateRetry",
	}
	JobState_value = map[string]int32{
		"JobStateNone":       0,
		"JobStateInit":       1,
		"JobStateInProgress": 2,
		"JobStateFinished":   3,
		"JobStateFailed":     4,
		"JobStateRetry":      5,
	}
)

Enum value maps for JobState.

View Source 
var (
	StatsSubJob_name = map[int32]string{
		0: "None",
		1: "Sort",
		2: "TextIndexJob",
		3: "BM25Job",
	}
	StatsSubJob_value = map[string]int32{
		"None":         0,
		"Sort":         1,
		"TextIndexJob": 2,
		"BM25Job":      3,
	}
)

Enum value maps for StatsSubJob.

View Source 
var File_index_coord_proto protoreflect.FileDescriptor
View Source 
var IndexCoord_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "milvus.proto.index.IndexCoord",
	HandlerType: (*IndexCoordServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetComponentStates",
			Handler:    _IndexCoord_GetComponentStates_Handler,
		},
		{
			MethodName: "GetStatisticsChannel",
			Handler:    _IndexCoord_GetStatisticsChannel_Handler,
		},
		{
			MethodName: "CreateIndex",
			Handler:    _IndexCoord_CreateIndex_Handler,
		},
		{
			MethodName: "AlterIndex",
			Handler:    _IndexCoord_AlterIndex_Handler,
		},
		{
			MethodName: "GetIndexState",
			Handler:    _IndexCoord_GetIndexState_Handler,
		},
		{
			MethodName: "GetSegmentIndexState",
			Handler:    _IndexCoord_GetSegmentIndexState_Handler,
		},
		{
			MethodName: "GetIndexInfos",
			Handler:    _IndexCoord_GetIndexInfos_Handler,
		},
		{
			MethodName: "DropIndex",
			Handler:    _IndexCoord_DropIndex_Handler,
		},
		{
			MethodName: "DescribeIndex",
			Handler:    _IndexCoord_DescribeIndex_Handler,
		},
		{
			MethodName: "GetIndexStatistics",
			Handler:    _IndexCoord_GetIndexStatistics_Handler,
		},
		{
			MethodName: "GetIndexBuildProgress",
			Handler:    _IndexCoord_GetIndexBuildProgress_Handler,
		},
		{
			MethodName: "ShowConfigurations",
			Handler:    _IndexCoord_ShowConfigurations_Handler,
		},
		{
			MethodName: "GetMetrics",
			Handler:    _IndexCoord_GetMetrics_Handler,
		},
		{
			MethodName: "CheckHealth",
			Handler:    _IndexCoord_CheckHealth_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "index_coord.proto",
}

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

Functions

func RegisterIndexCoordServer 

func RegisterIndexCoordServer(s grpc.ServiceRegistrar, srv IndexCoordServer)

Types

type AlterIndexRequest 

type AlterIndexRequest struct {
	CollectionID int64                    `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	IndexName    string                   `protobuf:"bytes,2,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	Params       []*commonpb.KeyValuePair `protobuf:"bytes,3,rep,name=params,proto3" json:"params,omitempty"`
	DeleteKeys   []string                 `protobuf:"bytes,4,rep,name=delete_keys,json=deleteKeys,proto3" json:"delete_keys,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterIndexRequest) Descriptor deprecated 

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

Deprecated: Use AlterIndexRequest.ProtoReflect.Descriptor instead.

func (*AlterIndexRequest) GetCollectionID 

func (x *AlterIndexRequest) GetCollectionID() int64

func (*AlterIndexRequest) GetDeleteKeys 

func (x *AlterIndexRequest) GetDeleteKeys() []string

func (*AlterIndexRequest) GetIndexName 

func (x *AlterIndexRequest) GetIndexName() string

func (*AlterIndexRequest) GetParams 

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

func (*AlterIndexRequest) ProtoMessage 

func (*AlterIndexRequest) ProtoMessage()

func (*AlterIndexRequest) ProtoReflect 

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

func (*AlterIndexRequest) Reset 

func (x *AlterIndexRequest) Reset()

func (*AlterIndexRequest) String 

func (x *AlterIndexRequest) String() string

type AnalyzeTask 

type AnalyzeTask 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"`
	FieldID       int64             `protobuf:"varint,3,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	FieldName     string            `protobuf:"bytes,4,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	FieldType     schemapb.DataType `protobuf:"varint,5,opt,name=field_type,json=fieldType,proto3,enum=milvus.proto.schema.DataType" json:"field_type,omitempty"`
	TaskID        int64             `protobuf:"varint,6,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Version       int64             `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"`
	SegmentIDs    []int64           `protobuf:"varint,8,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	NodeID        int64             `protobuf:"varint,9,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	State         JobState          `protobuf:"varint,10,opt,name=state,proto3,enum=milvus.proto.index.JobState" json:"state,omitempty"`
	FailReason    string            `protobuf:"bytes,11,opt,name=fail_reason,json=failReason,proto3" json:"fail_reason,omitempty"`
	Dim           int64             `protobuf:"varint,12,opt,name=dim,proto3" json:"dim,omitempty"`
	CentroidsFile string            `protobuf:"bytes,13,opt,name=centroids_file,json=centroidsFile,proto3" json:"centroids_file,omitempty"`
	// contains filtered or unexported fields
}

func (*AnalyzeTask) Descriptor deprecated 

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

Deprecated: Use AnalyzeTask.ProtoReflect.Descriptor instead.

func (*AnalyzeTask) GetCentroidsFile 

func (x *AnalyzeTask) GetCentroidsFile() string

func (*AnalyzeTask) GetCollectionID 

func (x *AnalyzeTask) GetCollectionID() int64

func (*AnalyzeTask) GetDim 

func (x *AnalyzeTask) GetDim() int64

func (*AnalyzeTask) GetFailReason 

func (x *AnalyzeTask) GetFailReason() string

func (*AnalyzeTask) GetFieldID 

func (x *AnalyzeTask) GetFieldID() int64

func (*AnalyzeTask) GetFieldName 

func (x *AnalyzeTask) GetFieldName() string

func (*AnalyzeTask) GetFieldType 

func (x *AnalyzeTask) GetFieldType() schemapb.DataType

func (*AnalyzeTask) GetNodeID 

func (x *AnalyzeTask) GetNodeID() int64

func (*AnalyzeTask) GetPartitionID 

func (x *AnalyzeTask) GetPartitionID() int64

func (*AnalyzeTask) GetSegmentIDs 

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

func (*AnalyzeTask) GetState 

func (x *AnalyzeTask) GetState() JobState

func (*AnalyzeTask) GetTaskID 

func (x *AnalyzeTask) GetTaskID() int64

func (*AnalyzeTask) GetVersion 

func (x *AnalyzeTask) GetVersion() int64

func (*AnalyzeTask) ProtoMessage 

func (*AnalyzeTask) ProtoMessage()

func (*AnalyzeTask) ProtoReflect 

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

func (*AnalyzeTask) Reset 

func (x *AnalyzeTask) Reset()

func (*AnalyzeTask) String 

func (x *AnalyzeTask) String() string

type CreateIndexRequest 

type CreateIndexRequest struct {
	CollectionID                     int64                    `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	FieldID                          int64                    `protobuf:"varint,2,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	IndexName                        string                   `protobuf:"bytes,3,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	TypeParams                       []*commonpb.KeyValuePair `protobuf:"bytes,4,rep,name=type_params,json=typeParams,proto3" json:"type_params,omitempty"`
	IndexParams                      []*commonpb.KeyValuePair `protobuf:"bytes,5,rep,name=index_params,json=indexParams,proto3" json:"index_params,omitempty"`
	Timestamp                        uint64                   `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	IsAutoIndex                      bool                     `protobuf:"varint,7,opt,name=is_auto_index,json=isAutoIndex,proto3" json:"is_auto_index,omitempty"`
	UserIndexParams                  []*commonpb.KeyValuePair `protobuf:"bytes,8,rep,name=user_index_params,json=userIndexParams,proto3" json:"user_index_params,omitempty"`
	UserAutoindexMetricTypeSpecified bool                     `` /* 164-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateIndexRequest) Descriptor deprecated 

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

Deprecated: Use CreateIndexRequest.ProtoReflect.Descriptor instead.

func (*CreateIndexRequest) GetCollectionID 

func (x *CreateIndexRequest) GetCollectionID() int64

func (*CreateIndexRequest) GetFieldID 

func (x *CreateIndexRequest) GetFieldID() int64

func (*CreateIndexRequest) GetIndexName 

func (x *CreateIndexRequest) GetIndexName() string

func (*CreateIndexRequest) GetIndexParams 

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

func (*CreateIndexRequest) GetIsAutoIndex 

func (x *CreateIndexRequest) GetIsAutoIndex() bool

func (*CreateIndexRequest) GetTimestamp 

func (x *CreateIndexRequest) GetTimestamp() uint64

func (*CreateIndexRequest) GetTypeParams 

func (x *CreateIndexRequest) GetTypeParams() []*commonpb.KeyValuePair

func (*CreateIndexRequest) GetUserAutoindexMetricTypeSpecified 

func (x *CreateIndexRequest) GetUserAutoindexMetricTypeSpecified() bool

func (*CreateIndexRequest) GetUserIndexParams 

func (x *CreateIndexRequest) GetUserIndexParams() []*commonpb.KeyValuePair

func (*CreateIndexRequest) ProtoMessage 

func (*CreateIndexRequest) ProtoMessage()

func (*CreateIndexRequest) ProtoReflect 

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

func (*CreateIndexRequest) Reset 

func (x *CreateIndexRequest) Reset()

func (*CreateIndexRequest) String 

func (x *CreateIndexRequest) String() string

type DescribeIndexRequest 

type DescribeIndexRequest struct {
	CollectionID int64  `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	IndexName    string `protobuf:"bytes,2,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	Timestamp    uint64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeIndexRequest) Descriptor deprecated 

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

Deprecated: Use DescribeIndexRequest.ProtoReflect.Descriptor instead.

func (*DescribeIndexRequest) GetCollectionID 

func (x *DescribeIndexRequest) GetCollectionID() int64

func (*DescribeIndexRequest) GetIndexName 

func (x *DescribeIndexRequest) GetIndexName() string

func (*DescribeIndexRequest) GetTimestamp 

func (x *DescribeIndexRequest) GetTimestamp() uint64

func (*DescribeIndexRequest) ProtoMessage 

func (*DescribeIndexRequest) ProtoMessage()

func (*DescribeIndexRequest) ProtoReflect 

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

func (*DescribeIndexRequest) Reset 

func (x *DescribeIndexRequest) Reset()

func (*DescribeIndexRequest) String 

func (x *DescribeIndexRequest) String() string

type DescribeIndexResponse 

type DescribeIndexResponse struct {
	Status     *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IndexInfos []*IndexInfo     `protobuf:"bytes,2,rep,name=index_infos,json=indexInfos,proto3" json:"index_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeIndexResponse) Descriptor deprecated 

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

Deprecated: Use DescribeIndexResponse.ProtoReflect.Descriptor instead.

func (*DescribeIndexResponse) GetIndexInfos 

func (x *DescribeIndexResponse) GetIndexInfos() []*IndexInfo

func (*DescribeIndexResponse) GetStatus 

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

func (*DescribeIndexResponse) ProtoMessage 

func (*DescribeIndexResponse) ProtoMessage()

func (*DescribeIndexResponse) ProtoReflect 

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

func (*DescribeIndexResponse) Reset 

func (x *DescribeIndexResponse) Reset()

func (*DescribeIndexResponse) String 

func (x *DescribeIndexResponse) String() string

type DropIndexRequest 

type DropIndexRequest struct {
	CollectionID int64   `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionIDs []int64 `protobuf:"varint,2,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	IndexName    string  `protobuf:"bytes,3,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	DropAll      bool    `protobuf:"varint,4,opt,name=drop_all,json=dropAll,proto3" json:"drop_all,omitempty"`
	// contains filtered or unexported fields
}

func (*DropIndexRequest) Descriptor deprecated 

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

Deprecated: Use DropIndexRequest.ProtoReflect.Descriptor instead.

func (*DropIndexRequest) GetCollectionID 

func (x *DropIndexRequest) GetCollectionID() int64

func (*DropIndexRequest) GetDropAll 

func (x *DropIndexRequest) GetDropAll() bool

func (*DropIndexRequest) GetIndexName 

func (x *DropIndexRequest) GetIndexName() string

func (*DropIndexRequest) GetPartitionIDs 

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

func (*DropIndexRequest) ProtoMessage 

func (*DropIndexRequest) ProtoMessage()

func (*DropIndexRequest) ProtoReflect 

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

func (*DropIndexRequest) Reset 

func (x *DropIndexRequest) Reset()

func (*DropIndexRequest) String 

func (x *DropIndexRequest) String() string

type FieldIndex 

type FieldIndex struct {
	IndexInfo  *IndexInfo `protobuf:"bytes,1,opt,name=index_info,json=indexInfo,proto3" json:"index_info,omitempty"`
	Deleted    bool       `protobuf:"varint,2,opt,name=deleted,proto3" json:"deleted,omitempty"`
	CreateTime uint64     `protobuf:"varint,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldIndex) Descriptor deprecated 

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

Deprecated: Use FieldIndex.ProtoReflect.Descriptor instead.

func (*FieldIndex) GetCreateTime 

func (x *FieldIndex) GetCreateTime() uint64

func (*FieldIndex) GetDeleted 

func (x *FieldIndex) GetDeleted() bool

func (*FieldIndex) GetIndexInfo 

func (x *FieldIndex) GetIndexInfo() *IndexInfo

func (*FieldIndex) ProtoMessage 

func (*FieldIndex) ProtoMessage()

func (*FieldIndex) ProtoReflect 

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

func (*FieldIndex) Reset 

func (x *FieldIndex) Reset()

func (*FieldIndex) String 

func (x *FieldIndex) String() string

type FieldLogPath 

type FieldLogPath struct {
	FieldID   int64    `protobuf:"varint,1,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	FilePaths []string `protobuf:"bytes,2,rep,name=file_paths,json=filePaths,proto3" json:"file_paths,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldLogPath) Descriptor deprecated 

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

Deprecated: Use FieldLogPath.ProtoReflect.Descriptor instead.

func (*FieldLogPath) GetFieldID 

func (x *FieldLogPath) GetFieldID() int64

func (*FieldLogPath) GetFilePaths 

func (x *FieldLogPath) GetFilePaths() []string

func (*FieldLogPath) ProtoMessage 

func (*FieldLogPath) ProtoMessage()

func (*FieldLogPath) ProtoReflect 

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

func (*FieldLogPath) Reset 

func (x *FieldLogPath) Reset()

func (*FieldLogPath) String 

func (x *FieldLogPath) String() string

type GetIndexBuildProgressRequest 

type GetIndexBuildProgressRequest struct {
	CollectionID int64  `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	IndexName    string `protobuf:"bytes,2,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIndexBuildProgressRequest) Descriptor deprecated 

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

Deprecated: Use GetIndexBuildProgressRequest.ProtoReflect.Descriptor instead.

func (*GetIndexBuildProgressRequest) GetCollectionID 

func (x *GetIndexBuildProgressRequest) GetCollectionID() int64

func (*GetIndexBuildProgressRequest) GetIndexName 

func (x *GetIndexBuildProgressRequest) GetIndexName() string

func (*GetIndexBuildProgressRequest) ProtoMessage 

func (*GetIndexBuildProgressRequest) ProtoMessage()

func (*GetIndexBuildProgressRequest) ProtoReflect 

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

func (*GetIndexBuildProgressRequest) Reset 

func (x *GetIndexBuildProgressRequest) Reset()

func (*GetIndexBuildProgressRequest) String 

func (x *GetIndexBuildProgressRequest) String() string

type GetIndexBuildProgressResponse 

type GetIndexBuildProgressResponse struct {
	Status           *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IndexedRows      int64            `protobuf:"varint,2,opt,name=indexed_rows,json=indexedRows,proto3" json:"indexed_rows,omitempty"`
	TotalRows        int64            `protobuf:"varint,3,opt,name=total_rows,json=totalRows,proto3" json:"total_rows,omitempty"`
	PendingIndexRows int64            `protobuf:"varint,4,opt,name=pending_index_rows,json=pendingIndexRows,proto3" json:"pending_index_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIndexBuildProgressResponse) Descriptor deprecated 

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

Deprecated: Use GetIndexBuildProgressResponse.ProtoReflect.Descriptor instead.

func (*GetIndexBuildProgressResponse) GetIndexedRows 

func (x *GetIndexBuildProgressResponse) GetIndexedRows() int64

func (*GetIndexBuildProgressResponse) GetPendingIndexRows 

func (x *GetIndexBuildProgressResponse) GetPendingIndexRows() int64

func (*GetIndexBuildProgressResponse) GetStatus 

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

func (*GetIndexBuildProgressResponse) GetTotalRows 

func (x *GetIndexBuildProgressResponse) GetTotalRows() int64

func (*GetIndexBuildProgressResponse) ProtoMessage 

func (*GetIndexBuildProgressResponse) ProtoMessage()

func (*GetIndexBuildProgressResponse) ProtoReflect 

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

func (*GetIndexBuildProgressResponse) Reset 

func (x *GetIndexBuildProgressResponse) Reset()

func (*GetIndexBuildProgressResponse) String 

func (x *GetIndexBuildProgressResponse) String() string

type GetIndexInfoRequest 

type GetIndexInfoRequest struct {
	CollectionID int64   `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	SegmentIDs   []int64 `protobuf:"varint,2,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	IndexName    string  `protobuf:"bytes,3,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIndexInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetIndexInfoRequest.ProtoReflect.Descriptor instead.

func (*GetIndexInfoRequest) GetCollectionID 

func (x *GetIndexInfoRequest) GetCollectionID() int64

func (*GetIndexInfoRequest) GetIndexName 

func (x *GetIndexInfoRequest) GetIndexName() string

func (*GetIndexInfoRequest) GetSegmentIDs 

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

func (*GetIndexInfoRequest) ProtoMessage 

func (*GetIndexInfoRequest) ProtoMessage()

func (*GetIndexInfoRequest) ProtoReflect 

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

func (*GetIndexInfoRequest) Reset 

func (x *GetIndexInfoRequest) Reset()

func (*GetIndexInfoRequest) String 

func (x *GetIndexInfoRequest) String() string

type GetIndexInfoResponse 

type GetIndexInfoResponse struct {
	Status      *commonpb.Status       `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	SegmentInfo map[int64]*SegmentInfo `` /* 183-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetIndexInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetIndexInfoResponse.ProtoReflect.Descriptor instead.

func (*GetIndexInfoResponse) GetSegmentInfo 

func (x *GetIndexInfoResponse) GetSegmentInfo() map[int64]*SegmentInfo

func (*GetIndexInfoResponse) GetStatus 

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

func (*GetIndexInfoResponse) ProtoMessage 

func (*GetIndexInfoResponse) ProtoMessage()

func (*GetIndexInfoResponse) ProtoReflect 

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

func (*GetIndexInfoResponse) Reset 

func (x *GetIndexInfoResponse) Reset()

func (*GetIndexInfoResponse) String 

func (x *GetIndexInfoResponse) String() string

type GetIndexStateRequest 

type GetIndexStateRequest struct {
	CollectionID int64  `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	IndexName    string `protobuf:"bytes,2,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIndexStateRequest) Descriptor deprecated 

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

Deprecated: Use GetIndexStateRequest.ProtoReflect.Descriptor instead.

func (*GetIndexStateRequest) GetCollectionID 

func (x *GetIndexStateRequest) GetCollectionID() int64

func (*GetIndexStateRequest) GetIndexName 

func (x *GetIndexStateRequest) GetIndexName() string

func (*GetIndexStateRequest) ProtoMessage 

func (*GetIndexStateRequest) ProtoMessage()

func (*GetIndexStateRequest) ProtoReflect 

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

func (*GetIndexStateRequest) Reset 

func (x *GetIndexStateRequest) Reset()

func (*GetIndexStateRequest) String 

func (x *GetIndexStateRequest) String() string

type GetIndexStateResponse 

type GetIndexStateResponse struct {
	Status     *commonpb.Status    `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	State      commonpb.IndexState `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.common.IndexState" json:"state,omitempty"`
	FailReason string              `protobuf:"bytes,3,opt,name=fail_reason,json=failReason,proto3" json:"fail_reason,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIndexStateResponse) Descriptor deprecated 

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

Deprecated: Use GetIndexStateResponse.ProtoReflect.Descriptor instead.

func (*GetIndexStateResponse) GetFailReason 

func (x *GetIndexStateResponse) GetFailReason() string

func (*GetIndexStateResponse) GetState 

func (x *GetIndexStateResponse) GetState() commonpb.IndexState

func (*GetIndexStateResponse) GetStatus 

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

func (*GetIndexStateResponse) ProtoMessage 

func (*GetIndexStateResponse) ProtoMessage()

func (*GetIndexStateResponse) ProtoReflect 

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

func (*GetIndexStateResponse) Reset 

func (x *GetIndexStateResponse) Reset()

func (*GetIndexStateResponse) String 

func (x *GetIndexStateResponse) String() string

type GetIndexStatisticsRequest 

type GetIndexStatisticsRequest struct {
	CollectionID int64  `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	IndexName    string `protobuf:"bytes,2,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIndexStatisticsRequest) Descriptor deprecated 

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

Deprecated: Use GetIndexStatisticsRequest.ProtoReflect.Descriptor instead.

func (*GetIndexStatisticsRequest) GetCollectionID 

func (x *GetIndexStatisticsRequest) GetCollectionID() int64

func (*GetIndexStatisticsRequest) GetIndexName 

func (x *GetIndexStatisticsRequest) GetIndexName() string

func (*GetIndexStatisticsRequest) ProtoMessage 

func (*GetIndexStatisticsRequest) ProtoMessage()

func (*GetIndexStatisticsRequest) ProtoReflect 

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

func (*GetIndexStatisticsRequest) Reset 

func (x *GetIndexStatisticsRequest) Reset()

func (*GetIndexStatisticsRequest) String 

func (x *GetIndexStatisticsRequest) String() string

type GetIndexStatisticsResponse 

type GetIndexStatisticsResponse struct {
	Status     *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IndexInfos []*IndexInfo     `protobuf:"bytes,2,rep,name=index_infos,json=indexInfos,proto3" json:"index_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIndexStatisticsResponse) Descriptor deprecated 

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

Deprecated: Use GetIndexStatisticsResponse.ProtoReflect.Descriptor instead.

func (*GetIndexStatisticsResponse) GetIndexInfos 

func (x *GetIndexStatisticsResponse) GetIndexInfos() []*IndexInfo

func (*GetIndexStatisticsResponse) GetStatus 

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

func (*GetIndexStatisticsResponse) ProtoMessage 

func (*GetIndexStatisticsResponse) ProtoMessage()

func (*GetIndexStatisticsResponse) ProtoReflect 

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

func (*GetIndexStatisticsResponse) Reset 

func (x *GetIndexStatisticsResponse) Reset()

func (*GetIndexStatisticsResponse) String 

func (x *GetIndexStatisticsResponse) String() string

type GetSegmentIndexStateRequest 

type GetSegmentIndexStateRequest struct {
	CollectionID int64   `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	IndexName    string  `protobuf:"bytes,2,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	SegmentIDs   []int64 `protobuf:"varint,3,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSegmentIndexStateRequest) Descriptor deprecated 

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

Deprecated: Use GetSegmentIndexStateRequest.ProtoReflect.Descriptor instead.

func (*GetSegmentIndexStateRequest) GetCollectionID 

func (x *GetSegmentIndexStateRequest) GetCollectionID() int64

func (*GetSegmentIndexStateRequest) GetIndexName 

func (x *GetSegmentIndexStateRequest) GetIndexName() string

func (*GetSegmentIndexStateRequest) GetSegmentIDs 

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

func (*GetSegmentIndexStateRequest) ProtoMessage 

func (*GetSegmentIndexStateRequest) ProtoMessage()

func (*GetSegmentIndexStateRequest) ProtoReflect 

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

func (*GetSegmentIndexStateRequest) Reset 

func (x *GetSegmentIndexStateRequest) Reset()

func (*GetSegmentIndexStateRequest) String 

func (x *GetSegmentIndexStateRequest) String() string

type GetSegmentIndexStateResponse 

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

func (*GetSegmentIndexStateResponse) Descriptor deprecated 

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

Deprecated: Use GetSegmentIndexStateResponse.ProtoReflect.Descriptor instead.

func (*GetSegmentIndexStateResponse) GetStates 

func (x *GetSegmentIndexStateResponse) GetStates() []*SegmentIndexState

func (*GetSegmentIndexStateResponse) GetStatus 

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

func (*GetSegmentIndexStateResponse) ProtoMessage 

func (*GetSegmentIndexStateResponse) ProtoMessage()

func (*GetSegmentIndexStateResponse) ProtoReflect 

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

func (*GetSegmentIndexStateResponse) Reset 

func (x *GetSegmentIndexStateResponse) Reset()

func (*GetSegmentIndexStateResponse) String 

func (x *GetSegmentIndexStateResponse) String() string

type IndexCoordClient 

type IndexCoordClient 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)
	CreateIndex(ctx context.Context, in *CreateIndexRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	AlterIndex(ctx context.Context, in *AlterIndexRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	// Deprecated: use DescribeIndex instead
	GetIndexState(ctx context.Context, in *GetIndexStateRequest, opts ...grpc.CallOption) (*GetIndexStateResponse, error)
	GetSegmentIndexState(ctx context.Context, in *GetSegmentIndexStateRequest, opts ...grpc.CallOption) (*GetSegmentIndexStateResponse, error)
	GetIndexInfos(ctx context.Context, in *GetIndexInfoRequest, opts ...grpc.CallOption) (*GetIndexInfoResponse, error)
	DropIndex(ctx context.Context, in *DropIndexRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DescribeIndex(ctx context.Context, in *DescribeIndexRequest, opts ...grpc.CallOption) (*DescribeIndexResponse, error)
	GetIndexStatistics(ctx context.Context, in *GetIndexStatisticsRequest, opts ...grpc.CallOption) (*GetIndexStatisticsResponse, error)
	// Deprecated: use DescribeIndex instead
	GetIndexBuildProgress(ctx context.Context, in *GetIndexBuildProgressRequest, opts ...grpc.CallOption) (*GetIndexBuildProgressResponse, 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)
	CheckHealth(ctx context.Context, in *milvuspb.CheckHealthRequest, opts ...grpc.CallOption) (*milvuspb.CheckHealthResponse, error)
}

IndexCoordClient is the client API for IndexCoord 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 NewIndexCoordClient 

func NewIndexCoordClient(cc grpc.ClientConnInterface) IndexCoordClient

type IndexCoordServer 

type IndexCoordServer interface {
	GetComponentStates(context.Context, *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)
	GetStatisticsChannel(context.Context, *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)
	CreateIndex(context.Context, *CreateIndexRequest) (*commonpb.Status, error)
	AlterIndex(context.Context, *AlterIndexRequest) (*commonpb.Status, error)
	// Deprecated: use DescribeIndex instead
	GetIndexState(context.Context, *GetIndexStateRequest) (*GetIndexStateResponse, error)
	GetSegmentIndexState(context.Context, *GetSegmentIndexStateRequest) (*GetSegmentIndexStateResponse, error)
	GetIndexInfos(context.Context, *GetIndexInfoRequest) (*GetIndexInfoResponse, error)
	DropIndex(context.Context, *DropIndexRequest) (*commonpb.Status, error)
	DescribeIndex(context.Context, *DescribeIndexRequest) (*DescribeIndexResponse, error)
	GetIndexStatistics(context.Context, *GetIndexStatisticsRequest) (*GetIndexStatisticsResponse, error)
	// Deprecated: use DescribeIndex instead
	GetIndexBuildProgress(context.Context, *GetIndexBuildProgressRequest) (*GetIndexBuildProgressResponse, 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)
	CheckHealth(context.Context, *milvuspb.CheckHealthRequest) (*milvuspb.CheckHealthResponse, error)
}

IndexCoordServer is the server API for IndexCoord service. All implementations should embed UnimplementedIndexCoordServer for forward compatibility

type IndexFilePathInfo 

type IndexFilePathInfo struct {
	SegmentID           int64                    `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	FieldID             int64                    `protobuf:"varint,2,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	IndexID             int64                    `protobuf:"varint,3,opt,name=indexID,proto3" json:"indexID,omitempty"`
	BuildID             int64                    `protobuf:"varint,4,opt,name=buildID,proto3" json:"buildID,omitempty"`
	IndexName           string                   `protobuf:"bytes,5,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	IndexParams         []*commonpb.KeyValuePair `protobuf:"bytes,6,rep,name=index_params,json=indexParams,proto3" json:"index_params,omitempty"`
	IndexFilePaths      []string                 `protobuf:"bytes,7,rep,name=index_file_paths,json=indexFilePaths,proto3" json:"index_file_paths,omitempty"`
	SerializedSize      uint64                   `protobuf:"varint,8,opt,name=serialized_size,json=serializedSize,proto3" json:"serialized_size,omitempty"`
	IndexVersion        int64                    `protobuf:"varint,9,opt,name=index_version,json=indexVersion,proto3" json:"index_version,omitempty"`
	NumRows             int64                    `protobuf:"varint,10,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	CurrentIndexVersion int32                    `protobuf:"varint,11,opt,name=current_index_version,json=currentIndexVersion,proto3" json:"current_index_version,omitempty"`
	MemSize             uint64                   `protobuf:"varint,12,opt,name=mem_size,json=memSize,proto3" json:"mem_size,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexFilePathInfo) Descriptor deprecated 

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

Deprecated: Use IndexFilePathInfo.ProtoReflect.Descriptor instead.

func (*IndexFilePathInfo) GetBuildID 

func (x *IndexFilePathInfo) GetBuildID() int64

func (*IndexFilePathInfo) GetCurrentIndexVersion 

func (x *IndexFilePathInfo) GetCurrentIndexVersion() int32

func (*IndexFilePathInfo) GetFieldID 

func (x *IndexFilePathInfo) GetFieldID() int64

func (*IndexFilePathInfo) GetIndexFilePaths 

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

func (*IndexFilePathInfo) GetIndexID 

func (x *IndexFilePathInfo) GetIndexID() int64

func (*IndexFilePathInfo) GetIndexName 

func (x *IndexFilePathInfo) GetIndexName() string

func (*IndexFilePathInfo) GetIndexParams 

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

func (*IndexFilePathInfo) GetIndexVersion 

func (x *IndexFilePathInfo) GetIndexVersion() int64

func (*IndexFilePathInfo) GetMemSize 

func (x *IndexFilePathInfo) GetMemSize() uint64

func (*IndexFilePathInfo) GetNumRows 

func (x *IndexFilePathInfo) GetNumRows() int64

func (*IndexFilePathInfo) GetSegmentID 

func (x *IndexFilePathInfo) GetSegmentID() int64

func (*IndexFilePathInfo) GetSerializedSize 

func (x *IndexFilePathInfo) GetSerializedSize() uint64

func (*IndexFilePathInfo) ProtoMessage 

func (*IndexFilePathInfo) ProtoMessage()

func (*IndexFilePathInfo) ProtoReflect 

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

func (*IndexFilePathInfo) Reset 

func (x *IndexFilePathInfo) Reset()

func (*IndexFilePathInfo) String 

func (x *IndexFilePathInfo) String() string

type IndexInfo 

type IndexInfo struct {
	CollectionID int64                    `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	FieldID      int64                    `protobuf:"varint,2,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	IndexName    string                   `protobuf:"bytes,3,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	IndexID      int64                    `protobuf:"varint,4,opt,name=indexID,proto3" json:"indexID,omitempty"`
	TypeParams   []*commonpb.KeyValuePair `protobuf:"bytes,5,rep,name=type_params,json=typeParams,proto3" json:"type_params,omitempty"`
	IndexParams  []*commonpb.KeyValuePair `protobuf:"bytes,6,rep,name=index_params,json=indexParams,proto3" json:"index_params,omitempty"`
	// index build progress
	// The real-time statistics may not be expected due to the existence of the compaction mechanism.
	IndexedRows int64 `protobuf:"varint,7,opt,name=indexed_rows,json=indexedRows,proto3" json:"indexed_rows,omitempty"`
	TotalRows   int64 `protobuf:"varint,8,opt,name=total_rows,json=totalRows,proto3" json:"total_rows,omitempty"`
	// index state
	State                commonpb.IndexState      `protobuf:"varint,9,opt,name=state,proto3,enum=milvus.proto.common.IndexState" json:"state,omitempty"`
	IndexStateFailReason string                   `` /* 126-byte string literal not displayed */
	IsAutoIndex          bool                     `protobuf:"varint,11,opt,name=is_auto_index,json=isAutoIndex,proto3" json:"is_auto_index,omitempty"`
	UserIndexParams      []*commonpb.KeyValuePair `protobuf:"bytes,12,rep,name=user_index_params,json=userIndexParams,proto3" json:"user_index_params,omitempty"`
	PendingIndexRows     int64                    `protobuf:"varint,13,opt,name=pending_index_rows,json=pendingIndexRows,proto3" json:"pending_index_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexInfo) Descriptor deprecated 

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

Deprecated: Use IndexInfo.ProtoReflect.Descriptor instead.

func (*IndexInfo) GetCollectionID 

func (x *IndexInfo) GetCollectionID() int64

func (*IndexInfo) GetFieldID 

func (x *IndexInfo) GetFieldID() int64

func (*IndexInfo) GetIndexID 

func (x *IndexInfo) GetIndexID() int64

func (*IndexInfo) GetIndexName 

func (x *IndexInfo) GetIndexName() string

func (*IndexInfo) GetIndexParams 

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

func (*IndexInfo) GetIndexStateFailReason 

func (x *IndexInfo) GetIndexStateFailReason() string

func (*IndexInfo) GetIndexedRows 

func (x *IndexInfo) GetIndexedRows() int64

func (*IndexInfo) GetIsAutoIndex 

func (x *IndexInfo) GetIsAutoIndex() bool

func (*IndexInfo) GetPendingIndexRows 

func (x *IndexInfo) GetPendingIndexRows() int64

func (*IndexInfo) GetState 

func (x *IndexInfo) GetState() commonpb.IndexState

func (*IndexInfo) GetTotalRows 

func (x *IndexInfo) GetTotalRows() int64

func (*IndexInfo) GetTypeParams 

func (x *IndexInfo) GetTypeParams() []*commonpb.KeyValuePair

func (*IndexInfo) GetUserIndexParams 

func (x *IndexInfo) GetUserIndexParams() []*commonpb.KeyValuePair

func (*IndexInfo) ProtoMessage 

func (*IndexInfo) ProtoMessage()

func (*IndexInfo) ProtoReflect 

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

func (*IndexInfo) Reset 

func (x *IndexInfo) Reset()

func (*IndexInfo) String 

func (x *IndexInfo) String() string

type JobInfo 

type JobInfo struct {
	NumRows     int64                    `protobuf:"varint,1,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	Dim         int64                    `protobuf:"varint,2,opt,name=dim,proto3" json:"dim,omitempty"`
	StartTime   int64                    `protobuf:"varint,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime     int64                    `protobuf:"varint,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	IndexParams []*commonpb.KeyValuePair `protobuf:"bytes,5,rep,name=index_params,json=indexParams,proto3" json:"index_params,omitempty"`
	PodID       int64                    `protobuf:"varint,6,opt,name=podID,proto3" json:"podID,omitempty"`
	// contains filtered or unexported fields
}

func (*JobInfo) Descriptor deprecated 

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

Deprecated: Use JobInfo.ProtoReflect.Descriptor instead.

func (*JobInfo) GetDim 

func (x *JobInfo) GetDim() int64

func (*JobInfo) GetEndTime 

func (x *JobInfo) GetEndTime() int64

func (*JobInfo) GetIndexParams 

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

func (*JobInfo) GetNumRows 

func (x *JobInfo) GetNumRows() int64

func (*JobInfo) GetPodID 

func (x *JobInfo) GetPodID() int64

func (*JobInfo) GetStartTime 

func (x *JobInfo) GetStartTime() int64

func (*JobInfo) ProtoMessage 

func (*JobInfo) ProtoMessage()

func (*JobInfo) ProtoReflect 

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

func (*JobInfo) Reset 

func (x *JobInfo) Reset()

func (*JobInfo) String 

func (x *JobInfo) String() string

type JobState 

type JobState int32
const (
	JobState_JobStateNone       JobState = 0
	JobState_JobStateInit       JobState = 1
	JobState_JobStateInProgress JobState = 2
	JobState_JobStateFinished   JobState = 3
	JobState_JobStateFailed     JobState = 4
	JobState_JobStateRetry      JobState = 5
)

func (JobState) Descriptor 

func (JobState) Descriptor() protoreflect.EnumDescriptor

func (JobState) Enum 

func (x JobState) Enum() *JobState

func (JobState) EnumDescriptor deprecated 

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

Deprecated: Use JobState.Descriptor instead.

func (JobState) Number 

func (x JobState) Number() protoreflect.EnumNumber

func (JobState) String 

func (x JobState) String() string

func (JobState) Type 

func (JobState) Type() protoreflect.EnumType

type JobType 

type JobType int32
const (
	JobType_JobTypeNone       JobType = 0
	JobType_JobTypeIndexJob   JobType = 1
	JobType_JobTypeAnalyzeJob JobType = 2
	JobType_JobTypeStatsJob   JobType = 3
)

func (JobType) Descriptor 

func (JobType) Descriptor() protoreflect.EnumDescriptor

func (JobType) Enum 

func (x JobType) Enum() *JobType

func (JobType) EnumDescriptor deprecated 

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

Deprecated: Use JobType.Descriptor instead.

func (JobType) Number 

func (x JobType) Number() protoreflect.EnumNumber

func (JobType) String 

func (x JobType) String() string

func (JobType) Type 

func (JobType) Type() protoreflect.EnumType

type ListIndexesRequest 

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

func (*ListIndexesRequest) Descriptor deprecated 

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

Deprecated: Use ListIndexesRequest.ProtoReflect.Descriptor instead.

func (*ListIndexesRequest) GetCollectionID 

func (x *ListIndexesRequest) GetCollectionID() int64

func (*ListIndexesRequest) ProtoMessage 

func (*ListIndexesRequest) ProtoMessage()

func (*ListIndexesRequest) ProtoReflect 

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

func (*ListIndexesRequest) Reset 

func (x *ListIndexesRequest) Reset()

func (*ListIndexesRequest) String 

func (x *ListIndexesRequest) String() string

type ListIndexesResponse 

type ListIndexesResponse struct {
	Status     *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IndexInfos []*IndexInfo     `protobuf:"bytes,2,rep,name=index_infos,json=indexInfos,proto3" json:"index_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*ListIndexesResponse) Descriptor deprecated 

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

Deprecated: Use ListIndexesResponse.ProtoReflect.Descriptor instead.

func (*ListIndexesResponse) GetIndexInfos 

func (x *ListIndexesResponse) GetIndexInfos() []*IndexInfo

func (*ListIndexesResponse) GetStatus 

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

func (*ListIndexesResponse) ProtoMessage 

func (*ListIndexesResponse) ProtoMessage()

func (*ListIndexesResponse) ProtoReflect 

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

func (*ListIndexesResponse) Reset 

func (x *ListIndexesResponse) Reset()

func (*ListIndexesResponse) String 

func (x *ListIndexesResponse) String() string

type OptionalFieldInfo 

type OptionalFieldInfo struct {
	FieldID   int64    `protobuf:"varint,1,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	FieldName string   `protobuf:"bytes,2,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	FieldType int32    `protobuf:"varint,3,opt,name=field_type,json=fieldType,proto3" json:"field_type,omitempty"`
	DataPaths []string `protobuf:"bytes,4,rep,name=data_paths,json=dataPaths,proto3" json:"data_paths,omitempty"`
	DataIds   []int64  `protobuf:"varint,5,rep,packed,name=data_ids,json=dataIds,proto3" json:"data_ids,omitempty"`
	// contains filtered or unexported fields
}

Synchronously modify OptionalFieldInfo in index_cgo_msg.proto file

func (*OptionalFieldInfo) Descriptor deprecated 

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

Deprecated: Use OptionalFieldInfo.ProtoReflect.Descriptor instead.

func (*OptionalFieldInfo) GetDataIds 

func (x *OptionalFieldInfo) GetDataIds() []int64

func (*OptionalFieldInfo) GetDataPaths 

func (x *OptionalFieldInfo) GetDataPaths() []string

func (*OptionalFieldInfo) GetFieldID 

func (x *OptionalFieldInfo) GetFieldID() int64

func (*OptionalFieldInfo) GetFieldName 

func (x *OptionalFieldInfo) GetFieldName() string

func (*OptionalFieldInfo) GetFieldType 

func (x *OptionalFieldInfo) GetFieldType() int32

func (*OptionalFieldInfo) ProtoMessage 

func (*OptionalFieldInfo) ProtoMessage()

func (*OptionalFieldInfo) ProtoReflect 

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

func (*OptionalFieldInfo) Reset 

func (x *OptionalFieldInfo) Reset()

func (*OptionalFieldInfo) String 

func (x *OptionalFieldInfo) String() string

type RegisterNodeRequest 

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

func (*RegisterNodeRequest) Descriptor deprecated 

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

Deprecated: Use RegisterNodeRequest.ProtoReflect.Descriptor instead.

func (*RegisterNodeRequest) GetAddress 

func (x *RegisterNodeRequest) GetAddress() *commonpb.Address

func (*RegisterNodeRequest) GetBase 

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

func (*RegisterNodeRequest) GetNodeID 

func (x *RegisterNodeRequest) GetNodeID() int64

func (*RegisterNodeRequest) ProtoMessage 

func (*RegisterNodeRequest) ProtoMessage()

func (*RegisterNodeRequest) ProtoReflect 

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

func (*RegisterNodeRequest) Reset 

func (x *RegisterNodeRequest) Reset()

func (*RegisterNodeRequest) String 

func (x *RegisterNodeRequest) String() string

type RegisterNodeResponse 

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

func (*RegisterNodeResponse) Descriptor deprecated 

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

Deprecated: Use RegisterNodeResponse.ProtoReflect.Descriptor instead.

func (*RegisterNodeResponse) GetInitParams 

func (x *RegisterNodeResponse) GetInitParams() *internalpb.InitParams

func (*RegisterNodeResponse) GetStatus 

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

func (*RegisterNodeResponse) ProtoMessage 

func (*RegisterNodeResponse) ProtoMessage()

func (*RegisterNodeResponse) ProtoReflect 

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

func (*RegisterNodeResponse) Reset 

func (x *RegisterNodeResponse) Reset()

func (*RegisterNodeResponse) String 

func (x *RegisterNodeResponse) String() string

type SegmentIndex 

type SegmentIndex 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"`
	SegmentID                 int64               `protobuf:"varint,3,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	NumRows                   int64               `protobuf:"varint,4,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	IndexID                   int64               `protobuf:"varint,5,opt,name=indexID,proto3" json:"indexID,omitempty"`
	BuildID                   int64               `protobuf:"varint,6,opt,name=buildID,proto3" json:"buildID,omitempty"`
	NodeID                    int64               `protobuf:"varint,7,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	IndexVersion              int64               `protobuf:"varint,8,opt,name=index_version,json=indexVersion,proto3" json:"index_version,omitempty"`
	State                     commonpb.IndexState `protobuf:"varint,9,opt,name=state,proto3,enum=milvus.proto.common.IndexState" json:"state,omitempty"`
	FailReason                string              `protobuf:"bytes,10,opt,name=fail_reason,json=failReason,proto3" json:"fail_reason,omitempty"`
	IndexFileKeys             []string            `protobuf:"bytes,11,rep,name=index_file_keys,json=indexFileKeys,proto3" json:"index_file_keys,omitempty"`
	Deleted                   bool                `protobuf:"varint,12,opt,name=deleted,proto3" json:"deleted,omitempty"`
	CreateTime                uint64              `protobuf:"varint,13,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	SerializeSize             uint64              `protobuf:"varint,14,opt,name=serialize_size,json=serializeSize,proto3" json:"serialize_size,omitempty"` // the total size of index file at oos. (may be compress)
	WriteHandoff              bool                `protobuf:"varint,15,opt,name=write_handoff,json=writeHandoff,proto3" json:"write_handoff,omitempty"`
	CurrentIndexVersion       int32               `protobuf:"varint,16,opt,name=current_index_version,json=currentIndexVersion,proto3" json:"current_index_version,omitempty"`
	IndexStoreVersion         int64               `protobuf:"varint,17,opt,name=index_store_version,json=indexStoreVersion,proto3" json:"index_store_version,omitempty"`
	FinishedTime              uint64              `protobuf:"varint,18,opt,name=finished_time,json=finishedTime,proto3" json:"finished_time,omitempty"`
	MemSize                   uint64              `protobuf:"varint,19,opt,name=mem_size,json=memSize,proto3" json:"mem_size,omitempty"` // the total size of index file at local (disk or memory) before loading by knowhere. (not compress)
	CurrentScalarIndexVersion int32               ``                                                                                     /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SegmentIndex) Descriptor deprecated 

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

Deprecated: Use SegmentIndex.ProtoReflect.Descriptor instead.

func (*SegmentIndex) GetBuildID 

func (x *SegmentIndex) GetBuildID() int64

func (*SegmentIndex) GetCollectionID 

func (x *SegmentIndex) GetCollectionID() int64

func (*SegmentIndex) GetCreateTime 

func (x *SegmentIndex) GetCreateTime() uint64

func (*SegmentIndex) GetCurrentIndexVersion 

func (x *SegmentIndex) GetCurrentIndexVersion() int32

func (*SegmentIndex) GetCurrentScalarIndexVersion 

func (x *SegmentIndex) GetCurrentScalarIndexVersion() int32

func (*SegmentIndex) GetDeleted 

func (x *SegmentIndex) GetDeleted() bool

func (*SegmentIndex) GetFailReason 

func (x *SegmentIndex) GetFailReason() string

func (*SegmentIndex) GetFinishedTime 

func (x *SegmentIndex) GetFinishedTime() uint64

func (*SegmentIndex) GetIndexFileKeys 

func (x *SegmentIndex) GetIndexFileKeys() []string

func (*SegmentIndex) GetIndexID 

func (x *SegmentIndex) GetIndexID() int64

func (*SegmentIndex) GetIndexStoreVersion 

func (x *SegmentIndex) GetIndexStoreVersion() int64

func (*SegmentIndex) GetIndexVersion 

func (x *SegmentIndex) GetIndexVersion() int64

func (*SegmentIndex) GetMemSize 

func (x *SegmentIndex) GetMemSize() uint64

func (*SegmentIndex) GetNodeID 

func (x *SegmentIndex) GetNodeID() int64

func (*SegmentIndex) GetNumRows 

func (x *SegmentIndex) GetNumRows() int64

func (*SegmentIndex) GetPartitionID 

func (x *SegmentIndex) GetPartitionID() int64

func (*SegmentIndex) GetSegmentID 

func (x *SegmentIndex) GetSegmentID() int64

func (*SegmentIndex) GetSerializeSize 

func (x *SegmentIndex) GetSerializeSize() uint64

func (*SegmentIndex) GetState 

func (x *SegmentIndex) GetState() commonpb.IndexState

func (*SegmentIndex) GetWriteHandoff 

func (x *SegmentIndex) GetWriteHandoff() bool

func (*SegmentIndex) ProtoMessage 

func (*SegmentIndex) ProtoMessage()

func (*SegmentIndex) ProtoReflect 

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

func (*SegmentIndex) Reset 

func (x *SegmentIndex) Reset()

func (*SegmentIndex) String 

func (x *SegmentIndex) String() string

type SegmentIndexState 

type SegmentIndexState struct {
	SegmentID  int64               `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	State      commonpb.IndexState `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.common.IndexState" json:"state,omitempty"`
	FailReason string              `protobuf:"bytes,3,opt,name=fail_reason,json=failReason,proto3" json:"fail_reason,omitempty"`
	IndexName  string              `protobuf:"bytes,4,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentIndexState) Descriptor deprecated 

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

Deprecated: Use SegmentIndexState.ProtoReflect.Descriptor instead.

func (*SegmentIndexState) GetFailReason 

func (x *SegmentIndexState) GetFailReason() string

func (*SegmentIndexState) GetIndexName 

func (x *SegmentIndexState) GetIndexName() string

func (*SegmentIndexState) GetSegmentID 

func (x *SegmentIndexState) GetSegmentID() int64

func (*SegmentIndexState) GetState 

func (x *SegmentIndexState) GetState() commonpb.IndexState

func (*SegmentIndexState) ProtoMessage 

func (*SegmentIndexState) ProtoMessage()

func (*SegmentIndexState) ProtoReflect 

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

func (*SegmentIndexState) Reset 

func (x *SegmentIndexState) Reset()

func (*SegmentIndexState) String 

func (x *SegmentIndexState) String() string

type SegmentInfo 

type SegmentInfo struct {
	CollectionID int64                `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	SegmentID    int64                `protobuf:"varint,2,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	EnableIndex  bool                 `protobuf:"varint,3,opt,name=enable_index,json=enableIndex,proto3" json:"enable_index,omitempty"`
	IndexInfos   []*IndexFilePathInfo `protobuf:"bytes,4,rep,name=index_infos,json=indexInfos,proto3" json:"index_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentInfo) Descriptor deprecated 

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

Deprecated: Use SegmentInfo.ProtoReflect.Descriptor instead.

func (*SegmentInfo) GetCollectionID 

func (x *SegmentInfo) GetCollectionID() int64

func (*SegmentInfo) GetEnableIndex 

func (x *SegmentInfo) GetEnableIndex() bool

func (*SegmentInfo) GetIndexInfos 

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

func (*SegmentInfo) GetSegmentID 

func (x *SegmentInfo) GetSegmentID() int64

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 SegmentStats 

type SegmentStats struct {
	ID      int64   `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	NumRows int64   `protobuf:"varint,2,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	LogIDs  []int64 `protobuf:"varint,3,rep,packed,name=logIDs,proto3" json:"logIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentStats) Descriptor deprecated 

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

Deprecated: Use SegmentStats.ProtoReflect.Descriptor instead.

func (*SegmentStats) GetID 

func (x *SegmentStats) GetID() int64

func (*SegmentStats) GetLogIDs 

func (x *SegmentStats) GetLogIDs() []int64

func (*SegmentStats) GetNumRows 

func (x *SegmentStats) GetNumRows() int64

func (*SegmentStats) ProtoMessage 

func (*SegmentStats) ProtoMessage()

func (*SegmentStats) ProtoReflect 

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

func (*SegmentStats) Reset 

func (x *SegmentStats) Reset()

func (*SegmentStats) String 

func (x *SegmentStats) String() string

type StatsSubJob 

type StatsSubJob int32
const (
	StatsSubJob_None         StatsSubJob = 0
	StatsSubJob_Sort         StatsSubJob = 1
	StatsSubJob_TextIndexJob StatsSubJob = 2
	StatsSubJob_BM25Job      StatsSubJob = 3
)

func (StatsSubJob) Descriptor 

func (StatsSubJob) Descriptor() protoreflect.EnumDescriptor

func (StatsSubJob) Enum 

func (x StatsSubJob) Enum() *StatsSubJob

func (StatsSubJob) EnumDescriptor deprecated 

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

Deprecated: Use StatsSubJob.Descriptor instead.

func (StatsSubJob) Number 

func (x StatsSubJob) Number() protoreflect.EnumNumber

func (StatsSubJob) String 

func (x StatsSubJob) String() string

func (StatsSubJob) Type 

func (StatsSubJob) Type() protoreflect.EnumType

type StatsTask 

type StatsTask 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"`
	SegmentID       int64       `protobuf:"varint,3,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	InsertChannel   string      `protobuf:"bytes,4,opt,name=insert_channel,json=insertChannel,proto3" json:"insert_channel,omitempty"`
	TaskID          int64       `protobuf:"varint,5,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Version         int64       `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
	NodeID          int64       `protobuf:"varint,7,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	State           JobState    `protobuf:"varint,8,opt,name=state,proto3,enum=milvus.proto.index.JobState" json:"state,omitempty"`
	FailReason      string      `protobuf:"bytes,9,opt,name=fail_reason,json=failReason,proto3" json:"fail_reason,omitempty"`
	TargetSegmentID int64       `protobuf:"varint,10,opt,name=target_segmentID,json=targetSegmentID,proto3" json:"target_segmentID,omitempty"`
	SubJobType      StatsSubJob `protobuf:"varint,11,opt,name=subJobType,proto3,enum=milvus.proto.index.StatsSubJob" json:"subJobType,omitempty"`
	CanRecycle      bool        `protobuf:"varint,12,opt,name=canRecycle,proto3" json:"canRecycle,omitempty"`
	// contains filtered or unexported fields
}

func (*StatsTask) Descriptor deprecated 

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

Deprecated: Use StatsTask.ProtoReflect.Descriptor instead.

func (*StatsTask) GetCanRecycle 

func (x *StatsTask) GetCanRecycle() bool

func (*StatsTask) GetCollectionID 

func (x *StatsTask) GetCollectionID() int64

func (*StatsTask) GetFailReason 

func (x *StatsTask) GetFailReason() string

func (*StatsTask) GetInsertChannel 

func (x *StatsTask) GetInsertChannel() string

func (*StatsTask) GetNodeID 

func (x *StatsTask) GetNodeID() int64

func (*StatsTask) GetPartitionID 

func (x *StatsTask) GetPartitionID() int64

func (*StatsTask) GetSegmentID 

func (x *StatsTask) GetSegmentID() int64

func (*StatsTask) GetState 

func (x *StatsTask) GetState() JobState

func (*StatsTask) GetSubJobType 

func (x *StatsTask) GetSubJobType() StatsSubJob

func (*StatsTask) GetTargetSegmentID 

func (x *StatsTask) GetTargetSegmentID() int64

func (*StatsTask) GetTaskID 

func (x *StatsTask) GetTaskID() int64

func (*StatsTask) GetVersion 

func (x *StatsTask) GetVersion() int64

func (*StatsTask) ProtoMessage 

func (*StatsTask) ProtoMessage()

func (*StatsTask) ProtoReflect 

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

func (*StatsTask) Reset 

func (x *StatsTask) Reset()

func (*StatsTask) String 

func (x *StatsTask) String() string

type StorageConfig 

type StorageConfig struct {
	Address           string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	AccessKeyID       string `protobuf:"bytes,2,opt,name=access_keyID,json=accessKeyID,proto3" json:"access_keyID,omitempty"`
	SecretAccessKey   string `protobuf:"bytes,3,opt,name=secret_access_key,json=secretAccessKey,proto3" json:"secret_access_key,omitempty"`
	UseSSL            bool   `protobuf:"varint,4,opt,name=useSSL,proto3" json:"useSSL,omitempty"`
	BucketName        string `protobuf:"bytes,5,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	RootPath          string `protobuf:"bytes,6,opt,name=root_path,json=rootPath,proto3" json:"root_path,omitempty"`
	UseIAM            bool   `protobuf:"varint,7,opt,name=useIAM,proto3" json:"useIAM,omitempty"`
	IAMEndpoint       string `protobuf:"bytes,8,opt,name=IAMEndpoint,proto3" json:"IAMEndpoint,omitempty"`
	StorageType       string `protobuf:"bytes,9,opt,name=storage_type,json=storageType,proto3" json:"storage_type,omitempty"`
	UseVirtualHost    bool   `protobuf:"varint,10,opt,name=use_virtual_host,json=useVirtualHost,proto3" json:"use_virtual_host,omitempty"`
	Region            string `protobuf:"bytes,11,opt,name=region,proto3" json:"region,omitempty"`
	CloudProvider     string `protobuf:"bytes,12,opt,name=cloud_provider,json=cloudProvider,proto3" json:"cloud_provider,omitempty"`
	RequestTimeoutMs  int64  `protobuf:"varint,13,opt,name=request_timeout_ms,json=requestTimeoutMs,proto3" json:"request_timeout_ms,omitempty"`
	SslCACert         string `protobuf:"bytes,14,opt,name=sslCACert,proto3" json:"sslCACert,omitempty"`
	GcpCredentialJSON string `protobuf:"bytes,15,opt,name=GcpCredentialJSON,proto3" json:"GcpCredentialJSON,omitempty"`
	// contains filtered or unexported fields
}

Synchronously modify StorageConfig in index_cgo_msg.proto/clustering.proto file

func (*StorageConfig) Descriptor deprecated 

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

Deprecated: Use StorageConfig.ProtoReflect.Descriptor instead.

func (*StorageConfig) GetAccessKeyID 

func (x *StorageConfig) GetAccessKeyID() string

func (*StorageConfig) GetAddress 

func (x *StorageConfig) GetAddress() string

func (*StorageConfig) GetBucketName 

func (x *StorageConfig) GetBucketName() string

func (*StorageConfig) GetCloudProvider 

func (x *StorageConfig) GetCloudProvider() string

func (*StorageConfig) GetGcpCredentialJSON 

func (x *StorageConfig) GetGcpCredentialJSON() string

func (*StorageConfig) GetIAMEndpoint 

func (x *StorageConfig) GetIAMEndpoint() string

func (*StorageConfig) GetRegion 

func (x *StorageConfig) GetRegion() string

func (*StorageConfig) GetRequestTimeoutMs 

func (x *StorageConfig) GetRequestTimeoutMs() int64

func (*StorageConfig) GetRootPath 

func (x *StorageConfig) GetRootPath() string

func (*StorageConfig) GetSecretAccessKey 

func (x *StorageConfig) GetSecretAccessKey() string

func (*StorageConfig) GetSslCACert 

func (x *StorageConfig) GetSslCACert() string

func (*StorageConfig) GetStorageType 

func (x *StorageConfig) GetStorageType() string

func (*StorageConfig) GetUseIAM 

func (x *StorageConfig) GetUseIAM() bool

func (*StorageConfig) GetUseSSL 

func (x *StorageConfig) GetUseSSL() bool

func (*StorageConfig) GetUseVirtualHost 

func (x *StorageConfig) GetUseVirtualHost() bool

func (*StorageConfig) ProtoMessage 

func (*StorageConfig) ProtoMessage()

func (*StorageConfig) ProtoReflect 

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

func (*StorageConfig) Reset 

func (x *StorageConfig) Reset()

func (*StorageConfig) String 

func (x *StorageConfig) String() string

type UnimplementedIndexCoordServer 

type UnimplementedIndexCoordServer struct {
}

UnimplementedIndexCoordServer should be embedded to have forward compatible implementations.

func (UnimplementedIndexCoordServer) AlterIndex 

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

func (UnimplementedIndexCoordServer) CheckHealth 

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

func (UnimplementedIndexCoordServer) CreateIndex 

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

func (UnimplementedIndexCoordServer) DescribeIndex 

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

func (UnimplementedIndexCoordServer) DropIndex 

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

func (UnimplementedIndexCoordServer) GetComponentStates 

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

func (UnimplementedIndexCoordServer) GetIndexBuildProgress 

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

func (UnimplementedIndexCoordServer) GetIndexInfos 

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

func (UnimplementedIndexCoordServer) GetIndexState 

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

func (UnimplementedIndexCoordServer) GetIndexStatistics 

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

func (UnimplementedIndexCoordServer) GetMetrics 

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

func (UnimplementedIndexCoordServer) GetSegmentIndexState 

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

func (UnimplementedIndexCoordServer) GetStatisticsChannel 

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

func (UnimplementedIndexCoordServer) ShowConfigurations 

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

type UnsafeIndexCoordServer 

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

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

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.