Versions in this module Expand all Collapse all v1 v1.0.0 Jun 26, 2026 Changes in this version + type ConsumerMock struct + ConsumeFunc func(ctx context.Context, stopChan chan bool, errors chan error) + func (mock *ConsumerMock) Consume(ctx context.Context, stopChan chan bool, errors chan error) + func (mock *ConsumerMock) ConsumeCalls() []struct{ ... } + type ConsumerProviderMock struct + ProvideConsumerFunc func(ctx context.Context, topic string, handlerFunc messagequeue.ConsumerFunc) (messagequeue.Consumer, error) + func (mock *ConsumerProviderMock) ProvideConsumer(ctx context.Context, topic string, handlerFunc messagequeue.ConsumerFunc) (messagequeue.Consumer, error) + func (mock *ConsumerProviderMock) ProvideConsumerCalls() []struct{ ... } + type PublisherMock struct + PublishAsyncFunc func(ctx context.Context, data any) + PublishFunc func(ctx context.Context, data any) error + StopFunc func() + func (mock *PublisherMock) Publish(ctx context.Context, data any) error + func (mock *PublisherMock) PublishAsync(ctx context.Context, data any) + func (mock *PublisherMock) PublishAsyncCalls() []struct{ ... } + func (mock *PublisherMock) PublishCalls() []struct{ ... } + func (mock *PublisherMock) Stop() + func (mock *PublisherMock) StopCalls() []struct{} + type PublisherProviderMock struct + CloseFunc func() + PingFunc func(ctx context.Context) error + ProvidePublisherFunc func(ctx context.Context, topic string) (messagequeue.Publisher, error) + func (mock *PublisherProviderMock) Close() + func (mock *PublisherProviderMock) CloseCalls() []struct{} + func (mock *PublisherProviderMock) Ping(ctx context.Context) error + func (mock *PublisherProviderMock) PingCalls() []struct{ ... } + func (mock *PublisherProviderMock) ProvidePublisher(ctx context.Context, topic string) (messagequeue.Publisher, error) + func (mock *PublisherProviderMock) ProvidePublisherCalls() []struct{ ... } Other modules containing this package github.com/primandproper/platform-go/v2
Go to main page