brokers

Documentation

Index

• Constants
• func NewPubSub(ctx context.Context, url string, logger *slog.Logger, opts ...messaging.Option) (messaging.PubSub, error)
• func NewPublisher(ctx context.Context, url string, opts ...messaging.Option) (messaging.Publisher, error)

Constants

const SubjectAllChannels = "channels.>"

SubjectAllChannels represents subject to subscribe for all the channels.

Functions

func NewPubSub

func NewPubSub(ctx context.Context, url string, logger *slog.Logger, opts ...messaging.Option) (messaging.PubSub, error)

func NewPublisher

func NewPublisher(ctx context.Context, url string, opts ...messaging.Option) (messaging.Publisher, error)