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, machName 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) 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
	MachineName string
}

func NewBid

func NewBid(jobName string, machName 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) 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"`
	Machine     *machine.Machine `json:"machine"`
}

func NewJobState

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