proto

package
v0.0.0-...-42a1afe Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	OperationType_name = map[int32]string{
		0: "OP_INSERT",
		1: "OP_UPDATE",
		2: "OP_DELETE",
	}
	OperationType_value = map[string]int32{
		"OP_INSERT": 0,
		"OP_UPDATE": 1,
		"OP_DELETE": 2,
	}
)

Enum value maps for OperationType.

View Source 
var (
	FeatureType_name = map[int32]string{
		0: "FT_UNDEFINED",
		1: "FT_BINARY32",
		2: "FT_BINARY64",
		3: "FT_FP16",
		4: "FT_FP32",
		5: "FT_FP64",
		6: "FT_INT8",
		7: "FT_INT16",
		8: "FT_INT4",
	}
	FeatureType_value = map[string]int32{
		"FT_UNDEFINED": 0,
		"FT_BINARY32":  1,
		"FT_BINARY64":  2,
		"FT_FP16":      3,
		"FT_FP32":      4,
		"FT_FP64":      5,
		"FT_INT8":      6,
		"FT_INT16":     7,
		"FT_INT4":      8,
	}
)

Enum value maps for FeatureType.

View Source 
var (
	IndexType_name = map[int32]string{
		0: "IT_UNDEFINED",
		1: "IT_PROXIMA_GRAPH_INDEX",
	}
	IndexType_value = map[string]int32{
		"IT_UNDEFINED":           0,
		"IT_PROXIMA_GRAPH_INDEX": 1,
	}
)

Enum value maps for IndexType.

View Source 
var (
	DataType_name = map[int32]string{
		0:  "DT_UNDEFINED",
		1:  "DT_BINARY",
		2:  "DT_STRING",
		3:  "DT_BOOL",
		4:  "DT_INT32",
		5:  "DT_INT64",
		6:  "DT_UINT32",
		7:  "DT_UINT64",
		8:  "DT_FLOAT",
		9:  "DT_DOUBLE",
		20: "DT_VECTOR_BINARY32",
		21: "DT_VECTOR_BINARY64",
		22: "DT_VECTOR_FP16",
		23: "DT_VECTOR_FP32",
		24: "DT_VECTOR_FP64",
		25: "DT_VECTOR_INT4",
		26: "DT_VECTOR_INT8",
		27: "DT_VECTOR_INT16",
	}
	DataType_value = map[string]int32{
		"DT_UNDEFINED":       0,
		"DT_BINARY":          1,
		"DT_STRING":          2,
		"DT_BOOL":            3,
		"DT_INT32":           4,
		"DT_INT64":           5,
		"DT_UINT32":          6,
		"DT_UINT64":          7,
		"DT_FLOAT":           8,
		"DT_DOUBLE":          9,
		"DT_VECTOR_BINARY32": 20,
		"DT_VECTOR_BINARY64": 21,
		"DT_VECTOR_FP16":     22,
		"DT_VECTOR_FP32":     23,
		"DT_VECTOR_FP64":     24,
		"DT_VECTOR_INT4":     25,
		"DT_VECTOR_INT8":     26,
		"DT_VECTOR_INT16":    27,
	}
)

Enum value maps for DataType.

View Source 
var (
	GenericValueMeta_FieldType_name = map[int32]string{
		0: "FT_BYTES",
		1: "FT_STRING",
		2: "FT_BOOL",
		3: "FT_INT32",
		4: "FT_INT64",
		5: "FT_UINT32",
		6: "FT_UINT64",
		7: "FT_FLOAT",
		8: "FT_DOUBLE",
	}
	GenericValueMeta_FieldType_value = map[string]int32{
		"FT_BYTES":  0,
		"FT_STRING": 1,
		"FT_BOOL":   2,
		"FT_INT32":  3,
		"FT_INT64":  4,
		"FT_UINT32": 5,
		"FT_UINT64": 6,
		"FT_FLOAT":  7,
		"FT_DOUBLE": 8,
	}
)

Enum value maps for GenericValueMeta_FieldType.

View Source 
var (
	CollectionConfig_RepositoryConfig_RepositoryType_name = map[int32]string{
		0: "RT_DATABASE",
	}
	CollectionConfig_RepositoryConfig_RepositoryType_value = map[string]int32{
		"RT_DATABASE": 0,
	}
)

Enum value maps for CollectionConfig_RepositoryConfig_RepositoryType.

View Source 
var (
	CollectionInfo_CollectionStatus_name = map[int32]string{
		0: "CS_INITIALIZED",
		1: "CS_SERVING",
		2: "CS_DROPPED",
	}
	CollectionInfo_CollectionStatus_value = map[string]int32{
		"CS_INITIALIZED": 0,
		"CS_SERVING":     1,
		"CS_DROPPED":     2,
	}
)

Enum value maps for CollectionInfo_CollectionStatus.

View Source 
var (
	CollectionStats_SegmentStats_SegmentState_name = map[int32]string{
		0: "SS_CREATED",
		1: "SS_WRITING",
		2: "SS_DUMPING",
		3: "SS_COMPACTING",
		4: "SS_PERSIST",
	}
	CollectionStats_SegmentStats_SegmentState_value = map[string]int32{
		"SS_CREATED":    0,
		"SS_WRITING":    1,
		"SS_DUMPING":    2,
		"SS_COMPACTING": 3,
		"SS_PERSIST":    4,
	}
)

Enum value maps for CollectionStats_SegmentStats_SegmentState.

View Source 
var (
	QueryRequest_QueryType_name = map[int32]string{
		0: "QT_KNN",
	}
	QueryRequest_QueryType_value = map[string]int32{
		"QT_KNN": 0,
	}
)

Enum value maps for QueryRequest_QueryType.

View Source 
var File_proto_common_proto protoreflect.FileDescriptor
View Source 
var File_proto_config_proto protoreflect.FileDescriptor
View Source 
var File_proto_proxima_be_proto protoreflect.FileDescriptor

Functions

func RegisterHttpProximaServiceServer 

func RegisterHttpProximaServiceServer(s *grpc.Server, srv HttpProximaServiceServer)

func RegisterProximaServiceServer 

func RegisterProximaServiceServer(s *grpc.Server, srv ProximaServiceServer)

Types

type CollectionConfig 

type CollectionConfig struct {
	CollectionName     string                               `protobuf:"bytes,1,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	MaxDocsPerSegment  uint64                               `protobuf:"varint,2,opt,name=max_docs_per_segment,json=maxDocsPerSegment,proto3" json:"max_docs_per_segment,omitempty"`
	ForwardColumnNames []string                             `protobuf:"bytes,3,rep,name=forward_column_names,json=forwardColumnNames,proto3" json:"forward_column_names,omitempty"`
	IndexColumnParams  []*CollectionConfig_IndexColumnParam `protobuf:"bytes,4,rep,name=index_column_params,json=indexColumnParams,proto3" json:"index_column_params,omitempty"`
	RepositoryConfig   *CollectionConfig_RepositoryConfig   `protobuf:"bytes,5,opt,name=repository_config,json=repositoryConfig,proto3" json:"repository_config,omitempty"` //optional
	// contains filtered or unexported fields
}

func (*CollectionConfig) Descriptor deprecated 

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

Deprecated: Use CollectionConfig.ProtoReflect.Descriptor instead.

func (*CollectionConfig) GetCollectionName 

func (x *CollectionConfig) GetCollectionName() string

func (*CollectionConfig) GetForwardColumnNames 

func (x *CollectionConfig) GetForwardColumnNames() []string

func (*CollectionConfig) GetIndexColumnParams 

func (x *CollectionConfig) GetIndexColumnParams() []*CollectionConfig_IndexColumnParam

func (*CollectionConfig) GetMaxDocsPerSegment 

func (x *CollectionConfig) GetMaxDocsPerSegment() uint64

func (*CollectionConfig) GetRepositoryConfig 

func (x *CollectionConfig) GetRepositoryConfig() *CollectionConfig_RepositoryConfig

func (*CollectionConfig) ProtoMessage 

func (*CollectionConfig) ProtoMessage()

func (*CollectionConfig) ProtoReflect 

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

func (*CollectionConfig) Reset 

func (x *CollectionConfig) Reset()

func (*CollectionConfig) String 

func (x *CollectionConfig) String() string

type CollectionConfig_IndexColumnParam 

type CollectionConfig_IndexColumnParam struct {
	ColumnName  string          `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	IndexType   IndexType       `protobuf:"varint,2,opt,name=index_type,json=indexType,proto3,enum=proxima.be.proto.IndexType" json:"index_type,omitempty"`
	DataType    DataType        `protobuf:"varint,3,opt,name=data_type,json=dataType,proto3,enum=proxima.be.proto.DataType" json:"data_type,omitempty"`
	Dimension   uint32          `protobuf:"varint,4,opt,name=dimension,proto3" json:"dimension,omitempty"`
	ExtraParams []*KeyValuePair `protobuf:"bytes,5,rep,name=extra_params,json=extraParams,proto3" json:"extra_params,omitempty"` //optional
	// contains filtered or unexported fields
}

func (*CollectionConfig_IndexColumnParam) Descriptor deprecated 

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

Deprecated: Use CollectionConfig_IndexColumnParam.ProtoReflect.Descriptor instead.

func (*CollectionConfig_IndexColumnParam) GetColumnName 

func (x *CollectionConfig_IndexColumnParam) GetColumnName() string

func (*CollectionConfig_IndexColumnParam) GetDataType 

func (x *CollectionConfig_IndexColumnParam) GetDataType() DataType

func (*CollectionConfig_IndexColumnParam) GetDimension 

func (x *CollectionConfig_IndexColumnParam) GetDimension() uint32

func (*CollectionConfig_IndexColumnParam) GetExtraParams 

func (x *CollectionConfig_IndexColumnParam) GetExtraParams() []*KeyValuePair

func (*CollectionConfig_IndexColumnParam) GetIndexType 

func (x *CollectionConfig_IndexColumnParam) GetIndexType() IndexType

func (*CollectionConfig_IndexColumnParam) ProtoMessage 

func (*CollectionConfig_IndexColumnParam) ProtoMessage()

func (*CollectionConfig_IndexColumnParam) ProtoReflect 

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

func (*CollectionConfig_IndexColumnParam) Reset 

func (x *CollectionConfig_IndexColumnParam) Reset()

func (*CollectionConfig_IndexColumnParam) String 

func (x *CollectionConfig_IndexColumnParam) String() string

type CollectionConfig_RepositoryConfig 

