recorder

type JobEntry struct {
	Status    string           `bson:"status,omitempty"`
	ExitCode  *int             `bson:"exitCode,omitempty"`
	Error     string           `bson:"error,omitempty"`
	Stdout    []byte           `bson:"stdout,omitempty"`
	Timestamp ftime.UnixMillis `bson:"timestamp"`
}

type JobRecord struct {
	Owner   string      `bson:"owner,omitempty"`
	JobId   uint64      `bson:"jobId"`
	Cmd     string      `bson:"cmd"`
	Entries []JobEntry  `bson:"entries"`
	Data    interface{} `bson:"data"`
}

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

type JobResult struct {

	// Buried is true if the job was buried.
	Buried bool

	// Executed is true if the job command was executed (or attempted).
	Executed bool

	// ExitStatus of the command; 0 for success.
	ExitStatus int

	// JobId from beanstalkd.
	JobId uint64

	// Stdout of the command.
	Stdout []byte

	// TimedOut indicates the worker exceeded TTR for the job.
	// Note this is tracked by a timer, separately to beanstalkd.
	TimedOut bool

	// Error raised while attempting to handle the job.
	Error error
}