registry

package
v0.1.2 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const (
	// ResourceMutexTTL is the number of seconds to allow a mutex to be held on a resource
	ResourceMutexTTL = 10
)

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) 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) LockJob added in v0.1.2

func (r *Registry) LockJob(jobName, context string) *TimedResourceMutex

func (*Registry) LockJobOffer added in v0.1.2

func (r *Registry) LockJobOffer(jobName, context string) *TimedResourceMutex

func (*Registry) LockMachine added in v0.1.2

func (r *Registry) LockMachine(machBootId, context string) *TimedResourceMutex

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

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) error

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) error

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)

type TimedResourceMutex added in v0.1.2

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

TimedResourceMutex is a proxy to an auto-expiring mutex stored in the Registry. It assumes the mutex creator has initialized a timer.

func (*TimedResourceMutex) Unlock added in v0.1.2

func (t *TimedResourceMutex) Unlock() error

Unlock will attempt to remove the lock held on the mutex in the Registry.

Jump to

Keyboard shortcuts

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