jobqueues

Documentation

Index

• func Init(db *mgo.Database, appRoleID string, nodeUuid string)
• type Job
  • func (job *Job) Kill() error
  • func (job *Job) String() string
• type JobQueues
• type Meta
• type PulledImage
• type TarEntry

Functions

func Init

func Init(db *mgo.Database, appRoleID string, nodeUuid string)

Init Initialises the job queues loop

Types

type Job

type Job struct {
	ID             bson.ObjectId `json:"_id"             bson:"_id,omitempty"`
	NodeUUID       string        `json:"node_uuid"       bson:"node_uuid"`
	Qname          string        `json:"qname"           bson:"qname"`
	ContainerImage string        `json:"container_image" bson:"container_image"`
	Content        string        `json:"content"         bson:"content"`
	EntryPoint     []string      `json:"entrypoint"      bson:"entrypoint"`
	Run            []string      `json:"run"             bson:"run"`
	WorkingDir     string        `json:"working_directory" bson:"working_directory"`
	Status         string        `json:"status"          bson:"status"`
	ReturnCode     int           `json:"return_code"     bson:"return_code"`
	Submitted      time.Time     `json:"submitted"       bson:"submitted"`
	Started        time.Time     `json:"started"         bson:"started,omitempty"`
	Ended          time.Time     `json:"ended"           bson:"ended,omitempty"`
	Output         string        `json:"output"          bson:"output"`
	SecretID       string        `json:"secret_id"       bson:"secret_id"`
	SecretRefs     []string      `json:"secret_refs"     bson:"secret_refs"`
	ContOnWarnings bool          `json:"cont_on_warnings" bson:"cont_on_warnings"`
	ContainerID    string        `json:"container_id"    bson:"container_id"`
	// contains filtered or unexported fields
}

Job structure to represent a job submission request

func (*Job) Kill

func (job *Job) Kill() error

func (*Job) String

func (job *Job) String() string

type JobQueues

type JobQueues struct {
	Db           *mgo.Database
	AppRoleID    string
	NodeUUID     string
	PulledImages map[string]PulledImage
}

type Meta

type Meta struct {
	ContainerImage string `yaml:"container_image"`
}

Meta defines the format of the goswim.yml file

type PulledImage

type PulledImage struct {
	When time.Time
}

type TarEntry

type TarEntry struct {
	Name    string
	Content []byte
}