worker

Documentation

Index

• Variables
• func Run(configPath string, taskPaths []string) error
• type APIExecutionSource
  • func (a *APIExecutionSource) Next() (Execution, error)
  • func (a *APIExecutionSource) Report(result Result) error
• type Execution
• type ExecutionSource
• type Result
• type Worker
  • func NewWorker(configPath string, taskPaths []string) (*Worker, error)
  • func (w *Worker) Start()
  • func (w *Worker) Stop() chan struct{}

Variables

var (
	ErrNoExec = errors.New("no execution")
)

Functions

func Run

func Run(configPath string, taskPaths []string) error

Types

type APIExecutionSource

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

func (*APIExecutionSource) Next

func (a *APIExecutionSource) Next() (Execution, error)

func (*APIExecutionSource) Report

func (a *APIExecutionSource) Report(result Result) error

type Execution

type Execution client.GetWorkV1Response

type ExecutionSource

type ExecutionSource interface {
	Next() (Execution, error)
	Report(Result) error
}

type Result

type Result struct {
	RunError    error
	Execution   Execution
	TaskResults []command.RunResult
}

type Worker

type Worker struct {
	Exec               ExecutionSource
	ParallelExecutions int
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(configPath string, taskPaths []string) (*Worker, error)

func (*Worker) Start

func (w *Worker) Start()

func (*Worker) Stop

func (w *Worker) Stop() chan struct{}