Versions in this module Expand all Collapse all v1 v1.0.0 Sep 8, 2026 Changes in this version + type ConsumerMock struct + ConsumeFunc func(ctx context.Context, errs chan<- error) + func (mock *ConsumerMock) Consume(ctx context.Context, errs chan<- error) + func (mock *ConsumerMock) ConsumeCalls() []struct{ ... } + type ConsumerProviderMock struct + CloseFunc func() + NewConsumerFunc func(ctx context.Context, topic string, handlerFunc messagequeue.ConsumerFunc) (messagequeue.Consumer, error) + func (mock *ConsumerProviderMock) Close() + func (mock *ConsumerProviderMock) CloseCalls() []struct{} + func (mock *ConsumerProviderMock) NewConsumer(ctx context.Context, topic string, handlerFunc messagequeue.ConsumerFunc) (messagequeue.Consumer, error) + func (mock *ConsumerProviderMock) NewConsumerCalls() []struct{ ... } + type PublisherMock struct + PublishAsyncFunc func(ctx context.Context, data any, opts ...messagequeue.PublishOption) + PublishFunc func(ctx context.Context, data any, opts ...messagequeue.PublishOption) error + StopFunc func() + func (mock *PublisherMock) Publish(ctx context.Context, data any, opts ...messagequeue.PublishOption) error + func (mock *PublisherMock) PublishAsync(ctx context.Context, data any, opts ...messagequeue.PublishOption) + func (mock *PublisherMock) PublishAsyncCalls() []struct{ ... } + func (mock *PublisherMock) PublishCalls() []struct{ ... } + func (mock *PublisherMock) Stop() + func (mock *PublisherMock) StopCalls() []struct{} + type PublisherProviderMock struct + CloseFunc func() + NewPublisherFunc func(ctx context.Context, topic string) (messagequeue.Publisher, error) + PingFunc func(ctx context.Context) error + func (mock *PublisherProviderMock) Close() + func (mock *PublisherProviderMock) CloseCalls() []struct{} + func (mock *PublisherProviderMock) NewPublisher(ctx context.Context, topic string) (messagequeue.Publisher, error) + func (mock *PublisherProviderMock) NewPublisherCalls() []struct{ ... } + func (mock *PublisherProviderMock) Ping(ctx context.Context) error + func (mock *PublisherProviderMock) PingCalls() []struct{ ... } Other modules containing this package github.com/primandproper/primitives-go/v2
Go to main page