model

Documentation

Index

• type WorkRequest
  • func NewWorkRequest(name, script, payload string, args []string, timeout int) *WorkRequest
  • func (wr *WorkRequest) GetLogContent(prefixFilter string) string
  • func (wr *WorkRequest) IsTerminated() bool
  • func (wr *WorkRequest) Terminate(err error) error
• type WorkStatus

Types

type WorkRequest

type WorkRequest struct {
	ID          uint64
	Name        string
	Script      string
	Payload     string
	Args        []string
	MessageChan chan []byte
	Timeout     int
	Status      WorkStatus
	LogFilename string
	Err         error
	// contains filtered or unexported fields
}

WorkRequest is a request of work for a worker

func NewWorkRequest

func NewWorkRequest(name, script, payload string, args []string, timeout int) *WorkRequest

NewWorkRequest creats new work request

func (*WorkRequest) GetLogContent

func (wr *WorkRequest) GetLogContent(prefixFilter string) string

GetLogContent returns work logs filtered with the prefix

func (*WorkRequest) IsTerminated

func (wr *WorkRequest) IsTerminated() bool

IsTerminated ask if the work request is terminated

func (*WorkRequest) Terminate

func (wr *WorkRequest) Terminate(err error) error

Terminate set work request as terminated

type WorkStatus

type WorkStatus int

WorkStatus is the status of a worload

const (
	// Idle means that the work is not yet started
	Idle WorkStatus = iota
	// Running means that the work is running
	Running
	// Success means that the work over
	Success
	// Error means that the work is over but in error
	Error
)