Versions in this module Expand all Collapse all v10 v10.1.0 Aug 15, 2026 v10.0.0 Aug 12, 2026 Changes in this version + const OrderingKeyAttribute + var ErrConsumerAlreadyRegistered = platformerrors.New("a consumer is already registered for this topic") + var ErrEmptyTopicName = platformerrors.New("empty topic name") + type Consumer interface + Consume func(ctx context.Context, errs chan<- error) + type ConsumerFunc func(context.Context, []byte) error + type ConsumerProvider interface + Close func() + NewConsumer func(ctx context.Context, topic string, handlerFunc ConsumerFunc) (Consumer, error) + type PublishOption func(*PublishOptions) + func WithDeduplicationKey(key string) PublishOption + func WithOrderingKey(key string) PublishOption + type PublishOptions struct + DeduplicationKey string + OrderingKey string + func NewPublishOptions(opts ...PublishOption) *PublishOptions + type Publisher interface + Publish func(ctx context.Context, data any, opts ...PublishOption) error + PublishAsync func(ctx context.Context, data any, opts ...PublishOption) + Stop func() + type PublisherProvider interface + Close func() + NewPublisher func(ctx context.Context, topic string) (Publisher, error) + Ping func(ctx context.Context) error Other modules containing this package github.com/primandproper/platform-go github.com/primandproper/platform-go/v11 github.com/primandproper/platform-go/v12 github.com/primandproper/platform-go/v2 github.com/primandproper/platform-go/v3 github.com/primandproper/platform-go/v4 github.com/primandproper/platform-go/v5 github.com/primandproper/platform-go/v6 github.com/primandproper/platform-go/v7 github.com/primandproper/platform-go/v8 github.com/primandproper/platform-go/v9
Go to main page