bus

type Bus ¶

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

Bus is a generic pub/sub message bus. Safe for concurrent use.

func New[T any](mws ...Middleware[T]) *Bus[T]

func (b *Bus[T]) Publish(ctx context.Context, subject string, msg T) error

func (b *Bus[T]) Subscribe(subject string, h Handler[T])

type Handler ¶

type Handler[T any] func(ctx context.Context, msg T) error

Handler is the subscriber function signature.

type Middleware ¶

type Middleware[T any] func(Handler[T]) Handler[T]

Middleware wraps a Handler for cross-cutting concerns.

func Logging[T any](log *slog.Logger) Middleware[T]

func Recover[T any](log *slog.Logger) Middleware[T]

func Timeout[T any](d time.Duration) Middleware[T]

type TypedBus ¶

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

func NewTyped() *TypedBus

type TypedHandler ¶

type TypedHandler[Req, Res any] func(ctx context.Context, req Req) (Res, error)