deployer

type API interface {
	Machine(names.MachineTag) (Machine, error)
	Unit(names.UnitTag) (Unit, error)
}

type Context interface {
	worker.Worker

	// DeployUnit causes the agent for the specified unit to be started and run
	// continuously until further notice without further intervention. It will
	// return an error if the agent is already deployed.
	DeployUnit(unitName, initialPassword string) error

	// RecallUnit causes the agent for the specified unit to be stopped, and
	// the agent's data to be destroyed. It will return an error if the agent
	// was not deployed by the manager.
	RecallUnit(unitName string) error

	// DeployedUnits returns the names of all units deployed by the manager.
	DeployedUnits() ([]string, error)

	// AgentConfig returns the agent config for the machine agent that is
	// running the deployer.
	AgentConfig() agent.Config

	Report() map[string]interface{}
}

type ContextConfig struct {
	Agent                    agent.Agent
	Clock                    clock.Clock
	Hub                      Hub
	Logger                   Logger
	UnitEngineConfig         func() dependency.EngineConfig
	SetupLogging             func(*loggo.Context, agent.Config)
	UnitManifolds            func(config UnitManifoldsConfig) dependency.Manifolds
	RebootMonitorStatePurger RebootMonitorStatePurger
}

type Deployer struct {
	// contains filtered or unexported fields
}

type Hub interface {
	Publish(topic string, data interface{}) func()
	Subscribe(topic string, handler func(string, interface{})) func()
}

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

type Machine interface {
	WatchUnits() (watcher.StringsWatcher, error)
}

type ManifoldConfig struct {
	AgentName     string
	APICallerName string
	Clock         clock.Clock
	Hub           Hub
	Logger        Logger

	UnitEngineConfig func() dependency.EngineConfig
	SetupLogging     func(*loggo.Context, agent.Config)
	NewDeployContext func(ContextConfig) (Context, error)
}

type RebootMonitorStatePurger interface {
	PurgeState(tag names.Tag) error
}

type Unit interface {
	Life() life.Value
	Name() string
	Remove() error
	SetPassword(password string) error
	SetStatus(unitStatus status.Status, info string, data map[string]interface{}) error
}

type UnitAgent struct {
	// contains filtered or unexported fields
}

type UnitAgentConfig struct {
	Name             string
	DataDir          string
	Clock            clock.Clock
	Logger           Logger
	UnitEngineConfig func() dependency.EngineConfig
	UnitManifolds    func(UnitManifoldsConfig) dependency.Manifolds
	SetupLogging     func(*loggo.Context, agent.Config)
}

type UnitManifoldsConfig struct {

	// LoggingContext holds the unit writers so that the loggers
	// for the unit get tagged with the right source.
	LoggingContext *loggo.Context

	// Agent contains the agent that will be wrapped and made available to
	// its dependencies via a dependency.Engine.
	Agent coreagent.Agent

	// LogSource will be read from by the logsender component.
	LogSource logsender.LogRecordCh

	// LeadershipGuarantee controls the behaviour of the leadership tracker.
	LeadershipGuarantee time.Duration

	// AgentConfigChanged is set whenever the unit agent's config
	// is updated.
	AgentConfigChanged *voyeur.Value

	// ValidateMigration is called by the migrationminion during the
	// migration process to check that the agent will be ok when
	// connected to the new target controller.
	ValidateMigration func(base.APICaller) error

	// UpdateLoggerConfig is a function that will save the specified
	// config value as the logging config in the agent.conf file.
	UpdateLoggerConfig func(string) error

	// MachineLock is a central source for acquiring the machine lock.
	// This is used by a number of workers to ensure serialisation of actions
	// across the machine.
	MachineLock machinelock.Lock

	// Clock supplies timekeeping services to various workers.
	Clock clock.Clock
}