Versions in this module Expand all Collapse all v3 v3.0.0 Mar 26, 2026 Changes in this version + type Consumer struct + func (m *Consumer) Consume(ctx context.Context, stopChan chan bool, errors chan error) + type ConsumerProvider struct + func (m *ConsumerProvider) ProvideConsumer(ctx context.Context, topic string, handlerFunc messagequeue.ConsumerFunc) (messagequeue.Consumer, error) + type Publisher struct + func (m *Publisher) Publish(ctx context.Context, data any) error + func (m *Publisher) PublishAsync(ctx context.Context, data any) + func (m *Publisher) Stop() + type PublisherProvider struct + func (m *PublisherProvider) Close() + func (m *PublisherProvider) Ping(ctx context.Context) error + func (m *PublisherProvider) ProvidePublisher(ctx context.Context, topic string) (messagequeue.Publisher, error) Other modules containing this package github.com/verygoodsoftwarenotvirus/platform github.com/verygoodsoftwarenotvirus/platform/v2 github.com/verygoodsoftwarenotvirus/platform/v4
Go to main page