registry

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 10, 2014 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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) 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.Machine

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(match *machine.Machine) []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.Machine

func (*Registry) GetMachineState

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

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(machine *machine.Machine) 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, machName string)

func (*Registry) SetMachineState

func (r *Registry) SetMachineState(machine *machine.Machine, ttl time.Duration)

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL