agent

Documentation

Index

• Constants
• type Agent
  • func New(mgr unit.UnitManager, uGen *unit.UnitStateGenerator, reg registry.Registry, ...) (*Agent, error)
  • func (a *Agent) Heartbeat(stop chan bool)
  • func (a *Agent) MarshalJSON() ([]byte, error)
• type AgentReconciler
  • func NewReconciler(reg registry.Registry, verifier *sign.SignatureVerifier) *AgentReconciler
  • func (ar *AgentReconciler) Purge(a *Agent)
  • func (ar *AgentReconciler) Reconcile(a *Agent)
  • func (ar *AgentReconciler) Run(a *Agent, stop chan bool)
  • func (ar *AgentReconciler) Trigger()
• type UnitStatePublisher
  • func NewUnitStatePublisher(mgr unit.UnitManager, reg registry.Registry, mach machine.Machine) *UnitStatePublisher
  • func (p *UnitStatePublisher) Run(beatchan <-chan *unit.UnitStateHeartbeat, stop chan bool)

Constants

const (
	// TTL to use with all state pushed to Registry
	DefaultTTL = "30s"
)

Types

type Agent

type Agent struct {
	Machine machine.Machine
	// contains filtered or unexported fields
}

func New

func New(mgr unit.UnitManager, uGen *unit.UnitStateGenerator, reg registry.Registry, mach machine.Machine, ttl string) (*Agent, error)

func (*Agent) Heartbeat

func (a *Agent) Heartbeat(stop chan bool)

Heartbeat updates the Registry periodically with an acknowledgement of the Jobs this Agent is expected to be running.

func (*Agent) MarshalJSON

func (a *Agent) MarshalJSON() ([]byte, error)

type AgentReconciler

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

func NewReconciler

func NewReconciler(reg registry.Registry, verifier *sign.SignatureVerifier) *AgentReconciler

func (*AgentReconciler) Purge

func (ar *AgentReconciler) Purge(a *Agent)

Purge attempts to unload all Jobs that have been loaded locally

func (*AgentReconciler) Reconcile

func (ar *AgentReconciler) Reconcile(a *Agent)

Reconcile drives the local Agent's state towards the desired state stored in the Registry. Reconcile also attempts to bid for any outstanding job offers that the local Agent can run.

func (*AgentReconciler) Run

func (ar *AgentReconciler) Run(a *Agent, stop chan bool)

Run periodically attempts to reconcile the provided Agent until the stop channel is closed. Run will also reconcile in reaction to calls to Trigger. While a reconciliation is being attempted, calls to Trigger are ignored.

func (*AgentReconciler) Trigger

func (ar *AgentReconciler) Trigger()

Trigger causes Reconcile to run if the Agent is running but is not currently reconciling.

type UnitStatePublisher

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

func NewUnitStatePublisher

func NewUnitStatePublisher(mgr unit.UnitManager, reg registry.Registry, mach machine.Machine) *UnitStatePublisher

func (*UnitStatePublisher) Run

func (p *UnitStatePublisher) Run(beatchan <-chan *unit.UnitStateHeartbeat, stop chan bool)

Run caches all of the heartbeat objects from the provided channel, publishing them to the Registry every 5s. Heartbeat objects are also published as they are received on the channel.