Method Output

rivertype/river_type.go:146–157

Output returns the previously recorded output for the job, if any. The return value is a raw JSON payload from the output that was recorded by the job, or nil if no output was recorded.

()

// value is a raw JSON payload from the output that was recorded by the job, or
// nil if no output was recorded.
func (j *JobRow) Output() []byte {
	type metadataWithOutput struct {
		Output json.RawMessage `json:"output"`
	}

	var metadata metadataWithOutput
	if err := json.Unmarshal(j.Metadata, &metadata); err != nil {
		return nil
	}

	return metadata.Output
}

// JobState is the state of a job. Jobs start their lifecycle as either
// JobStateAvailable or JobStateScheduled, and if all goes well, transition to