runnercommunicator

Documentation

Index

• type RunnerHTTPApiV1
  • func NewRunnerHTTPApiV1(logger controller.Logger, httpServer controller.HTTPServer, ...) RunnerHTTPApiV1
  • func (r *RunnerHTTPApiV1) CompletedJobs() (j []controller.CompletedJob)
  • func (r *RunnerHTTPApiV1) NeedNewJob() bool
  • func (r *RunnerHTTPApiV1) NewJob(cJob controller.Job)
  • func (r *RunnerHTTPApiV1) NullifyUUIDs(uuids []controller.UUID)
  • func (r *RunnerHTTPApiV1) Start(ctx *context.Context, wg *sync.WaitGroup)
  • func (r *RunnerHTTPApiV1) WaitingRunners() (runnerNames []string)

Types

type RunnerHTTPApiV1

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

RunnerHTTPApiV1 satisfies the controller.RunnerCommunicator interface using an HTTP server.

func NewRunnerHTTPApiV1

func NewRunnerHTTPApiV1(logger controller.Logger, httpServer controller.HTTPServer, ds controller.RunnerCommunicatorDataStorer) RunnerHTTPApiV1

NewRunnerHTTPApiV1 returns a new RunnerHTTPApiV1.

func (*RunnerHTTPApiV1) CompletedJobs

func (r *RunnerHTTPApiV1) CompletedJobs() (j []controller.CompletedJob)

CompletedJobs returns any completed jobs as told by the Runners.

func (*RunnerHTTPApiV1) NeedNewJob

func (r *RunnerHTTPApiV1) NeedNewJob() bool

NeedNewJob returns a boolean indicating whether or not there are waiting runners.

func (*RunnerHTTPApiV1) NewJob

func (r *RunnerHTTPApiV1) NewJob(cJob controller.Job)

NewJob sends a new job to the next running in the queue.

func (*RunnerHTTPApiV1) NullifyUUIDs

func (r *RunnerHTTPApiV1) NullifyUUIDs(uuids []controller.UUID)

NullifyUUIDs marks a job uuid as null.

func (*RunnerHTTPApiV1) Start

func (r *RunnerHTTPApiV1) Start(ctx *context.Context, wg *sync.WaitGroup)

Start starts the HTTP server. It does not block the thread.

func (*RunnerHTTPApiV1) WaitingRunners

func (r *RunnerHTTPApiV1) WaitingRunners() (runnerNames []string)

WaitingRunners returns a list of Runner names which are waiting for jobs.