modelworkermanager

Documentation

Index

• func New(config Config) (worker.Worker, error)
• type Backend
• type Config
  • func (config Config) Validate() error
• type NewWorkerFunc

Functions

func New

func New(config Config) (worker.Worker, error)

Types

type Backend

type Backend interface {
	WatchModels() state.StringsWatcher
}

Backend defines the State functionality used by the manager worker.

type Config

type Config struct {
	Backend    Backend
	NewWorker  NewWorkerFunc
	ErrorDelay time.Duration
}

Config holds the dependencies and configuration necessary to run a model worker manager.

func (Config) Validate

func (config Config) Validate() error

Validate returns an error if config cannot be expected to drive a functional model worker manager.

type NewWorkerFunc

type NewWorkerFunc func(modelUUID string) (worker.Worker, error)

NewWorkerFunc should return a worker responsible for running all a model's required workers; and for returning nil when there's no more model to manage.