Versions in this module Expand all Collapse all v0 v0.3.0 May 26, 2026 Changes in this version + func FxModule(opts ...Option) fx.Option + type InMemoryQueue struct + func NewInMemoryQueue() *InMemoryQueue + func (q *InMemoryQueue) Close() + func (q *InMemoryQueue) Publish(ctx context.Context, topic string, payload []byte) error + func (q *InMemoryQueue) Subscribe(ctx context.Context, topic string, handler func(context.Context, []byte) error) error + type Option func(*config) + func Cron(interval time.Duration, name string, fn func(context.Context) error) Option + func Queue[T any](topic string, handler func(context.Context, T) error) Option + func WithBackend(b QueueBackend) Option + type Publisher interface + Publish func(ctx context.Context, topic string, msg any) error + func NewPublisher(b QueueBackend) Publisher + type QueueBackend interface + Publish func(ctx context.Context, topic string, payload []byte) error + Subscribe func(ctx context.Context, topic string, handler func(context.Context, []byte) error) error
Go to main page