querycoord

Documentation

Index

• Constants
• Variables
• func EncodeCollectionLoadInfoKey(collection int64) string
• func EncodePartitionLoadInfoKey(collection, partition int64) string
• type Catalog
  • func NewCatalog(cli kv.MetaKv) Catalog
  • func (s Catalog) GetCollectionTargets() (map[int64]*querypb.CollectionTarget, error)
  • func (s Catalog) GetCollections() ([]*querypb.CollectionLoadInfo, error)
  • func (s Catalog) GetPartitions() (map[int64][]*querypb.PartitionLoadInfo, error)
  • func (s Catalog) GetReplicas() ([]*querypb.Replica, error)
  • func (s Catalog) GetResourceGroups() ([]*querypb.ResourceGroup, error)
  • func (s Catalog) ReleaseCollection(collection int64) error
  • func (s Catalog) ReleasePartition(collection int64, partitions ...int64) error
  • func (s Catalog) ReleaseReplica(collection, replica int64) error
  • func (s Catalog) ReleaseReplicas(collectionID int64) error
  • func (s Catalog) RemoveCollectionTarget(collectionID int64) error
  • func (s Catalog) RemoveResourceGroup(rgName string) error
  • func (s Catalog) SaveCollection(collection *querypb.CollectionLoadInfo, ...) error
  • func (s Catalog) SaveCollectionTargets(targets ...*querypb.CollectionTarget) error
  • func (s Catalog) SavePartition(info ...*querypb.PartitionLoadInfo) error
  • func (s Catalog) SaveReplica(replicas ...*querypb.Replica) error
  • func (s Catalog) SaveResourceGroup(rgs ...*querypb.ResourceGroup) error

Constants

const (
	CollectionLoadInfoPrefix = "querycoord-collection-loadinfo"
	PartitionLoadInfoPrefix  = "querycoord-partition-loadinfo"
	ReplicaPrefix            = "querycoord-replica"
	CollectionMetaPrefixV1   = "queryCoord-collectionMeta"
	ReplicaMetaPrefixV1      = "queryCoord-ReplicaMeta"
	ResourceGroupPrefix      = "queryCoord-ResourceGroup"

	MetaOpsBatchSize       = 128
	CollectionTargetPrefix = "queryCoord-Collection-Target"
)

Variables

var ErrInvalidKey = errors.New("invalid load info key")

Functions

func EncodeCollectionLoadInfoKey

func EncodeCollectionLoadInfoKey(collection int64) string

func EncodePartitionLoadInfoKey

func EncodePartitionLoadInfoKey(collection, partition int64) string

Types

type Catalog

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

func NewCatalog

func NewCatalog(cli kv.MetaKv) Catalog

func (Catalog) GetCollectionTargets

func (s Catalog) GetCollectionTargets() (map[int64]*querypb.CollectionTarget, error)

func (Catalog) GetCollections

func (s Catalog) GetCollections() ([]*querypb.CollectionLoadInfo, error)

func (Catalog) GetPartitions

func (s Catalog) GetPartitions() (map[int64][]*querypb.PartitionLoadInfo, error)

func (Catalog) GetReplicas

func (s Catalog) GetReplicas() ([]*querypb.Replica, error)

func (Catalog) GetResourceGroups

func (s Catalog) GetResourceGroups() ([]*querypb.ResourceGroup, error)

func (Catalog) ReleaseCollection

func (s Catalog) ReleaseCollection(collection int64) error

func (Catalog) ReleasePartition

func (s Catalog) ReleasePartition(collection int64, partitions ...int64) error

func (Catalog) ReleaseReplica

func (s Catalog) ReleaseReplica(collection, replica int64) error

func (Catalog) ReleaseReplicas

func (s Catalog) ReleaseReplicas(collectionID int64) error

func (Catalog) RemoveCollectionTarget

func (s Catalog) RemoveCollectionTarget(collectionID int64) error

func (Catalog) RemoveResourceGroup

func (s Catalog) RemoveResourceGroup(rgName string) error

func (Catalog) SaveCollection

func (s Catalog) SaveCollection(collection *querypb.CollectionLoadInfo, partitions ...*querypb.PartitionLoadInfo) error

func (Catalog) SaveCollectionTargets

func (s Catalog) SaveCollectionTargets(targets ...*querypb.CollectionTarget) error

func (Catalog) SavePartition

func (s Catalog) SavePartition(info ...*querypb.PartitionLoadInfo) error

func (Catalog) SaveReplica

func (s Catalog) SaveReplica(replicas ...*querypb.Replica) error

func (Catalog) SaveResourceGroup

func (s Catalog) SaveResourceGroup(rgs ...*querypb.ResourceGroup) error