imageworker

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(handler handler.Handler) *Worker

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

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