invoker

type ConfigPlanQuantityOverrider ¶

type ConfigPlanQuantityOverrider struct {
	// PostPlanOverrides applies any overrides that should happen after the machine overrides.
	PostPlanOverrides quantity.MachNodeSet
}

ConfigPlanQuantityOverrider overrides quantities by looking up the machine that the plan targets in a config map, then extracting the overrides from there.

func (c *ConfigPlanQuantityOverrider) OverrideQuantitiesFromPlan(p *plan.Plan, qs *quantity.MachNodeSet) error

type Invoker ¶

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

Invoker runs the machine-runner, through SSH if needed.

Much of the invoker's behaviour is injected through two sources: a runner factory (which can either pass in cached SSH-or-lack-therof configuration, or delegate to the incoming machine plan), and a set of quantity overrides (that can either be fully pre-cached, or also delegate in part to the plan). This set-up is intended to let the single-shot binary for the invoker rely almost entirely on information coming to it through the plan, while also letting the director set up the configuration in advance and bypass plan inspection.

func New(ldir string, fac runner.Factory, o ...Option) (*Invoker, error)

func (m *Invoker) Close() error

func (m *Invoker) Run(ctx context.Context, p *plan.Plan) (*plan.Plan, error)

func (*Invoker) Stage() stage.Stage

type NopPlanQuantityOverrider ¶

type NopPlanQuantityOverrider struct{}

NopPlanQuantityOverrider is a PlanQuantityOverrider that doesn't actually override quantities.

func (n NopPlanQuantityOverrider) OverrideQuantitiesFromPlan(*plan.Plan, *quantity.MachNodeSet) error

type Observer ¶

type Observer interface {
	copier.Observer
	builder.Observer
}

Observer is the union of the various interfaces of observers used by invoker.

type Option ¶

type Option func(*Invoker) error

Option is the type of options for the invoker.

func AllowReinvoke(allow bool) Option

func ObserveCopiesWith(obs ...copier.Observer) Option

func ObserveMachWith(obs ...observer.Observer) Option

func Options(ops ...Option) Option

func OverrideBaseQuantities(qs quantity.MachNodeSet) Option

func OverrideQuantitiesFromPlanThen(qs quantity.MachNodeSet) Option

type PlanQuantityOverrider ¶

type PlanQuantityOverrider interface {
	// OverrideQuantitiesFromPlan applies to qs any quantity overrides that require information from the plan p.
	// This is part of the Factory interface because some, but not all, factories require plan information.
	OverrideQuantitiesFromPlan(p *plan.Plan, qs *quantity.MachNodeSet) error
}

PlanQuantityOverrider is the interface of things that may, or may not, override the invoker's quantity set with quantities according to information in a plan.