Versions in this module Expand all Collapse all v0 v0.4.0 Feb 27, 2025 v0.3.1 Mar 14, 2024 Changes in this version + func FormatTopic(app, ns, topic string) string + type Config struct + App string + ChannelSize int + Namespace string + SendTimeout time.Duration + type Consumer interface + Close func() error + Subscribe func(ctx context.Context, topics ...string) error + Unsubscribe func(ctx context.Context, topics ...string) error + type Msg struct + Payload []byte + Topic string + type PublishConfig struct + App string + Namespace string + func (c *PublishConfig) Apply(pc *PublishConfig) + type PublishOption interface + Apply func(*PublishConfig) + func WithPublishApp(value string) PublishOption + func WithPublishNamespace(value string) PublishOption + type PublishOptionFunc func(*PublishConfig) + func (f PublishOptionFunc) Apply(config *PublishConfig) + type Publisher interface + Publish func(ctx context.Context, topic string, payload []byte, options ...PublishOption) error + type SubscribeConfig struct + App string + ChannelSize int + HealthInterval time.Duration + Namespace string + SendTimeout time.Duration + Topics []string + type SubscribeOption interface + Apply func(*SubscribeConfig) + func WithChannelHealthCheckInterval(value time.Duration) SubscribeOption + func WithChannelNamespace(value string) SubscribeOption + func WithChannelSendTimeout(value time.Duration) SubscribeOption + func WithChannelSize(value int) SubscribeOption + func WithTopics(topics ...string) SubscribeOption + type SubscribeOptionFunc func(*SubscribeConfig) + func (f SubscribeOptionFunc) Apply(config *SubscribeConfig) + type Subscriber interface + Subscribe func(ctx context.Context, topic string, handler func(payload *Msg) error, ...) Consumer + SubscribeChan func(ctx context.Context, topic string, options ...SubscribeOption) (Consumer, <-chan *Msg)
Go to main page