workers

Documentation

Index

• type Worker
  • func New[T any](ctx context.Context, opts *options.Subscriber) (*Worker[T], error)
  • func (w *Worker[T]) Start(workerFn WorkerFn[T], descriptor <-chan T) error
  • func (w *Worker[T]) Stop() error
• type WorkerFn

Types

type Worker

type Worker[T any] struct {
	// contains filtered or unexported fields
}

Worker applies generics to the Worker struct, making it type-specific.

func New

func New[T any](ctx context.Context, opts *options.Subscriber) (*Worker[T], error)

New is now a generic function that returns an instance of a type-specific Worker.

func (*Worker[T]) Start

func (w *Worker[T]) Start(workerFn WorkerFn[T], descriptor <-chan T) error

Start accepts a WorkerFn that is specific to the type T.

func (*Worker[T]) Stop

func (w *Worker[T]) Stop() error

Stop provides functionality to stop the worker's operations.

type WorkerFn

type WorkerFn[T any] func(descriptor T) error

WorkerFn defines WorkerFn as a generic type with a type parameter T.