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 ¶
View Source
const MongoPosName = "mongo"
View Source
const MysqlPosName = "mysql"
Variables ¶
View Source
var DbName = "_go_mysql_sr"
Functions ¶
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 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()
Source Files
Click to show internal directories.
Click to hide internal directories.