position

Documentation

Index

• func FindPositionFileNotCreate(filePath string, initPositionData string)
• func GetPositionFilePath(conf *config.BaseConfig) string
• type MongoPosition
  • func (pos *MongoPosition) Close()
  • func (pos *MongoPosition) LoadPosition(config *config.BaseConfig)
  • func (pos *MongoPosition) ModifyPosition(v string) error
  • func (pos *MongoPosition) SavePosition() error
  • func (pos *MongoPosition) StartPosition()
• type MysqlBasePosition
• type MysqlPosition
  • func (pos *MysqlPosition) Close()
  • func (pos *MysqlPosition) LoadPosition(config *config.BaseConfig)
  • func (pos *MysqlPosition) ModifyPosition(v string) error
  • func (pos *MysqlPosition) SavePosition() error
  • func (pos *MysqlPosition) StartPosition()
• type Position

Functions

func FindPositionFileNotCreate

func FindPositionFileNotCreate(filePath string, initPositionData string)

func GetPositionFilePath

func GetPositionFilePath(conf *config.BaseConfig) string

Types

type MongoPosition

type MongoPosition struct {
	sync.RWMutex

	FilePath string

	InitStartPosition time.Time
	// contains filtered or unexported fields
}

func (*MongoPosition) Close

func (pos *MongoPosition) Close()

func (*MongoPosition) LoadPosition

func (pos *MongoPosition) LoadPosition(config *config.BaseConfig)

func (*MongoPosition) ModifyPosition

func (pos *MongoPosition) ModifyPosition(v string) error

func (*MongoPosition) SavePosition

func (pos *MongoPosition) SavePosition() error

func (*MongoPosition) StartPosition

func (pos *MongoPosition) StartPosition()

type MysqlBasePosition

type MysqlBasePosition struct {
	BinlogName string `toml:"binlog-name"`
	BinlogPos  uint32 `toml:"binlog-pos"`
	BinlogGTID string `toml:"binlog-gtid"`
}

type MysqlPosition

type MysqlPosition struct {
	sync.RWMutex
	*MysqlBasePosition
	FilePath string
	// contains filtered or unexported fields
}

func (*MysqlPosition) Close

func (pos *MysqlPosition) Close()

func (*MysqlPosition) LoadPosition

func (pos *MysqlPosition) LoadPosition(config *config.BaseConfig)

func (*MysqlPosition) ModifyPosition

func (pos *MysqlPosition) ModifyPosition(v string) error

func (*MysqlPosition) SavePosition

func (pos *MysqlPosition) SavePosition() error

func (*MysqlPosition) StartPosition

func (pos *MysqlPosition) StartPosition()

type Position

type Position interface {
	LoadPosition(config *config.BaseConfig)
	SavePosition() error
	ModifyPosition(v string) error
	StartPosition()
	Close()
}