Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrInvalidConfig = errors.New("invalid config")
)
Functions ¶
This section is empty.
Types ¶
type ConsumerWorker ¶
type ConsumerWorker struct { Collection string `yaml:"collection"` StopFilePath string `yaml:"stop_file_path"` QueueURL string `yaml:"queue_url"` BatchSize int `yaml:"batch_size" default:"10"` WaitTimeSeconds int `yaml:"wait_time_seconds" default:"20"` MaxSourceWorkers uint `yaml:"max_source_workers" default:"10"` MaxFeedWorkers uint `yaml:"max_feed_workers" default:"20"` MaxDeleteWorkers uint `yaml:"max_delete_workers" default:"10"` PerMessageInterval time.Duration `yaml:"per_message_interval" default:"10ms"` ScriptPath string `yaml:"script_path"` StdoutPath string `yaml:"stdout_path"` StderrPath string `yaml:"stderr_path"` }
Click to show internal directories.
Click to hide internal directories.