internalpb

package
v2.5.8 Latest Latest
Warning

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

 Go to latest Published: Mar 31, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	RateScope_name = map[int32]string{
		0: "Cluster",
		1: "Database",
		2: "Collection",
		3: "Partition",
	}
	RateScope_value = map[string]int32{
		"Cluster":    0,
		"Database":   1,
		"Collection": 2,
		"Partition":  3,
	}
)

Enum value maps for RateScope.

View Source 
var (
	RateType_name = map[int32]string{
		0:  "DDLCollection",
		1:  "DDLPartition",
		2:  "DDLIndex",
		3:  "DDLFlush",
		4:  "DDLCompaction",
		5:  "DMLInsert",
		6:  "DMLDelete",
		7:  "DMLBulkLoad",
		8:  "DQLSearch",
		9:  "DQLQuery",
		10: "DMLUpsert",
		11: "DDLDB",
	}
	RateType_value = map[string]int32{
		"DDLCollection": 0,
		"DDLPartition":  1,
		"DDLIndex":      2,
		"DDLFlush":      3,
		"DDLCompaction": 4,
		"DMLInsert":     5,
		"DMLDelete":     6,
		"DMLBulkLoad":   7,
		"DQLSearch":     8,
		"DQLQuery":      9,
		"DMLUpsert":     10,
		"DDLDB":         11,
	}
)

Enum value maps for RateType.

View Source 
var (
	ImportJobState_name = map[int32]string{
		0: "None",
		1: "Pending",
		2: "PreImporting",
		3: "Importing",
		4: "Failed",
		5: "Completed",
		6: "IndexBuilding",
		7: "Stats",
	}
	ImportJobState_value = map[string]int32{
		"None":          0,
		"Pending":       1,
		"PreImporting":  2,
		"Importing":     3,
		"Failed":        4,
		"Completed":     5,
		"IndexBuilding": 6,
		"Stats":         7,
	}
)

Enum value maps for ImportJobState.

View Source 
var File_internal_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AlterAliasRequest 

type AlterAliasRequest struct {
	Base           *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName         string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	Alias          string            `protobuf:"bytes,4,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterAliasRequest) Descriptor deprecated 

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

Deprecated: Use AlterAliasRequest.ProtoReflect.Descriptor instead.

func (*AlterAliasRequest) GetAlias 

func (x *AlterAliasRequest) GetAlias() string

func (*AlterAliasRequest) GetBase 

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

func (*AlterAliasRequest) GetCollectionName 

func (x *AlterAliasRequest) GetCollectionName() string

func (*AlterAliasRequest) GetDbName 

func (x *AlterAliasRequest) GetDbName() string

func (*AlterAliasRequest) ProtoMessage 

func (*AlterAliasRequest) ProtoMessage()

func (*AlterAliasRequest) ProtoReflect 

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

func (*AlterAliasRequest) Reset 

func (x *AlterAliasRequest) Reset()

func (*AlterAliasRequest) String 

func (x *AlterAliasRequest) String() string

type ChannelTimeTickMsg 

type ChannelTimeTickMsg struct {
	Base             *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	ChannelNames     []string          `protobuf:"bytes,2,rep,name=channelNames,proto3" json:"channelNames,omitempty"`
	Timestamps       []uint64          `protobuf:"varint,3,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	DefaultTimestamp uint64            `protobuf:"varint,4,opt,name=default_timestamp,json=defaultTimestamp,proto3" json:"default_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelTimeTickMsg) Descriptor deprecated 

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

Deprecated: Use ChannelTimeTickMsg.ProtoReflect.Descriptor instead.

func (*ChannelTimeTickMsg) GetBase 

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

func (*ChannelTimeTickMsg) GetChannelNames 

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

func (*ChannelTimeTickMsg) GetDefaultTimestamp 

func (x *ChannelTimeTickMsg) GetDefaultTimestamp() uint64

func (*ChannelTimeTickMsg) GetTimestamps 

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

func (*ChannelTimeTickMsg) ProtoMessage 

func (*ChannelTimeTickMsg) ProtoMessage()

func (*ChannelTimeTickMsg) ProtoReflect 

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

func (*ChannelTimeTickMsg) Reset 

func (x *ChannelTimeTickMsg) Reset()

func (*ChannelTimeTickMsg) String 

func (x *ChannelTimeTickMsg) String() string

type CostAggregation 

type CostAggregation struct {
	ResponseTime         int64 `protobuf:"varint,1,opt,name=responseTime,proto3" json:"responseTime,omitempty"`
	ServiceTime          int64 `protobuf:"varint,2,opt,name=serviceTime,proto3" json:"serviceTime,omitempty"`
	TotalNQ              int64 `protobuf:"varint,3,opt,name=totalNQ,proto3" json:"totalNQ,omitempty"`
	TotalRelatedDataSize int64 `protobuf:"varint,4,opt,name=totalRelatedDataSize,proto3" json:"totalRelatedDataSize,omitempty"`
	// contains filtered or unexported fields
}

func (*CostAggregation) Descriptor deprecated 

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

Deprecated: Use CostAggregation.ProtoReflect.Descriptor instead.

func (*CostAggregation) GetResponseTime 

func (x *CostAggregation) GetResponseTime() int64

func (*CostAggregation) GetServiceTime 

func (x *CostAggregation) GetServiceTime() int64

func (*CostAggregation) GetTotalNQ 

func (x *CostAggregation) GetTotalNQ() int64

func (*CostAggregation) GetTotalRelatedDataSize 

func (x *CostAggregation) GetTotalRelatedDataSize() int64

func (*CostAggregation) ProtoMessage 

func (*CostAggregation) ProtoMessage()

func (*CostAggregation) ProtoReflect 

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

func (*CostAggregation) Reset 

func (x *CostAggregation) Reset()

func (*CostAggregation) String 

func (x *CostAggregation) String() string

type CreateAliasRequest 

