config

Documentation

Index

• Variables
• type ConsumerWorker
  • func Parse(in io.Reader) (*ConsumerWorker, error)

Variables

var (
	ErrInvalidConfig = errors.New("invalid config")
)

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"`
}

func Parse

func Parse(in io.Reader) (*ConsumerWorker, error)