worker

Documentation

Index

• func Main(options Options)
• type ConfigWorker
• type Options
  • func (options *Options) Parse()
  • func (options *Options) Register(name string, workerConfig WorkerConfig)
• type StatsWorker
• type StopWorker
• type Worker
• type WorkerConfig

Functions

func Main

func Main(options Options)

Types

type ConfigWorker

type ConfigWorker interface {
	ConfigSub(*config.Sub) error
}

type Options

type Options struct {
	Stats  stats.WriterOptions `group:"Stats Writer"`
	Config config.SubOptions   `group:"Config Sub"`
	// contains filtered or unexported fields
}

func (*Options) Parse

func (options *Options) Parse()

func (*Options) Register

func (options *Options) Register(name string, workerConfig WorkerConfig)

type StatsWorker

type StatsWorker interface {
	StatsWriter(*stats.Writer) error
}

type StopWorker

type StopWorker interface {
	Stop()
}

type Worker

type Worker interface {
	Run() error
}

type WorkerConfig

type WorkerConfig interface {
	Worker() (Worker, error)
}