type CollectionConfig_RepositoryConfig struct {
	RepositoryType CollectionConfig_RepositoryConfig_RepositoryType `` /* 175-byte string literal not displayed */
	RepositoryName string                                           `protobuf:"bytes,2,opt,name=repository_name,json=repositoryName,proto3" json:"repository_name,omitempty"`
	// Types that are assignable to Entity:
	//	*CollectionConfig_RepositoryConfig_Database_
	Entity isCollectionConfig_RepositoryConfig_Entity `protobuf_oneof:"entity"`
	// contains filtered or unexported fields
}

func (*CollectionConfig_RepositoryConfig) Descriptor deprecated 

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

Deprecated: Use CollectionConfig_RepositoryConfig.ProtoReflect.Descriptor instead.

func (*CollectionConfig_RepositoryConfig) GetDatabase 

func (x *CollectionConfig_RepositoryConfig) GetDatabase() *CollectionConfig_RepositoryConfig_Database

func (*CollectionConfig_RepositoryConfig) GetEntity 

func (m *CollectionConfig_RepositoryConfig) GetEntity() isCollectionConfig_RepositoryConfig_Entity

func (*CollectionConfig_RepositoryConfig) GetRepositoryName 

func (x *CollectionConfig_RepositoryConfig) GetRepositoryName() string

func (*CollectionConfig_RepositoryConfig) GetRepositoryType 

func (x *CollectionConfig_RepositoryConfig) GetRepositoryType() CollectionConfig_RepositoryConfig_RepositoryType

func (*CollectionConfig_RepositoryConfig) ProtoMessage 

func (*CollectionConfig_RepositoryConfig) ProtoMessage()

func (*CollectionConfig_RepositoryConfig) ProtoReflect 

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

func (*CollectionConfig_RepositoryConfig) Reset 

func (x *CollectionConfig_RepositoryConfig) Reset()

func (*CollectionConfig_RepositoryConfig) String 

func (x *CollectionConfig_RepositoryConfig) String() string

type CollectionConfig_RepositoryConfig_Database 

type CollectionConfig_RepositoryConfig_Database struct {
	ConnectionUri string `protobuf:"bytes,1,opt,name=connection_uri,json=connectionUri,proto3" json:"connection_uri,omitempty"`
	TableName     string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	User          string `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	Password      string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectionConfig_RepositoryConfig_Database) Descriptor deprecated 

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

Deprecated: Use CollectionConfig_RepositoryConfig_Database.ProtoReflect.Descriptor instead.

func (*CollectionConfig_RepositoryConfig_Database) GetConnectionUri 

func (x *CollectionConfig_RepositoryConfig_Database) GetConnectionUri() string

func (*CollectionConfig_RepositoryConfig_Database) GetPassword 

func (x *CollectionConfig_RepositoryConfig_Database) GetPassword() string

func (*CollectionConfig_RepositoryConfig_Database) GetTableName 

func (x *CollectionConfig_RepositoryConfig_Database) GetTableName() string

func (*CollectionConfig_RepositoryConfig_Database) GetUser 

func (x *CollectionConfig_RepositoryConfig_Database) GetUser() string

func (*CollectionConfig_RepositoryConfig_Database) ProtoMessage 

func (*CollectionConfig_RepositoryConfig_Database) ProtoMessage()

func (*CollectionConfig_RepositoryConfig_Database) ProtoReflect 

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

func (*CollectionConfig_RepositoryConfig_Database) Reset 

func (x *CollectionConfig_RepositoryConfig_Database) Reset()

func (*CollectionConfig_RepositoryConfig_Database) String 

func (x *CollectionConfig_RepositoryConfig_Database) String() string

type CollectionConfig_RepositoryConfig_Database_ 

type CollectionConfig_RepositoryConfig_Database_ struct {
	Database *CollectionConfig_RepositoryConfig_Database `protobuf:"bytes,3,opt,name=database,proto3,oneof"`
}

type CollectionConfig_RepositoryConfig_RepositoryType 

type CollectionConfig_RepositoryConfig_RepositoryType int32
const (
	CollectionConfig_RepositoryConfig_RT_DATABASE CollectionConfig_RepositoryConfig_RepositoryType = 0
)

func (CollectionConfig_RepositoryConfig_RepositoryType) Descriptor 

func (CollectionConfig_RepositoryConfig_RepositoryType) Descriptor() protoreflect.EnumDescriptor

func (CollectionConfig_RepositoryConfig_RepositoryType) Enum 

func (x CollectionConfig_RepositoryConfig_RepositoryType) Enum() *CollectionConfig_RepositoryConfig_RepositoryType

func (CollectionConfig_RepositoryConfig_RepositoryType) EnumDescriptor deprecated 

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

Deprecated: Use CollectionConfig_RepositoryConfig_RepositoryType.Descriptor instead.

func (CollectionConfig_RepositoryConfig_RepositoryType) Number 

func (x CollectionConfig_RepositoryConfig_RepositoryType) Number() protoreflect.EnumNumber

func (CollectionConfig_RepositoryConfig_RepositoryType) String 

func (x CollectionConfig_RepositoryConfig_RepositoryType) String() string

func (CollectionConfig_RepositoryConfig_RepositoryType) Type 

func (CollectionConfig_RepositoryConfig_RepositoryType) Type() protoreflect.EnumType

type CollectionInfo 

type CollectionInfo struct {

	// static collection config
	Config *CollectionConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// variable collection status
	Status           CollectionInfo_CollectionStatus `protobuf:"varint,2,opt,name=status,proto3,enum=proxima.be.proto.CollectionInfo_CollectionStatus" json:"status,omitempty"`
	Uuid             string                          `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	LatestLsnContext *LsnContext                     `protobuf:"bytes,4,opt,name=latest_lsn_context,json=latestLsnContext,proto3" json:"latest_lsn_context,omitempty"`
	MagicNumber      uint64                          `protobuf:"varint,5,opt,name=magic_number,json=magicNumber,proto3" json:"magic_number,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectionInfo) Descriptor deprecated 

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

Deprecated: Use CollectionInfo.ProtoReflect.Descriptor instead.

func (*CollectionInfo) GetConfig 

func (x *CollectionInfo) GetConfig() *CollectionConfig

func (*CollectionInfo) GetLatestLsnContext 

func (x *CollectionInfo) GetLatestLsnContext() *LsnContext

func (*CollectionInfo) GetMagicNumber 

func (x *CollectionInfo) GetMagicNumber() uint64

func (*CollectionInfo) GetStatus 

func (x *CollectionInfo) GetStatus() CollectionInfo_CollectionStatus

func (*CollectionInfo) GetUuid 

func (x *CollectionInfo) GetUuid() string

func (*CollectionInfo) ProtoMessage 

func (*CollectionInfo) ProtoMessage()

func (*CollectionInfo) ProtoReflect 

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

func (*CollectionInfo) Reset 

func (x *CollectionInfo) Reset()

func (*CollectionInfo) String 

func (x *CollectionInfo) String() string

type CollectionInfo_CollectionStatus 

type CollectionInfo_CollectionStatus int32
const (
	CollectionInfo_CS_INITIALIZED CollectionInfo_CollectionStatus = 0
	CollectionInfo_CS_SERVING     CollectionInfo_CollectionStatus = 1
	CollectionInfo_CS_DROPPED     CollectionInfo_CollectionStatus = 2
)

func (CollectionInfo_CollectionStatus) Descriptor 

func (CollectionInfo_CollectionStatus) Descriptor() protoreflect.EnumDescriptor

func (CollectionInfo_CollectionStatus) Enum 

func (x CollectionInfo_CollectionStatus) Enum() *CollectionInfo_CollectionStatus

func (CollectionInfo_CollectionStatus) EnumDescriptor deprecated 

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

Deprecated: Use CollectionInfo_CollectionStatus.Descriptor instead.

func (CollectionInfo_CollectionStatus) Number 

func (x CollectionInfo_CollectionStatus) Number() protoreflect.EnumNumber

func (CollectionInfo_CollectionStatus) String 

func (x CollectionInfo_CollectionStatus) String() string

func (CollectionInfo_CollectionStatus) Type 

func (CollectionInfo_CollectionStatus) Type() protoreflect.EnumType

type CollectionName 

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

func (*CollectionName) Descriptor deprecated 

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

Deprecated: Use CollectionName.ProtoReflect.Descriptor instead.

func (*CollectionName) GetCollectionName 

func (x *CollectionName) GetCollectionName() string

func (*CollectionName) ProtoMessage 

func (*CollectionName) ProtoMessage()

func (*CollectionName) ProtoReflect 

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

func (*CollectionName) Reset 

func (x *CollectionName) Reset()

func (*CollectionName) String 

func (x *CollectionName) String() string

type CollectionStats 

type CollectionStats struct {
	CollectionName      string                          `protobuf:"bytes,1,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	CollectionPath      string                          `protobuf:"bytes,2,opt,name=collection_path,json=collectionPath,proto3" json:"collection_path,omitempty"`
	TotalDocCount       uint64                          `protobuf:"varint,3,opt,name=total_doc_count,json=totalDocCount,proto3" json:"total_doc_count,omitempty"`
	TotalSegmentCount   uint64                          `protobuf:"varint,4,opt,name=total_segment_count,json=totalSegmentCount,proto3" json:"total_segment_count,omitempty"`
	TotalIndexFileCount uint64                          `protobuf:"varint,5,opt,name=total_index_file_count,json=totalIndexFileCount,proto3" json:"total_index_file_count,omitempty"`
	TotalIndexFileSize  uint64                          `protobuf:"varint,6,opt,name=total_index_file_size,json=totalIndexFileSize,proto3" json:"total_index_file_size,omitempty"`
	SegmentStats        []*CollectionStats_SegmentStats `protobuf:"bytes,7,rep,name=segment_stats,json=segmentStats,proto3" json:"segment_stats,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectionStats) Descriptor deprecated 

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

Deprecated: Use CollectionStats.ProtoReflect.Descriptor instead.

func (*CollectionStats) GetCollectionName 

func (x *CollectionStats) GetCollectionName() string

func (*CollectionStats) GetCollectionPath 

func (x *CollectionStats) GetCollectionPath() string

func (*CollectionStats) GetSegmentStats 

func (x *CollectionStats) GetSegmentStats() []*CollectionStats_SegmentStats

func (*CollectionStats) GetTotalDocCount 

func (x *CollectionStats) GetTotalDocCount() uint64

func (*CollectionStats) GetTotalIndexFileCount 

func (x *CollectionStats) GetTotalIndexFileCount() uint64

func (*CollectionStats) GetTotalIndexFileSize 

func (x *CollectionStats) GetTotalIndexFileSize() uint64

func (*CollectionStats) GetTotalSegmentCount 

func (x *CollectionStats) GetTotalSegmentCount() uint64

func (*CollectionStats) ProtoMessage 

func (*CollectionStats) ProtoMessage()

func (*CollectionStats) ProtoReflect 

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

func (*CollectionStats) Reset 

func (x *CollectionStats) Reset()

func (*CollectionStats) String 

func (x *CollectionStats) String() string

type CollectionStats_SegmentStats 

type CollectionStats_SegmentStats struct {
	SegmentId      uint32                                    `protobuf:"varint,1,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	State          CollectionStats_SegmentStats_SegmentState `` /* 128-byte string literal not displayed */
	DocCount       uint64                                    `protobuf:"varint,3,opt,name=doc_count,json=docCount,proto3" json:"doc_count,omitempty"`
	IndexFileCount uint64                                    `protobuf:"varint,4,opt,name=index_file_count,json=indexFileCount,proto3" json:"index_file_count,omitempty"`
	IndexFileSize  uint64                                    `protobuf:"varint,5,opt,name=index_file_size,json=indexFileSize,proto3" json:"index_file_size,omitempty"`
	MinDocId       uint64                                    `protobuf:"varint,6,opt,name=min_doc_id,json=minDocId,proto3" json:"min_doc_id,omitempty"`
	MaxDocId       uint64                                    `protobuf:"varint,7,opt,name=max_doc_id,json=maxDocId,proto3" json:"max_doc_id,omitempty"`
	MinPrimaryKey  uint64                                    `protobuf:"varint,8,opt,name=min_primary_key,json=minPrimaryKey,proto3" json:"min_primary_key,omitempty"`
	MaxPrimaryKey  uint64                                    `protobuf:"varint,9,opt,name=max_primary_key,json=maxPrimaryKey,proto3" json:"max_primary_key,omitempty"`
	MinTimestamp   uint64                                    `protobuf:"varint,10,opt,name=min_timestamp,json=minTimestamp,proto3" json:"min_timestamp,omitempty"`
	MaxTimestamp   uint64                                    `protobuf:"varint,11,opt,name=max_timestamp,json=maxTimestamp,proto3" json:"max_timestamp,omitempty"`
	MinLsn         uint64                                    `protobuf:"varint,12,opt,name=min_lsn,json=minLsn,proto3" json:"min_lsn,omitempty"`
	MaxLsn         uint64                                    `protobuf:"varint,13,opt,name=max_lsn,json=maxLsn,proto3" json:"max_lsn,omitempty"`
	SegmentPath    string                                    `protobuf:"bytes,14,opt,name=segment_path,json=segmentPath,proto3" json:"segment_path,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectionStats_SegmentStats) Descriptor deprecated 

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

Deprecated: Use CollectionStats_SegmentStats.ProtoReflect.Descriptor instead.

func (*CollectionStats_SegmentStats) GetDocCount 

func (x *CollectionStats_SegmentStats) GetDocCount() uint64

func (*CollectionStats_SegmentStats) GetIndexFileCount 

func (x *CollectionStats_SegmentStats) GetIndexFileCount() uint64

func (*CollectionStats_SegmentStats) GetIndexFileSize 

func (x *CollectionStats_SegmentStats) GetIndexFileSize() uint64

func (*CollectionStats_SegmentStats) GetMaxDocId 

func (x *CollectionStats_SegmentStats) GetMaxDocId() uint64

func (*CollectionStats_SegmentStats) GetMaxLsn 

func (x *CollectionStats_SegmentStats) GetMaxLsn() uint64

func (*CollectionStats_SegmentStats) GetMaxPrimaryKey 

func (x *CollectionStats_SegmentStats) GetMaxPrimaryKey() uint64

func (*CollectionStats_SegmentStats) GetMaxTimestamp 

func (x *CollectionStats_SegmentStats) GetMaxTimestamp() uint64

func (*CollectionStats_SegmentStats) GetMinDocId 

func (x *CollectionStats_SegmentStats) GetMinDocId() uint64

func (*CollectionStats_SegmentStats) GetMinLsn 

func (x *CollectionStats_SegmentStats) GetMinLsn() uint64

func (*CollectionStats_SegmentStats) GetMinPrimaryKey 

func (x *CollectionStats_SegmentStats) GetMinPrimaryKey() uint64

func (*CollectionStats_SegmentStats) GetMinTimestamp 

func (x *CollectionStats_SegmentStats) GetMinTimestamp() uint64

func (*CollectionStats_SegmentStats) GetSegmentId 

func (x *CollectionStats_SegmentStats) GetSegmentId() uint32

func (*CollectionStats_SegmentStats) GetSegmentPath 

func (x *CollectionStats_SegmentStats) GetSegmentPath() string

func (*CollectionStats_SegmentStats) GetState 

func (x *CollectionStats_SegmentStats) GetState() CollectionStats_SegmentStats_SegmentState

func (*CollectionStats_SegmentStats) ProtoMessage 

func (*CollectionStats_SegmentStats) ProtoMessage()

func (*CollectionStats_SegmentStats) ProtoReflect 

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

func (*CollectionStats_SegmentStats) Reset 

func (x *CollectionStats_SegmentStats) Reset()

func (*CollectionStats_SegmentStats) String 

func (x *CollectionStats_SegmentStats) String() string

type CollectionStats_SegmentStats_SegmentState 

type CollectionStats_SegmentStats_SegmentState int32
const (
	CollectionStats_SegmentStats_SS_CREATED    CollectionStats_SegmentStats_SegmentState = 0
	CollectionStats_SegmentStats_SS_WRITING    CollectionStats_SegmentStats_SegmentState = 1
	CollectionStats_SegmentStats_SS_DUMPING    CollectionStats_SegmentStats_SegmentState = 2
	CollectionStats_SegmentStats_SS_COMPACTING CollectionStats_SegmentStats_SegmentState = 3
	CollectionStats_SegmentStats_SS_PERSIST    CollectionStats_SegmentStats_SegmentState = 4
)

func (CollectionStats_SegmentStats_SegmentState) Descriptor 

func (CollectionStats_SegmentStats_SegmentState) Descriptor() protoreflect.EnumDescriptor

func (CollectionStats_SegmentStats_SegmentState) Enum 

func (x CollectionStats_SegmentStats_SegmentState) Enum() *CollectionStats_SegmentStats_SegmentState

func (CollectionStats_SegmentStats_SegmentState) EnumDescriptor deprecated 

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

Deprecated: Use CollectionStats_SegmentStats_SegmentState.Descriptor instead.

func (CollectionStats_SegmentStats_SegmentState) Number 

func (x CollectionStats_SegmentStats_SegmentState) Number() protoreflect.EnumNumber

func (CollectionStats_SegmentStats_SegmentState) String 

func (x CollectionStats_SegmentStats_SegmentState) String() string

func (CollectionStats_SegmentStats_SegmentState) Type 

func (CollectionStats_SegmentStats_SegmentState) Type() protoreflect.EnumType

type CommonConfig 

type CommonConfig struct {
	Protocol       string         `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	GrpcListenPort uint32         `protobuf:"varint,2,opt,name=grpc_listen_port,json=grpcListenPort,proto3" json:"grpc_listen_port,omitempty"`
	HttpListenPort uint32         `protobuf:"varint,3,opt,name=http_listen_port,json=httpListenPort,proto3" json:"http_listen_port,omitempty"`
	LoggerType     string         `protobuf:"bytes,4,opt,name=logger_type,json=loggerType,proto3" json:"logger_type,omitempty"`
	LogDirectory   string         `protobuf:"bytes,5,opt,name=log_directory,json=logDirectory,proto3" json:"log_directory,omitempty"`
	LogFile        string         `protobuf:"bytes,6,opt,name=log_file,json=logFile,proto3" json:"log_file,omitempty"`
	LogLevel       int32          `protobuf:"varint,7,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"`
	MetricsConfig  *MetricsConfig `protobuf:"bytes,8,opt,name=metrics_config,json=metricsConfig,proto3" json:"metrics_config,omitempty"`
	// contains filtered or unexported fields
}

