querycoord

Documentation

Index

• Constants
• Variables
• func EncodeCollectionLoadInfoKey(collection int64) string
• func EncodePartitionLoadInfoKey(collection, partition int64) string
• func EncodePartitionLoadInfoPrefix(collection int64) string
• type Catalog
  • func NewCatalog(cli kv.MetaKv) Catalog
  • func (s Catalog) GetCollectionTargets(ctx context.Context) (map[int64]*querypb.CollectionTarget, error)
  • func (s Catalog) GetCollections(ctx context.Context) ([]*querypb.CollectionLoadInfo, error)
  • func (s Catalog) GetPartitions(ctx context.Context, collectionIDs []int64) (map[int64][]*querypb.PartitionLoadInfo, error)
  • func (s Catalog) GetReplicas(ctx context.Context) ([]*querypb.Replica, error)
  • func (s Catalog) GetResourceGroups(ctx context.Context) ([]*querypb.ResourceGroup, error)
  • func (s Catalog) ReleaseCollection(ctx context.Context, collection int64) error
  • func (s Catalog) ReleasePartition(ctx context.Context, collection int64, partitions ...int64) error
  • func (s Catalog) ReleaseReplica(ctx context.Context, collection int64, replicas ...int64) error
  • func (s Catalog) ReleaseReplicas(ctx context.Context, collectionID int64) error
  • func (s Catalog) RemoveCollectionTarget(ctx context.Context, collectionID int64) error
  • func (s Catalog) RemoveResourceGroup(ctx context.Context, rgName string) error
  • func (s Catalog) SaveCollection(ctx context.Context, collection *querypb.CollectionLoadInfo, ...) error
  • func (s Catalog) SaveCollectionTargets(ctx context.Context, targets ...*querypb.CollectionTarget) error
  • func (s Catalog) SavePartition(ctx context.Context, info ...*querypb.PartitionLoadInfo) error
  • func (s Catalog) SaveReplica(ctx context.Context, replicas ...*querypb.Replica) error
  • func (s Catalog) SaveResourceGroup(ctx context.Context, 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

func EncodePartitionLoadInfoPrefix

func EncodePartitionLoadInfoPrefix(collection 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(ctx context.Context) (map[int64]*querypb.CollectionTarget, error)

func (Catalog) GetCollections

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

func (Catalog) GetPartitions

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

func (Catalog) GetReplicas

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

func (Catalog) GetResourceGroups

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

func (Catalog) ReleaseCollection

func (s Catalog) ReleaseCollection(ctx context.Context, collection int64) error

func (Catalog) ReleasePartition

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

func (Catalog) ReleaseReplica

func (s Catalog) ReleaseReplica(ctx context.Context, collection int64, replicas ...int64) error

func (Catalog) ReleaseReplicas

func (s Catalog) ReleaseReplicas(ctx context.Context, collectionID int64) error

func (Catalog) RemoveCollectionTarget

func (s Catalog) RemoveCollectionTarget(ctx context.Context, collectionID int64) error

func (Catalog) RemoveResourceGroup

func (s Catalog) RemoveResourceGroup(ctx context.Context, rgName string) error

func (Catalog) SaveCollection

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

func (Catalog) SaveCollectionTargets

func (s Catalog) SaveCollectionTargets(ctx context.Context, targets ...*querypb.CollectionTarget) error

func (Catalog) SavePartition

func (s Catalog) SavePartition(ctx context.Context, info ...*querypb.PartitionLoadInfo) error

func (Catalog) SaveReplica

func (s Catalog) SaveReplica(ctx context.Context, replicas ...*querypb.Replica) error

func (Catalog) SaveResourceGroup

func (s Catalog) SaveResourceGroup(ctx context.Context, rgs ...*querypb.ResourceGroup) error