runnermanager

Documentation

Index

• func RegisterRunner(conn *websocket.Conn, registerCh chan RunnerRegistrationRequest)
• type Runner
  • func (r *Runner) HasTags(requestedTags []string) bool
  • func (r *Runner) Id() uuid.UUID
  • func (r *Runner) RunCommand(cmd string, args []string) (returnCode int64, stdout string, stderr string, err error)
• type RunnerAllocationRequest
• type RunnerAllocationResponse
• type RunnerData
• type RunnerManagerChans
  • func StartRunnerManager(configuredRunners map[string]config.Runner, db database.Database) (RunnerManagerChans, error)
• type RunnerRegistrationRequest
• type RunnerReleaseRequest

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

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

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

type RunnerAllocationResponse

type RunnerAllocationResponse struct {
	Runner *Runner
	Err    error
}

type RunnerData

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

type RunnerManagerChans

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

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

type RunnerReleaseRequest

type RunnerReleaseRequest struct {
	Runner *Runner
}