clusteringpb

package
v2.5.5 Latest Latest
Warning

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

 Go to latest Published: Feb 25, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_clustering_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AnalyzeInfo 

type AnalyzeInfo struct {
	ClusterID       string                 `protobuf:"bytes,1,opt,name=clusterID,proto3" json:"clusterID,omitempty"`
	BuildID         int64                  `protobuf:"varint,2,opt,name=buildID,proto3" json:"buildID,omitempty"`
	CollectionID    int64                  `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionID     int64                  `protobuf:"varint,4,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	SegmentID       int64                  `protobuf:"varint,5,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	Version         int64                  `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
	Dim             int64                  `protobuf:"varint,7,opt,name=dim,proto3" json:"dim,omitempty"`
	NumClusters     int64                  `protobuf:"varint,8,opt,name=num_clusters,json=numClusters,proto3" json:"num_clusters,omitempty"`
	TrainSize       int64                  `protobuf:"varint,9,opt,name=train_size,json=trainSize,proto3" json:"train_size,omitempty"`
	MinClusterRatio float64                `protobuf:"fixed64,10,opt,name=min_cluster_ratio,json=minClusterRatio,proto3" json:"min_cluster_ratio,omitempty"` // min_cluster_size / avg_cluster_size < min_cluster_ratio, is skew
	MaxClusterRatio float64                `protobuf:"fixed64,11,opt,name=max_cluster_ratio,json=maxClusterRatio,proto3" json:"max_cluster_ratio,omitempty"` // max_cluster_size / avg_cluster_size > max_cluster_ratio, is skew
	MaxClusterSize  int64                  `protobuf:"varint,12,opt,name=max_cluster_size,json=maxClusterSize,proto3" json:"max_cluster_size,omitempty"`
	InsertFiles     map[int64]*InsertFiles `` /* 184-byte string literal not displayed */
	NumRows         map[int64]int64        `` /* 173-byte string literal not displayed */
	FieldSchema     *schemapb.FieldSchema  `protobuf:"bytes,15,opt,name=field_schema,json=fieldSchema,proto3" json:"field_schema,omitempty"`
	StorageConfig   *StorageConfig         `protobuf:"bytes,16,opt,name=storage_config,json=storageConfig,proto3" json:"storage_config,omitempty"`
	// contains filtered or unexported fields
}

func (*AnalyzeInfo) Descriptor deprecated 

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

Deprecated: Use AnalyzeInfo.ProtoReflect.Descriptor instead.

func (*AnalyzeInfo) GetBuildID 

func (x *AnalyzeInfo) GetBuildID() int64

func (*AnalyzeInfo) GetClusterID 

func (x *AnalyzeInfo) GetClusterID() string

func (*AnalyzeInfo) GetCollectionID 

func (x *AnalyzeInfo) GetCollectionID() int64

func (*AnalyzeInfo) GetDim 

func (x *AnalyzeInfo) GetDim() int64

func (*AnalyzeInfo) GetFieldSchema 

func (x *AnalyzeInfo) GetFieldSchema() *schemapb.FieldSchema

func (*AnalyzeInfo) GetInsertFiles 

func (x *AnalyzeInfo) GetInsertFiles() map[int64]*InsertFiles

func (*AnalyzeInfo) GetMaxClusterRatio 

func (x *AnalyzeInfo) GetMaxClusterRatio() float64

func (*AnalyzeInfo) GetMaxClusterSize 

func (x *AnalyzeInfo) GetMaxClusterSize() int64

func (*AnalyzeInfo) GetMinClusterRatio 

func (x *AnalyzeInfo) GetMinClusterRatio() float64

func (*AnalyzeInfo) GetNumClusters 

func (x *AnalyzeInfo) GetNumClusters() int64

func (*AnalyzeInfo) GetNumRows 

func (x *AnalyzeInfo) GetNumRows() map[int64]int64

func (*AnalyzeInfo) GetPartitionID 

func (x *AnalyzeInfo) GetPartitionID() int64

func (*AnalyzeInfo) GetSegmentID 

func (x *AnalyzeInfo) GetSegmentID() int64

func (*AnalyzeInfo) GetStorageConfig 

func (x *AnalyzeInfo) GetStorageConfig() *StorageConfig

func (*AnalyzeInfo) GetTrainSize 

func (x *AnalyzeInfo) GetTrainSize() int64

func (*AnalyzeInfo) GetVersion 

func (x *AnalyzeInfo) GetVersion() int64

func (*AnalyzeInfo) ProtoMessage 

func (*AnalyzeInfo) ProtoMessage()

func (*AnalyzeInfo) ProtoReflect 

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

func (*AnalyzeInfo) Reset 

func (x *AnalyzeInfo) Reset()

func (*AnalyzeInfo) String 

func (x *AnalyzeInfo) String() string

type ClusteringCentroidIdMappingStats 

type ClusteringCentroidIdMappingStats struct {
	CentroidIdMapping []uint32 `protobuf:"varint,1,rep,packed,name=centroid_id_mapping,json=centroidIdMapping,proto3" json:"centroid_id_mapping,omitempty"`
	NumInCentroid     []int64  `protobuf:"varint,2,rep,packed,name=num_in_centroid,json=numInCentroid,proto3" json:"num_in_centroid,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusteringCentroidIdMappingStats) Descriptor deprecated 

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

Deprecated: Use ClusteringCentroidIdMappingStats.ProtoReflect.Descriptor instead.

func (*ClusteringCentroidIdMappingStats) GetCentroidIdMapping 

func (x *ClusteringCentroidIdMappingStats) GetCentroidIdMapping() []uint32

func (*ClusteringCentroidIdMappingStats) GetNumInCentroid 

func (x *ClusteringCentroidIdMappingStats) GetNumInCentroid() []int64

func (*ClusteringCentroidIdMappingStats) ProtoMessage 

func (*ClusteringCentroidIdMappingStats) ProtoMessage()

func (*ClusteringCentroidIdMappingStats) ProtoReflect 

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

func (*ClusteringCentroidIdMappingStats) Reset 

func (x *ClusteringCentroidIdMappingStats) Reset()

func (*ClusteringCentroidIdMappingStats) String 

func (x *ClusteringCentroidIdMappingStats) String() string

type ClusteringCentroidsStats 

type ClusteringCentroidsStats struct {
	Centroids []*schemapb.VectorField `protobuf:"bytes,1,rep,name=centroids,proto3" json:"centroids,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusteringCentroidsStats) Descriptor deprecated 

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

Deprecated: Use ClusteringCentroidsStats.ProtoReflect.Descriptor instead.

func (*ClusteringCentroidsStats) GetCentroids 

func (x *ClusteringCentroidsStats) GetCentroids() []*schemapb.VectorField

func (*ClusteringCentroidsStats) ProtoMessage 

func (*ClusteringCentroidsStats) ProtoMessage()

func (*ClusteringCentroidsStats) ProtoReflect 

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

func (*ClusteringCentroidsStats) Reset 

func (x *ClusteringCentroidsStats) Reset()

func (*ClusteringCentroidsStats) String 

func (x *ClusteringCentroidsStats) String() string

type InsertFiles 

type InsertFiles struct {
	InsertFiles []string `protobuf:"bytes,1,rep,name=insert_files,json=insertFiles,proto3" json:"insert_files,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertFiles) Descriptor deprecated 

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

Deprecated: Use InsertFiles.ProtoReflect.Descriptor instead.

func (*InsertFiles) GetInsertFiles 

func (x *InsertFiles) GetInsertFiles() []string

func (*InsertFiles) ProtoMessage 

func (*InsertFiles) ProtoMessage()

func (*InsertFiles) ProtoReflect 

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

func (*InsertFiles) Reset 

func (x *InsertFiles) Reset()

func (*InsertFiles) String 

func (x *InsertFiles) String() string

type StorageConfig 

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

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

func (*StorageConfig) Descriptor deprecated 

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

Deprecated: Use StorageConfig.ProtoReflect.Descriptor instead.

func (*StorageConfig) GetAccessKeyID 

func (x *StorageConfig) GetAccessKeyID() string

func (*StorageConfig) GetAddress 

func (x *StorageConfig) GetAddress() string

func (*StorageConfig) GetBucketName 

func (x *StorageConfig) GetBucketName() string

func (*StorageConfig) GetCloudProvider 

func (x *StorageConfig) GetCloudProvider() string

func (*StorageConfig) GetGcpCredentialJSON 

func (x *StorageConfig) GetGcpCredentialJSON() string

func (*StorageConfig) GetIAMEndpoint 

func (x *StorageConfig) GetIAMEndpoint() string

func (*StorageConfig) GetRegion 

func (x *StorageConfig) GetRegion() string

func (*StorageConfig) GetRequestTimeoutMs 

func (x *StorageConfig) GetRequestTimeoutMs() int64

func (*StorageConfig) GetRootPath 

func (x *StorageConfig) GetRootPath() string

func (*StorageConfig) GetSecretAccessKey 

func (x *StorageConfig) GetSecretAccessKey() string

func (*StorageConfig) GetSslCACert 

func (x *StorageConfig) GetSslCACert() string

func (*StorageConfig) GetStorageType 

func (x *StorageConfig) GetStorageType() string

func (*StorageConfig) GetUseIAM 

func (x *StorageConfig) GetUseIAM() bool

func (*StorageConfig) GetUseSSL 

func (x *StorageConfig) GetUseSSL() bool

func (*StorageConfig) GetUseVirtualHost 

func (x *StorageConfig) GetUseVirtualHost() bool

func (*StorageConfig) ProtoMessage 

func (*StorageConfig) ProtoMessage()

func (*StorageConfig) ProtoReflect 

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

func (*StorageConfig) Reset 

func (x *StorageConfig) Reset()

func (*StorageConfig) String 

func (x *StorageConfig) String() string

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.