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 + 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/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