job

Documentation

Index

• type Job
  • func NewJob(name string, requirements map[string][]string, payload *JobPayload, ...) *Job
  • func (self *Job) Requirements() map[string][]string
• type JobBid
  • func NewBid(jobName string, machBootID string) *JobBid
• type JobOffer
  • func NewOfferFromJob(j Job, machineBootIDs []string) *JobOffer
  • func (jo *JobOffer) OfferedTo(machineBootID string) bool
• type JobPayload
  • func NewJobPayload(name string, uFile unit.SystemdUnitFile) *JobPayload
  • func (jp *JobPayload) Conflicts() []string
  • func (jp *JobPayload) MarshalJSON() ([]byte, error)
  • func (jp *JobPayload) Peers() []string
  • func (jp *JobPayload) Type() (string, error)
  • func (jp *JobPayload) UnmarshalJSON(data []byte) error
• type JobState
  • func NewJobState(loadState, activeState, subState string, sockets []string, ...) *JobState

Types

type Job

type Job struct {
	Name            string
	JobRequirements map[string][]string
	Payload         *JobPayload
	State           *JobState
}

func NewJob

func NewJob(name string, requirements map[string][]string, payload *JobPayload, state *JobState) *Job

func (*Job) Requirements

func (self *Job) Requirements() map[string][]string

type JobBid

type JobBid struct {
	JobName string

	// MachineBootID started life as MachineBootId in the datastore.
	// It cannot be changed without a migration.
	MachineBootID string `json:"MachineBootId"`
}

func NewBid

func NewBid(jobName string, machBootID string) *JobBid

type JobOffer

type JobOffer struct {
	Job Job

	// MachineBootIDs represents a set of machines for which this offer is valid.
	// If nil or len == 0 then all machines. Must be to be sorted.
	// MachineBootIDs started life as MachineBootIds in the datastore.
	// It cannot be changed without a migration
	MachineBootIDs []string `json:"MachineBootIds"`
}

func NewOfferFromJob

func NewOfferFromJob(j Job, machineBootIDs []string) *JobOffer

func (*JobOffer) OfferedTo

func (jo *JobOffer) OfferedTo(machineBootID string) bool

OfferedTo returns true if job is being offered to specified machine.

type JobPayload

type JobPayload struct {
	Name string
	Unit unit.SystemdUnitFile
}

func NewJobPayload

func NewJobPayload(name string, uFile unit.SystemdUnitFile) *JobPayload

func (*JobPayload) Conflicts

func (jp *JobPayload) Conflicts() []string

func (*JobPayload) MarshalJSON

func (jp *JobPayload) MarshalJSON() ([]byte, error)

func (*JobPayload) Peers

func (jp *JobPayload) Peers() []string

func (*JobPayload) Type

func (jp *JobPayload) Type() (string, error)

func (*JobPayload) UnmarshalJSON

func (jp *JobPayload) UnmarshalJSON(data []byte) error

type JobState

type JobState struct {
	LoadState    string                `json:"loadState"`
	ActiveState  string                `json:"activeState"`
	SubState     string                `json:"subState"`
	Sockets      []string              `json:"sockets"`
	MachineState *machine.MachineState `json:"machineState"`
}

func NewJobState

func NewJobState(loadState, activeState, subState string, sockets []string, ms *machine.MachineState) *JobState