worker

Documentation

Index

• Constants
• type Worker
  • func NewWorker(resultsRepository result.Repository, runner runner.Runner) Worker
  • func (w *Worker) PullExecution() (execution testkube.Execution, err error)
  • func (w *Worker) PullExecutions() chan testkube.Execution
  • func (w *Worker) Run(executionChan chan testkube.Execution)
  • func (w *Worker) RunExecution(ctx context.Context, e testkube.Execution) (testkube.Execution, error)

Constants

const EmptyQueueWaitTime = 2 * time.Second

const WorkerQueueBufferSize = 10000

Types

type Worker

type Worker struct {
	Concurrency int
	BufferSize  int
	Repository  result.Repository
	Runner      runner.Runner
	Log         *zap.SugaredLogger
}

func NewWorker

func NewWorker(resultsRepository result.Repository, runner runner.Runner) Worker

NewWorker returns new worker instance with data repository and runner

func (*Worker) PullExecution

func (w *Worker) PullExecution() (execution testkube.Execution, err error)

func (*Worker) PullExecutions

func (w *Worker) PullExecutions() chan testkube.Execution

PullExecutions gets executions from queue - returns executions channel

func (*Worker) Run

func (w *Worker) Run(executionChan chan testkube.Execution)

func (*Worker) RunExecution

func (w *Worker) RunExecution(ctx context.Context, e testkube.Execution) (testkube.Execution, error)