worker

Documentation

Index

• type Config
• type ErrorHandler
• type MsgHandler
• type Worker
  • func NewWorker(cfg *Config) *Worker
  • func (w *Worker) Close()
  • func (w *Worker) Size() int
  • func (w *Worker) TryEnqueue(msg *message.SSVMessage) bool
  • func (w *Worker) UseErrorHandler(errHandler ErrorHandler)
  • func (w *Worker) UseHandler(handler MsgHandler)

Types

type Config

type Config struct {
	Ctx          context.Context
	Logger       *zap.Logger
	WorkersCount int
	Buffer       int
	MetrixPrefix string
}

Config holds all necessary config for worker

type ErrorHandler

type ErrorHandler func(msg *message.SSVMessage, err error) error

ErrorHandler func that handles an error for a specific message

type MsgHandler

type MsgHandler func(msg *message.SSVMessage) error

MsgHandler func that receive message.SSVMessage to handle

type Worker

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

Worker listen to queue and process the messages

func NewWorker

func NewWorker(cfg *Config) *Worker

NewWorker return new Worker

func (*Worker) Close

func (w *Worker) Close()

Close queue and worker listener

func (*Worker) Size

func (w *Worker) Size() int

Size returns the queue size

func (*Worker) TryEnqueue

func (w *Worker) TryEnqueue(msg *message.SSVMessage) bool

TryEnqueue tries to enqueue a job to the given job channel. Returns true if the operation was successful, and false if enqueuing would not have been possible without blocking. Job is not enqueued in the latter case.

func (*Worker) UseErrorHandler

func (w *Worker) UseErrorHandler(errHandler ErrorHandler)

UseErrorHandler registers an error handler

func (*Worker) UseHandler

func (w *Worker) UseHandler(handler MsgHandler)

UseHandler registers a message handler