registry

Documentation

Index

• type EventStream
  • func NewEventStream(client *etcd.Client) *EventStream
  • func (self *EventStream) Close()
  • func (self *EventStream) Stream(eventchan chan *event.Event)
• type Registry
  • func New(client *etcd.Client) (registry *Registry)
  • func (r *Registry) ClaimJob(jobName string, m *machine.Machine, ttl time.Duration) bool
  • func (r *Registry) ClaimJobOffer(jobName string, m *machine.Machine, ttl time.Duration) bool
  • func (r *Registry) ClaimMachine(machBootId string, m *machine.Machine, ttl time.Duration) bool
  • func (r *Registry) CreateJob(j *job.Job) error
  • func (r *Registry) CreateJobOffer(jo *job.JobOffer)
  • func (r *Registry) CreatePayload(jp *job.JobPayload) error
  • func (r *Registry) DestroyPayload(payloadName string)
  • func (r *Registry) GetActiveMachines() []machine.MachineState
  • func (r *Registry) GetAllJobs() []job.Job
  • func (r *Registry) GetAllJobsByMachine(machBootId string) []job.Job
  • func (r *Registry) GetAllPayloads() []job.JobPayload
  • func (r *Registry) GetJob(jobName string) *job.Job
  • func (r *Registry) GetJobState(jobName string) *job.JobState
  • func (r *Registry) GetJobTarget(jobName string) *machine.MachineState
  • func (r *Registry) GetMachineState(bootid string) *machine.MachineState
  • func (r *Registry) GetPayload(payloadName string) *job.JobPayload
  • func (r *Registry) RemoveJobState(jobName string) error
  • func (r *Registry) RemoveMachineState(machBootId string) error
  • func (r *Registry) ResolveJobOffer(jobName string)
  • func (r *Registry) SaveJobState(jobName string, jobState *job.JobState)
  • func (r *Registry) ScheduleJob(jobName string, machBootId string)
  • func (r *Registry) SetMachineState(ms machine.MachineState, ttl time.Duration) error
  • func (r *Registry) StopJob(jobName string)
  • func (r *Registry) SubmitJobBid(jb *job.JobBid)
  • func (r *Registry) UnresolvedJobOffers() []job.JobOffer
  • func (r *Registry) UnscheduleJob(jobName string)

Types

type EventStream

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

func NewEventStream

func NewEventStream(client *etcd.Client) *EventStream

func (*EventStream) Close

func (self *EventStream) Close()

func (*EventStream) Stream

func (self *EventStream) Stream(eventchan chan *event.Event)

type Registry

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

func New

func New(client *etcd.Client) (registry *Registry)

func (*Registry) ClaimJob

func (r *Registry) ClaimJob(jobName string, m *machine.Machine, ttl time.Duration) bool

func (*Registry) ClaimJobOffer

func (r *Registry) ClaimJobOffer(jobName string, m *machine.Machine, ttl time.Duration) bool

func (*Registry) ClaimMachine

func (r *Registry) ClaimMachine(machBootId string, m *machine.Machine, ttl time.Duration) bool

Attempt to acquire a lock on a given machine for a given amount of time

func (*Registry) CreateJob

func (r *Registry) CreateJob(j *job.Job) error

func (*Registry) CreateJobOffer

func (r *Registry) CreateJobOffer(jo *job.JobOffer)

func (*Registry) CreatePayload

func (r *Registry) CreatePayload(jp *job.JobPayload) error

func (*Registry) DestroyPayload

func (r *Registry) DestroyPayload(payloadName string)

func (*Registry) GetActiveMachines

func (r *Registry) GetActiveMachines() []machine.MachineState

Describe all active Machines

func (*Registry) GetAllJobs

func (r *Registry) GetAllJobs() []job.Job

List the jobs all Machines are scheduled to run

func (*Registry) GetAllJobsByMachine

func (r *Registry) GetAllJobsByMachine(machBootId string) []job.Job

func (*Registry) GetAllPayloads

func (r *Registry) GetAllPayloads() []job.JobPayload

func (*Registry) GetJob

func (r *Registry) GetJob(jobName string) *job.Job

func (*Registry) GetJobState

func (r *Registry) GetJobState(jobName string) *job.JobState

Get the current JobState of the provided Job

func (*Registry) GetJobTarget

func (r *Registry) GetJobTarget(jobName string) *machine.MachineState

func (*Registry) GetMachineState

func (r *Registry) GetMachineState(bootid string) *machine.MachineState

Get Machine object from etcd

func (*Registry) GetPayload

func (r *Registry) GetPayload(payloadName string) *job.JobPayload

func (*Registry) RemoveJobState

func (r *Registry) RemoveJobState(jobName string) error

Delete the state from the Registry for the given Job

func (*Registry) RemoveMachineState

func (r *Registry) RemoveMachineState(machBootId string) error

Remove Machine object from etcd

func (*Registry) ResolveJobOffer

func (r *Registry) ResolveJobOffer(jobName string)

func (*Registry) SaveJobState

func (r *Registry) SaveJobState(jobName string, jobState *job.JobState)

Persist the changes in a provided Machine's Job to etcd with the provided TTL

func (*Registry) ScheduleJob

func (r *Registry) ScheduleJob(jobName string, machBootId string)

func (*Registry) SetMachineState

func (r *Registry) SetMachineState(ms machine.MachineState, ttl time.Duration) error

Push Machine object to etcd

func (*Registry) StopJob

func (r *Registry) StopJob(jobName string)

func (*Registry) SubmitJobBid

func (r *Registry) SubmitJobBid(jb *job.JobBid)

func (*Registry) UnresolvedJobOffers

func (r *Registry) UnresolvedJobOffers() []job.JobOffer

func (*Registry) UnscheduleJob

func (r *Registry) UnscheduleJob(jobName string)