metautil

Documentation

Index

• func BuildDeltaLogPath(rootPath string, collectionID, partitionID, segmentID, logID typeutil.UniqueID) string
• func BuildInsertLogPath(rootPath string, ...) string
• func BuildSegmentIndexFilePath(rootPath string, buildID, indexVersion, partID, segID int64, fileKey string) string
• func BuildSegmentIndexFilePaths(rootPath string, buildID, indexVersion, partID, segID int64, fileKeys []string) []string
• func BuildStatsLogPath(rootPath string, ...) string
• func GetSegmentIDFromDeltaLogPath(logPath string) typeutil.UniqueID
• func GetSegmentIDFromInsertLogPath(logPath string) typeutil.UniqueID
• func GetSegmentIDFromStatsLogPath(logPath string) typeutil.UniqueID
• func JoinIDPath(ids ...typeutil.UniqueID) string
• func NewDynChannelMapper() *dynamicChannelMapper
• func ParseInsertLogPath(path string) (collectionID, partitionID, segmentID, fieldID, logID typeutil.UniqueID, ...)
• type Channel
  • func NewChannel(physicalName string, collectionID int64, idx int64, mapper ChannelMapper) Channel
  • func ParseChannel(virtualName string, mapper ChannelMapper) (Channel, error)
  • func (c Channel) Equal(ac Channel) bool
  • func (c Channel) EqualString(str string) bool
  • func (c Channel) PhysicalName() string
  • func (c Channel) VirtualName() string
• type ChannelMapper

Functions

func BuildDeltaLogPath

func BuildDeltaLogPath(rootPath string, collectionID, partitionID, segmentID, logID typeutil.UniqueID) string

func BuildInsertLogPath

func BuildInsertLogPath(rootPath string, collectionID, partitionID, segmentID, fieldID, logID typeutil.UniqueID) string

func BuildSegmentIndexFilePath

func BuildSegmentIndexFilePath(rootPath string, buildID, indexVersion, partID, segID int64, fileKey string) string

func BuildSegmentIndexFilePaths

func BuildSegmentIndexFilePaths(rootPath string, buildID, indexVersion, partID, segID int64, fileKeys []string) []string

func BuildStatsLogPath

func BuildStatsLogPath(rootPath string, collectionID, partitionID, segmentID, fieldID, logID typeutil.UniqueID) string

func GetSegmentIDFromDeltaLogPath

func GetSegmentIDFromDeltaLogPath(logPath string) typeutil.UniqueID

func GetSegmentIDFromInsertLogPath

func GetSegmentIDFromInsertLogPath(logPath string) typeutil.UniqueID

func GetSegmentIDFromStatsLogPath

func GetSegmentIDFromStatsLogPath(logPath string) typeutil.UniqueID

func JoinIDPath

func JoinIDPath(ids ...typeutil.UniqueID) string

JoinIDPath joins ids to path format.

func NewDynChannelMapper

func NewDynChannelMapper() *dynamicChannelMapper

func ParseInsertLogPath

func ParseInsertLogPath(path string) (collectionID, partitionID, segmentID, fieldID, logID typeutil.UniqueID, ok bool)

Types

type Channel

type Channel struct {
	ChannelMapper
	// contains filtered or unexported fields
}

Channel struct maintains the channel information

func NewChannel

func NewChannel(physicalName string, collectionID int64, idx int64, mapper ChannelMapper) Channel

NewChannel returns a Channel instance with provided physical channel and other informations.

func ParseChannel

func ParseChannel(virtualName string, mapper ChannelMapper) (Channel, error)

func (Channel) Equal

func (c Channel) Equal(ac Channel) bool

func (Channel) EqualString

func (c Channel) EqualString(str string) bool

func (Channel) PhysicalName

func (c Channel) PhysicalName() string

func (Channel) VirtualName

func (c Channel) VirtualName() string

type ChannelMapper

type ChannelMapper interface {
	ChannelIdx(string) int
	ChannelName(int) string
}

ChannelMapper is the interface provides physical channel name mapping functions.