mongobatch

type Config struct {
	Source         *config.MongoConnConfig     `mapstructure:"source" toml:"source" json:"source"`
	PositionRepo   *config.GenericPluginConfig `mapstructure:"position-repo" toml:"position-repo" json:"position-repo"`
	BatchSize      int                         `mapstructure:"batch-size"  toml:"batch-size" json:"batch-size"`
	WorkerCnt      int                         `mapstructure:"worker-cnt" toml:"worker-cnt" json:"worker-cnt"`
	ChunkThreshold int                         `mapstructure:"chunk-threshold"  toml:"chunk-threshold"  json:"chunk-threshold"`
	// IgnoreOplogError ignores error with oplog.
	// Some mongo cluster setup may not support oplog.
	IgnoreOplogError bool `mapstructure: "ignore-oplog-error" toml:"ignore-oplog-error" json:"ignore-oplog-error"`
}

type PositionValue struct {
	Start  bson.MongoTimestamp `bson:"start" json:"start"`
	Chunks []chunk             `bson:"chunks"  json:"chunks"`
}