imageworker

Documentation

Index

• type Worker
  • func New(handler handler.Handler) *Worker
  • func (w *Worker) Receive(obj observe.ImageInfo)
  • func (w *Worker) Start(workers uint, stop <-chan struct{}) error

Types

type Worker

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

Worker implements Observer[string] to receive Docker image names from Observables. The received images are added to a queue for processing. Items in the queue is read by one or more worker go-routings when the Worker is started, and the handler.Handle is called with the gived image name

func New

func New(handler handler.Handler) *Worker

New returns a new Worker

func (*Worker) Receive

func (w *Worker) Receive(obj observe.ImageInfo)

Receive implementation of Observer

func (*Worker) Start

func (w *Worker) Start(workers uint, stop <-chan struct{}) error

Start the worker in its own goroutine