position_store

type MongoPosition struct {
	StartPosition   config.MongoPosition `json:"start_position" bson:"start_position"`
	CurrentPosition config.MongoPosition `json:"current_position" bson:"current_position"`
}

type Position struct {
	// Version is the schema version of position
	Version string
	// Name is the unique name of a pipeline
	Name       string
	Stage      config.InputMode
	Value      string
	UpdateTime time.Time
}

type PositionCacheInterface interface {
	Start() error
	Close()
	Put(position Position) error
	Get() (position Position, exist bool, err error)
	Flush() error
	Clear() error
}

type PositionEntity struct {
	Name          string `json:"name" bson:"name"`
	Stage         string `json:"stage" bson:"stage"`
	MongoPosition `json:",inline" bson:",inline"`
	LastUpdate    string `json:"last_update" bson:"last_update"`
}

type PositionRepo interface {
	Get(pipelineName string) (Position, bool, error)
	Put(pipelineName string, position Position) error
	Delete(pipelineName string) error
	Close() error
}