jobworker

Documentation

Overview

Package jobworker implements worker for performing tasks defined by jobpacket that are in the queue.

Index

• type JobWorker
  • func New(jobQueueOut <-chan *jobpacket.JobPacket, id uint64, l *logger.Logger) *JobWorker

Types

type JobWorker

type JobWorker struct {
	worker.Worker
	// contains filtered or unexported fields
}

JobWorker is an instance of jobWorker.

func New

func New(jobQueueOut <-chan *jobpacket.JobPacket, id uint64, l *logger.Logger) *JobWorker

New creates new instance of a jobWorker.