runnermanager

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 8, 2023 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterRunner

func RegisterRunner(conn *websocket.Conn, registerCh chan RunnerRegistrationRequest)

Types

type Runner

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

func (*Runner) HasTags added in v0.2.0

func (r *Runner) HasTags(requestedTags []string) bool

func (*Runner) Id

func (r *Runner) Id() uuid.UUID

func (*Runner) RunCommand

func (r *Runner) RunCommand(cmd string, args []string) (returnCode int64, stdout string, stderr string, err error)

type RunnerAllocationRequest added in v0.2.0

type RunnerAllocationRequest struct {
	Tags       []string
	RespChan   chan RunnerAllocationResponse
	CancelChan chan string
}

type RunnerAllocationResponse added in v0.2.0

type RunnerAllocationResponse struct {
	Runner *Runner
	Err    error
}

type RunnerData

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

type RunnerManagerChans added in v0.2.0

type RunnerManagerChans struct {
	Allocation   chan RunnerAllocationRequest
	Release      chan RunnerReleaseRequest
	Registration chan RunnerRegistrationRequest
}

func StartRunnerManager

func StartRunnerManager(configuredRunners map[string]config.Runner, db database.Database) (RunnerManagerChans, error)

type RunnerRegistrationRequest added in v0.2.0

type RunnerRegistrationRequest struct {
	Secret string
	Id     string
	Tags   []string
	// contains filtered or unexported fields
}

type RunnerReleaseRequest added in v0.2.0

type RunnerReleaseRequest struct {
	Runner *Runner
}

Jump to

Keyboard shortcuts

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