modelworkermanager

Documentation

Index

• func Manifold(config ManifoldConfig) dependency.Manifold
• func New(config Config) (worker.Worker, error)
• type Config
  • func (config Config) Validate() error
• type Controller
• type Logger
• type ManifoldConfig
  • func (config ManifoldConfig) Validate() error
• type Model
• type ModelLogger
• type ModelMetrics
• type ModelWatcher
• type NewModelConfig
• type NewModelWorkerFunc
• type RecordLogger
• type StatePoolController
  • func (g StatePoolController) Config() (controller.Config, error)
  • func (g StatePoolController) Model(modelUUID string) (Model, func(), error)
  • func (g StatePoolController) RecordLogger(modelUUID string) (RecordLogger, error)

Functions

func Manifold

func Manifold(config ManifoldConfig) dependency.Manifold

Manifold returns a dependency.Manifold that will run a model worker manager.

func New

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

New starts a new model worker manager.

Types

type Config

type Config struct {
	Authority      pki.Authority
	Clock          clock.Clock
	Logger         Logger
	MachineID      string
	ModelWatcher   ModelWatcher
	ModelMetrics   ModelMetrics
	Mux            *apiserverhttp.Mux
	Controller     Controller
	NewModelWorker NewModelWorkerFunc
	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 Controller

type Controller interface {
	Config() (controller.Config, error)
	Model(modelUUID string) (Model, func(), error)
	RecordLogger(modelUUID string) (RecordLogger, error)
}

Controller provides an interface for getting models by UUID, and other details needed to pass into the function to start workers for a model. Once a model is no longer required, the returned function must be called to dispose of the model.

type Logger

type Logger interface {
	Debugf(string, ...interface{})
	Warningf(string, ...interface{})
	Errorf(string, ...interface{})
	Infof(string, ...interface{})
}

Logger defines the logging methods used by the worker.

type ManifoldConfig

type ManifoldConfig struct {
	AgentName      string
	AuthorityName  string
	StateName      string
	MuxName        string
	SyslogName     string
	Clock          clock.Clock
	NewWorker      func(Config) (worker.Worker, error)
	NewModelWorker NewModelWorkerFunc
	ModelMetrics   ModelMetrics
	Logger         Logger
}

ManifoldConfig holds the information necessary to run a model worker manager in a dependency.Engine.

func (ManifoldConfig) Validate

func (config ManifoldConfig) Validate() error

Validate validates the manifold configuration.

type Model

type Model interface {
	MigrationMode() state.MigrationMode
	Type() state.ModelType
	Name() string
	Owner() names.UserTag
}

Model represents a model.

type ModelLogger

type ModelLogger interface {
	loggo.Writer
	Close() error
}

ModelLogger is a database backed loggo Writer.

type ModelMetrics

type ModelMetrics interface {
	ForModel(names.ModelTag) engine.MetricSink
}

ModelMetrics defines a way to create metrics for a model.

type ModelWatcher

type ModelWatcher interface {
	WatchModels() state.StringsWatcher
}

ModelWatcher provides an interface for watching the additiona and removal of models.

type NewModelConfig

type NewModelConfig struct {
	Authority        pki.Authority
	ModelName        string // Use a fully qualified name "<namespace>-<name>"
	ModelUUID        string
	ModelType        state.ModelType
	ModelLogger      ModelLogger
	ModelMetrics     engine.MetricSink
	Mux              *apiserverhttp.Mux
	ControllerConfig controller.Config
}

NewModelConfig holds the information required by the NewModelWorkerFunc to start the workers for the specified model

type NewModelWorkerFunc

type NewModelWorkerFunc func(config NewModelConfig) (worker.Worker, error)

NewModelWorkerFunc 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.

type RecordLogger

type RecordLogger interface {
	io.Closer
	// Log writes the given log records to the logger's storage.
	Log([]corelogger.LogRecord) error
}

RecordLogger writes logs to backing store.

type StatePoolController

type StatePoolController struct {
	*state.StatePool
	SysLogger corelogger.Logger
}

StatePoolController implements Controller in terms of a *state.StatePool.

func (StatePoolController) Config

func (g StatePoolController) Config() (controller.Config, error)

Config is part of the Controller interface.

func (StatePoolController) Model

func (g StatePoolController) Model(modelUUID string) (Model, func(), error)

Model is part of the Controller interface.

func (StatePoolController) RecordLogger

func (g StatePoolController) RecordLogger(modelUUID string) (RecordLogger, error)

RecordLogger returns a database logger for the specified model.