runtime package - codeberg.org/forgejo/runner/runtime

Documentation ¶

Index ¶

func ParseLabel(str string) (label, schema, arg string, err error)
type Reporter
- func NewReporter(ctx context.Context, cancel context.CancelFunc, client client.Client, ...) *Reporter
type Runner
- func (s *Runner) Run(ctx context.Context, task *runnerv1.Task) error
type Task
- func NewTask(buildID int64, client client.Client, runnerEnvs map[string]string, ...) *Task
- func (t *Task) Run(ctx context.Context, task *runnerv1.Task, runnerName, runnerVersion string) (lastErr error)
type TaskInput

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ParseLabel ¶ added in v1.6.0

func ParseLabel(str string) (label, schema, arg string, err error)

Types ¶

type Reporter ¶

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

func NewReporter ¶

func NewReporter(ctx context.Context, cancel context.CancelFunc, client client.Client, task *runnerv1.Task) *Reporter

func (*Reporter) Close ¶

func (r *Reporter) Close(lastWords string) error

func (*Reporter) Fire ¶

func (r *Reporter) Fire(entry *log.Entry) error

func (*Reporter) Levels ¶

func (r *Reporter) Levels() []log.Level

func (*Reporter) Logf ¶

func (r *Reporter) Logf(format string, a ...interface{})

func (*Reporter) ReportLog ¶

func (r *Reporter) ReportLog(noMore bool) error

func (*Reporter) ReportState ¶

func (r *Reporter) ReportState() error

func (*Reporter) ResetSteps ¶

func (r *Reporter) ResetSteps(l int)

func (*Reporter) RunDaemon ¶

func (r *Reporter) RunDaemon()

type Runner ¶

type Runner struct {
	Machine       string
	Version       string
	ForgeInstance string
	Environ       map[string]string
	Client        client.Client
	Labels        []string
	Network       string
	CacheHandler  *artifactcache.Handler
}

Runner runs the pipeline.

func (*Runner) Run ¶

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

Run runs the pipeline stage.

type Task ¶

type Task struct {
	BuildID int64
	Input   *TaskInput
	// contains filtered or unexported fields
}

func NewTask ¶

func NewTask(buildID int64, client client.Client, runnerEnvs map[string]string, network string, picker func([]string) string) *Task

NewTask creates a new task

func (*Task) Run ¶

func (t *Task) Run(ctx context.Context, task *runnerv1.Task, runnerName, runnerVersion string) (lastErr error)

type TaskInput ¶

type TaskInput struct {
	EnvFile string
	// contains filtered or unexported fields
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL