runner

Documentation

Index

• type ClaimJobInput
• type ClaimJobResponse
• type Client
• type JobDispatcherSettings
• type Runner
  • func NewRunner(ctx context.Context, runnerPath string, logger logger.Logger, client Client, ...) (*Runner, error)
  • func (r *Runner) Start(ctx context.Context)

Types

type ClaimJobInput

type ClaimJobInput struct {
	RunnerPath string
}

ClaimJobInput is the input for claiming the next availble job

type ClaimJobResponse

type ClaimJobResponse struct {
	JobID string
	Token string
}

ClaimJobResponse is the response when claiming a job

type Client

type Client interface {
	ClaimJob(ctx context.Context, input *ClaimJobInput) (*ClaimJobResponse, error)
}

Client interface for claiming a job

type JobDispatcherSettings

type JobDispatcherSettings struct {
	PluginData           map[string]string
	DispatcherType       string
	ServiceDiscoveryHost string
}

JobDispatcherSettings defines the job dispatcher that'll be used for this runner

type Runner

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

Runner will claim the next available job and dispatch it using the configured job dispatcher

func NewRunner

func NewRunner(
	ctx context.Context,
	runnerPath string,
	logger logger.Logger,
	client Client,
	jobDispatcherSettings *JobDispatcherSettings,
) (*Runner, error)

NewRunner creates a new Runner

func (*Runner) Start

func (r *Runner) Start(ctx context.Context)

Start will start the runner so it can begin picking up jobs