concurrency

Documentation

Index

• func WithWorkers(recr nc.Receiver, workers int, errHandler errHandlerFnk, options ...Option) nc.Receiver
• type Option
  • func WithRecoverHandler(f func(any)) Option
  • func WithWorkerPoolSize(size int) Option

Functions

func WithWorkers

func WithWorkers(recr nc.Receiver, workers int, errHandler errHandlerFnk, options ...Option) nc.Receiver

WithWorkers wraps receiver in concurrent pool

Types

type Option

type Option func() rpool.Option

Option func type which adjust option values

func WithRecoverHandler

func WithRecoverHandler(f func(any)) Option

WithRecoverHandler defined error handler

func WithWorkerPoolSize

func WithWorkerPoolSize(size int) Option

WithWorkerPoolSize setup maximal size of worker pool