registry

Documentation

Index

• Constants
• type EventStream
  • func NewEventStream(client *etcd.Client, registry *Registry) *EventStream
  • func (self *EventStream) Close()
  • func (self *EventStream) Stream(idx uint64, eventchan chan *event.Event)
• type Registry
  • func New(client *etcd.Client) (registry *Registry)
  • func (r *Registry) CreateJob(j *job.Job) (err error)
  • func (r *Registry) CreateJobOffer(jo *job.JobOffer)
  • func (r *Registry) CreatePayload(jp *job.JobPayload) error
  • func (r *Registry) CreateSignatureSet(s *sign.SignatureSet) error
  • func (r *Registry) DestroyPayload(payloadName string)
  • func (r *Registry) DestroySignatureSet(tag string)
  • func (r *Registry) DestroySignatureSetOfPayload(name 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) GetDebugInfo() (string, error)
  • 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) GetSignatureSet(tag string) *sign.SignatureSet
  • func (r *Registry) GetSignatureSetOfPayload(name string) *sign.SignatureSet
  • func (r *Registry) JobScheduled(jobName string) bool
  • func (r *Registry) LockJob(jobName, context string) *TimedResourceMutex
  • func (r *Registry) LockJobOffer(jobName, context string) *TimedResourceMutex
  • func (r *Registry) LockMachine(machBootID, context string) *TimedResourceMutex
  • func (r *Registry) RemoveJobState(jobName string) error
  • func (r *Registry) RemoveMachineState(machBootID string) error
  • func (r *Registry) ResolveJobOffer(jobName string) error
  • func (r *Registry) SaveJobState(jobName string, jobState *job.JobState)
  • func (r *Registry) ScheduleJob(jobName string, machBootID string) error
  • func (r *Registry) SetMachineState(ms machine.MachineState, ttl time.Duration) (uint64, 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)
• type TimedResourceMutex
  • func (t *TimedResourceMutex) Unlock() error

Constants

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

Types

type EventStream

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

func NewEventStream

func NewEventStream(client *etcd.Client, registry *Registry) *EventStream

func (*EventStream) Close

func (self *EventStream) Close()

func (*EventStream) Stream

func (self *EventStream) Stream(idx uint64, 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) (err error)

func (*Registry) CreateJobOffer

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

func (*Registry) CreatePayload

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

func (*Registry) CreateSignatureSet

func (r *Registry) CreateSignatureSet(s *sign.SignatureSet) error

func (*Registry) DestroyPayload

func (r *Registry) DestroyPayload(payloadName string)

func (*Registry) DestroySignatureSet

func (r *Registry) DestroySignatureSet(tag string)

func (*Registry) DestroySignatureSetOfPayload

func (r *Registry) DestroySignatureSetOfPayload(name 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) GetDebugInfo

func (r *Registry) GetDebugInfo() (string, error)

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

func (r *Registry) GetSignatureSet(tag string) *sign.SignatureSet

func (*Registry) GetSignatureSetOfPayload

func (r *Registry) GetSignatureSetOfPayload(name string) *sign.SignatureSet

func (*Registry) JobScheduled

func (r *Registry) JobScheduled(jobName string) bool

func (*Registry) LockJob

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

func (*Registry) LockJobOffer

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

func (*Registry) LockMachine

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) (uint64, 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

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

func (t *TimedResourceMutex) Unlock() error

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