mongooplog

Documentation

Index

• Constants
• func GetRowDataFromOp(op *gtm.Op) *map[string]interface{}
• type OplogChecker
  • 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
• type OplogTailer
  • 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
• type PluginConfig

Constants

const OplogCheckerCollectionName = "heartbeat"

const OplogCheckerDBName = "drc"

Functions

func GetRowDataFromOp

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

Types

type OplogChecker

type OplogChecker struct {
	// contains filtered or unexported fields
}

func NewOplogChecker

func NewOplogChecker(session *mgo.Session, sourceHost string, pipelineName string, ctx context.Context) *OplogChecker

func (*OplogChecker) MarkActive

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

func (*OplogChecker) Run

func (checker *OplogChecker) Run()

func (*OplogChecker) Stop

func (checker *OplogChecker) Stop()

type OplogHeartbeat

type OplogHeartbeat struct {
	ID   bson.ObjectId `bson:"_id,omitempty"`
	Name string        `bson:"name"`
	T    string        `bson:"t"`
}

type OplogTailer

type OplogTailer struct {
	// contains filtered or unexported fields
}

func NewOplogTailer

func NewOplogTailer(opts *OplogTailerOpt) *OplogTailer

func (*OplogTailer) AfterMsgCommit

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

func (*OplogTailer) Filter

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

func (*OplogTailer) Run

func (tailer *OplogTailer) Run()

func (*OplogTailer) SendDeadSignal

func (tailer *OplogTailer) SendDeadSignal() error

func (*OplogTailer) Stop

func (tailer *OplogTailer) Stop()

func (*OplogTailer) Wait

func (tailer *OplogTailer) Wait()

type OplogTailerOpt

type OplogTailerOpt struct {
	// contains filtered or unexported fields
}

type PluginConfig

type PluginConfig struct {
	// MongoSource *config.MongoSource `mapstructure:"source" toml:"source" json:"source"`
	Source        *config.MongoConnConfig `mapstructure:"source" toml:"source" json:"source"`
	StartPosition *config.MongoPosition   `mapstructure:"start-position" toml:"start-position" json:"start-position"`
	GtmConfig     *config.GtmConfig       `mapstructure:"gtm-config" toml:"gtm-config" json:"gtm-config"`
}