meta

package
v0.10.3-0...-f06509b Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AliasesMeta210 

type AliasesMeta210 map[string]*pb.CollectionInfo // alias name -> coll

func (*AliasesMeta210) AddAlias 

func (meta *AliasesMeta210) AddAlias(alias string, info *pb.CollectionInfo)

func (*AliasesMeta210) GenerateSaves 

func (meta *AliasesMeta210) GenerateSaves() map[string]string

type AliasesMeta220 

type AliasesMeta220 map[string]*model.Alias // alias name -> coll

func (*AliasesMeta220) AddAlias 

func (meta *AliasesMeta220) AddAlias(alias string, aliasInfo *model.Alias)

func (*AliasesMeta220) GenerateSaves 

func (meta *AliasesMeta220) GenerateSaves() (map[string]string, error)

type All210 

type All210 struct {
	TtAliases TtAliasesMeta210
	Aliases   AliasesMeta210

	TtCollections TtCollectionsMeta210
	Collections   CollectionsMeta210

	CollectionIndexes CollectionIndexesMeta210
	SegmentIndexes    SegmentIndexesMeta210
	IndexBuildMeta    IndexBuildMeta210

	LastDDLRecords LastDDLRecords

	CollectionLoadInfos CollectionLoadInfo210
}

func (*All210) GenerateSaves 

func (meta *All210) GenerateSaves() map[string]string

type All220 

type All220 struct {
	TtCollections TtCollectionsMeta220
	Collections   CollectionsMeta220

	TtAliases TtAliasesMeta220
	Aliases   AliasesMeta220

	TtPartitions TtPartitionsMeta220
	Partitions   PartitionsMeta220

	TtFields TtFieldsMeta220
	Fields   FieldsMeta220

	CollectionIndexes CollectionIndexesMeta220
	SegmentIndexes    SegmentIndexesMeta220

	// QueryCoord Meta
	CollectionLoadInfos CollectionLoadInfo220
	PartitionLoadInfos  PartitionLoadInfo220
}

type CollectionIndexesMeta210 

type CollectionIndexesMeta210 map[UniqueID]map[UniqueID]*pb.IndexInfo // coll_id -> index_id -> index

func (*CollectionIndexesMeta210) AddIndex 

func (meta *CollectionIndexesMeta210) AddIndex(collectionID UniqueID, indexID UniqueID, index *pb.IndexInfo)

func (*CollectionIndexesMeta210) GenerateSaves 

func (meta *CollectionIndexesMeta210) GenerateSaves() map[string]string

func (*CollectionIndexesMeta210) GetIndex 

func (meta *CollectionIndexesMeta210) GetIndex(collectionID UniqueID, indexID UniqueID) (*pb.IndexInfo, error)

type CollectionIndexesMeta220 

type CollectionIndexesMeta220 map[UniqueID]map[UniqueID]*model.Index // coll_id -> index_id -> index

func (*CollectionIndexesMeta220) AddRecord 

func (meta *CollectionIndexesMeta220) AddRecord(collID UniqueID, indexID int64, record *model.Index)

func (*CollectionIndexesMeta220) GenerateSaves 

func (meta *CollectionIndexesMeta220) GenerateSaves() (map[string]string, error)

type CollectionLoadInfo210 

type CollectionLoadInfo210 map[UniqueID]*model.CollectionLoadInfo // collectionID -> CollectionLoadInfo

type CollectionLoadInfo220 

type CollectionLoadInfo220 map[UniqueID]*model.CollectionLoadInfo // collectionID -> CollectionLoadInfo

func (*CollectionLoadInfo220) GenerateSaves 

func (meta *CollectionLoadInfo220) GenerateSaves() (map[string]string, error)

type CollectionsMeta210 

type CollectionsMeta210 map[UniqueID]*pb.CollectionInfo // coll_id -> coll

func (*CollectionsMeta210) AddCollection 

func (meta *CollectionsMeta210) AddCollection(collID UniqueID, coll *pb.CollectionInfo)

func (*CollectionsMeta210) GenerateSaves 

func (meta *CollectionsMeta210) GenerateSaves() map[string]string

type CollectionsMeta220 

type CollectionsMeta220 map[UniqueID]*model.Collection // coll_id -> coll

func (*CollectionsMeta220) AddCollection 

func (meta *CollectionsMeta220) AddCollection(collectionID UniqueID, coll *model.Collection)

func (*CollectionsMeta220) GenerateSaves 

func (meta *CollectionsMeta220) GenerateSaves(sourceVersion semver.Version) (map[string]string, error)

type FieldIndexes210 

type FieldIndexes210 map[UniqueID]*FieldIndexesWithSchema // coll_id -> field indexes.

func (*FieldIndexes210) AddRecord 

func (meta *FieldIndexes210) AddRecord(collectionID UniqueID, fieldIndexes []*pb.FieldIndexInfo, schema *schemapb.CollectionSchema)

func (*FieldIndexes210) Merge 

func (meta *FieldIndexes210) Merge(other FieldIndexes210)

type FieldIndexesWithSchema 

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

type FieldsMeta220 

type FieldsMeta220 map[UniqueID][]*model.Field // coll_id -> ts -> fields

