agent

Documentation

Index

• Constants
• type Agent
  • func New(mgr *systemd.SystemdManager, reg registry.Registry, mach *machine.Machine, ...) (*Agent, error)
  • func (a *Agent) AbleToRun(j *job.Job) bool
  • func (a *Agent) Bid(jobName string)
  • func (a *Agent) BidForPossibleJobs()
  • func (a *Agent) BidForPossiblePeers(jobName string)
  • func (a *Agent) FetchJob(jobName string) *job.Job
  • func (a *Agent) HasConflict(potentialJobName string, potentialConflicts []string) (bool, string)
  • func (a *Agent) Heartbeat(stop chan bool)
  • func (a *Agent) Initialize() uint64
  • func (a *Agent) LoadJob(j *job.Job)
  • func (a *Agent) Machine() *machine.Machine
  • func (a *Agent) MarshalJSON() ([]byte, error)
  • func (a *Agent) Purge()
  • func (a *Agent) ReportUnitState(jobName string, us *unit.UnitState)
  • func (a *Agent) StartJob(jobName string)
  • func (a *Agent) StopJob(jobName string)
  • func (a *Agent) UnloadJob(jobName string)
  • func (a *Agent) VerifyJob(j *job.Job) bool
• type AgentState
  • func NewState() *AgentState
  • func (as *AgentState) GetJobsByPeer(peerName string) []string
  • func (as *AgentState) GetOffersWithoutBids() []job.JobOffer
  • func (as *AgentState) HasBid(name string) bool
  • func (as *AgentState) LaunchedJobs() []string
  • func (as *AgentState) Lock()
  • func (as *AgentState) MarshalJSON() ([]byte, error)
  • func (as *AgentState) PurgeJob(jobName string)
  • func (as *AgentState) PurgeOffer(name string)
  • func (as *AgentState) ScheduledHere(jobName string) bool
  • func (as *AgentState) ScheduledJobs() []string
  • func (as *AgentState) SetTargetState(jobName string, state job.JobState)
  • func (as *AgentState) TrackBid(name string)
  • func (as *AgentState) TrackJob(j *job.Job)
  • func (as *AgentState) TrackOffer(offer job.JobOffer)
  • func (as *AgentState) Unlock()
• type EventHandler
  • func NewEventHandler(agent *Agent) *EventHandler
  • func (eh *EventHandler) HandleCommandStartJob(ev event.Event)
  • func (eh *EventHandler) HandleCommandStopJob(ev event.Event)
  • func (eh *EventHandler) HandleEventJobDestroyed(ev event.Event)
  • func (eh *EventHandler) HandleEventJobOffered(ev event.Event)
  • func (eh *EventHandler) HandleEventJobScheduled(ev event.Event)
  • func (eh *EventHandler) HandleEventJobUnscheduled(ev event.Event)
  • func (eh *EventHandler) HandleEventUnitStateUpdated(ev event.Event)

Constants

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

Types

type Agent

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

The Agent owns all of the coordination between the Registry, the local Machine, and the local SystemdManager.

func New

func New(mgr *systemd.SystemdManager, reg registry.Registry, mach *machine.Machine, ttl string, verifier *sign.SignatureVerifier) (*Agent, error)

func (*Agent) AbleToRun

func (a *Agent) AbleToRun(j *job.Job) bool

Determine if the Agent can run the provided Job

func (*Agent) Bid

func (a *Agent) Bid(jobName string)

Submit a bid for the given Job

func (*Agent) BidForPossibleJobs

func (a *Agent) BidForPossibleJobs()

Submit all possible bids for unresolved offers

func (*Agent) BidForPossiblePeers

func (a *Agent) BidForPossiblePeers(jobName string)

Submit all possible bids for known peers of the provided job

func (*Agent) FetchJob

func (a *Agent) FetchJob(jobName string) *job.Job

Pull a Job and its payload from the Registry

func (*Agent) HasConflict

func (a *Agent) HasConflict(potentialJobName string, potentialConflicts []string) (bool, string)

HasConflict determines whether there are any known conflicts with the given argument

func (*Agent) Heartbeat

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

Heartbeat updates the Registry periodically with this Agent's presence information as well as an acknowledgement of the jobs it is expected to be running.

func (*Agent) Initialize

func (a *Agent) Initialize() uint64

