Struct Job

pkg/waveobj/wtype.go:313–351

}

type Job struct {
	OID     string `json:"oid"`
	Version int    `json:"version"`

	// job metadata
	Connection      string            `json:"connection"`
	JobKind         string            `json:"jobkind"` // shell, task
	Cmd             string            `json:"cmd"`
	CmdArgs         []string          `json:"cmdargs,omitempty"`
	CmdEnv          map[string]string `json:"cmdenv,omitempty"`
	JobAuthToken    string            `json:"jobauthtoken"` // job manger -> wave
	AttachedBlockId string            `json:"attachedblockid,omitempty"`
	WaveVersion     string            `json:"waveversion,omitempty"`

	// reconnect option (e.g. orphaned, so we need to kill on connect)
	TerminateOnReconnect bool `json:"terminateonreconnect,omitempty"`

	// job manager state
	JobManagerStatus       string `json:"jobmanagerstatus"`               // init, running, done
	JobManagerDoneReason   string `json:"jobmanagerdonereason,omitempty"` // startuperror, gone, terminated
	JobManagerStartupError string `json:"jobmanagerstartuperror,omitempty"`
	JobManagerPid          int    `json:"jobmanagerpid,omitempty"`
	JobManagerStartTs      int64  `json:"jobmanagerstartts,omitempty"` // exact process start time (milliseconds)

	// cmd/process runtime info
	CmdPid        int      `json:"cmdpid,omitempty"`     // command process id
	CmdStartTs    int64    `json:"cmdstartts,omitempty"` // exact command process start time (milliseconds from epoch)
	CmdTermSize   TermSize `json:"cmdtermsize"`
	CmdExitTs     int64    `json:"cmdexitts,omitempty"`     // timestamp (milliseconds) -- use CmdExitTs > 0 to check if command has exited
	CmdExitCode   *int     `json:"cmdexitcode,omitempty"`   // nil when CmdExitSignal is set.  success exit is when CmdExitCode is 0
	CmdExitSignal string   `json:"cmdexitsignal,omitempty"` // empty string if CmdExitCode is set
	CmdExitError  string   `json:"cmdexiterror,omitempty"`

	// output info
	StreamDone  bool   `json:"streamdone,omitempty"`
	StreamError string `json:"streamerror,omitempty"`

	Meta MetaMapType `json:"meta"`
}

func (*Job) GetOType() string {
	return OType_Job