job

Documentation

Index

• Constants
• type Job
  • func NewJob(sandboxId string, jobData jrds.JobData, jrdsClient jrdsClient) Job
  • func (job *Job) Run()
• type PendingAction
  • func GetPendingAction(enum int) PendingAction
• type StreamHandler
  • func NewStreamHandler(client streamClient, jobId, runbookVersionId string) StreamHandler
  • func (s *StreamHandler) SetStream(message string)

Constants

const (
	None      = 0
	Activate  = 1
	Abort     = 2
	Suspend   = 3
	Resume    = 4
	Stop      = 5
	Terminate = 6
	Remove    = 7
)

Types

type Job

type Job struct {
	Id string

	// runtime
	StartTime time.Time
	Completed bool

	// channels
	PendingActions chan PendingAction
	Exceptions     chan string
	// contains filtered or unexported fields
}

func NewJob

func NewJob(sandboxId string, jobData jrds.JobData, jrdsClient jrdsClient) Job

func (*Job) Run

func (job *Job) Run()

type PendingAction

type PendingAction struct {
	Enum int
	Name string
}

func GetPendingAction

func GetPendingAction(enum int) PendingAction

type StreamHandler

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

func NewStreamHandler

func NewStreamHandler(client streamClient, jobId, runbookVersionId string) StreamHandler

func (*StreamHandler) SetStream

func (s *StreamHandler) SetStream(message string)