run

type NullLogger ¶

type NullLogger struct{}

NullLogger is used to create a new JobLogger to discard logs. This will prevent these logs from being logged to the stdout, but forward them to the Reporter via its hook.

func (n NullLogger) WithJobLogger() *log.Logger

type Runner ¶

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

Runner runs the pipeline.

func NewRunner(cfg *config.Config, name string, ls labels.Labels, cli client.Client, cacheProxy *cacheproxy.Handler) *Runner

func (r *Runner) Declare(ctx context.Context, labels []string) (*connect.Response[runnerv1.DeclareResponse], error)

func (r *Runner) Run(ctx context.Context, task *runnerv1.Task)

func (r *Runner) Update(ctx context.Context, labels labels.Labels)

type RunnerInterface ¶

type RunnerInterface interface {
	Run(ctx context.Context, task *runnerv1.Task)
}