config

package
v0.0.0-...-24585cf Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 30, 2024 License: MIT Imports: 5 Imported by: 1

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

func Parse

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL