mqtt

Documentation

Index

• type JobDefinition
  • func NewDefinition(topic string, job worker.Job, concurrentJobs uint32) *JobDefinition
• type Worker
  • func NewWorker(client mqtt.Client, jobDef *JobDefinition, opts ...WorkerOpt) *Worker
  • func (a *Worker) Stop(ctx context.Context) error
• type WorkerOpt
  • func WithGetWorkFunc(getWork worker.GetWorkFunc) WorkerOpt
  • func WithName(name string) WorkerOpt

Types

type JobDefinition

type JobDefinition struct {
	Topic          string
	Job            worker.Job
	ConcurrentJobs uint32
}

func NewDefinition

func NewDefinition(topic string, job worker.Job, concurrentJobs uint32) *JobDefinition

type Worker

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

An MQTT worker that will subscribe to a topic and execute a job for each message received

func NewWorker

func NewWorker(client mqtt.Client, jobDef *JobDefinition, opts ...WorkerOpt) *Worker

func (*Worker) Stop

func (a *Worker) Stop(ctx context.Context) error

type WorkerOpt

type WorkerOpt func(*Worker)

func WithGetWorkFunc

func WithGetWorkFunc(getWork worker.GetWorkFunc) WorkerOpt

func WithName

func WithName(name string) WorkerOpt