jobexecutor

Documentation

Overview

Package jobexecutor provides the functionality to execute a job

Index

• type JobConfig
• type JobExecutor
  • func NewJobExecutor(ctx context.Context, cfg *JobConfig, client client.Client, ...) (*JobExecutor, error)
  • func (j *JobExecutor) Execute(ctx context.Context) error

Types

type JobConfig

type JobConfig struct {
	JobID           string
	JobToken        string
	HTTPEndpoint    string
	VolumeSizeLimit int
}

JobConfig is used to configure the job

type JobExecutor

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

JobExecutor executes a job

func NewJobExecutor

func NewJobExecutor(
	ctx context.Context,
	cfg *JobConfig,
	client client.Client,
	logger logger.Logger,
) (*JobExecutor, error)

NewJobExecutor creates a new JobExecutor

func (*JobExecutor) Execute

func (j *JobExecutor) Execute(ctx context.Context) error

Execute executes the job associated with the JobExecutor instance