mongooplog

Feb 18, 2019

Changes in this version

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

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

Feb 14, 2019

Changes in this version

+ func Serialize(oplogPositionValue *OplogPositionValue) (string, error)

+ func SetupInitialPosition(cache position_store.PositionCacheInterface, ...) error

+ func UpdateCurrentPositionValue(cache position_store.PositionCacheInterface, ...) error

+ type OplogPositionValue struct

+ CurrentPosition *config.MongoPosition

+ StartPosition *config.MongoPosition

+ func Deserialize(v string) (*OplogPositionValue, error)

+ func GetPositionValue(cache position_store.PositionCacheInterface) (*OplogPositionValue, error)

Jan 14, 2019

Changes in this version

+ const OplogCheckerCollectionName

+ const OplogCheckerDBName

+ func GetRowDataFromOp(op *gtm.Op) *map[string]interface

+ type OplogChecker struct

+ func NewOplogChecker(session *mgo.Session, sourceHost string, pipelineName string, ...) *OplogChecker

+ func (checker *OplogChecker) MarkActive(source string, data map[string]interface{})

+ func (checker *OplogChecker) Run()

+ func (checker *OplogChecker) Stop()

+ type OplogHeartbeat struct

+ ID bson.ObjectId

+ Name string

+ T string

+ type OplogTailer struct

+ func NewOplogTailer(opts *OplogTailerOpt) *OplogTailer

+ func (tailer *OplogTailer) AfterMsgCommit(msg *core.Msg) error

+ func (tailer *OplogTailer) Filter(op *gtm.Op, option *filterOpt) bool

+ func (tailer *OplogTailer) Run()

+ func (tailer *OplogTailer) SendDeadSignal() error

+ func (tailer *OplogTailer) Stop()

+ func (tailer *OplogTailer) Wait()

+ type OplogTailerOpt struct

+ type PluginConfig struct

+ GtmConfig *config.GtmConfig

+ Source *config.MongoConnConfig

+ StartPosition *config.MongoPosition