Documentation ¶
Index ¶
Constants ¶
View Source
const OplogCheckerCollectionName = "heartbeat"
View Source
const OplogCheckerDBName = "drc"
Variables ¶
This section is empty.
Functions ¶
func GetRowDataFromOp ¶
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 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) 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"` }
Click to show internal directories.
Click to hide internal directories.