querycoord

package

v0.10.3-0...-f06509b Latest Latest Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/milvus-io/milvus

Documentation ¶

Index ¶

Constants
Variables
func EncodeCollectionLoadInfoKey(collection int64) string
func EncodePartitionLoadInfoKey(collection, partition int64) string
type Catalog
- func NewCatalog(cli kv.MetaKv) Catalog

Constants ¶

View Source

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 ¶

View Source

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

Source Files ¶

View all Source files

kv_catalog.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL