utils

Documentation

Index

• Constants
• func ArrayToMap(strs []int64) map[int64]bool
• func Base64MsgPosition(position *msgpb.MsgPosition) string
• func ComposeTS(physical, logical int64) uint64
• func GetCreateDBCollections(request *backuppb.CreateBackupRequest) string
• func GetRestoreDBCollections(request *backuppb.RestoreBackupRequest) string
• func IsSupportVersion(versionStr string) (bool, error)
• func KVPairToMap(m []*backuppb.KeyValuePair) (map[string]string, error)
• func KvPairsMap(kvps []*backuppb.KeyValuePair) map[string]string
• func MapKeyArray(dict map[int64]bool) []int64
• func MapToKVPair(dict map[string]string) []*backuppb.KeyValuePair
• func ParseTS(ts uint64) (time.Time, uint64)
• func UUID() string
• func ValidateType(entity, entityType string) error
• func WrapDBCollections(dbCollections string) *structpb.Value
• type FlakeIdGenerator
  • func NewFlakeIdGenerator() FlakeIdGenerator
  • func (f FlakeIdGenerator) NextId() (int64, error)
• type IdGenerator

Constants

const (
	MaxNameLength = 128
)

const (
	NotSupportVersionMsg = "milvus version doesn't support backup tool. Lowest support version is 2.2.0"
)

const (
	PARAMS = "params"
)

Functions

func ArrayToMap

func ArrayToMap(strs []int64) map[int64]bool

func Base64MsgPosition

func Base64MsgPosition(position *msgpb.MsgPosition) string

func ComposeTS

func ComposeTS(physical, logical int64) uint64

ComposeTS returns a timestamp composed of physical part and logical part

func GetCreateDBCollections

func GetCreateDBCollections(request *backuppb.CreateBackupRequest) string

func GetRestoreDBCollections

func GetRestoreDBCollections(request *backuppb.RestoreBackupRequest) string

func IsSupportVersion

func IsSupportVersion(versionStr string) (bool, error)

func KVPairToMap

func KVPairToMap(m []*backuppb.KeyValuePair) (map[string]string, error)

kvPairToMap largely copied from internal/proxy/task.go#parseIndexParams

func KvPairsMap

func KvPairsMap(kvps []*backuppb.KeyValuePair) map[string]string

KvPairsMap converts common.KeyValuePair slices into map

func MapKeyArray

func MapKeyArray(dict map[int64]bool) []int64

func MapToKVPair

func MapToKVPair(dict map[string]string) []*backuppb.KeyValuePair

func ParseTS

func ParseTS(ts uint64) (time.Time, uint64)

ParseTS returns a timestamp composed of physical part and logical part

func UUID

func UUID() string

func ValidateType

func ValidateType(entity, entityType string) error

func WrapDBCollections

func WrapDBCollections(dbCollections string) *structpb.Value

Types

type FlakeIdGenerator

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

func NewFlakeIdGenerator

func NewFlakeIdGenerator() FlakeIdGenerator

func (FlakeIdGenerator) NextId

func (f FlakeIdGenerator) NextId() (int64, error)

type IdGenerator

type IdGenerator interface {
	NextId() (int64, error)
}