job

Documentation

Index

• Constants
• type Job
  • func NewJob() (*Job, error)
  • func (j *Job) AfterRun(ctx context.Context) error
  • func (j *Job) EnsureActiveWorkspace(workspace string) error
  • func (j *Job) Run(ctx context.Context) error

Constants

const (
	// MaxContainerTerminationMessageLength is the upper bound any one container may write to
	// its termination message path. Contents above this length will cause a failure.
	MaxContainerTerminationMessageLength = 1024 * 4
)

Types

type Job

type Job struct {
	Ctx              *meta.JobContext
	StartTime        time.Time
	ActiveWorkspace  string
	UserEnvs         map[string]string
	OutputsJsonBytes []byte
	ConfigMapUpdater configmap.Updater
}

func NewJob

func NewJob() (*Job, error)

func (*Job) AfterRun

func (j *Job) AfterRun(ctx context.Context) error

func (*Job) EnsureActiveWorkspace

func (j *Job) EnsureActiveWorkspace(workspace string) error

func (*Job) Run

func (j *Job) Run(ctx context.Context) error