subscriber

Documentation

Index

• type Subscriber
  • func Run[T types.Ordered](log slog.Logger, b broker.Broker[T], workers int, worker Worker[T], ...) *Subscriber[T]
  • func (s *Subscriber[T]) Stop()
  • func (s *Subscriber[T]) Wait()
• type Worker

Types

type Subscriber

type Subscriber[T types.Ordered] struct {
	// contains filtered or unexported fields
}

func Run

func Run[T types.Ordered](log slog.Logger, b broker.Broker[T], workers int, worker Worker[T], kinds ...fmt.Stringer) *Subscriber[T]

func (*Subscriber[T]) Stop

func (s *Subscriber[T]) Stop()

func (*Subscriber[T]) Wait

func (s *Subscriber[T]) Wait()

type Worker

type Worker[T types.Ordered] func(queue <-chan broker.Event[T])