! Message of Common Config

func (*CommonConfig) Descriptor deprecated 

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

Deprecated: Use CommonConfig.ProtoReflect.Descriptor instead.

func (*CommonConfig) GetGrpcListenPort 

func (x *CommonConfig) GetGrpcListenPort() uint32

func (*CommonConfig) GetHttpListenPort 

func (x *CommonConfig) GetHttpListenPort() uint32

func (*CommonConfig) GetLogDirectory 

func (x *CommonConfig) GetLogDirectory() string

func (*CommonConfig) GetLogFile 

func (x *CommonConfig) GetLogFile() string

func (*CommonConfig) GetLogLevel 

func (x *CommonConfig) GetLogLevel() int32

func (*CommonConfig) GetLoggerType 

func (x *CommonConfig) GetLoggerType() string

func (*CommonConfig) GetMetricsConfig 

func (x *CommonConfig) GetMetricsConfig() *MetricsConfig

func (*CommonConfig) GetProtocol 

func (x *CommonConfig) GetProtocol() string

func (*CommonConfig) ProtoMessage 

func (*CommonConfig) ProtoMessage()

func (*CommonConfig) ProtoReflect 

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

func (*CommonConfig) Reset 

func (x *CommonConfig) Reset()

func (*CommonConfig) String 

func (x *CommonConfig) String() string

type CommonResponse 