Initialize prepares the Agent for normal operation by doing three things: 1. Announce presence to the Registry, tracking the etcd index of the operation 2. Discover any jobs that are scheduled locally, loading/starting them if they can run locally 3. Cache all unresolved job offers and bid for any that can be run locally The returned value is the etcd index at which the agent's presence was announced.

func (*Agent) LoadJob

func (a *Agent) LoadJob(j *job.Job)

func (*Agent) Machine

func (a *Agent) Machine() *machine.Machine

Access Agent's machine field

func (*Agent) MarshalJSON

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

func (*Agent) Purge

func (a *Agent) Purge()

Purge removes the Agent's state from the Registry

func (*Agent) ReportUnitState

func (a *Agent) ReportUnitState(jobName string, us *unit.UnitState)

ReportUnitState attaches the current state of the Agent's Machine to the given unit.UnitState object, then persists that state in the Registry

func (*Agent) StartJob

func (a *Agent) StartJob(jobName string)

func (*Agent) StopJob

func (a *Agent) StopJob(jobName string)

func (*Agent) UnloadJob

func (a *Agent) UnloadJob(jobName string)

func (*Agent) VerifyJob

func (a *Agent) VerifyJob(j *job.Job) bool

VerifyJob attempts to verify the integrity of the given Job by checking the signature against a SignatureSet stored in its repository.

type AgentState

type AgentState struct {

	// index of local payload conflicts to the job they belong to
	Conflicts map[string][]string
	// contains filtered or unexported fields
}

func NewState

func NewState() *AgentState

func (*AgentState) GetJobsByPeer

func (as *AgentState) GetJobsByPeer(peerName string) []string

Retrieve all Jobs that share a given Peer

func (*AgentState) GetOffersWithoutBids

func (as *AgentState) GetOffersWithoutBids() []job.JobOffer

GetOffersWithoutBids returns all tracked JobOffers that have no corresponding JobBid tracked in the same AgentState object.

func (*AgentState) HasBid

func (as *AgentState) HasBid(name string) bool

func (*AgentState) LaunchedJobs

func (as *AgentState) LaunchedJobs() []string

func (*AgentState) Lock

func (as *AgentState) Lock()

func (*AgentState) MarshalJSON

func (as *AgentState) MarshalJSON() ([]byte, error)

func (*AgentState) PurgeJob

func (as *AgentState) PurgeJob(jobName string)

PurgeJob removes all state tracked on behalf of a given job

func (*AgentState) PurgeOffer

func (as *AgentState) PurgeOffer(name string)

func (*AgentState) ScheduledHere

func (as *AgentState) ScheduledHere(jobName string) bool

func (*AgentState) ScheduledJobs

func (as *AgentState) ScheduledJobs() []string

func (*AgentState) SetTargetState

func (as *AgentState) SetTargetState(jobName string, state job.JobState)

func (*AgentState) TrackBid

func (as *AgentState) TrackBid(name string)

func (*AgentState) TrackJob

func (as *AgentState) TrackJob(j *job.Job)

TrackJob extracts and stores information about the given job for later reference

func (*AgentState) TrackOffer

func (as *AgentState) TrackOffer(offer job.JobOffer)

func (*AgentState) Unlock

func (as *AgentState) Unlock()

type EventHandler

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

func NewEventHandler

func NewEventHandler(agent *Agent) *EventHandler

func (*EventHandler) HandleCommandStartJob

func (eh *EventHandler) HandleCommandStartJob(ev event.Event)

func (*EventHandler) HandleCommandStopJob

func (eh *EventHandler) HandleCommandStopJob(ev event.Event)

func (*EventHandler) HandleEventJobDestroyed

func (eh *EventHandler) HandleEventJobDestroyed(ev event.Event)

func (*EventHandler) HandleEventJobOffered

func (eh *EventHandler) HandleEventJobOffered(ev event.Event)

func (*EventHandler) HandleEventJobScheduled

func (eh *EventHandler) HandleEventJobScheduled(ev event.Event)

func (*EventHandler) HandleEventJobUnscheduled

func (eh *EventHandler) HandleEventJobUnscheduled(ev event.Event)

func (*EventHandler) HandleEventUnitStateUpdated

func (eh *EventHandler) HandleEventUnitStateUpdated(ev event.Event)