type IndexBuildMeta210 

type IndexBuildMeta210 map[UniqueID]*legacypb.IndexMeta // index_build_id -> index

func (*IndexBuildMeta210) AddRecord 

func (meta *IndexBuildMeta210) AddRecord(indexBuildID UniqueID, record *legacypb.IndexMeta)

func (*IndexBuildMeta210) GenerateSaves 

func (meta *IndexBuildMeta210) GenerateSaves() map[string]string

func (*IndexBuildMeta210) GetAllBuildIDs 

func (meta *IndexBuildMeta210) GetAllBuildIDs() []UniqueID

type LastDDLRecords 

type LastDDLRecords map[string]string // We don't care this since it didn't work.

func (*LastDDLRecords) AddRecord 

func (meta *LastDDLRecords) AddRecord(k, v string)

func (*LastDDLRecords) GenerateSaves 

func (meta *LastDDLRecords) GenerateSaves() map[string]string

type Meta 

type Meta struct {
	SourceVersion semver.Version
	Version       semver.Version

	Meta210 *All210
	Meta220 *All220
}

func From210To220 

func From210To220(metas *Meta) (*Meta, error)

type PartitionLoadInfo220 

type PartitionLoadInfo220 map[UniqueID]map[UniqueID]*model.PartitionLoadInfo // collectionID, partitionID -> PartitionLoadInfo

func (*PartitionLoadInfo220) GenerateSaves 

func (meta *PartitionLoadInfo220) GenerateSaves() (map[string]string, error)

type PartitionsMeta220 

type PartitionsMeta220 map[UniqueID][]*model.Partition // coll_id -> ts -> partitions

type SegmentIndexesMeta210 

type SegmentIndexesMeta210 map[UniqueID]map[UniqueID]*pb.SegmentIndexInfo // seg_id -> index_id -> segment index

func (*SegmentIndexesMeta210) AddIndex 

func (meta *SegmentIndexesMeta210) AddIndex(segmentID UniqueID, indexID UniqueID, index *pb.SegmentIndexInfo)

func (*SegmentIndexesMeta210) GenerateSaves 

func (meta *SegmentIndexesMeta210) GenerateSaves() map[string]string

type SegmentIndexesMeta220 

type SegmentIndexesMeta220 map[UniqueID]map[UniqueID]*model.SegmentIndex // seg_id -> index_id -> segment index

func (*SegmentIndexesMeta220) AddRecord 

func (meta *SegmentIndexesMeta220) AddRecord(segID UniqueID, indexID UniqueID, record *model.SegmentIndex)

func (*SegmentIndexesMeta220) GenerateSaves 

func (meta *SegmentIndexesMeta220) GenerateSaves() (map[string]string, error)

type Timestamp 

type Timestamp = typeutil.Timestamp

type TtAliasesMeta210 

type TtAliasesMeta210 map[string]map[Timestamp]*pb.CollectionInfo // alias name -> ts -> coll

func (*TtAliasesMeta210) AddAlias 

func (meta *TtAliasesMeta210) AddAlias(alias string, info *pb.CollectionInfo, ts Timestamp)

func (*TtAliasesMeta210) GenerateSaves 

func (meta *TtAliasesMeta210) GenerateSaves() map[string]string

type TtAliasesMeta220 

type TtAliasesMeta220 map[string]map[Timestamp]*model.Alias // alias name -> ts -> coll

func (*TtAliasesMeta220) AddAlias 

func (meta *TtAliasesMeta220) AddAlias(alias string, aliasInfo *model.Alias, ts Timestamp)

func (*TtAliasesMeta220) GenerateSaves 

func (meta *TtAliasesMeta220) GenerateSaves() (map[string]string, error)

type TtCollectionsMeta210 

type TtCollectionsMeta210 map[UniqueID]map[Timestamp]*pb.CollectionInfo // coll_id -> ts -> coll

func (*TtCollectionsMeta210) AddCollection 

func (meta *TtCollectionsMeta210) AddCollection(collID UniqueID, coll *pb.CollectionInfo, ts Timestamp)

func (*TtCollectionsMeta210) GenerateSaves 

func (meta *TtCollectionsMeta210) GenerateSaves() map[string]string

type TtCollectionsMeta220 

type TtCollectionsMeta220 map[UniqueID]map[Timestamp]*model.Collection // coll_id -> ts -> coll

func (*TtCollectionsMeta220) AddCollection 

func (meta *TtCollectionsMeta220) AddCollection(collectionID UniqueID, coll *model.Collection, ts Timestamp)

func (*TtCollectionsMeta220) GenerateSaves 

func (meta *TtCollectionsMeta220) GenerateSaves(sourceVersion semver.Version) (map[string]string, error)

type TtFieldsMeta220 

type TtFieldsMeta220 map[UniqueID]map[Timestamp][]*model.Field // coll_id -> ts -> fields

type TtPartitionsMeta220 

type TtPartitionsMeta220 map[UniqueID]map[Timestamp][]*model.Partition // coll_id -> ts -> partitions

type UniqueID 

type UniqueID = typeutil.UniqueID

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.