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, reg *config.Registration, cli client.Client) *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) error

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

type RunnerInterface ¶

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