meta

Documentation

Index

• Constants
• type PositionInfo
• type TaskCollectionPosition
• type TaskInfo
  • func (t *TaskInfo) CollectionNames() []string
  • func (t *TaskInfo) MapNames(db, collection string) (string, string)
• type TaskState
  • func (t TaskState) IsValidTaskState() bool
  • func (t TaskState) String() string

Constants

const (
	// MinTaskState Must ATTENTION the of `add` and `reduce` method of server.TaskNumMetric
	// if you add new task state !!!!
	MinTaskState = TaskStateInitial
	MaxTaskState = TaskStatePaused
)

Types

type PositionInfo

type PositionInfo struct {
	StartTime int64
	Time      int64
	DataPair  *commonpb.KeyDataPair
	Dropped   bool
}

type TaskCollectionPosition

type TaskCollectionPosition struct {
	TaskID         string
	CollectionID   int64
	CollectionName string
	// Positions key -> channel name, value -> check point
	Positions map[string]*PositionInfo
	// OpPositions latest op positions
	OpPositions map[string]*PositionInfo
	// TargetPositions target instance positions
	TargetPositions map[string]*PositionInfo
}

type TaskInfo

type TaskInfo struct {
	TaskID                string
	MilvusConnectParam    model.MilvusConnectParam
	KafkaConnectParam     model.KafkaConnectParam
	WriterCacheConfig     model.BufferConfig
	CollectionInfos       []model.CollectionInfo
	DBCollections         map[string][]model.CollectionInfo
	NameMapping           []model.NameMapping
	RPCRequestChannelInfo model.ChannelInfo
	ExtraInfo             model.ExtraInfo
	ExcludeCollections    []string // it's used for the `*` collection name
	DisableAutoStart      bool
	State                 TaskState
	Reason                string
}

func (*TaskInfo) CollectionNames

func (t *TaskInfo) CollectionNames() []string

func (*TaskInfo) MapNames

func (t *TaskInfo) MapNames(db, collection string) (string, string)

type TaskState

type TaskState int

const (
	TaskStateInitial TaskState = iota
	TaskStateRunning
	TaskStatePaused
)

func (TaskState) IsValidTaskState

func (t TaskState) IsValidTaskState() bool

func (TaskState) String

func (t TaskState) String() string