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) *JobOffer
• type JobPayload
  • func NewJobPayload(name string, uFile unit.SystemdUnitFile) *JobPayload
  • func (jp *JobPayload) Conflicts() []string
  • func (jp *JobPayload) Description() string
  • func (jp *JobPayload) Peers() []string
  • func (jp *JobPayload) Type() (string, 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 string
}

func NewBid

func NewBid(jobName string, machBootId string) *JobBid

type JobOffer

type JobOffer struct {
	Job Job
}

func NewOfferFromJob

func NewOfferFromJob(j Job) *JobOffer

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

func (jp *JobPayload) Description() string

func (*JobPayload) Peers

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

func (*JobPayload) Type

func (jp *JobPayload) Type() (string, 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