Documentation ¶
Index ¶
Constants ¶
const (
// TTL to use with all state pushed to Registry
DefaultTTL = "30s"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Agent ¶
func (*Agent) Heartbeat ¶
Heartbeat updates the Registry periodically with an acknowledgement of the Jobs this Agent is expected to be running.
func (*Agent) MarshalJSON ¶ added in v0.2.0
type AgentReconciler ¶ added in v0.6.0
type AgentReconciler struct {
// contains filtered or unexported fields
}
func NewReconciler ¶ added in v0.6.0
func NewReconciler(reg registry.Registry, rStream registry.EventStream) *AgentReconciler
func (*AgentReconciler) Purge ¶ added in v0.6.0
func (ar *AgentReconciler) Purge(a *Agent)
Purge attempts to unload all Jobs that have been loaded locally
func (*AgentReconciler) Reconcile ¶ added in v0.6.0
func (ar *AgentReconciler) Reconcile(a *Agent)
Reconcile drives the local Agent's state towards the desired state stored in the Registry.
func (*AgentReconciler) Run ¶ added in v0.6.0
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.
type AgentState ¶
type AgentState struct { MState *machine.MachineState Jobs map[string]*job.Job }
func NewAgentState ¶ added in v0.7.0
func NewAgentState(ms *machine.MachineState) *AgentState
func (*AgentState) AbleToRun ¶ added in v0.7.0
func (as *AgentState) AbleToRun(j *job.Job) (bool, string)
AbleToRun determines if an Agent can run the provided Job based on the Agent's current state. A boolean indicating whether this is the case or not is returned. The following criteria is used:
- Agent must meet the Job's machine target requirement (if any)
- Agent must have all of the Job's required metadata (if any)
- Agent must have all required Peers of the Job scheduled locally (if any)
- Job must not conflict with any other Jobs scheduled to the agent
type UnitStatePublisher ¶ added in v0.6.0
type UnitStatePublisher struct {
// contains filtered or unexported fields
}
func NewUnitStatePublisher ¶ added in v0.6.0
func NewUnitStatePublisher(mgr unit.UnitManager, reg registry.Registry, mach machine.Machine, ttl time.Duration) *UnitStatePublisher
func (*UnitStatePublisher) Purge ¶ added in v0.7.1
func (p *UnitStatePublisher) Purge()
func (*UnitStatePublisher) Run ¶ added in v0.6.0
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.