mockpublishers

package

v2.0.2 Latest Latest Go to latest Published: Mar 23, 2026 License: AGPL-3.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Consumer struct {
	mock.Mock
}

Consumer is a mock consumers.Consumer.

func (m *Consumer) Consume(ctx context.Context, stopChan chan bool, errors chan error)

Consume implements the interface.

type ConsumerProvider struct {
	mock.Mock
}

ConsumerProvider is a mock consumers.ConsumerProvider.

func (m *ConsumerProvider) ProvideConsumer(ctx context.Context, topic string, handlerFunc messagequeue.ConsumerFunc) (messagequeue.Consumer, error)

ProvideConsumer implements the interface.

type Publisher struct {
	mock.Mock
}

Publisher implements our interface.

func (m *Publisher) Publish(ctx context.Context, data any) error

Publish implements our interface.

func (m *Publisher) PublishAsync(ctx context.Context, data any)

PublishAsync implements our interface.

func (m *Publisher) Stop()

Stop implements our interface.

type PublisherProvider struct {
	mock.Mock
}

PublisherProvider implements our interface.

func (m *PublisherProvider) Close()

Close implements our interface.

func (m *PublisherProvider) ProvidePublisher(ctx context.Context, topic string) (messagequeue.Publisher, error)

ProvidePublisher implements our interface.