worker

Documentation

Index

• type Worker
  • func NewWorker(image string, tag string, entryPoint string, commandParams ...string) (*Worker, error)
  • func (w *Worker) Start() (<-chan string, error)
  • func (w *Worker) Stopped() <-chan int64

Types

type Worker

type Worker struct {
	CommandParameters []string
	DockerClient      *client.Client
	DockerContext     context.Context
	DockerHost        string
	EntryPoint        string
	ExitStatus        chan int64
	ExecutionTimeout  time.Duration
	ImageName         string
}

Worker represents a container executor. It has a lifetime of a single command execution.

func NewWorker

func NewWorker(image string, tag string, entryPoint string, commandParams ...string) (*Worker, error)

NewWorker will build and returns a new Worker for a single command execution.

func (*Worker) Start

func (w *Worker) Start() (<-chan string, error)

Start triggers a worker to run a container according to its settings. It returns a string channel that emits the container's combined stdout and stderr streams.

func (*Worker) Stopped

func (w *Worker) Stopped() <-chan int64

Stopped returns a channel that blocks until this worker's container has stopped. The value emitted is the exit status code of the underlying process.