position

Documentation

Index

• Constants
• Variables
• func FindPositionFileNotCreate(filePath string, initPositionData string)
• func GetPositionFilePath(conf *config.BaseConfig) string
• type MongoPosition
  • func (pos *MongoPosition) Close()
  • func (pos *MongoPosition) Configure(pipelineName string, configInput map[string]interface{}) error
  • 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 MysqlPosition
  • func (pos *MysqlPosition) Close()
  • func (pos *MysqlPosition) Configure(pipelineName string, configInput map[string]interface{}) error
  • func (pos *MysqlPosition) LoadPosition(conf *config.BaseConfig) string
  • func (pos *MysqlPosition) ModifyPosition(v string) error
  • func (pos *MysqlPosition) SavePosition() error
  • func (pos *MysqlPosition) StartPosition()

Constants

const MongoPosName = "mongo"

const MysqlPosName = "mysql"

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

func (pos *MongoPosition) Configure(pipelineName string, configInput map[string]interface{}) error

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" 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
	Name     string
	// contains filtered or unexported fields
}

func (*MysqlPosition) Close

func (pos *MysqlPosition) Close()

func (*MysqlPosition) Configure

func (pos *MysqlPosition) Configure(pipelineName string, configInput map[string]interface{}) error

func (*MysqlPosition) LoadPosition

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

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