position_store

Feb 18, 2019

Changes in this version

+ func StringDecoder(s string) (interface{}, error)

+ func StringEncoder(v interface{}) (string, error)

+ type MongoPositionRet struct

+ LastUpdate string

+ Name string

+ Stage string

+ Value string

+ Version string

type PositionCacheInterface

+ GetEncodedPersistentPosition func() (position PositionMeta, v string, exist bool, err error)

+ type PositionMeta struct

+ Name string

+ Stage config.InputMode

+ UpdateTime time.Time

+ Version string

+ func (meta PositionMeta) Validate() error

+ type PositionValueDecoder func(s string) (interface{}, error)

+ type PositionValueEncoder func(v interface{}) (string, error)

+ type PositionWrapper struct

+ MongoValue string

Feb 14, 2019

Changes in this version

+ const Version

+ var DefaultFlushPeriod = 5 * time.Second

type Position

+ Value string

+ Version string

+ func (p Position) Validate() error

+ type PositionCacheInterface interface

+ Clear func() error

+ Close func()

+ Flush func() error

+ Get func() (position Position, exist bool, err error)

+ Put func(position Position) error

+ Start func() error

+ func NewPositionCache(pipelineName string, repo PositionRepo, flushDuration time.Duration) (PositionCacheInterface, error)

+ type PositionEntity struct

+ LastUpdate string

+ Name string

+ Stage string

+ type PositionRepo interface

+ Close func() error

+ Delete func(pipelineName string) error

+ Get func(pipelineName string) (Position, bool, error)

+ Put func(pipelineName string, position Position) error

+ func NewMemoRepo() PositionRepo

+ func NewMongoPositionRepo(session *mgo.Session) (PositionRepo, error)

+ func NewMySQLRepo(dbConfig *utils.DBConfig, annotation string) (PositionRepo, error)

Jan 14, 2019

Changes in this version

+ const DefaultMySQLTableLocalPositionFile

+ const PlainBytes

+ const PlainInt

+ const PlainString

+ const SQLNullBool

+ const SQLNullInt64

+ const SQLNullString

+ const SQLNullTime

+ const SQLRawBytes

+ func DeserializeMySQLBinlogPosition(p utils.MySQLBinlogPosition) (gomysql.Position, gomysql.MysqlGTIDSet, error)

+ func IsPositionStoreEvent(schema string, tableName string) bool

+ func NewMongoPositionStore(pipelineName string, conn *config.MongoConnConfig, pos *config.MongoPosition) (*mongoPositionStore, error)

+ func NewMySQLBinlogDBPositionStore(pipelineName string, dbConfig *utils.DBConfig, annotation string, ...) (*mysqlBinlogDBPositionStore, error)

+ func NewMySQLTableDBPositionStore(name string, dbConfig *utils.DBConfig, annotation string) (*mysqlTableDBPositionStore, error)

+ func PrepareMetaRepo(db *sql.DB, annotation string) error

+ func SerializeMySQLBinlogPosition(pos gomysql.Position, gtidSet gomysql.MysqlGTIDSet) utils.MySQLBinlogPosition

+ type ISerializablePosition interface

+ Get func() interface{}

+ GetRaw func() string

+ Put func(pos interface{})

+ PutRaw func(pos string)

+ Stage func() config.InputMode

+ type MongoPosition struct

+ CurrentPosition config.MongoPosition

+ StartPosition config.MongoPosition

+ type MongoPositionStore interface

+ Close func()

+ Get func() config.MongoPosition

+ Put func(position config.MongoPosition)

+ Start func() error

+ type MySQLPositionStore interface

+ Close func()

+ FSync func()

+ Get func() utils.MySQLBinlogPosition

+ Put func(position utils.MySQLBinlogPosition)

+ Start func() error

+ type MySQLTablePosition struct

+ Column string

+ Type string

+ Value interface{}

+ func (p *MySQLTablePosition) UnmarshalJSON(value []byte) error

+ func (p MySQLTablePosition) MapString() (map[string]string, error)

+ func (p MySQLTablePosition) MarshalJSON() ([]byte, error)

+ type MySQLTablePositionState struct

+ Current map[string]MySQLTablePosition

+ Max map[string]MySQLTablePosition

+ Min map[string]MySQLTablePosition

+ Start *utils.MySQLBinlogPosition

+ func (tablePositionState *MySQLTablePositionState) Get() interface{}

+ func (tablePositionState *MySQLTablePositionState) GetCurrent(sourceName string) (MySQLTablePosition, bool)

+ func (tablePositionState *MySQLTablePositionState) GetMaxMin(sourceName string) (MySQLTablePosition, MySQLTablePosition, bool)

+ func (tablePositionState *MySQLTablePositionState) GetRaw() string

+ func (tablePositionState *MySQLTablePositionState) GetStartBinlogPos() (utils.MySQLBinlogPosition, bool)

+ func (tablePositionState *MySQLTablePositionState) Put(pos interface{})

+ func (tablePositionState *MySQLTablePositionState) PutCurrent(sourceName string, pos MySQLTablePosition)

+ func (tablePositionState *MySQLTablePositionState) PutMaxMin(sourceName string, max MySQLTablePosition, min MySQLTablePosition)

+ func (tablePositionState *MySQLTablePositionState) PutRaw(pos string)

+ func (tablePositionState *MySQLTablePositionState) PutStartBinlogPos(p utils.MySQLBinlogPosition)

+ func (tablePositionState *MySQLTablePositionState) Stage() config.InputMode

+ func (tablePositionState *MySQLTablePositionState) ToJSON() (string, error)

+ type MySQLTablePositionStore interface

+ Close func()

+ GetCurrent func(sourceName string) (MySQLTablePosition, bool)

+ GetMaxMin func(sourceName string) (max MySQLTablePosition, min MySQLTablePosition, ok bool)

+ GetStartBinlogPos func() (utils.MySQLBinlogPosition, bool)

+ PutCurrent func(sourceName string, pos MySQLTablePosition)

+ PutMaxMin func(sourceName string, max MySQLTablePosition, min MySQLTablePosition)

+ PutStartBinlogPos func(position utils.MySQLBinlogPosition)

+ Start func() error

+ func NewMySQLTableLocalPositionStore(fileName string) (MySQLTablePositionStore, error)

+ type PipelineGravityMySQLPosition struct

+ CurrentPosition *utils.MySQLBinlogPosition

+ StartPosition *utils.MySQLBinlogPosition

+ func (p *PipelineGravityMySQLPosition) Get() interface{}

+ func (p *PipelineGravityMySQLPosition) GetRaw() string

+ func (p *PipelineGravityMySQLPosition) Put(pos interface{})

+ func (p *PipelineGravityMySQLPosition) PutRaw(pos string)

+ func (p *PipelineGravityMySQLPosition) Stage() config.InputMode

+ func (p *PipelineGravityMySQLPosition) String() string

+ type Position struct

+ Name string

+ Raw interface{}

+ Stage config.InputMode

+ UpdateTime time.Time

+ type PositionStore interface

+ Clear func()

+ Close func()

+ Position func() Position

+ Stage func() config.InputMode

+ Start func() error

+ Update func(pos Position)