type CommonResponse struct {
	Code   int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

! Common Response

func (*CommonResponse) Descriptor deprecated 

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

Deprecated: Use CommonResponse.ProtoReflect.Descriptor instead.

func (*CommonResponse) GetCode 

func (x *CommonResponse) GetCode() int32

func (*CommonResponse) GetReason 

func (x *CommonResponse) GetReason() string

func (*CommonResponse) ProtoMessage 

func (*CommonResponse) ProtoMessage()

func (*CommonResponse) ProtoReflect 

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

func (*CommonResponse) Reset 

func (x *CommonResponse) Reset()

func (*CommonResponse) String 

func (x *CommonResponse) String() string

type DataType 

type DataType int32
const (
	DataType_DT_UNDEFINED       DataType = 0
	DataType_DT_BINARY          DataType = 1
	DataType_DT_STRING          DataType = 2
	DataType_DT_BOOL            DataType = 3
	DataType_DT_INT32           DataType = 4
	DataType_DT_INT64           DataType = 5
	DataType_DT_UINT32          DataType = 6
	DataType_DT_UINT64          DataType = 7
	DataType_DT_FLOAT           DataType = 8
	DataType_DT_DOUBLE          DataType = 9
	DataType_DT_VECTOR_BINARY32 DataType = 20
	DataType_DT_VECTOR_BINARY64 DataType = 21
	DataType_DT_VECTOR_FP16     DataType = 22
	DataType_DT_VECTOR_FP32     DataType = 23
	DataType_DT_VECTOR_FP64     DataType = 24
	DataType_DT_VECTOR_INT4     DataType = 25
	DataType_DT_VECTOR_INT8     DataType = 26
	DataType_DT_VECTOR_INT16    DataType = 27
)

func (DataType) Descriptor 

func (DataType) Descriptor() protoreflect.EnumDescriptor

func (DataType) Enum 

func (x DataType) Enum() *DataType

func (DataType) EnumDescriptor deprecated 

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

Deprecated: Use DataType.Descriptor instead.

func (DataType) Number 

func (x DataType) Number() protoreflect.EnumNumber

func (DataType) String 

func (x DataType) String() string

func (DataType) Type 

func (DataType) Type() protoreflect.EnumType

type DescribeCollectionResponse 

type DescribeCollectionResponse struct {
	Status     *Status         `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Collection *CollectionInfo `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeCollectionResponse) Descriptor deprecated 

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

Deprecated: Use DescribeCollectionResponse.ProtoReflect.Descriptor instead.

func (*DescribeCollectionResponse) GetCollection 

func (x *DescribeCollectionResponse) GetCollection() *CollectionInfo

func (*DescribeCollectionResponse) GetStatus 

func (x *DescribeCollectionResponse) GetStatus() *Status

func (*DescribeCollectionResponse) ProtoMessage 

func (*DescribeCollectionResponse) ProtoMessage()

func (*DescribeCollectionResponse) ProtoReflect 

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

func (*DescribeCollectionResponse) Reset 

func (x *DescribeCollectionResponse) Reset()

func (*DescribeCollectionResponse) String 

func (x *DescribeCollectionResponse) String() string

type Document 

type Document struct {
	PrimaryKey          uint64             `protobuf:"varint,1,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	Score               float32            `protobuf:"fixed32,2,opt,name=score,proto3" json:"score,omitempty"`
	ForwardColumnValues []*GenericKeyValue `protobuf:"bytes,3,rep,name=forward_column_values,json=forwardColumnValues,proto3" json:"forward_column_values,omitempty"`
	// contains filtered or unexported fields
}

func (*Document) Descriptor deprecated 

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

Deprecated: Use Document.ProtoReflect.Descriptor instead.

func (*Document) GetForwardColumnValues 

func (x *Document) GetForwardColumnValues() []*GenericKeyValue

func (*Document) GetPrimaryKey 

func (x *Document) GetPrimaryKey() uint64

func (*Document) GetScore 

func (x *Document) GetScore() float32

func (*Document) ProtoMessage 

func (*Document) ProtoMessage()

func (*Document) ProtoReflect 

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

func (*Document) Reset 

func (x *Document) Reset()

func (*Document) String 

func (x *Document) String() string

type FeatureType 

type FeatureType int32

! Types of Feature (same as Proxima) 

const (
	FeatureType_FT_UNDEFINED FeatureType = 0 // Undefined
	FeatureType_FT_BINARY32  FeatureType = 1 // 32-bits Binary
	FeatureType_FT_BINARY64  FeatureType = 2 // 64-bits Binary
	FeatureType_FT_FP16      FeatureType = 3 // 16-bits Float Number
	FeatureType_FT_FP32      FeatureType = 4 // 32-bits Float Number
	FeatureType_FT_FP64      FeatureType = 5 // 64-bits Float Number
	FeatureType_FT_INT8      FeatureType = 6 // 8-bits Integer
	FeatureType_FT_INT16     FeatureType = 7 // 16-bits Integer
	FeatureType_FT_INT4      FeatureType = 8 // 4-bits Integer
)

func (FeatureType) Descriptor 

func (FeatureType) Descriptor() protoreflect.EnumDescriptor

func (FeatureType) Enum 

func (x FeatureType) Enum() *FeatureType

func (FeatureType) EnumDescriptor deprecated 

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

Deprecated: Use FeatureType.Descriptor instead.

func (FeatureType) Number 

func (x FeatureType) Number() protoreflect.EnumNumber

func (FeatureType) String 

func (x FeatureType) String() string

func (FeatureType) Type 

func (FeatureType) Type() protoreflect.EnumType

type GenericKeyValue 

type GenericKeyValue struct {
	Key   string        `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *GenericValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

! Message of Generic Key-Value Pair

func (*GenericKeyValue) Descriptor deprecated 

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

Deprecated: Use GenericKeyValue.ProtoReflect.Descriptor instead.

func (*GenericKeyValue) GetKey 

func (x *GenericKeyValue) GetKey() string

func (*GenericKeyValue) GetValue 

func (x *GenericKeyValue) GetValue() *GenericValue

func (*GenericKeyValue) ProtoMessage 

func (*GenericKeyValue) ProtoMessage()

func (*GenericKeyValue) ProtoReflect 

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

func (*GenericKeyValue) Reset 

func (x *GenericKeyValue) Reset()

func (*GenericKeyValue) String 

func (x *GenericKeyValue) String() string

type GenericValue 

type GenericValue struct {

	// Types that are assignable to ValueOneof:
	//	*GenericValue_BytesValue
	//	*GenericValue_StringValue
	//	*GenericValue_BoolValue
	//	*GenericValue_Int32Value
	//	*GenericValue_Int64Value
	//	*GenericValue_Uint32Value
	//	*GenericValue_Uint64Value
	//	*GenericValue_FloatValue
	//	*GenericValue_DoubleValue
	ValueOneof isGenericValue_ValueOneof `protobuf_oneof:"value_oneof"`
	// contains filtered or unexported fields
}

! Union of Generic Value

func (*GenericValue) Descriptor deprecated 

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

Deprecated: Use GenericValue.ProtoReflect.Descriptor instead.

func (*GenericValue) GetBoolValue 

func (x *GenericValue) GetBoolValue() bool

func (*GenericValue) GetBytesValue 

func (x *GenericValue) GetBytesValue() []byte

func (*GenericValue) GetDoubleValue 

func (x *GenericValue) GetDoubleValue() float64

func (*GenericValue) GetFloatValue 

func (x *GenericValue) GetFloatValue() float32

func (*GenericValue) GetInt32Value 

func (x *GenericValue) GetInt32Value() int32

func (*GenericValue) GetInt64Value 

func (x *GenericValue) GetInt64Value() int64

func (*GenericValue) GetStringValue 

func (x *GenericValue) GetStringValue() string

func (*GenericValue) GetUint32Value 

func (x *GenericValue) GetUint32Value() uint32

func (*GenericValue) GetUint64Value 

func (x *GenericValue) GetUint64Value() uint64

func (*GenericValue) GetValueOneof 

func (m *GenericValue) GetValueOneof() isGenericValue_ValueOneof

func (*GenericValue) ProtoMessage 

func (*GenericValue) ProtoMessage()

func (*GenericValue) ProtoReflect 

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

func (*GenericValue) Reset 

func (x *GenericValue) Reset()

func (*GenericValue) String 

func (x *GenericValue) String() string

type GenericValueList 

type GenericValueList struct {
	Values []*GenericValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

! Message of Generic Value List

func (*GenericValueList) Descriptor deprecated 

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

Deprecated: Use GenericValueList.ProtoReflect.Descriptor instead.

func (*GenericValueList) GetValues 

func (x *GenericValueList) GetValues() []*GenericValue

func (*GenericValueList) ProtoMessage 

func (*GenericValueList) ProtoMessage()

func (*GenericValueList) ProtoReflect 

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

func (*GenericValueList) Reset 

func (x *GenericValueList) Reset()

func (*GenericValueList) String 

func (x *GenericValueList) String() string

type GenericValueMeta 

type GenericValueMeta struct {
	FieldName string                     `protobuf:"bytes,1,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	FieldType GenericValueMeta_FieldType `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

! Message of Generic Value Meta

func (*GenericValueMeta) Descriptor deprecated 

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

Deprecated: Use GenericValueMeta.ProtoReflect.Descriptor instead.

func (*GenericValueMeta) GetFieldName 

func (x *GenericValueMeta) GetFieldName() string

func (*GenericValueMeta) GetFieldType 

func (x *GenericValueMeta) GetFieldType() GenericValueMeta_FieldType

func (*GenericValueMeta) ProtoMessage 

func (*GenericValueMeta) ProtoMessage()

func (*GenericValueMeta) ProtoReflect 

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

func (*GenericValueMeta) Reset 

func (x *GenericValueMeta) Reset()

func (*GenericValueMeta) String 

func (x *GenericValueMeta) String() string

type GenericValueMeta_FieldType 

type GenericValueMeta_FieldType int32

! Types of Field 

const (
	GenericValueMeta_FT_BYTES  GenericValueMeta_FieldType = 0 // bytes
	GenericValueMeta_FT_STRING GenericValueMeta_FieldType = 1 // string
	GenericValueMeta_FT_BOOL   GenericValueMeta_FieldType = 2 // bool
	GenericValueMeta_FT_INT32  GenericValueMeta_FieldType = 3 // int32
	GenericValueMeta_FT_INT64  GenericValueMeta_FieldType = 4 // int64
	GenericValueMeta_FT_UINT32 GenericValueMeta_FieldType = 5 // uint32
	GenericValueMeta_FT_UINT64 GenericValueMeta_FieldType = 6 // uint64
	GenericValueMeta_FT_FLOAT  GenericValueMeta_FieldType = 7 // float
	GenericValueMeta_FT_DOUBLE GenericValueMeta_FieldType = 8 // double float
)

func (GenericValueMeta_FieldType) Descriptor 

func (GenericValueMeta_FieldType) Descriptor() protoreflect.EnumDescriptor

func (GenericValueMeta_FieldType) Enum 

func (x GenericValueMeta_FieldType) Enum() *GenericValueMeta_FieldType

func (GenericValueMeta_FieldType) EnumDescriptor deprecated 

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

Deprecated: Use GenericValueMeta_FieldType.Descriptor instead.

func (GenericValueMeta_FieldType) Number 

func (x GenericValueMeta_FieldType) Number() protoreflect.EnumNumber

func (GenericValueMeta_FieldType) String 

func (x GenericValueMeta_FieldType) String() string

func (GenericValueMeta_FieldType) Type 

func (GenericValueMeta_FieldType) Type() protoreflect.EnumType

type GenericValue_BoolValue 

type GenericValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,3,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type GenericValue_BytesValue 

type GenericValue_BytesValue struct {
	BytesValue []byte `protobuf:"bytes,1,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type GenericValue_DoubleValue 

type GenericValue_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,9,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type GenericValue_FloatValue 

type GenericValue_FloatValue struct {
	FloatValue float32 `protobuf:"fixed32,8,opt,name=float_value,json=floatValue,proto3,oneof"`
}

type GenericValue_Int32Value 

type GenericValue_Int32Value struct {
	Int32Value int32 `protobuf:"varint,4,opt,name=int32_value,json=int32Value,proto3,oneof"`
}

type GenericValue_Int64Value 

type GenericValue_Int64Value struct {
	Int64Value int64 `protobuf:"varint,5,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

type GenericValue_StringValue 

type GenericValue_StringValue struct {
	StringValue string `protobuf:"bytes,2,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type GenericValue_Uint32Value 

type GenericValue_Uint32Value struct {
	Uint32Value uint32 `protobuf:"varint,6,opt,name=uint32_value,json=uint32Value,proto3,oneof"`
}

type GenericValue_Uint64Value 

type GenericValue_Uint64Value struct {
	Uint64Value uint64 `protobuf:"varint,7,opt,name=uint64_value,json=uint64Value,proto3,oneof"`
}

type GetDocumentRequest 

type GetDocumentRequest struct {
	CollectionName string `protobuf:"bytes,1,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PrimaryKey     uint64 `protobuf:"varint,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	DebugMode      bool   `protobuf:"varint,3,opt,name=debug_mode,json=debugMode,proto3" json:"debug_mode,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDocumentRequest) Descriptor deprecated 

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

Deprecated: Use GetDocumentRequest.ProtoReflect.Descriptor instead.

func (*GetDocumentRequest) GetCollectionName 

func (x *GetDocumentRequest) GetCollectionName() string

func (*GetDocumentRequest) GetDebugMode 

func (x *GetDocumentRequest) GetDebugMode() bool

func (*GetDocumentRequest) GetPrimaryKey 

func (x *GetDocumentRequest) GetPrimaryKey() uint64

func (*GetDocumentRequest) ProtoMessage 

func (*GetDocumentRequest) ProtoMessage()

func (*GetDocumentRequest) ProtoReflect 

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

func (*GetDocumentRequest) Reset 

func (x *GetDocumentRequest) Reset()

func (*GetDocumentRequest) String 

func (x *GetDocumentRequest) String() string

type GetDocumentResponse 

type GetDocumentResponse struct {
	Status    *Status   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	DebugInfo string    `protobuf:"bytes,2,opt,name=debug_info,json=debugInfo,proto3" json:"debug_info,omitempty"`
	Document  *Document `protobuf:"bytes,3,opt,name=document,proto3" json:"document,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDocumentResponse) Descriptor deprecated 

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

Deprecated: Use GetDocumentResponse.ProtoReflect.Descriptor instead.

func (*GetDocumentResponse) GetDebugInfo 

func (x *GetDocumentResponse) GetDebugInfo() string

func (*GetDocumentResponse) GetDocument 

func (x *GetDocumentResponse) GetDocument() *Document

func (*GetDocumentResponse) GetStatus 

func (x *GetDocumentResponse) GetStatus() *Status

func (*GetDocumentResponse) ProtoMessage 

func (*GetDocumentResponse) ProtoMessage()

func (*GetDocumentResponse) ProtoReflect 

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

func (*GetDocumentResponse) Reset 

func (x *GetDocumentResponse) Reset()

func (*GetDocumentResponse) String 

func (x *GetDocumentResponse) String() string

type GetVersionRequest 

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

func (*GetVersionRequest) Descriptor deprecated 

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

Deprecated: Use GetVersionRequest.ProtoReflect.Descriptor instead.

func (*GetVersionRequest) ProtoMessage 

func (*GetVersionRequest) ProtoMessage()

func (*GetVersionRequest) ProtoReflect 

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

func (*GetVersionRequest) Reset 

func (x *GetVersionRequest) Reset()

func (*GetVersionRequest) String 

func (x *GetVersionRequest) String() string

type GetVersionResponse 

type GetVersionResponse struct {
	Status  *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Version string  `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVersionResponse) Descriptor deprecated 

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

Deprecated: Use GetVersionResponse.ProtoReflect.Descriptor instead.

func (*GetVersionResponse) GetStatus 

func (x *GetVersionResponse) GetStatus() *Status

func (*GetVersionResponse) GetVersion 

func (x *GetVersionResponse) GetVersion() string

func (*GetVersionResponse) ProtoMessage 

func (*GetVersionResponse) ProtoMessage()

func (*GetVersionResponse) ProtoReflect 

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

func (*GetVersionResponse) Reset 

func (x *GetVersionResponse) Reset()

func (*GetVersionResponse) String 

func (x *GetVersionResponse) String() string

type HttpProximaServiceClient 

type HttpProximaServiceClient interface {
	//! Collection management APIS
	//  1. Create Collection
	//     Http: POST /v1/collection/{collection}
	//     You can use the create collection API to add a new collection to an Proxima BE server. When creating an
	//     index, you need specify the CollectionConfig as json string attached to the body
	//  2. Get Collection
	//     HTTP: GET /{collection}
	//     Returns information about one collection named by Path Param ${collection}.
	//  3. Delete Collection
	//     HTTP: DEL /{collection}
	//     Deletes an existing collection named by Path Param ${collection}
	//  4. Update Collection
	//     HTTP: PUT /{collection}, supported later
	//
	Collection(ctx context.Context, in *HttpRequest, opts ...grpc.CallOption) (*HttpResponse, error)
	//! Retrieve Stat of Collection
	// HTTP: GET /v1/collection/{collection}/stat
	//
	StatsCollection(ctx context.Context, in *HttpRequest, opts ...grpc.CallOption) (*HttpResponse, error)
	//! Write records to collection
	// HTTP: POST /v1/collection/{collection}/index
	//
	Write(ctx context.Context, in *HttpRequest, opts ...grpc.CallOption) (*HttpResponse, error)
	//! Query documents on collection
	// HTTP: POST /v1/collection/{collection}/query
	//
	Query(ctx context.Context, in *HttpRequest, opts ...grpc.CallOption) (*HttpResponse, error)
	//! Write records to collection
	// HTTP: GET /v1/collection/{collection}/doc?key={primary_key}
	//
	GetDocumentByKey(ctx context.Context, in *HttpRequest, opts ...grpc.CallOption) (*HttpResponse, error)
	//! List Collections
	// HTTP: GET /v1/collections?repository={repo}
	// Returns information about collections. Query param ${repo} specified collection should have been attached
	// repository named by ${repo}
	//
	ListCollections(ctx context.Context, in *HttpRequest, opts ...grpc.CallOption) (*HttpResponse, error)
	//! Get server version
	// HTTP: GET /version
	// Returns version string
	GetVersion(ctx context.Context, in *HttpRequest, opts ...grpc.CallOption) (*HttpResponse, error)
}

HttpProximaServiceClient is the client API for HttpProximaService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewHttpProximaServiceClient 

func NewHttpProximaServiceClient(cc grpc.ClientConnInterface) HttpProximaServiceClient

type HttpProximaServiceServer 

type HttpProximaServiceServer interface {
	//! Collection management APIS
	//  1. Create Collection
	//     Http: POST /v1/collection/{collection}
	//     You can use the create collection API to add a new collection to an Proxima BE server. When creating an
	//     index, you need specify the CollectionConfig as json string attached to the body
	//  2. Get Collection
	//     HTTP: GET /{collection}
	//     Returns information about one collection named by Path Param ${collection}.
	//  3. Delete Collection
	//     HTTP: DEL /{collection}
	//     Deletes an existing collection named by Path Param ${collection}
	//  4. Update Collection
	//     HTTP: PUT /{collection}, supported later
	//
	Collection(context.Context, *HttpRequest) (*HttpResponse, error)
	//! Retrieve Stat of Collection
	// HTTP: GET /v1/collection/{collection}/stat
	//
	StatsCollection(context.Context, *HttpRequest) (*HttpResponse, error)
	//! Write records to collection
	// HTTP: POST /v1/collection/{collection}/index
	//
	Write(context.Context, *HttpRequest) (*HttpResponse, error)
	//! Query documents on collection
	// HTTP: POST /v1/collection/{collection}/query
	//
	Query(context.Context, *HttpRequest) (*HttpResponse, error)
	//! Write records to collection
	// HTTP: GET /v1/collection/{collection}/doc?key={primary_key}
	//
	GetDocumentByKey(context.Context, *HttpRequest) (*HttpResponse, error)
	//! List Collections
	// HTTP: GET /v1/collections?repository={repo}
	// Returns information about collections. Query param ${repo} specified collection should have been attached
	// repository named by ${repo}
	//
	ListCollections(context.Context, *HttpRequest) (*HttpResponse, error)
	//! Get server version
	// HTTP: GET /version
	// Returns version string
	GetVersion(context.Context, *HttpRequest) (*HttpResponse, error)
}

HttpProximaServiceServer is the server API for HttpProximaService service.

type HttpRequest 

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

! Common Http Request for admin

func (*HttpRequest) Descriptor deprecated 

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

Deprecated: Use HttpRequest.ProtoReflect.Descriptor instead.

func (*HttpRequest) ProtoMessage 

func (*HttpRequest) ProtoMessage()

func (*HttpRequest) ProtoReflect 

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

func (*HttpRequest) Reset 

func (x *HttpRequest) Reset()

func (*HttpRequest) String 

func (x *HttpRequest) String() string

type HttpResponse 

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

! Common Http Response for admin

func (*HttpResponse) Descriptor deprecated 

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

Deprecated: Use HttpResponse.ProtoReflect.Descriptor instead.

func (*HttpResponse) ProtoMessage 

func (*HttpResponse) ProtoMessage()

func (*HttpResponse) ProtoReflect 

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

func (*HttpResponse) Reset 

func (x *HttpResponse) Reset()

func (*HttpResponse) String 

func (x *HttpResponse) String() string

type IndexConfig 

type IndexConfig struct {
	BuildThreadCount uint32 `protobuf:"varint,1,opt,name=build_thread_count,json=buildThreadCount,proto3" json:"build_thread_count,omitempty"`
	DumpThreadCount  uint32 `protobuf:"varint,2,opt,name=dump_thread_count,json=dumpThreadCount,proto3" json:"dump_thread_count,omitempty"`
	MaxBuildQps      uint32 `protobuf:"varint,3,opt,name=max_build_qps,json=maxBuildQps,proto3" json:"max_build_qps,omitempty"`
	IndexDirectory   string `protobuf:"bytes,5,opt,name=index_directory,json=indexDirectory,proto3" json:"index_directory,omitempty"`
	FlushInternal    uint32 `protobuf:"varint,6,opt,name=flush_internal,json=flushInternal,proto3" json:"flush_internal,omitempty"`
	// contains filtered or unexported fields
}

! Message of Index Config

func (*IndexConfig) Descriptor deprecated 

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

Deprecated: Use IndexConfig.ProtoReflect.Descriptor instead.

func (*IndexConfig) GetBuildThreadCount 

func (x *IndexConfig) GetBuildThreadCount() uint32

func (*IndexConfig) GetDumpThreadCount 

func (x *IndexConfig) GetDumpThreadCount() uint32

func (*IndexConfig) GetFlushInternal 

func (x *IndexConfig) GetFlushInternal() uint32

func (*IndexConfig) GetIndexDirectory 

func (x *IndexConfig) GetIndexDirectory() string

func (*IndexConfig) GetMaxBuildQps 

func (x *IndexConfig) GetMaxBuildQps() uint32

func (*IndexConfig) ProtoMessage 

func (*IndexConfig) ProtoMessage()

func (*IndexConfig) ProtoReflect 

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

func (*IndexConfig) Reset 

func (x *IndexConfig) Reset()

func (*IndexConfig) String 

func (x *IndexConfig) String() string

type IndexType 

type IndexType int32

! Types of Index 

const (
	IndexType_IT_UNDEFINED           IndexType = 0 // Undefined
	IndexType_IT_PROXIMA_GRAPH_INDEX IndexType = 1 // Proxima Graph Index
)

func (IndexType) Descriptor 

func (IndexType) Descriptor() protoreflect.EnumDescriptor

func (IndexType) Enum 

func (x IndexType) Enum() *IndexType

func (IndexType) EnumDescriptor deprecated 

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

Deprecated: Use IndexType.Descriptor instead.

func (IndexType) Number 

func (x IndexType) Number() protoreflect.EnumNumber

func (IndexType) String 

func (x IndexType) String() string

func (IndexType) Type 

func (IndexType) Type() protoreflect.EnumType

type KeyValuePair 

type KeyValuePair struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

! Message of IndexParameter, which used to customize index, and query

func (*KeyValuePair) Descriptor deprecated 

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

Deprecated: Use KeyValuePair.ProtoReflect.Descriptor instead.

func (*KeyValuePair) GetKey 

func (x *KeyValuePair) GetKey() string

func (*KeyValuePair) GetValue 

func (x *KeyValuePair) GetValue() string

func (*KeyValuePair) ProtoMessage 

func (*KeyValuePair) ProtoMessage()

func (*KeyValuePair) ProtoReflect 

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

func (*KeyValuePair) Reset 

func (x *KeyValuePair) Reset()

func (*KeyValuePair) String 

func (x *KeyValuePair) String() string

type ListCollectionsResponse 

type ListCollectionsResponse struct {
	Status      *Status           `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Collections []*CollectionInfo `protobuf:"bytes,2,rep,name=collections,proto3" json:"collections,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCollectionsResponse) Descriptor deprecated 

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

Deprecated: Use ListCollectionsResponse.ProtoReflect.Descriptor instead.

func (*ListCollectionsResponse) GetCollections 

func (x *ListCollectionsResponse) GetCollections() []*CollectionInfo

func (*ListCollectionsResponse) GetStatus 

func (x *ListCollectionsResponse) GetStatus() *Status

func (*ListCollectionsResponse) ProtoMessage 

func (*ListCollectionsResponse) ProtoMessage()

func (*ListCollectionsResponse) ProtoReflect 

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

func (*ListCollectionsResponse) Reset 

func (x *ListCollectionsResponse) Reset()

func (*ListCollectionsResponse) String 

func (x *ListCollectionsResponse) String() string

type ListCondition 

type ListCondition struct {
	RepositoryName string `protobuf:"bytes,1,opt,name=repository_name,json=repositoryName,proto3" json:"repository_name,omitempty"` // optional
	// contains filtered or unexported fields
}

func (*ListCondition) Descriptor deprecated 

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

Deprecated: Use ListCondition.ProtoReflect.Descriptor instead.

func (*ListCondition) GetRepositoryName 

func (x *ListCondition) GetRepositoryName() string

func (*ListCondition) ProtoMessage 

func (*ListCondition) ProtoMessage()

func (*ListCondition) ProtoReflect 

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

func (*ListCondition) Reset 

func (x *ListCondition) Reset()

func (*ListCondition) String 

func (x *ListCondition) String() string

type LsnContext 

type LsnContext struct {
	Lsn     uint64 `protobuf:"varint,1,opt,name=lsn,proto3" json:"lsn,omitempty"`
	Context string `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`
	// contains filtered or unexported fields
}

func (*LsnContext) Descriptor deprecated 

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

Deprecated: Use LsnContext.ProtoReflect.Descriptor instead.

func (*LsnContext) GetContext 

func (x *LsnContext) GetContext() string

func (*LsnContext) GetLsn 

func (x *LsnContext) GetLsn() uint64

func (*LsnContext) ProtoMessage 

func (*LsnContext) ProtoMessage()

func (*LsnContext) ProtoReflect 

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

func (*LsnContext) Reset 

func (x *LsnContext) Reset()

func (*LsnContext) String 

func (x *LsnContext) String() string

type MetaConfig 

type MetaConfig struct {
	MetaUri string `protobuf:"bytes,1,opt,name=meta_uri,json=metaUri,proto3" json:"meta_uri,omitempty"` // meta database config, default sqlite://meta.sqlite
	// contains filtered or unexported fields
}

! Meta configuration

func (*MetaConfig) Descriptor deprecated 

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

Deprecated: Use MetaConfig.ProtoReflect.Descriptor instead.

func (*MetaConfig) GetMetaUri 

func (x *MetaConfig) GetMetaUri() string

func (*MetaConfig) ProtoMessage 

func (*MetaConfig) ProtoMessage()

func (*MetaConfig) ProtoReflect 

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

func (*MetaConfig) Reset 

func (x *MetaConfig) Reset()

func (*MetaConfig) String 

func (x *MetaConfig) String() string

type MetricsConfig 

type MetricsConfig struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsConfig) Descriptor deprecated 

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

Deprecated: Use MetricsConfig.ProtoReflect.Descriptor instead.

func (*MetricsConfig) GetName 

func (x *MetricsConfig) GetName() string

func (*MetricsConfig) ProtoMessage 

func (*MetricsConfig) ProtoMessage()

func (*MetricsConfig) ProtoReflect 

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

func (*MetricsConfig) Reset 

func (x *MetricsConfig) Reset()

func (*MetricsConfig) String 

func (x *MetricsConfig) String() string

type OperationType 

type OperationType int32

! Types of Operation 

const (
	OperationType_OP_INSERT OperationType = 0 // Insert Operation
	OperationType_OP_UPDATE OperationType = 1 // Update Operation
	OperationType_OP_DELETE OperationType = 2 // Delete Operation
)

func (OperationType) Descriptor 

func (OperationType) Descriptor() protoreflect.EnumDescriptor

func (OperationType) Enum 

func (x OperationType) Enum() *OperationType

func (OperationType) EnumDescriptor deprecated 

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

Deprecated: Use OperationType.Descriptor instead.

func (OperationType) Number 

func (x OperationType) Number() protoreflect.EnumNumber

func (OperationType) String 

func (x OperationType) String() string

func (OperationType) Type 

func (OperationType) Type() protoreflect.EnumType

type ProximaSEConfig 

type ProximaSEConfig struct {
	CommonConfig *CommonConfig `protobuf:"bytes,1,opt,name=common_config,json=commonConfig,proto3" json:"common_config,omitempty"`
	QueryConfig  *QueryConfig  `protobuf:"bytes,2,opt,name=query_config,json=queryConfig,proto3" json:"query_config,omitempty"`
	IndexConfig  *IndexConfig  `protobuf:"bytes,3,opt,name=index_config,json=indexConfig,proto3" json:"index_config,omitempty"`
	MetaConfig   *MetaConfig   `protobuf:"bytes,4,opt,name=meta_config,json=metaConfig,proto3" json:"meta_config,omitempty"`
	// contains filtered or unexported fields
}

! Message of Proxima BE Config

func (*ProximaSEConfig) Descriptor deprecated 

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

Deprecated: Use ProximaSEConfig.ProtoReflect.Descriptor instead.

func (*ProximaSEConfig) GetCommonConfig 

func (x *ProximaSEConfig) GetCommonConfig() *CommonConfig

func (*ProximaSEConfig) GetIndexConfig 

func (x *ProximaSEConfig) GetIndexConfig() *IndexConfig

func (*ProximaSEConfig) GetMetaConfig 

func (x *ProximaSEConfig) GetMetaConfig() *MetaConfig

func (*ProximaSEConfig) GetQueryConfig 

func (x *ProximaSEConfig) GetQueryConfig() *QueryConfig

func (*ProximaSEConfig) ProtoMessage 

func (*ProximaSEConfig) ProtoMessage()

func (*ProximaSEConfig) ProtoReflect 

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

func (*ProximaSEConfig) Reset 

func (x *ProximaSEConfig) Reset()

func (*ProximaSEConfig) String 

func (x *ProximaSEConfig) String() string

type ProximaServiceClient 

type ProximaServiceClient interface {
	// Create a collection
	CreateCollection(ctx context.Context, in *CollectionConfig, opts ...grpc.CallOption) (*Status, error)
	// Drop a collection
	DropCollection(ctx context.Context, in *CollectionName, opts ...grpc.CallOption) (*Status, error)
	// Get information of a collection
	DescribeCollection(ctx context.Context, in *CollectionName, opts ...grpc.CallOption) (*DescribeCollectionResponse, error)
	// Get all collection information
	ListCollections(ctx context.Context, in *ListCondition, opts ...grpc.CallOption) (*ListCollectionsResponse, error)
	// Get collection statstics
	StatsCollection(ctx context.Context, in *CollectionName, opts ...grpc.CallOption) (*StatsCollectionResponse, error)
	// Write records
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*Status, error)
	// Knn query records
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	// Get document information by primary key
	GetDocumentByKey(ctx context.Context, in *GetDocumentRequest, opts ...grpc.CallOption) (*GetDocumentResponse, error)
	// Get server version
	GetVersion(ctx context.Context, in *GetVersionRequest, opts ...grpc.CallOption) (*GetVersionResponse, error)
}

ProximaServiceClient is the client API for ProximaService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewProximaServiceClient 

func NewProximaServiceClient(cc grpc.ClientConnInterface) ProximaServiceClient

type ProximaServiceServer 

type ProximaServiceServer interface {
	// Create a collection
	CreateCollection(context.Context, *CollectionConfig) (*Status, error)
	// Drop a collection
	DropCollection(context.Context, *CollectionName) (*Status, error)
	// Get information of a collection
	DescribeCollection(context.Context, *CollectionName) (*DescribeCollectionResponse, error)
	// Get all collection information
	ListCollections(context.Context, *ListCondition) (*ListCollectionsResponse, error)
	// Get collection statstics
	StatsCollection(context.Context, *CollectionName) (*StatsCollectionResponse, error)
	// Write records
	Write(context.Context, *WriteRequest) (*Status, error)
	// Knn query records
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	// Get document information by primary key
	GetDocumentByKey(context.Context, *GetDocumentRequest) (*GetDocumentResponse, error)
	// Get server version
	GetVersion(context.Context, *GetVersionRequest) (*GetVersionResponse, error)
}

ProximaServiceServer is the server API for ProximaService service.

type QueryConfig 

type QueryConfig struct {
	QueryThreadCount uint32 `protobuf:"varint,1,opt,name=query_thread_count,json=queryThreadCount,proto3" json:"query_thread_count,omitempty"`
	// contains filtered or unexported fields
}

! Message of Query Config

func (*QueryConfig) Descriptor deprecated 

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

Deprecated: Use QueryConfig.ProtoReflect.Descriptor instead.

func (*QueryConfig) GetQueryThreadCount 

func (x *QueryConfig) GetQueryThreadCount() uint32

func (*QueryConfig) ProtoMessage 

func (*QueryConfig) ProtoMessage()

func (*QueryConfig) ProtoReflect 

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

func (*QueryConfig) Reset 

func (x *QueryConfig) Reset()

func (*QueryConfig) String 

func (x *QueryConfig) String() string

type QueryRequest 

type QueryRequest struct {
	CollectionName string                 `protobuf:"bytes,1,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	QueryType      QueryRequest_QueryType `` /* 134-byte string literal not displayed */
	DebugMode      bool                   `protobuf:"varint,3,opt,name=debug_mode,json=debugMode,proto3" json:"debug_mode,omitempty"`
	// Types that are assignable to QueryParam:
	//	*QueryRequest_KnnParam
	QueryParam isQueryRequest_QueryParam `protobuf_oneof:"query_param"`
	// contains filtered or unexported fields
}

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetCollectionName 

func (x *QueryRequest) GetCollectionName() string

func (*QueryRequest) GetDebugMode 

func (x *QueryRequest) GetDebugMode() bool

func (*QueryRequest) GetKnnParam 

func (x *QueryRequest) GetKnnParam() *QueryRequest_KnnQueryParam

func (*QueryRequest) GetQueryParam 

func (m *QueryRequest) GetQueryParam() isQueryRequest_QueryParam

func (*QueryRequest) GetQueryType 

func (x *QueryRequest) GetQueryType() QueryRequest_QueryType

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryRequest_KnnParam 

type QueryRequest_KnnParam struct {
	KnnParam *QueryRequest_KnnQueryParam `protobuf:"bytes,4,opt,name=knn_param,json=knnParam,proto3,oneof"`
}

type QueryRequest_KnnQueryParam 

type QueryRequest_KnnQueryParam struct {
	ColumnName string `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	Topk       uint32 `protobuf:"varint,2,opt,name=topk,proto3" json:"topk,omitempty"`
	// Types that are assignable to FeaturesValue:
	//	*QueryRequest_KnnQueryParam_Features
	//	*QueryRequest_KnnQueryParam_Matrix
	FeaturesValue isQueryRequest_KnnQueryParam_FeaturesValue `protobuf_oneof:"features_value"`
	BatchCount    uint32                                     `protobuf:"varint,5,opt,name=batch_count,json=batchCount,proto3" json:"batch_count,omitempty"`
	Dimension     uint32                                     `protobuf:"varint,6,opt,name=dimension,proto3" json:"dimension,omitempty"`
	DataType      DataType                                   `protobuf:"varint,7,opt,name=data_type,json=dataType,proto3,enum=proxima.be.proto.DataType" json:"data_type,omitempty"`
	Radius        float32                                    `protobuf:"fixed32,8,opt,name=radius,proto3" json:"radius,omitempty"`                             // optional
	IsLinear      bool                                       `protobuf:"varint,9,opt,name=is_linear,json=isLinear,proto3" json:"is_linear,omitempty"`          // optional
	ExtraParams   []*KeyValuePair                            `protobuf:"bytes,10,rep,name=extra_params,json=extraParams,proto3" json:"extra_params,omitempty"` // optional
	// contains filtered or unexported fields
}

func (*QueryRequest_KnnQueryParam) Descriptor deprecated 

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

Deprecated: Use QueryRequest_KnnQueryParam.ProtoReflect.Descriptor instead.

func (*QueryRequest_KnnQueryParam) GetBatchCount 

func (x *QueryRequest_KnnQueryParam) GetBatchCount() uint32

func (*QueryRequest_KnnQueryParam) GetColumnName 

func (x *QueryRequest_KnnQueryParam) GetColumnName() string

func (*QueryRequest_KnnQueryParam) GetDataType 

func (x *QueryRequest_KnnQueryParam) GetDataType() DataType

func (*QueryRequest_KnnQueryParam) GetDimension 

func (x *QueryRequest_KnnQueryParam) GetDimension() uint32

func (*QueryRequest_KnnQueryParam) GetExtraParams 

func (x *QueryRequest_KnnQueryParam) GetExtraParams() []*KeyValuePair

func (*QueryRequest_KnnQueryParam) GetFeatures 

func (x *QueryRequest_KnnQueryParam) GetFeatures() []byte

func (*QueryRequest_KnnQueryParam) GetFeaturesValue 

func (m *QueryRequest_KnnQueryParam) GetFeaturesValue() isQueryRequest_KnnQueryParam_FeaturesValue

func (*QueryRequest_KnnQueryParam) GetIsLinear 

func (x *QueryRequest_KnnQueryParam) GetIsLinear() bool

func (*QueryRequest_KnnQueryParam) GetMatrix 

func (x *QueryRequest_KnnQueryParam) GetMatrix() string

func (*QueryRequest_KnnQueryParam) GetRadius 

func (x *QueryRequest_KnnQueryParam) GetRadius() float32

func (*QueryRequest_KnnQueryParam) GetTopk 

func (x *QueryRequest_KnnQueryParam) GetTopk() uint32

func (*QueryRequest_KnnQueryParam) ProtoMessage 

func (*QueryRequest_KnnQueryParam) ProtoMessage()

func (*QueryRequest_KnnQueryParam) ProtoReflect 

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

func (*QueryRequest_KnnQueryParam) Reset 

func (x *QueryRequest_KnnQueryParam) Reset()

func (*QueryRequest_KnnQueryParam) String 

func (x *QueryRequest_KnnQueryParam) String() string

type QueryRequest_KnnQueryParam_Features 

type QueryRequest_KnnQueryParam_Features struct {
	Features []byte `protobuf:"bytes,3,opt,name=features,proto3,oneof"`
}

type QueryRequest_KnnQueryParam_Matrix 

type QueryRequest_KnnQueryParam_Matrix struct {
	Matrix string `protobuf:"bytes,4,opt,name=matrix,proto3,oneof"`
}

type QueryRequest_QueryType 

type QueryRequest_QueryType int32
const (
	QueryRequest_QT_KNN QueryRequest_QueryType = 0
)

func (QueryRequest_QueryType) Descriptor 

func (QueryRequest_QueryType) Descriptor() protoreflect.EnumDescriptor

func (QueryRequest_QueryType) Enum 

func (x QueryRequest_QueryType) Enum() *QueryRequest_QueryType

func (QueryRequest_QueryType) EnumDescriptor deprecated 

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

Deprecated: Use QueryRequest_QueryType.Descriptor instead.

func (QueryRequest_QueryType) Number 

func (x QueryRequest_QueryType) Number() protoreflect.EnumNumber

func (QueryRequest_QueryType) String 

func (x QueryRequest_QueryType) String() string

func (QueryRequest_QueryType) Type 

func (QueryRequest_QueryType) Type() protoreflect.EnumType

type QueryResponse 

type QueryResponse struct {
	Status    *Status                 `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	DebugInfo string                  `protobuf:"bytes,2,opt,name=debug_info,json=debugInfo,proto3" json:"debug_info,omitempty"`
	LatencyUs uint64                  `protobuf:"varint,3,opt,name=latency_us,json=latencyUs,proto3" json:"latency_us,omitempty"`
	Results   []*QueryResponse_Result `protobuf:"bytes,4,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResponse) Descriptor deprecated 

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetDebugInfo 

func (x *QueryResponse) GetDebugInfo() string

func (*QueryResponse) GetLatencyUs 

func (x *QueryResponse) GetLatencyUs() uint64

func (*QueryResponse) GetResults 

func (x *QueryResponse) GetResults() []*QueryResponse_Result

func (*QueryResponse) GetStatus 

func (x *QueryResponse) GetStatus() *Status

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

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

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) String 

func (x *QueryResponse) String() string

type QueryResponse_Result 

type QueryResponse_Result struct {
	Documents []*Document `protobuf:"bytes,1,rep,name=documents,proto3" json:"documents,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResponse_Result) Descriptor deprecated 

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

Deprecated: Use QueryResponse_Result.ProtoReflect.Descriptor instead.

func (*QueryResponse_Result) GetDocuments 

func (x *QueryResponse_Result) GetDocuments() []*Document

func (*QueryResponse_Result) ProtoMessage 

func (*QueryResponse_Result) ProtoMessage()

func (*QueryResponse_Result) ProtoReflect 

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

func (*QueryResponse_Result) Reset 

func (x *QueryResponse_Result) Reset()

func (*QueryResponse_Result) String 

func (x *QueryResponse_Result) String() string

type StatsCollectionResponse 

type StatsCollectionResponse struct {
	Status          *Status          `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	CollectionStats *CollectionStats `protobuf:"bytes,2,opt,name=collection_stats,json=collectionStats,proto3" json:"collection_stats,omitempty"`
	// contains filtered or unexported fields
}

func (*StatsCollectionResponse) Descriptor deprecated 

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

Deprecated: Use StatsCollectionResponse.ProtoReflect.Descriptor instead.

func (*StatsCollectionResponse) GetCollectionStats 

func (x *StatsCollectionResponse) GetCollectionStats() *CollectionStats

func (*StatsCollectionResponse) GetStatus 

func (x *StatsCollectionResponse) GetStatus() *Status

func (*StatsCollectionResponse) ProtoMessage 

func (*StatsCollectionResponse) ProtoMessage()

func (*StatsCollectionResponse) ProtoReflect 

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

func (*StatsCollectionResponse) Reset 

func (x *StatsCollectionResponse) Reset()

func (*StatsCollectionResponse) String 

func (x *StatsCollectionResponse) String() string

type Status 

type Status struct {
	Code   int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode 

func (x *Status) GetCode() int32

func (*Status) GetReason 

func (x *Status) GetReason() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type UnimplementedHttpProximaServiceServer 

type UnimplementedHttpProximaServiceServer struct {
}

UnimplementedHttpProximaServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedHttpProximaServiceServer) Collection 

func (*UnimplementedHttpProximaServiceServer) Collection(context.Context, *HttpRequest) (*HttpResponse, error)

func (*UnimplementedHttpProximaServiceServer) GetDocumentByKey 

func (*UnimplementedHttpProximaServiceServer) GetDocumentByKey(context.Context, *HttpRequest) (*HttpResponse, error)

func (*UnimplementedHttpProximaServiceServer) GetVersion 

func (*UnimplementedHttpProximaServiceServer) GetVersion(context.Context, *HttpRequest) (*HttpResponse, error)

func (*UnimplementedHttpProximaServiceServer) ListCollections 

func (*UnimplementedHttpProximaServiceServer) ListCollections(context.Context, *HttpRequest) (*HttpResponse, error)

func (*UnimplementedHttpProximaServiceServer) Query 

func (*UnimplementedHttpProximaServiceServer) Query(context.Context, *HttpRequest) (*HttpResponse, error)

func (*UnimplementedHttpProximaServiceServer) StatsCollection 

func (*UnimplementedHttpProximaServiceServer) StatsCollection(context.Context, *HttpRequest) (*HttpResponse, error)

func (*UnimplementedHttpProximaServiceServer) Write 

func (*UnimplementedHttpProximaServiceServer) Write(context.Context, *HttpRequest) (*HttpResponse, error)

type UnimplementedProximaServiceServer 

type UnimplementedProximaServiceServer struct {
}

UnimplementedProximaServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedProximaServiceServer) CreateCollection 

func (*UnimplementedProximaServiceServer) CreateCollection(context.Context, *CollectionConfig) (*Status, error)

func (*UnimplementedProximaServiceServer) DescribeCollection 

func (*UnimplementedProximaServiceServer) DescribeCollection(context.Context, *CollectionName) (*DescribeCollectionResponse, error)

func (*UnimplementedProximaServiceServer) DropCollection 

func (*UnimplementedProximaServiceServer) DropCollection(context.Context, *CollectionName) (*Status, error)

func (*UnimplementedProximaServiceServer) GetDocumentByKey 

func (*UnimplementedProximaServiceServer) GetDocumentByKey(context.Context, *GetDocumentRequest) (*GetDocumentResponse, error)

func (*UnimplementedProximaServiceServer) GetVersion 

func (*UnimplementedProximaServiceServer) GetVersion(context.Context, *GetVersionRequest) (*GetVersionResponse, error)

func (*UnimplementedProximaServiceServer) ListCollections 

func (*UnimplementedProximaServiceServer) ListCollections(context.Context, *ListCondition) (*ListCollectionsResponse, error)

func (*UnimplementedProximaServiceServer) Query 

func (*UnimplementedProximaServiceServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)

func (*UnimplementedProximaServiceServer) StatsCollection 

func (*UnimplementedProximaServiceServer) StatsCollection(context.Context, *CollectionName) (*StatsCollectionResponse, error)

func (*UnimplementedProximaServiceServer) Write 

func (*UnimplementedProximaServiceServer) Write(context.Context, *WriteRequest) (*Status, error)

type WriteRequest 

type WriteRequest struct {
	CollectionName string                `protobuf:"bytes,1,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	RowMeta        *WriteRequest_RowMeta `protobuf:"bytes,2,opt,name=row_meta,json=rowMeta,proto3" json:"row_meta,omitempty"`
	Rows           []*WriteRequest_Row   `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"`
	RequestId      string                `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`        // optional
	MagicNumber    uint64                `protobuf:"varint,5,opt,name=magic_number,json=magicNumber,proto3" json:"magic_number,omitempty"` // optional
	// contains filtered or unexported fields
}

func (*WriteRequest) Descriptor deprecated 

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

Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.

func (*WriteRequest) GetCollectionName 

func (x *WriteRequest) GetCollectionName() string

func (*WriteRequest) GetMagicNumber 

func (x *WriteRequest) GetMagicNumber() uint64

func (*WriteRequest) GetRequestId 

func (x *WriteRequest) GetRequestId() string

func (*WriteRequest) GetRowMeta 

func (x *WriteRequest) GetRowMeta() *WriteRequest_RowMeta

func (*WriteRequest) GetRows 

func (x *WriteRequest) GetRows() []*WriteRequest_Row

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) ProtoReflect 

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

func (*WriteRequest) Reset 

func (x *WriteRequest) Reset()

func (*WriteRequest) String 

func (x *WriteRequest) String() string

type WriteRequest_IndexColumnMeta 

type WriteRequest_IndexColumnMeta struct {
	ColumnName string   `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	DataType   DataType `protobuf:"varint,2,opt,name=data_type,json=dataType,proto3,enum=proxima.be.proto.DataType" json:"data_type,omitempty"`
	Dimension  uint32   `protobuf:"varint,3,opt,name=dimension,proto3" json:"dimension,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteRequest_IndexColumnMeta) Descriptor deprecated 

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

Deprecated: Use WriteRequest_IndexColumnMeta.ProtoReflect.Descriptor instead.

func (*WriteRequest_IndexColumnMeta) GetColumnName 

func (x *WriteRequest_IndexColumnMeta) GetColumnName() string

func (*WriteRequest_IndexColumnMeta) GetDataType 

func (x *WriteRequest_IndexColumnMeta) GetDataType() DataType

func (*WriteRequest_IndexColumnMeta) GetDimension 

func (x *WriteRequest_IndexColumnMeta) GetDimension() uint32

func (*WriteRequest_IndexColumnMeta) ProtoMessage 

func (*WriteRequest_IndexColumnMeta) ProtoMessage()

func (*WriteRequest_IndexColumnMeta) ProtoReflect 

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

func (*WriteRequest_IndexColumnMeta) Reset 

func (x *WriteRequest_IndexColumnMeta) Reset()

func (*WriteRequest_IndexColumnMeta) String 

func (x *WriteRequest_IndexColumnMeta) String() string

type WriteRequest_Row 

type WriteRequest_Row struct {
	PrimaryKey          uint64            `protobuf:"varint,1,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	OperationType       OperationType     `` /* 137-byte string literal not displayed */
	ForwardColumnValues *GenericValueList `protobuf:"bytes,3,opt,name=forward_column_values,json=forwardColumnValues,proto3" json:"forward_column_values,omitempty"`
	IndexColumnValues   *GenericValueList `protobuf:"bytes,4,opt,name=index_column_values,json=indexColumnValues,proto3" json:"index_column_values,omitempty"`
	LsnContext          *LsnContext       `protobuf:"bytes,5,opt,name=lsn_context,json=lsnContext,proto3" json:"lsn_context,omitempty"` // optional
	// contains filtered or unexported fields
}

func (*WriteRequest_Row) Descriptor deprecated 

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

Deprecated: Use WriteRequest_Row.ProtoReflect.Descriptor instead.

func (*WriteRequest_Row) GetForwardColumnValues 

func (x *WriteRequest_Row) GetForwardColumnValues() *GenericValueList

func (*WriteRequest_Row) GetIndexColumnValues 

func (x *WriteRequest_Row) GetIndexColumnValues() *GenericValueList

func (*WriteRequest_Row) GetLsnContext 

func (x *WriteRequest_Row) GetLsnContext() *LsnContext

func (*WriteRequest_Row) GetOperationType 

func (x *WriteRequest_Row) GetOperationType() OperationType

func (*WriteRequest_Row) GetPrimaryKey 

func (x *WriteRequest_Row) GetPrimaryKey() uint64

func (*WriteRequest_Row) ProtoMessage 

func (*WriteRequest_Row) ProtoMessage()

func (*WriteRequest_Row) ProtoReflect 

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

func (*WriteRequest_Row) Reset 

func (x *WriteRequest_Row) Reset()

func (*WriteRequest_Row) String 

func (x *WriteRequest_Row) String() string

type WriteRequest_RowMeta 

type WriteRequest_RowMeta struct {
	ForwardColumnNames []string                        `protobuf:"bytes,1,rep,name=forward_column_names,json=forwardColumnNames,proto3" json:"forward_column_names,omitempty"`
	IndexColumnMetas   []*WriteRequest_IndexColumnMeta `protobuf:"bytes,2,rep,name=index_column_metas,json=indexColumnMetas,proto3" json:"index_column_metas,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteRequest_RowMeta) Descriptor deprecated 

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

Deprecated: Use WriteRequest_RowMeta.ProtoReflect.Descriptor instead.

func (*WriteRequest_RowMeta) GetForwardColumnNames 

func (x *WriteRequest_RowMeta) GetForwardColumnNames() []string

func (*WriteRequest_RowMeta) GetIndexColumnMetas 

func (x *WriteRequest_RowMeta) GetIndexColumnMetas() []*WriteRequest_IndexColumnMeta

func (*WriteRequest_RowMeta) ProtoMessage 

func (*WriteRequest_RowMeta) ProtoMessage()

func (*WriteRequest_RowMeta) ProtoReflect 

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

func (*WriteRequest_RowMeta) Reset 

func (x *WriteRequest_RowMeta) Reset()

func (*WriteRequest_RowMeta) String 

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