mongostream

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

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

type OplogPositionValue struct {
	StartPosition   *config.MongoPosition `json:"start_position" bson:"start_position"`
	CurrentPosition config.MongoPosition  `json:"current_position" bson:"current_position"`
}

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

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

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