position

Documentation

Index

• Variables
• 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) string
  • func (pos *MongoPosition) ModifyPosition(v string) error
  • func (pos *MongoPosition) SavePosition() error
  • func (pos *MongoPosition) StartPosition()
• type MysqlBasePosition
• type MysqlBasePositionV2
• 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 MysqlPositionV2
  • func (pos *MysqlPositionV2) Close()
  • func (pos *MysqlPositionV2) LoadPosition(conf *config.BaseConfig) string
  • func (pos *MysqlPositionV2) ModifyPosition(v string) error
  • func (pos *MysqlPositionV2) SavePosition() error
  • func (pos *MysqlPositionV2) StartPosition()
• type Position

Variables

var DbName = "_go_mysql_sr"

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) string

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 MysqlBasePositionV2

type MysqlBasePositionV2 struct {
	BinlogName string `toml:"binlog-name" json:"binlog-name"`
	BinlogPos  uint32 `toml:"binlog-pos" json:"binlog-pos"`
	BinlogGTID string `toml:"binlog-gtid" json:"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 MysqlPositionV2

type MysqlPositionV2 struct {
	sync.RWMutex
	*MysqlBasePositionV2
	FilePath string
	Name     string
	// contains filtered or unexported fields
}

func (*MysqlPositionV2) Close

func (pos *MysqlPositionV2) Close()

func (*MysqlPositionV2) LoadPosition

func (pos *MysqlPositionV2) LoadPosition(conf *config.BaseConfig) string

func (*MysqlPositionV2) ModifyPosition

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

func (*MysqlPositionV2) SavePosition

func (pos *MysqlPositionV2) SavePosition() error

func (*MysqlPositionV2) StartPosition

func (pos *MysqlPositionV2) StartPosition()

type Position

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