position

Documentation

Index

• type MongoPosition
  • func LoadMongoPosition(conf *config.MongoSrConfig) (*MongoPosition, error)
  • func (pos *MongoPosition) MongoSave(resumeToken *msg.WatchId) error
• type Position
  • func LoadPosition(conf *config.MysqlSrConfig) (*Position, error)
  • func (pos *Position) GetFilePath() string
  • func (pos *Position) GetMongoFilePath() string
  • func (pos *Position) Save(gtid mysql.GTIDSet) error

Types

type MongoPosition

type MongoPosition struct {
	sync.RWMutex
	ResumeTokens *msg.WatchId `bson:"_id"`
	// contains filtered or unexported fields
}

func LoadMongoPosition

func LoadMongoPosition(conf *config.MongoSrConfig) (*MongoPosition, error)

func (*MongoPosition) MongoSave

func (pos *MongoPosition) MongoSave(resumeToken *msg.WatchId) error

type Position

type Position struct {
	sync.RWMutex
	BinlogName string `toml:"binlog-name"`
	BinlogPos  string `toml:"binlog-pos"`
	BinlogGTID string `toml:"binlog-gtid"`
	// contains filtered or unexported fields
}

func LoadPosition

func LoadPosition(conf *config.MysqlSrConfig) (*Position, error)

func (*Position) GetFilePath

func (pos *Position) GetFilePath() string

func (*Position) GetMongoFilePath

func (pos *Position) GetMongoFilePath() string

func (*Position) Save

func (pos *Position) Save(gtid mysql.GTIDSet) error