type CreateAliasRequest struct {
	Base           *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName         string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	Alias          string            `protobuf:"bytes,4,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateAliasRequest) Descriptor deprecated 

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

Deprecated: Use CreateAliasRequest.ProtoReflect.Descriptor instead.

func (*CreateAliasRequest) GetAlias 

func (x *CreateAliasRequest) GetAlias() string

func (*CreateAliasRequest) GetBase 

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

func (*CreateAliasRequest) GetCollectionName 

func (x *CreateAliasRequest) GetCollectionName() string

func (*CreateAliasRequest) GetDbName 

func (x *CreateAliasRequest) GetDbName() string

func (*CreateAliasRequest) ProtoMessage 

func (*CreateAliasRequest) ProtoMessage()

func (*CreateAliasRequest) ProtoReflect 

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

func (*CreateAliasRequest) Reset 

func (x *CreateAliasRequest) Reset()

func (*CreateAliasRequest) String 

func (x *CreateAliasRequest) String() string

type CreateIndexRequest 

type CreateIndexRequest struct {
	Base           *commonpb.MsgBase        `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName         string                   `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName string                   `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	FieldName      string                   `protobuf:"bytes,4,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	DbID           int64                    `protobuf:"varint,5,opt,name=dbID,proto3" json:"dbID,omitempty"`
	CollectionID   int64                    `protobuf:"varint,6,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	FieldID        int64                    `protobuf:"varint,7,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	ExtraParams    []*commonpb.KeyValuePair `protobuf:"bytes,8,rep,name=extra_params,json=extraParams,proto3" json:"extra_params,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateIndexRequest) Descriptor deprecated 

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

Deprecated: Use CreateIndexRequest.ProtoReflect.Descriptor instead.

func (*CreateIndexRequest) GetBase 

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

func (*CreateIndexRequest) GetCollectionID 

func (x *CreateIndexRequest) GetCollectionID() int64

func (*CreateIndexRequest) GetCollectionName 

func (x *CreateIndexRequest) GetCollectionName() string

func (*CreateIndexRequest) GetDbID 

func (x *CreateIndexRequest) GetDbID() int64

func (*CreateIndexRequest) GetDbName 

func (x *CreateIndexRequest) GetDbName() string

func (*CreateIndexRequest) GetExtraParams 

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

func (*CreateIndexRequest) GetFieldID 

func (x *CreateIndexRequest) GetFieldID() int64

func (*CreateIndexRequest) GetFieldName 

func (x *CreateIndexRequest) GetFieldName() string

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 CredentialInfo 

type CredentialInfo struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// encrypted by bcrypt (for higher security level)
	EncryptedPassword string `protobuf:"bytes,2,opt,name=encrypted_password,json=encryptedPassword,proto3" json:"encrypted_password,omitempty"`
	Tenant            string `protobuf:"bytes,3,opt,name=tenant,proto3" json:"tenant,omitempty"`
	IsSuper           bool   `protobuf:"varint,4,opt,name=is_super,json=isSuper,proto3" json:"is_super,omitempty"`
	// encrypted by sha256 (for good performance in cache mapping)
	Sha256Password string `protobuf:"bytes,5,opt,name=sha256_password,json=sha256Password,proto3" json:"sha256_password,omitempty"`
	// contains filtered or unexported fields
}

func (*CredentialInfo) Descriptor deprecated 

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

Deprecated: Use CredentialInfo.ProtoReflect.Descriptor instead.

func (*CredentialInfo) GetEncryptedPassword 

func (x *CredentialInfo) GetEncryptedPassword() string

func (*CredentialInfo) GetIsSuper 

func (x *CredentialInfo) GetIsSuper() bool

func (*CredentialInfo) GetSha256Password 

func (x *CredentialInfo) GetSha256Password() string

func (*CredentialInfo) GetTenant 

func (x *CredentialInfo) GetTenant() string

func (*CredentialInfo) GetUsername 

func (x *CredentialInfo) GetUsername() string

func (*CredentialInfo) ProtoMessage 

func (*CredentialInfo) ProtoMessage()

func (*CredentialInfo) ProtoReflect 

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

func (*CredentialInfo) Reset 

func (x *CredentialInfo) Reset()

func (*CredentialInfo) String 

func (x *CredentialInfo) String() string

type DropAliasRequest 

type DropAliasRequest struct {
	Base   *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	Alias  string            `protobuf:"bytes,3,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*DropAliasRequest) Descriptor deprecated 

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

Deprecated: Use DropAliasRequest.ProtoReflect.Descriptor instead.

func (*DropAliasRequest) GetAlias 

func (x *DropAliasRequest) GetAlias() string

func (*DropAliasRequest) GetBase 

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

func (*DropAliasRequest) GetDbName 

func (x *DropAliasRequest) GetDbName() string

func (*DropAliasRequest) ProtoMessage 

func (*DropAliasRequest) ProtoMessage()

func (*DropAliasRequest) ProtoReflect 

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

func (*DropAliasRequest) Reset 

func (x *DropAliasRequest) Reset()

func (*DropAliasRequest) String 

func (x *DropAliasRequest) String() string

type FieldBinlog added in v2.5.7 

type FieldBinlog struct {
	FieldID int64   `protobuf:"varint,1,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	LogIDs  []int64 `protobuf:"varint,2,rep,packed,name=logIDs,proto3" json:"logIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldBinlog) Descriptor deprecated added in v2.5.7 

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

Deprecated: Use FieldBinlog.ProtoReflect.Descriptor instead.

func (*FieldBinlog) GetFieldID added in v2.5.7 

func (x *FieldBinlog) GetFieldID() int64

func (*FieldBinlog) GetLogIDs added in v2.5.7 

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

func (*FieldBinlog) ProtoMessage added in v2.5.7 

func (*FieldBinlog) ProtoMessage()

func (*FieldBinlog) ProtoReflect added in v2.5.7 

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

func (*FieldBinlog) Reset added in v2.5.7 

func (x *FieldBinlog) Reset()

func (*FieldBinlog) String added in v2.5.7 

func (x *FieldBinlog) String() string

type FieldStats 

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

func (*FieldStats) Descriptor deprecated 

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

Deprecated: Use FieldStats.ProtoReflect.Descriptor instead.

func (*FieldStats) GetCollectionID 

func (x *FieldStats) GetCollectionID() int64

func (*FieldStats) GetFieldID 

func (x *FieldStats) GetFieldID() int64

func (*FieldStats) GetIndexStats 

func (x *FieldStats) GetIndexStats() []*IndexStats

func (*FieldStats) ProtoMessage 

func (*FieldStats) ProtoMessage()

func (*FieldStats) ProtoReflect 

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

func (*FieldStats) Reset 

func (x *FieldStats) Reset()

func (*FieldStats) String 

func (x *FieldStats) String() string

type GetDdChannelRequest 

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

func (*GetDdChannelRequest) Descriptor deprecated 

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

Deprecated: Use GetDdChannelRequest.ProtoReflect.Descriptor instead.

func (*GetDdChannelRequest) ProtoMessage 

func (*GetDdChannelRequest) ProtoMessage()

func (*GetDdChannelRequest) ProtoReflect 

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

func (*GetDdChannelRequest) Reset 

func (x *GetDdChannelRequest) Reset()

func (*GetDdChannelRequest) String 

func (x *GetDdChannelRequest) String() string

type GetImportProgressRequest 

type GetImportProgressRequest struct {
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	JobID  string `protobuf:"bytes,2,opt,name=jobID,proto3" json:"jobID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetImportProgressRequest) Descriptor deprecated 

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

Deprecated: Use GetImportProgressRequest.ProtoReflect.Descriptor instead.

func (*GetImportProgressRequest) GetDbName 

func (x *GetImportProgressRequest) GetDbName() string

func (*GetImportProgressRequest) GetJobID 

func (x *GetImportProgressRequest) GetJobID() string

func (*GetImportProgressRequest) ProtoMessage 

func (*GetImportProgressRequest) ProtoMessage()

func (*GetImportProgressRequest) ProtoReflect 

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

func (*GetImportProgressRequest) Reset 

func (x *GetImportProgressRequest) Reset()

func (*GetImportProgressRequest) String 

func (x *GetImportProgressRequest) String() string

type GetImportProgressResponse 

type GetImportProgressResponse struct {
	Status         *commonpb.Status      `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	State          ImportJobState        `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.internal.ImportJobState" json:"state,omitempty"`
	Reason         string                `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	Progress       int64                 `protobuf:"varint,4,opt,name=progress,proto3" json:"progress,omitempty"`
	CollectionName string                `protobuf:"bytes,5,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	CompleteTime   string                `protobuf:"bytes,6,opt,name=complete_time,json=completeTime,proto3" json:"complete_time,omitempty"`
	TaskProgresses []*ImportTaskProgress `protobuf:"bytes,7,rep,name=task_progresses,json=taskProgresses,proto3" json:"task_progresses,omitempty"`
	ImportedRows   int64                 `protobuf:"varint,8,opt,name=imported_rows,json=importedRows,proto3" json:"imported_rows,omitempty"`
	TotalRows      int64                 `protobuf:"varint,9,opt,name=total_rows,json=totalRows,proto3" json:"total_rows,omitempty"`
	StartTime      string                `protobuf:"bytes,10,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

func (*GetImportProgressResponse) Descriptor deprecated 

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

Deprecated: Use GetImportProgressResponse.ProtoReflect.Descriptor instead.

func (*GetImportProgressResponse) GetCollectionName 

func (x *GetImportProgressResponse) GetCollectionName() string

func (*GetImportProgressResponse) GetCompleteTime 

func (x *GetImportProgressResponse) GetCompleteTime() string

func (*GetImportProgressResponse) GetImportedRows 

func (x *GetImportProgressResponse) GetImportedRows() int64

func (*GetImportProgressResponse) GetProgress 

func (x *GetImportProgressResponse) GetProgress() int64

func (*GetImportProgressResponse) GetReason 

func (x *GetImportProgressResponse) GetReason() string

func (*GetImportProgressResponse) GetStartTime 

func (x *GetImportProgressResponse) GetStartTime() string

func (*GetImportProgressResponse) GetState 

func (x *GetImportProgressResponse) GetState() ImportJobState

func (*GetImportProgressResponse) GetStatus 

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

func (*GetImportProgressResponse) GetTaskProgresses 

func (x *GetImportProgressResponse) GetTaskProgresses() []*ImportTaskProgress

func (*GetImportProgressResponse) GetTotalRows 

func (x *GetImportProgressResponse) GetTotalRows() int64

func (*GetImportProgressResponse) ProtoMessage 

func (*GetImportProgressResponse) ProtoMessage()

func (*GetImportProgressResponse) ProtoReflect 

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

func (*GetImportProgressResponse) Reset 

func (x *GetImportProgressResponse) Reset()

func (*GetImportProgressResponse) String 

func (x *GetImportProgressResponse) String() string

type GetSegmentsInfoRequest added in v2.5.7 

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

func (*GetSegmentsInfoRequest) Descriptor deprecated added in v2.5.7 

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

Deprecated: Use GetSegmentsInfoRequest.ProtoReflect.Descriptor instead.

func (*GetSegmentsInfoRequest) GetCollectionID added in v2.5.7 

func (x *GetSegmentsInfoRequest) GetCollectionID() int64

func (*GetSegmentsInfoRequest) GetDbName added in v2.5.7 

func (x *GetSegmentsInfoRequest) GetDbName() string

func (*GetSegmentsInfoRequest) GetSegmentIDs added in v2.5.7 

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

func (*GetSegmentsInfoRequest) ProtoMessage added in v2.5.7 

func (*GetSegmentsInfoRequest) ProtoMessage()

func (*GetSegmentsInfoRequest) ProtoReflect added in v2.5.7 

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

func (*GetSegmentsInfoRequest) Reset added in v2.5.7 

func (x *GetSegmentsInfoRequest) Reset()

func (*GetSegmentsInfoRequest) String added in v2.5.7 

func (x *GetSegmentsInfoRequest) String() string

type GetSegmentsInfoResponse added in v2.5.7 

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

func (*GetSegmentsInfoResponse) Descriptor deprecated added in v2.5.7 

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

Deprecated: Use GetSegmentsInfoResponse.ProtoReflect.Descriptor instead.

func (*GetSegmentsInfoResponse) GetSegmentInfos added in v2.5.7 

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

func (*GetSegmentsInfoResponse) GetStatus added in v2.5.7 

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

func (*GetSegmentsInfoResponse) ProtoMessage added in v2.5.7 

func (*GetSegmentsInfoResponse) ProtoMessage()

func (*GetSegmentsInfoResponse) ProtoReflect added in v2.5.7 

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

func (*GetSegmentsInfoResponse) Reset added in v2.5.7 

func (x *GetSegmentsInfoResponse) Reset()

func (*GetSegmentsInfoResponse) String added in v2.5.7 

func (x *GetSegmentsInfoResponse) String() string

type GetStatisticsChannelRequest 

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

func (*GetStatisticsChannelRequest) Descriptor deprecated 

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

Deprecated: Use GetStatisticsChannelRequest.ProtoReflect.Descriptor instead.

func (*GetStatisticsChannelRequest) ProtoMessage 

func (*GetStatisticsChannelRequest) ProtoMessage()

func (*GetStatisticsChannelRequest) ProtoReflect 

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

func (*GetStatisticsChannelRequest) Reset 

func (x *GetStatisticsChannelRequest) Reset()

func (*GetStatisticsChannelRequest) String 

func (x *GetStatisticsChannelRequest) String() string

type GetStatisticsRequest 

type GetStatisticsRequest struct {
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbID int64 `protobuf:"varint,2,opt,name=dbID,proto3" json:"dbID,omitempty"`
	// The collection you want get statistics
	CollectionID int64 `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	// The partitions you want get statistics
	PartitionIDs []int64 `protobuf:"varint,4,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	// timestamp of the statistics
	TravelTimestamp    uint64 `protobuf:"varint,5,opt,name=travel_timestamp,json=travelTimestamp,proto3" json:"travel_timestamp,omitempty"`
	GuaranteeTimestamp uint64 `protobuf:"varint,6,opt,name=guarantee_timestamp,json=guaranteeTimestamp,proto3" json:"guarantee_timestamp,omitempty"`
	TimeoutTimestamp   uint64 `protobuf:"varint,7,opt,name=timeout_timestamp,json=timeoutTimestamp,proto3" json:"timeout_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatisticsRequest) Descriptor deprecated 

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

Deprecated: Use GetStatisticsRequest.ProtoReflect.Descriptor instead.

func (*GetStatisticsRequest) GetBase 

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

func (*GetStatisticsRequest) GetCollectionID 

func (x *GetStatisticsRequest) GetCollectionID() int64

func (*GetStatisticsRequest) GetDbID 

func (x *GetStatisticsRequest) GetDbID() int64

func (*GetStatisticsRequest) GetGuaranteeTimestamp 

func (x *GetStatisticsRequest) GetGuaranteeTimestamp() uint64

func (*GetStatisticsRequest) GetPartitionIDs 

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

func (*GetStatisticsRequest) GetTimeoutTimestamp 

func (x *GetStatisticsRequest) GetTimeoutTimestamp() uint64

func (*GetStatisticsRequest) GetTravelTimestamp 

func (x *GetStatisticsRequest) GetTravelTimestamp() uint64

func (*GetStatisticsRequest) ProtoMessage 

func (*GetStatisticsRequest) ProtoMessage()

func (*GetStatisticsRequest) ProtoReflect 

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

func (*GetStatisticsRequest) Reset 

func (x *GetStatisticsRequest) Reset()

func (*GetStatisticsRequest) String 

func (x *GetStatisticsRequest) String() string

type GetStatisticsResponse 

type GetStatisticsResponse struct {
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Contain error_code and reason
	Status *commonpb.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// Collection statistics data. Contain pairs like {"row_count": "1"}
	Stats []*commonpb.KeyValuePair `protobuf:"bytes,3,rep,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatisticsResponse) Descriptor deprecated 

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

Deprecated: Use GetStatisticsResponse.ProtoReflect.Descriptor instead.

func (*GetStatisticsResponse) GetBase 

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

func (*GetStatisticsResponse) GetStats 

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

func (*GetStatisticsResponse) GetStatus 

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

func (*GetStatisticsResponse) ProtoMessage 

func (*GetStatisticsResponse) ProtoMessage()

func (*GetStatisticsResponse) ProtoReflect 

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

func (*GetStatisticsResponse) Reset 

func (x *GetStatisticsResponse) Reset()

func (*GetStatisticsResponse) String 

func (x *GetStatisticsResponse) String() string

type GetTimeTickChannelRequest 

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

func (*GetTimeTickChannelRequest) Descriptor deprecated 

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

Deprecated: Use GetTimeTickChannelRequest.ProtoReflect.Descriptor instead.

func (*GetTimeTickChannelRequest) ProtoMessage 

func (*GetTimeTickChannelRequest) ProtoMessage()

func (*GetTimeTickChannelRequest) ProtoReflect 

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

func (*GetTimeTickChannelRequest) Reset 

func (x *GetTimeTickChannelRequest) Reset()

func (*GetTimeTickChannelRequest) String 

func (x *GetTimeTickChannelRequest) String() string

type ImportFile 

type ImportFile struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// A singular row-based file or multiple column-based files.
	Paths []string `protobuf:"bytes,2,rep,name=paths,proto3" json:"paths,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportFile) Descriptor deprecated 

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

Deprecated: Use ImportFile.ProtoReflect.Descriptor instead.

func (*ImportFile) GetId 

func (x *ImportFile) GetId() int64

func (*ImportFile) GetPaths 

func (x *ImportFile) GetPaths() []string

func (*ImportFile) ProtoMessage 

func (*ImportFile) ProtoMessage()

func (*ImportFile) ProtoReflect 

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

func (*ImportFile) Reset 

func (x *ImportFile) Reset()

func (*ImportFile) String 

func (x *ImportFile) String() string

type ImportJobState 

type ImportJobState int32
const (
	ImportJobState_None          ImportJobState = 0
	ImportJobState_Pending       ImportJobState = 1
	ImportJobState_PreImporting  ImportJobState = 2
	ImportJobState_Importing     ImportJobState = 3
	ImportJobState_Failed        ImportJobState = 4
	ImportJobState_Completed     ImportJobState = 5
	ImportJobState_IndexBuilding ImportJobState = 6
	ImportJobState_Stats         ImportJobState = 7
)

func (ImportJobState) Descriptor 

func (ImportJobState) Descriptor() protoreflect.EnumDescriptor

func (ImportJobState) Enum 

func (x ImportJobState) Enum() *ImportJobState

func (ImportJobState) EnumDescriptor deprecated 

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

Deprecated: Use ImportJobState.Descriptor instead.

func (ImportJobState) Number 

func (x ImportJobState) Number() protoreflect.EnumNumber

func (ImportJobState) String 

func (x ImportJobState) String() string

func (ImportJobState) Type 

func (ImportJobState) Type() protoreflect.EnumType

type ImportRequest 

type ImportRequest struct {
	DbName         string                   `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName string                   `protobuf:"bytes,2,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionName  string                   `protobuf:"bytes,3,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	Files          []*ImportFile            `protobuf:"bytes,4,rep,name=files,proto3" json:"files,omitempty"`
	Options        []*commonpb.KeyValuePair `protobuf:"bytes,5,rep,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportRequest) Descriptor deprecated 

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

Deprecated: Use ImportRequest.ProtoReflect.Descriptor instead.

func (*ImportRequest) GetCollectionName 

func (x *ImportRequest) GetCollectionName() string

func (*ImportRequest) GetDbName 

func (x *ImportRequest) GetDbName() string

func (*ImportRequest) GetFiles 

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

func (*ImportRequest) GetOptions 

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

func (*ImportRequest) GetPartitionName 

func (x *ImportRequest) GetPartitionName() 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 ImportRequestInternal 

type ImportRequestInternal struct {

	// Deprecated: Marked as deprecated in internal.proto.
	DbID           int64                      `protobuf:"varint,1,opt,name=dbID,proto3" json:"dbID,omitempty"`
	CollectionID   int64                      `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	CollectionName string                     `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionIDs   []int64                    `protobuf:"varint,4,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	ChannelNames   []string                   `protobuf:"bytes,5,rep,name=channel_names,json=channelNames,proto3" json:"channel_names,omitempty"`
	Schema         *schemapb.CollectionSchema `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"`
	Files          []*ImportFile              `protobuf:"bytes,7,rep,name=files,proto3" json:"files,omitempty"`
	Options        []*commonpb.KeyValuePair   `protobuf:"bytes,8,rep,name=options,proto3" json:"options,omitempty"`
	DataTimestamp  uint64                     `protobuf:"varint,9,opt,name=data_timestamp,json=dataTimestamp,proto3" json:"data_timestamp,omitempty"`
	JobID          int64                      `protobuf:"varint,10,opt,name=jobID,proto3" json:"jobID,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportRequestInternal) Descriptor deprecated 

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

Deprecated: Use ImportRequestInternal.ProtoReflect.Descriptor instead.

func (*ImportRequestInternal) GetChannelNames 

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

func (*ImportRequestInternal) GetCollectionID 

func (x *ImportRequestInternal) GetCollectionID() int64

func (*ImportRequestInternal) GetCollectionName 

func (x *ImportRequestInternal) GetCollectionName() string

func (*ImportRequestInternal) GetDataTimestamp 

func (x *ImportRequestInternal) GetDataTimestamp() uint64

func (*ImportRequestInternal) GetDbID deprecated 

func (x *ImportRequestInternal) GetDbID() int64

Deprecated: Marked as deprecated in internal.proto.

func (*ImportRequestInternal) GetFiles 

func (x *ImportRequestInternal) GetFiles() []*ImportFile

func (*ImportRequestInternal) GetJobID 

func (x *ImportRequestInternal) GetJobID() int64

func (*ImportRequestInternal) GetOptions 

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

func (*ImportRequestInternal) GetPartitionIDs 

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

func (*ImportRequestInternal) GetSchema 

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

func (*ImportRequestInternal) ProtoMessage 

func (*ImportRequestInternal) ProtoMessage()

func (*ImportRequestInternal) ProtoReflect 

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

func (*ImportRequestInternal) Reset 

func (x *ImportRequestInternal) Reset()

func (*ImportRequestInternal) String 

func (x *ImportRequestInternal) String() string

type ImportResponse 

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

func (*ImportResponse) Descriptor deprecated 

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

Deprecated: Use ImportResponse.ProtoReflect.Descriptor instead.

func (*ImportResponse) GetJobID 

func (x *ImportResponse) GetJobID() string

func (*ImportResponse) GetStatus 

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

func (*ImportResponse) ProtoMessage 

func (*ImportResponse) ProtoMessage()

func (*ImportResponse) ProtoReflect 

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

func (*ImportResponse) Reset 

func (x *ImportResponse) Reset()

func (*ImportResponse) String 

func (x *ImportResponse) String() string

type ImportTaskProgress 

type ImportTaskProgress struct {
	FileName     string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	FileSize     int64  `protobuf:"varint,2,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	Reason       string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	Progress     int64  `protobuf:"varint,4,opt,name=progress,proto3" json:"progress,omitempty"`
	CompleteTime string `protobuf:"bytes,5,opt,name=complete_time,json=completeTime,proto3" json:"complete_time,omitempty"`
	State        string `protobuf:"bytes,6,opt,name=state,proto3" json:"state,omitempty"`
	ImportedRows int64  `protobuf:"varint,7,opt,name=imported_rows,json=importedRows,proto3" json:"imported_rows,omitempty"`
	TotalRows    int64  `protobuf:"varint,8,opt,name=total_rows,json=totalRows,proto3" json:"total_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportTaskProgress) Descriptor deprecated 

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

Deprecated: Use ImportTaskProgress.ProtoReflect.Descriptor instead.

func (*ImportTaskProgress) GetCompleteTime 

func (x *ImportTaskProgress) GetCompleteTime() string

func (*ImportTaskProgress) GetFileName 

func (x *ImportTaskProgress) GetFileName() string

func (*ImportTaskProgress) GetFileSize 

func (x *ImportTaskProgress) GetFileSize() int64

func (*ImportTaskProgress) GetImportedRows 

func (x *ImportTaskProgress) GetImportedRows() int64

func (*ImportTaskProgress) GetProgress 

func (x *ImportTaskProgress) GetProgress() int64

func (*ImportTaskProgress) GetReason 

func (x *ImportTaskProgress) GetReason() string

func (*ImportTaskProgress) GetState 

func (x *ImportTaskProgress) GetState() string

func (*ImportTaskProgress) GetTotalRows 

func (x *ImportTaskProgress) GetTotalRows() int64

func (*ImportTaskProgress) ProtoMessage 

func (*ImportTaskProgress) ProtoMessage()

func (*ImportTaskProgress) ProtoReflect 

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

func (*ImportTaskProgress) Reset 

func (x *ImportTaskProgress) Reset()

func (*ImportTaskProgress) String 

func (x *ImportTaskProgress) String() string

type IndexStats 

type IndexStats struct {
	IndexParams        []*commonpb.KeyValuePair `protobuf:"bytes,1,rep,name=index_params,json=indexParams,proto3" json:"index_params,omitempty"`
	NumRelatedSegments int64                    `protobuf:"varint,2,opt,name=num_related_segments,json=numRelatedSegments,proto3" json:"num_related_segments,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexStats) Descriptor deprecated 

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

Deprecated: Use IndexStats.ProtoReflect.Descriptor instead.

func (*IndexStats) GetIndexParams 

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

func (*IndexStats) GetNumRelatedSegments 

func (x *IndexStats) GetNumRelatedSegments() int64

func (*IndexStats) ProtoMessage 

func (*IndexStats) ProtoMessage()

func (*IndexStats) ProtoReflect 

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

func (*IndexStats) Reset 

func (x *IndexStats) Reset()

func (*IndexStats) String 

func (x *IndexStats) String() string

type InitParams 

type InitParams struct {
	NodeID      int64                    `protobuf:"varint,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	StartParams []*commonpb.KeyValuePair `protobuf:"bytes,2,rep,name=start_params,json=startParams,proto3" json:"start_params,omitempty"`
	// contains filtered or unexported fields
}

func (*InitParams) Descriptor deprecated 

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

Deprecated: Use InitParams.ProtoReflect.Descriptor instead.

func (*InitParams) GetNodeID 

func (x *InitParams) GetNodeID() int64

func (*InitParams) GetStartParams 

func (x *InitParams) GetStartParams() []*commonpb.KeyValuePair

func (*InitParams) ProtoMessage 

func (*InitParams) ProtoMessage()

func (*InitParams) ProtoReflect 

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

func (*InitParams) Reset 

func (x *InitParams) Reset()

func (*InitParams) String 

func (x *InitParams) String() string

type ListImportsRequest 

type ListImportsRequest struct {
	DbName         string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName string `protobuf:"bytes,2,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListImportsRequest) Descriptor deprecated 

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

Deprecated: Use ListImportsRequest.ProtoReflect.Descriptor instead.

func (*ListImportsRequest) GetCollectionName 

func (x *ListImportsRequest) GetCollectionName() string

func (*ListImportsRequest) GetDbName 

func (x *ListImportsRequest) GetDbName() string

func (*ListImportsRequest) ProtoMessage 

func (*ListImportsRequest) ProtoMessage()

func (*ListImportsRequest) ProtoReflect 

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

func (*ListImportsRequest) Reset 

func (x *ListImportsRequest) Reset()

func (*ListImportsRequest) String 

func (x *ListImportsRequest) String() string

type ListImportsRequestInternal 

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

func (*ListImportsRequestInternal) Descriptor deprecated 

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

Deprecated: Use ListImportsRequestInternal.ProtoReflect.Descriptor instead.

func (*ListImportsRequestInternal) GetCollectionID 

func (x *ListImportsRequestInternal) GetCollectionID() int64

func (*ListImportsRequestInternal) GetDbID 

func (x *ListImportsRequestInternal) GetDbID() int64

func (*ListImportsRequestInternal) ProtoMessage 

func (*ListImportsRequestInternal) ProtoMessage()

func (*ListImportsRequestInternal) ProtoReflect 

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

func (*ListImportsRequestInternal) Reset 

func (x *ListImportsRequestInternal) Reset()

func (*ListImportsRequestInternal) String 

func (x *ListImportsRequestInternal) String() string

type ListImportsResponse 

type ListImportsResponse struct {
	Status          *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	JobIDs          []string         `protobuf:"bytes,2,rep,name=jobIDs,proto3" json:"jobIDs,omitempty"`
	States          []ImportJobState `protobuf:"varint,3,rep,packed,name=states,proto3,enum=milvus.proto.internal.ImportJobState" json:"states,omitempty"`
	Reasons         []string         `protobuf:"bytes,4,rep,name=reasons,proto3" json:"reasons,omitempty"`
	Progresses      []int64          `protobuf:"varint,5,rep,packed,name=progresses,proto3" json:"progresses,omitempty"`
	CollectionNames []string         `protobuf:"bytes,6,rep,name=collection_names,json=collectionNames,proto3" json:"collection_names,omitempty"`
	// contains filtered or unexported fields
}

func (*ListImportsResponse) Descriptor deprecated 

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

Deprecated: Use ListImportsResponse.ProtoReflect.Descriptor instead.

func (*ListImportsResponse) GetCollectionNames 

func (x *ListImportsResponse) GetCollectionNames() []string

func (*ListImportsResponse) GetJobIDs 

func (x *ListImportsResponse) GetJobIDs() []string

func (*ListImportsResponse) GetProgresses 

func (x *ListImportsResponse) GetProgresses() []int64

func (*ListImportsResponse) GetReasons 

func (x *ListImportsResponse) GetReasons() []string

func (*ListImportsResponse) GetStates 

func (x *ListImportsResponse) GetStates() []ImportJobState

func (*ListImportsResponse) GetStatus 

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

func (*ListImportsResponse) ProtoMessage 

func (*ListImportsResponse) ProtoMessage()

func (*ListImportsResponse) ProtoReflect 

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

func (*ListImportsResponse) Reset 

func (x *ListImportsResponse) Reset()

func (*ListImportsResponse) String 

func (x *ListImportsResponse) String() string

type ListPolicyRequest 

type ListPolicyRequest struct {

	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPolicyRequest) Descriptor deprecated 

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

Deprecated: Use ListPolicyRequest.ProtoReflect.Descriptor instead.

func (*ListPolicyRequest) GetBase 

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

func (*ListPolicyRequest) ProtoMessage 

func (*ListPolicyRequest) ProtoMessage()

func (*ListPolicyRequest) ProtoReflect 

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

func (*ListPolicyRequest) Reset 

func (x *ListPolicyRequest) Reset()

func (*ListPolicyRequest) String 

func (x *ListPolicyRequest) String() string

type ListPolicyResponse 

type ListPolicyResponse struct {

	// Contain error_code and reason
	Status          *commonpb.Status               `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	PolicyInfos     []string                       `protobuf:"bytes,2,rep,name=policy_infos,json=policyInfos,proto3" json:"policy_infos,omitempty"`
	UserRoles       []string                       `protobuf:"bytes,3,rep,name=user_roles,json=userRoles,proto3" json:"user_roles,omitempty"`
	PrivilegeGroups []*milvuspb.PrivilegeGroupInfo `protobuf:"bytes,4,rep,name=privilege_groups,json=privilegeGroups,proto3" json:"privilege_groups,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPolicyResponse) Descriptor deprecated 

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

Deprecated: Use ListPolicyResponse.ProtoReflect.Descriptor instead.

func (*ListPolicyResponse) GetPolicyInfos 

func (x *ListPolicyResponse) GetPolicyInfos() []string

func (*ListPolicyResponse) GetPrivilegeGroups 

func (x *ListPolicyResponse) GetPrivilegeGroups() []*milvuspb.PrivilegeGroupInfo

func (*ListPolicyResponse) GetStatus 

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

func (*ListPolicyResponse) GetUserRoles 

func (x *ListPolicyResponse) GetUserRoles() []string

func (*ListPolicyResponse) ProtoMessage 

func (*ListPolicyResponse) ProtoMessage()

func (*ListPolicyResponse) ProtoReflect 

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

func (*ListPolicyResponse) Reset 

func (x *ListPolicyResponse) Reset()

func (*ListPolicyResponse) String 

func (x *ListPolicyResponse) String() string

type LoadIndex 

type LoadIndex 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"`
	FieldName   string                   `protobuf:"bytes,3,opt,name=fieldName,proto3" json:"fieldName,omitempty"`
	FieldID     int64                    `protobuf:"varint,4,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	IndexPaths  []string                 `protobuf:"bytes,5,rep,name=index_paths,json=indexPaths,proto3" json:"index_paths,omitempty"`
	IndexParams []*commonpb.KeyValuePair `protobuf:"bytes,6,rep,name=index_params,json=indexParams,proto3" json:"index_params,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadIndex) Descriptor deprecated 

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

Deprecated: Use LoadIndex.ProtoReflect.Descriptor instead.

func (*LoadIndex) GetBase 

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

func (*LoadIndex) GetFieldID 

func (x *LoadIndex) GetFieldID() int64

func (*LoadIndex) GetFieldName 

func (x *LoadIndex) GetFieldName() string

func (*LoadIndex) GetIndexParams 

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

func (*LoadIndex) GetIndexPaths 

func (x *LoadIndex) GetIndexPaths() []string

func (*LoadIndex) GetSegmentID 

func (x *LoadIndex) GetSegmentID() int64

func (*LoadIndex) ProtoMessage 

func (*LoadIndex) ProtoMessage()

func (*LoadIndex) ProtoReflect 

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

func (*LoadIndex) Reset 

func (x *LoadIndex) Reset()

func (*LoadIndex) String 

func (x *LoadIndex) String() string

type NodeInfo 

type NodeInfo struct {
	Address *commonpb.Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Role    string            `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetAddress 

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

func (*NodeInfo) GetRole 

func (x *NodeInfo) GetRole() string

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

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

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

type Rate 

type Rate struct {
	Rt RateType `protobuf:"varint,1,opt,name=rt,proto3,enum=milvus.proto.internal.RateType" json:"rt,omitempty"`
	R  float64  `protobuf:"fixed64,2,opt,name=r,proto3" json:"r,omitempty"`
	// contains filtered or unexported fields
}

func (*Rate) Descriptor deprecated 

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

Deprecated: Use Rate.ProtoReflect.Descriptor instead.

func (*Rate) GetR 

func (x *Rate) GetR() float64

func (*Rate) GetRt 

func (x *Rate) GetRt() RateType

func (*Rate) ProtoMessage 

func (*Rate) ProtoMessage()

func (*Rate) ProtoReflect 

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

func (*Rate) Reset 

func (x *Rate) Reset()

func (*Rate) String 

func (x *Rate) String() string

type RateScope 

type RateScope int32
const (
	RateScope_Cluster    RateScope = 0
	RateScope_Database   RateScope = 1
	RateScope_Collection RateScope = 2
	RateScope_Partition  RateScope = 3
)

func (RateScope) Descriptor 

func (RateScope) Descriptor() protoreflect.EnumDescriptor

func (RateScope) Enum 

func (x RateScope) Enum() *RateScope

func (RateScope) EnumDescriptor deprecated 

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

Deprecated: Use RateScope.Descriptor instead.

func (RateScope) Number 

func (x RateScope) Number() protoreflect.EnumNumber

func (RateScope) String 

func (x RateScope) String() string

func (RateScope) Type 

func (RateScope) Type() protoreflect.EnumType

type RateType 

type RateType int32
const (
	RateType_DDLCollection RateType = 0
	RateType_DDLPartition  RateType = 1
	RateType_DDLIndex      RateType = 2
	RateType_DDLFlush      RateType = 3
	RateType_DDLCompaction RateType = 4
	RateType_DMLInsert     RateType = 5
	RateType_DMLDelete     RateType = 6
	RateType_DMLBulkLoad   RateType = 7
	RateType_DQLSearch     RateType = 8
	RateType_DQLQuery      RateType = 9
	RateType_DMLUpsert     RateType = 10
	RateType_DDLDB         RateType = 11
)

func (RateType) Descriptor 

func (RateType) Descriptor() protoreflect.EnumDescriptor

func (RateType) Enum 

func (x RateType) Enum() *RateType

func (RateType) EnumDescriptor deprecated 

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

Deprecated: Use RateType.Descriptor instead.

func (RateType) Number 

func (x RateType) Number() protoreflect.EnumNumber

func (RateType) String 

func (x RateType) String() string

func (RateType) Type 

func (RateType) Type() protoreflect.EnumType

type RetrieveRequest 

type RetrieveRequest struct {
	Base                         *commonpb.MsgBase         `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	ReqID                        int64                     `protobuf:"varint,2,opt,name=reqID,proto3" json:"reqID,omitempty"`
	DbID                         int64                     `protobuf:"varint,3,opt,name=dbID,proto3" json:"dbID,omitempty"`
	CollectionID                 int64                     `protobuf:"varint,4,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionIDs                 []int64                   `protobuf:"varint,5,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	SerializedExprPlan           []byte                    `protobuf:"bytes,6,opt,name=serialized_expr_plan,json=serializedExprPlan,proto3" json:"serialized_expr_plan,omitempty"`
	OutputFieldsId               []int64                   `protobuf:"varint,7,rep,packed,name=output_fields_id,json=outputFieldsId,proto3" json:"output_fields_id,omitempty"`
	MvccTimestamp                uint64                    `protobuf:"varint,8,opt,name=mvcc_timestamp,json=mvccTimestamp,proto3" json:"mvcc_timestamp,omitempty"`
	GuaranteeTimestamp           uint64                    `protobuf:"varint,9,opt,name=guarantee_timestamp,json=guaranteeTimestamp,proto3" json:"guarantee_timestamp,omitempty"`
	TimeoutTimestamp             uint64                    `protobuf:"varint,10,opt,name=timeout_timestamp,json=timeoutTimestamp,proto3" json:"timeout_timestamp,omitempty"`
	Limit                        int64                     `protobuf:"varint,11,opt,name=limit,proto3" json:"limit,omitempty"` // Optional
	IgnoreGrowing                bool                      `protobuf:"varint,12,opt,name=ignoreGrowing,proto3" json:"ignoreGrowing,omitempty"`
	IsCount                      bool                      `protobuf:"varint,13,opt,name=is_count,json=isCount,proto3" json:"is_count,omitempty"`
	IterationExtensionReduceRate int64                     `` /* 151-byte string literal not displayed */
	Username                     string                    `protobuf:"bytes,15,opt,name=username,proto3" json:"username,omitempty"`
	ReduceStopForBest            bool                      `protobuf:"varint,16,opt,name=reduce_stop_for_best,json=reduceStopForBest,proto3" json:"reduce_stop_for_best,omitempty"` //deprecated
	ReduceType                   int32                     `protobuf:"varint,17,opt,name=reduce_type,json=reduceType,proto3" json:"reduce_type,omitempty"`
	ConsistencyLevel             commonpb.ConsistencyLevel `` /* 153-byte string literal not displayed */
	IsIterator                   bool                      `protobuf:"varint,19,opt,name=is_iterator,json=isIterator,proto3" json:"is_iterator,omitempty"`
	// contains filtered or unexported fields
}

func (*RetrieveRequest) Descriptor deprecated 

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

Deprecated: Use RetrieveRequest.ProtoReflect.Descriptor instead.

func (*RetrieveRequest) GetBase 

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

func (*RetrieveRequest) GetCollectionID 

func (x *RetrieveRequest) GetCollectionID() int64

func (*RetrieveRequest) GetConsistencyLevel 

func (x *RetrieveRequest) GetConsistencyLevel() commonpb.ConsistencyLevel

func (*RetrieveRequest) GetDbID 

func (x *RetrieveRequest) GetDbID() int64

func (*RetrieveRequest) GetGuaranteeTimestamp 

func (x *RetrieveRequest) GetGuaranteeTimestamp() uint64

func (*RetrieveRequest) GetIgnoreGrowing 

func (x *RetrieveRequest) GetIgnoreGrowing() bool

func (*RetrieveRequest) GetIsCount 

func (x *RetrieveRequest) GetIsCount() bool

func (*RetrieveRequest) GetIsIterator 

func (x *RetrieveRequest) GetIsIterator() bool

func (*RetrieveRequest) GetIterationExtensionReduceRate 

func (x *RetrieveRequest) GetIterationExtensionReduceRate() int64

func (*RetrieveRequest) GetLimit 

func (x *RetrieveRequest) GetLimit() int64

func (*RetrieveRequest) GetMvccTimestamp 

func (x *RetrieveRequest) GetMvccTimestamp() uint64

func (*RetrieveRequest) GetOutputFieldsId 

func (x *RetrieveRequest) GetOutputFieldsId() []int64

func (*RetrieveRequest) GetPartitionIDs 

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

func (*RetrieveRequest) GetReduceStopForBest 

func (x *RetrieveRequest) GetReduceStopForBest() bool

func (*RetrieveRequest) GetReduceType 

func (x *RetrieveRequest) GetReduceType() int32

func (*RetrieveRequest) GetReqID 

func (x *RetrieveRequest) GetReqID() int64

func (*RetrieveRequest) GetSerializedExprPlan 

func (x *RetrieveRequest) GetSerializedExprPlan() []byte

func (*RetrieveRequest) GetTimeoutTimestamp 

func (x *RetrieveRequest) GetTimeoutTimestamp() uint64

func (*RetrieveRequest) GetUsername 

func (x *RetrieveRequest) GetUsername() string

func (*RetrieveRequest) ProtoMessage 

func (*RetrieveRequest) ProtoMessage()

func (*RetrieveRequest) ProtoReflect 

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

func (*RetrieveRequest) Reset 

func (x *RetrieveRequest) Reset()

func (*RetrieveRequest) String 

func (x *RetrieveRequest) String() string

type RetrieveResults 

type RetrieveResults struct {
	Base                      *commonpb.MsgBase     `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Status                    *commonpb.Status      `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	ReqID                     int64                 `protobuf:"varint,3,opt,name=reqID,proto3" json:"reqID,omitempty"`
	Ids                       *schemapb.IDs         `protobuf:"bytes,4,opt,name=ids,proto3" json:"ids,omitempty"`
	FieldsData                []*schemapb.FieldData `protobuf:"bytes,5,rep,name=fields_data,json=fieldsData,proto3" json:"fields_data,omitempty"`
	SealedSegmentIDsRetrieved []int64               `` /* 146-byte string literal not displayed */
	ChannelIDsRetrieved       []string              `protobuf:"bytes,7,rep,name=channelIDs_retrieved,json=channelIDsRetrieved,proto3" json:"channelIDs_retrieved,omitempty"`
	GlobalSealedSegmentIDs    []int64               `` /* 137-byte string literal not displayed */
	// query request cost
	CostAggregation  *CostAggregation `protobuf:"bytes,13,opt,name=costAggregation,proto3" json:"costAggregation,omitempty"`
	AllRetrieveCount int64            `protobuf:"varint,14,opt,name=all_retrieve_count,json=allRetrieveCount,proto3" json:"all_retrieve_count,omitempty"`
	HasMoreResult    bool             `protobuf:"varint,15,opt,name=has_more_result,json=hasMoreResult,proto3" json:"has_more_result,omitempty"`
	// contains filtered or unexported fields
}

func (*RetrieveResults) Descriptor deprecated 

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

Deprecated: Use RetrieveResults.ProtoReflect.Descriptor instead.

func (*RetrieveResults) GetAllRetrieveCount 

func (x *RetrieveResults) GetAllRetrieveCount() int64

func (*RetrieveResults) GetBase 

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

func (*RetrieveResults) GetChannelIDsRetrieved 

func (x *RetrieveResults) GetChannelIDsRetrieved() []string

func (*RetrieveResults) GetCostAggregation 

func (x *RetrieveResults) GetCostAggregation() *CostAggregation

func (*RetrieveResults) GetFieldsData 

func (x *RetrieveResults) GetFieldsData() []*schemapb.FieldData

func (*RetrieveResults) GetGlobalSealedSegmentIDs 

func (x *RetrieveResults) GetGlobalSealedSegmentIDs() []int64

func (*RetrieveResults) GetHasMoreResult 

func (x *RetrieveResults) GetHasMoreResult() bool

func (*RetrieveResults) GetIds 

func (x *RetrieveResults) GetIds() *schemapb.IDs

func (*RetrieveResults) GetReqID 

func (x *RetrieveResults) GetReqID() int64

func (*RetrieveResults) GetSealedSegmentIDsRetrieved 

func (x *RetrieveResults) GetSealedSegmentIDsRetrieved() []int64

func (*RetrieveResults) GetStatus 

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

func (*RetrieveResults) ProtoMessage 

func (*RetrieveResults) ProtoMessage()

func (*RetrieveResults) ProtoReflect 

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

func (*RetrieveResults) Reset 

func (x *RetrieveResults) Reset()

func (*RetrieveResults) String 

func (x *RetrieveResults) String() string

type SearchRequest 

type SearchRequest struct {
	Base         *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	ReqID        int64             `protobuf:"varint,2,opt,name=reqID,proto3" json:"reqID,omitempty"`
	DbID         int64             `protobuf:"varint,3,opt,name=dbID,proto3" json:"dbID,omitempty"`
	CollectionID int64             `protobuf:"varint,4,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionIDs []int64           `protobuf:"varint,5,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	Dsl          string            `protobuf:"bytes,6,opt,name=dsl,proto3" json:"dsl,omitempty"`
	// serialized `PlaceholderGroup`
	PlaceholderGroup   []byte                    `protobuf:"bytes,7,opt,name=placeholder_group,json=placeholderGroup,proto3" json:"placeholder_group,omitempty"`
	DslType            commonpb.DslType          `protobuf:"varint,8,opt,name=dsl_type,json=dslType,proto3,enum=milvus.proto.common.DslType" json:"dsl_type,omitempty"`
	SerializedExprPlan []byte                    `protobuf:"bytes,9,opt,name=serialized_expr_plan,json=serializedExprPlan,proto3" json:"serialized_expr_plan,omitempty"`
	OutputFieldsId     []int64                   `protobuf:"varint,10,rep,packed,name=output_fields_id,json=outputFieldsId,proto3" json:"output_fields_id,omitempty"`
	MvccTimestamp      uint64                    `protobuf:"varint,11,opt,name=mvcc_timestamp,json=mvccTimestamp,proto3" json:"mvcc_timestamp,omitempty"`
	GuaranteeTimestamp uint64                    `protobuf:"varint,12,opt,name=guarantee_timestamp,json=guaranteeTimestamp,proto3" json:"guarantee_timestamp,omitempty"`
	TimeoutTimestamp   uint64                    `protobuf:"varint,13,opt,name=timeout_timestamp,json=timeoutTimestamp,proto3" json:"timeout_timestamp,omitempty"`
	Nq                 int64                     `protobuf:"varint,14,opt,name=nq,proto3" json:"nq,omitempty"`
	Topk               int64                     `protobuf:"varint,15,opt,name=topk,proto3" json:"topk,omitempty"`
	MetricType         string                    `protobuf:"bytes,16,opt,name=metricType,proto3" json:"metricType,omitempty"`
	IgnoreGrowing      bool                      `protobuf:"varint,17,opt,name=ignoreGrowing,proto3" json:"ignoreGrowing,omitempty"` // Optional
	Username           string                    `protobuf:"bytes,18,opt,name=username,proto3" json:"username,omitempty"`
	SubReqs            []*SubSearchRequest       `protobuf:"bytes,19,rep,name=sub_reqs,json=subReqs,proto3" json:"sub_reqs,omitempty"`
	IsAdvanced         bool                      `protobuf:"varint,20,opt,name=is_advanced,json=isAdvanced,proto3" json:"is_advanced,omitempty"`
	Offset             int64                     `protobuf:"varint,21,opt,name=offset,proto3" json:"offset,omitempty"`
	ConsistencyLevel   commonpb.ConsistencyLevel `` /* 153-byte string literal not displayed */
	GroupByFieldId     int64                     `protobuf:"varint,23,opt,name=group_by_field_id,json=groupByFieldId,proto3" json:"group_by_field_id,omitempty"`
	GroupSize          int64                     `protobuf:"varint,24,opt,name=group_size,json=groupSize,proto3" json:"group_size,omitempty"`
	FieldId            int64                     `protobuf:"varint,25,opt,name=field_id,json=fieldId,proto3" json:"field_id,omitempty"`
	IsTopkReduce       bool                      `protobuf:"varint,26,opt,name=is_topk_reduce,json=isTopkReduce,proto3" json:"is_topk_reduce,omitempty"`
	IsRecallEvaluation bool                      `protobuf:"varint,27,opt,name=is_recall_evaluation,json=isRecallEvaluation,proto3" json:"is_recall_evaluation,omitempty"`
	IsIterator         bool                      `protobuf:"varint,28,opt,name=is_iterator,json=isIterator,proto3" json:"is_iterator,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchRequest) Descriptor deprecated 

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetBase 

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

func (*SearchRequest) GetCollectionID 

func (x *SearchRequest) GetCollectionID() int64

func (*SearchRequest) GetConsistencyLevel 

func (x *SearchRequest) GetConsistencyLevel() commonpb.ConsistencyLevel

func (*SearchRequest) GetDbID 

func (x *SearchRequest) GetDbID() int64

func (*SearchRequest) GetDsl 

func (x *SearchRequest) GetDsl() string

func (*SearchRequest) GetDslType 

func (x *SearchRequest) GetDslType() commonpb.DslType

func (*SearchRequest) GetFieldId 

func (x *SearchRequest) GetFieldId() int64

func (*SearchRequest) GetGroupByFieldId 

func (x *SearchRequest) GetGroupByFieldId() int64

func (*SearchRequest) GetGroupSize 

func (x *SearchRequest) GetGroupSize() int64

func (*SearchRequest) GetGuaranteeTimestamp 

func (x *SearchRequest) GetGuaranteeTimestamp() uint64

func (*SearchRequest) GetIgnoreGrowing 

func (x *SearchRequest) GetIgnoreGrowing() bool

func (*SearchRequest) GetIsAdvanced 

func (x *SearchRequest) GetIsAdvanced() bool

func (*SearchRequest) GetIsIterator 

func (x *SearchRequest) GetIsIterator() bool

func (*SearchRequest) GetIsRecallEvaluation 

func (x *SearchRequest) GetIsRecallEvaluation() bool

func (*SearchRequest) GetIsTopkReduce 

func (x *SearchRequest) GetIsTopkReduce() bool

func (*SearchRequest) GetMetricType 

func (x *SearchRequest) GetMetricType() string

func (*SearchRequest) GetMvccTimestamp 

func (x *SearchRequest) GetMvccTimestamp() uint64

func (*SearchRequest) GetNq 

func (x *SearchRequest) GetNq() int64

func (*SearchRequest) GetOffset 

func (x *SearchRequest) GetOffset() int64

func (*SearchRequest) GetOutputFieldsId 

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

func (*SearchRequest) GetPartitionIDs 

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

func (*SearchRequest) GetPlaceholderGroup 

func (x *SearchRequest) GetPlaceholderGroup() []byte

func (*SearchRequest) GetReqID 

func (x *SearchRequest) GetReqID() int64

func (*SearchRequest) GetSerializedExprPlan 

func (x *SearchRequest) GetSerializedExprPlan() []byte

func (*SearchRequest) GetSubReqs 

func (x *SearchRequest) GetSubReqs() []*SubSearchRequest

func (*SearchRequest) GetTimeoutTimestamp 

func (x *SearchRequest) GetTimeoutTimestamp() uint64

func (*SearchRequest) GetTopk 

func (x *SearchRequest) GetTopk() int64

func (*SearchRequest) GetUsername 

func (x *SearchRequest) GetUsername() string

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

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

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) String 

func (x *SearchRequest) String() string

type SearchResults 

type SearchResults struct {
	Base                     *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Status                   *commonpb.Status  `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	ReqID                    int64             `protobuf:"varint,3,opt,name=reqID,proto3" json:"reqID,omitempty"`
	MetricType               string            `protobuf:"bytes,4,opt,name=metric_type,json=metricType,proto3" json:"metric_type,omitempty"`
	NumQueries               int64             `protobuf:"varint,5,opt,name=num_queries,json=numQueries,proto3" json:"num_queries,omitempty"`
	TopK                     int64             `protobuf:"varint,6,opt,name=top_k,json=topK,proto3" json:"top_k,omitempty"`
	SealedSegmentIDsSearched []int64           `` /* 143-byte string literal not displayed */
	ChannelIDsSearched       []string          `protobuf:"bytes,8,rep,name=channelIDs_searched,json=channelIDsSearched,proto3" json:"channelIDs_searched,omitempty"`
	GlobalSealedSegmentIDs   []int64           `` /* 137-byte string literal not displayed */
	// schema.SearchResultsData inside
	SlicedBlob     []byte `protobuf:"bytes,10,opt,name=sliced_blob,json=slicedBlob,proto3" json:"sliced_blob,omitempty"`
	SlicedNumCount int64  `protobuf:"varint,11,opt,name=sliced_num_count,json=slicedNumCount,proto3" json:"sliced_num_count,omitempty"`
	SlicedOffset   int64  `protobuf:"varint,12,opt,name=sliced_offset,json=slicedOffset,proto3" json:"sliced_offset,omitempty"`
	// search request cost
	CostAggregation    *CostAggregation    `protobuf:"bytes,13,opt,name=costAggregation,proto3" json:"costAggregation,omitempty"`
	ChannelsMvcc       map[string]uint64   `` /* 187-byte string literal not displayed */
	SubResults         []*SubSearchResults `protobuf:"bytes,15,rep,name=sub_results,json=subResults,proto3" json:"sub_results,omitempty"`
	IsAdvanced         bool                `protobuf:"varint,16,opt,name=is_advanced,json=isAdvanced,proto3" json:"is_advanced,omitempty"`
	AllSearchCount     int64               `protobuf:"varint,17,opt,name=all_search_count,json=allSearchCount,proto3" json:"all_search_count,omitempty"`
	IsTopkReduce       bool                `protobuf:"varint,18,opt,name=is_topk_reduce,json=isTopkReduce,proto3" json:"is_topk_reduce,omitempty"`
	IsRecallEvaluation bool                `protobuf:"varint,19,opt,name=is_recall_evaluation,json=isRecallEvaluation,proto3" json:"is_recall_evaluation,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResults) Descriptor deprecated 

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

Deprecated: Use SearchResults.ProtoReflect.Descriptor instead.

func (*SearchResults) GetAllSearchCount 

func (x *SearchResults) GetAllSearchCount() int64

func (*SearchResults) GetBase 

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

func (*SearchResults) GetChannelIDsSearched 

func (x *SearchResults) GetChannelIDsSearched() []string

func (*SearchResults) GetChannelsMvcc 

func (x *SearchResults) GetChannelsMvcc() map[string]uint64

func (*SearchResults) GetCostAggregation 

func (x *SearchResults) GetCostAggregation() *CostAggregation

func (*SearchResults) GetGlobalSealedSegmentIDs 

func (x *SearchResults) GetGlobalSealedSegmentIDs() []int64

func (*SearchResults) GetIsAdvanced 

func (x *SearchResults) GetIsAdvanced() bool

func (*SearchResults) GetIsRecallEvaluation 

func (x *SearchResults) GetIsRecallEvaluation() bool

func (*SearchResults) GetIsTopkReduce 

func (x *SearchResults) GetIsTopkReduce() bool

func (*SearchResults) GetMetricType 

func (x *SearchResults) GetMetricType() string

func (*SearchResults) GetNumQueries 

func (x *SearchResults) GetNumQueries() int64

func (*SearchResults) GetReqID 

func (x *SearchResults) GetReqID() int64

func (*SearchResults) GetSealedSegmentIDsSearched 

func (x *SearchResults) GetSealedSegmentIDsSearched() []int64

func (*SearchResults) GetSlicedBlob 

func (x *SearchResults) GetSlicedBlob() []byte

func (*SearchResults) GetSlicedNumCount 

func (x *SearchResults) GetSlicedNumCount() int64

func (*SearchResults) GetSlicedOffset 

func (x *SearchResults) GetSlicedOffset() int64

func (*SearchResults) GetStatus 

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

func (*SearchResults) GetSubResults 

func (x *SearchResults) GetSubResults() []*SubSearchResults

func (*SearchResults) GetTopK 

func (x *SearchResults) GetTopK() int64

func (*SearchResults) ProtoMessage 

func (*SearchResults) ProtoMessage()

func (*SearchResults) ProtoReflect 

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

func (*SearchResults) Reset 

func (x *SearchResults) Reset()

func (*SearchResults) String 

func (x *SearchResults) String() string

type SegmentInfo added in v2.5.7 

type SegmentInfo struct {
	SegmentID    int64                 `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	CollectionID int64                 `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionID  int64                 `protobuf:"varint,3,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	VChannel     string                `protobuf:"bytes,4,opt,name=vChannel,proto3" json:"vChannel,omitempty"`
	NumRows      int64                 `protobuf:"varint,5,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	State        commonpb.SegmentState `protobuf:"varint,6,opt,name=state,proto3,enum=milvus.proto.common.SegmentState" json:"state,omitempty"`
	Level        commonpb.SegmentLevel `protobuf:"varint,7,opt,name=level,proto3,enum=milvus.proto.common.SegmentLevel" json:"level,omitempty"`
	IsSorted     bool                  `protobuf:"varint,8,opt,name=is_sorted,json=isSorted,proto3" json:"is_sorted,omitempty"`
	InsertLogs   []*FieldBinlog        `protobuf:"bytes,9,rep,name=insert_logs,json=insertLogs,proto3" json:"insert_logs,omitempty"`
	DeltaLogs    []*FieldBinlog        `protobuf:"bytes,10,rep,name=delta_logs,json=deltaLogs,proto3" json:"delta_logs,omitempty"`
	StatsLogs    []*FieldBinlog        `protobuf:"bytes,11,rep,name=stats_logs,json=statsLogs,proto3" json:"stats_logs,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentInfo) Descriptor deprecated added in v2.5.7 

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

Deprecated: Use SegmentInfo.ProtoReflect.Descriptor instead.

func (*SegmentInfo) GetCollectionID added in v2.5.7 

func (x *SegmentInfo) GetCollectionID() int64

func (*SegmentInfo) GetDeltaLogs added in v2.5.7 

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

func (*SegmentInfo) GetInsertLogs added in v2.5.7 

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

func (*SegmentInfo) GetIsSorted added in v2.5.7 

func (x *SegmentInfo) GetIsSorted() bool

func (*SegmentInfo) GetLevel added in v2.5.7 

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

func (*SegmentInfo) GetNumRows added in v2.5.7 

func (x *SegmentInfo) GetNumRows() int64

func (*SegmentInfo) GetPartitionID added in v2.5.7 

func (x *SegmentInfo) GetPartitionID() int64

func (*SegmentInfo) GetSegmentID added in v2.5.7 

func (x *SegmentInfo) GetSegmentID() int64

func (*SegmentInfo) GetState added in v2.5.7 

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

func (*SegmentInfo) GetStatsLogs added in v2.5.7 

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

func (*SegmentInfo) GetVChannel added in v2.5.7 

func (x *SegmentInfo) GetVChannel() string

func (*SegmentInfo) ProtoMessage added in v2.5.7 

func (*SegmentInfo) ProtoMessage()

func (*SegmentInfo) ProtoReflect added in v2.5.7 

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

func (*SegmentInfo) Reset added in v2.5.7 

func (x *SegmentInfo) Reset()

func (*SegmentInfo) String added in v2.5.7 

func (x *SegmentInfo) String() string

type SegmentStats 

type SegmentStats struct {
	SegmentID        int64 `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	MemorySize       int64 `protobuf:"varint,2,opt,name=memory_size,json=memorySize,proto3" json:"memory_size,omitempty"`
	NumRows          int64 `protobuf:"varint,3,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	RecentlyModified bool  `protobuf:"varint,4,opt,name=recently_modified,json=recentlyModified,proto3" json:"recently_modified,omitempty"`
	// contains filtered or unexported fields
}

func (*SegmentStats) Descriptor deprecated 

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

Deprecated: Use SegmentStats.ProtoReflect.Descriptor instead.

func (*SegmentStats) GetMemorySize 

func (x *SegmentStats) GetMemorySize() int64

func (*SegmentStats) GetNumRows 

func (x *SegmentStats) GetNumRows() int64

func (*SegmentStats) GetRecentlyModified 

func (x *SegmentStats) GetRecentlyModified() bool

func (*SegmentStats) GetSegmentID 

func (x *SegmentStats) GetSegmentID() 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 ShowConfigurationsRequest 

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

func (*ShowConfigurationsRequest) Descriptor deprecated 

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

Deprecated: Use ShowConfigurationsRequest.ProtoReflect.Descriptor instead.

func (*ShowConfigurationsRequest) GetBase 

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

func (*ShowConfigurationsRequest) GetPattern 

func (x *ShowConfigurationsRequest) GetPattern() string

func (*ShowConfigurationsRequest) ProtoMessage 

func (*ShowConfigurationsRequest) ProtoMessage()

func (*ShowConfigurationsRequest) ProtoReflect 

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

func (*ShowConfigurationsRequest) Reset 

func (x *ShowConfigurationsRequest) Reset()

func (*ShowConfigurationsRequest) String 

func (x *ShowConfigurationsRequest) String() string

type ShowConfigurationsResponse 

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

func (*ShowConfigurationsResponse) Descriptor deprecated 

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

Deprecated: Use ShowConfigurationsResponse.ProtoReflect.Descriptor instead.

func (*ShowConfigurationsResponse) GetConfiguations 

func (x *ShowConfigurationsResponse) GetConfiguations() []*commonpb.KeyValuePair

func (*ShowConfigurationsResponse) GetStatus 

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

func (*ShowConfigurationsResponse) ProtoMessage 

func (*ShowConfigurationsResponse) ProtoMessage()

func (*ShowConfigurationsResponse) ProtoReflect 

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

func (*ShowConfigurationsResponse) Reset 

func (x *ShowConfigurationsResponse) Reset()

func (*ShowConfigurationsResponse) String 

func (x *ShowConfigurationsResponse) String() string

type StringList 

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

func (*StringList) Descriptor deprecated 

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

Deprecated: Use StringList.ProtoReflect.Descriptor instead.

func (*StringList) GetStatus 

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

func (*StringList) GetValues 

func (x *StringList) GetValues() []string

func (*StringList) ProtoMessage 

func (*StringList) ProtoMessage()

func (*StringList) ProtoReflect 

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

func (*StringList) Reset 

func (x *StringList) Reset()

func (*StringList) String 

func (x *StringList) String() string

type SubSearchRequest 

type SubSearchRequest struct {
	Dsl string `protobuf:"bytes,1,opt,name=dsl,proto3" json:"dsl,omitempty"`
	// serialized `PlaceholderGroup`
	PlaceholderGroup   []byte           `protobuf:"bytes,2,opt,name=placeholder_group,json=placeholderGroup,proto3" json:"placeholder_group,omitempty"`
	DslType            commonpb.DslType `protobuf:"varint,3,opt,name=dsl_type,json=dslType,proto3,enum=milvus.proto.common.DslType" json:"dsl_type,omitempty"`
	SerializedExprPlan []byte           `protobuf:"bytes,4,opt,name=serialized_expr_plan,json=serializedExprPlan,proto3" json:"serialized_expr_plan,omitempty"`
	Nq                 int64            `protobuf:"varint,5,opt,name=nq,proto3" json:"nq,omitempty"`
	PartitionIDs       []int64          `protobuf:"varint,6,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	Topk               int64            `protobuf:"varint,7,opt,name=topk,proto3" json:"topk,omitempty"`
	Offset             int64            `protobuf:"varint,8,opt,name=offset,proto3" json:"offset,omitempty"`
	MetricType         string           `protobuf:"bytes,9,opt,name=metricType,proto3" json:"metricType,omitempty"`
	GroupByFieldId     int64            `protobuf:"varint,10,opt,name=group_by_field_id,json=groupByFieldId,proto3" json:"group_by_field_id,omitempty"`
	GroupSize          int64            `protobuf:"varint,11,opt,name=group_size,json=groupSize,proto3" json:"group_size,omitempty"`
	FieldId            int64            `protobuf:"varint,12,opt,name=field_id,json=fieldId,proto3" json:"field_id,omitempty"`
	IgnoreGrowing      bool             `protobuf:"varint,13,opt,name=ignore_growing,json=ignoreGrowing,proto3" json:"ignore_growing,omitempty"`
	// contains filtered or unexported fields
}

func (*SubSearchRequest) Descriptor deprecated 

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

Deprecated: Use SubSearchRequest.ProtoReflect.Descriptor instead.

func (*SubSearchRequest) GetDsl 

func (x *SubSearchRequest) GetDsl() string

func (*SubSearchRequest) GetDslType 

func (x *SubSearchRequest) GetDslType() commonpb.DslType

func (*SubSearchRequest) GetFieldId 

func (x *SubSearchRequest) GetFieldId() int64

func (*SubSearchRequest) GetGroupByFieldId 

func (x *SubSearchRequest) GetGroupByFieldId() int64

func (*SubSearchRequest) GetGroupSize 

func (x *SubSearchRequest) GetGroupSize() int64

func (*SubSearchRequest) GetIgnoreGrowing 

func (x *SubSearchRequest) GetIgnoreGrowing() bool

func (*SubSearchRequest) GetMetricType 

func (x *SubSearchRequest) GetMetricType() string

func (*SubSearchRequest) GetNq 

func (x *SubSearchRequest) GetNq() int64

func (*SubSearchRequest) GetOffset 

func (x *SubSearchRequest) GetOffset() int64

func (*SubSearchRequest) GetPartitionIDs 

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

func (*SubSearchRequest) GetPlaceholderGroup 

func (x *SubSearchRequest) GetPlaceholderGroup() []byte

func (*SubSearchRequest) GetSerializedExprPlan 

func (x *SubSearchRequest) GetSerializedExprPlan() []byte

func (*SubSearchRequest) GetTopk 

func (x *SubSearchRequest) GetTopk() int64

func (*SubSearchRequest) ProtoMessage 

func (*SubSearchRequest) ProtoMessage()

func (*SubSearchRequest) ProtoReflect 

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

func (*SubSearchRequest) Reset 

func (x *SubSearchRequest) Reset()

func (*SubSearchRequest) String 

func (x *SubSearchRequest) String() string

type SubSearchResults 

type SubSearchResults struct {
	MetricType string `protobuf:"bytes,1,opt,name=metric_type,json=metricType,proto3" json:"metric_type,omitempty"`
	NumQueries int64  `protobuf:"varint,2,opt,name=num_queries,json=numQueries,proto3" json:"num_queries,omitempty"`
	TopK       int64  `protobuf:"varint,3,opt,name=top_k,json=topK,proto3" json:"top_k,omitempty"`
	// schema.SearchResultsData inside
	SlicedBlob     []byte `protobuf:"bytes,4,opt,name=sliced_blob,json=slicedBlob,proto3" json:"sliced_blob,omitempty"`
	SlicedNumCount int64  `protobuf:"varint,5,opt,name=sliced_num_count,json=slicedNumCount,proto3" json:"sliced_num_count,omitempty"`
	SlicedOffset   int64  `protobuf:"varint,6,opt,name=sliced_offset,json=slicedOffset,proto3" json:"sliced_offset,omitempty"`
	// to indicate it belongs to which sub request
	ReqIndex int64 `protobuf:"varint,7,opt,name=req_index,json=reqIndex,proto3" json:"req_index,omitempty"`
	// contains filtered or unexported fields
}

func (*SubSearchResults) Descriptor deprecated 

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

Deprecated: Use SubSearchResults.ProtoReflect.Descriptor instead.

func (*SubSearchResults) GetMetricType 

func (x *SubSearchResults) GetMetricType() string

func (*SubSearchResults) GetNumQueries 

func (x *SubSearchResults) GetNumQueries() int64

func (*SubSearchResults) GetReqIndex 

func (x *SubSearchResults) GetReqIndex() int64

func (*SubSearchResults) GetSlicedBlob 

func (x *SubSearchResults) GetSlicedBlob() []byte

func (*SubSearchResults) GetSlicedNumCount 

func (x *SubSearchResults) GetSlicedNumCount() int64

func (*SubSearchResults) GetSlicedOffset 

func (x *SubSearchResults) GetSlicedOffset() int64

func (*SubSearchResults) GetTopK 

func (x *SubSearchResults) GetTopK() int64

func (*SubSearchResults) ProtoMessage 

func (*SubSearchResults) ProtoMessage()

func (*SubSearchResults) ProtoReflect 

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

func (*SubSearchResults) Reset 

func (x *SubSearchResults) Reset()

func (*SubSearchResults) String 

func (x *SubSearchResults) 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.