Versions in this module Expand all Collapse all v3 v3.0.0 Mar 26, 2026 Changes in this version + var ErrEmptyTopicName = platformerrors.New("empty topic name") + type Consumer interface + Consume func(ctx context.Context, stopChan chan bool, errors chan error) + type ConsumerFunc func(context.Context, []byte) error + type ConsumerProvider interface + ProvideConsumer func(ctx context.Context, topic string, handlerFunc ConsumerFunc) (Consumer, error) + type NoopConsumer struct + func (n *NoopConsumer) Consume(context.Context, chan bool, chan error) + type NoopConsumerProvider struct + func (n *NoopConsumerProvider) ProvideConsumer(context.Context, string, ConsumerFunc) (Consumer, error) + type NoopPublisher struct + func (n *NoopPublisher) Publish(context.Context, any) error + func (n *NoopPublisher) PublishAsync(context.Context, any) + func (n *NoopPublisher) Stop() + type NoopPublisherProvider struct + func (n *NoopPublisherProvider) Close() + func (n *NoopPublisherProvider) Ping(context.Context) error + func (n *NoopPublisherProvider) ProvidePublisher(context.Context, string) (Publisher, error) + type Publisher interface + Publish func(ctx context.Context, data any) error + PublishAsync func(ctx context.Context, data any) + Stop func() + func NewNoopPublisher() Publisher + type PublisherProvider interface + Close func() + Ping func(ctx context.Context) error + ProvidePublisher func(ctx context.Context, topic string) (Publisher, error) + func NewNoopPublisherProvider() PublisherProvider Other modules containing this package github.com/verygoodsoftwarenotvirus/platform github.com/verygoodsoftwarenotvirus/platform/v2
Go to main page