mockpublishers

Documentation

Index

• type Consumer
  • func (m *Consumer) Consume(stopChan chan bool, errors chan error)
• type ConsumerProvider
  • func (m *ConsumerProvider) ProvideConsumer(ctx context.Context, topic string, ...) (messagequeue.Consumer, error)
• type ProducerProvider
  • func (m *ProducerProvider) Close()
  • func (m *ProducerProvider) ProvidePublisher(topic string) (messagequeue.Publisher, error)
• type Publisher
  • func (m *Publisher) Publish(ctx context.Context, data any) error
  • func (m *Publisher) Stop()

Types

type Consumer

type Consumer struct {
	mock.Mock
}

Consumer is a mock consumers.Consumer.

func (*Consumer) Consume

func (m *Consumer) Consume(stopChan chan bool, errors chan error)

Consume implements the interface.

type ConsumerProvider

type ConsumerProvider struct {
	mock.Mock
}

ConsumerProvider is a mock consumers.ConsumerProvider.

func (*ConsumerProvider) ProvideConsumer

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

ProvideConsumer implements the interface.

type ProducerProvider

type ProducerProvider struct {
	mock.Mock
}

ProducerProvider implements our interface.

func (*ProducerProvider) Close

func (m *ProducerProvider) Close()

Close implements our interface.

func (*ProducerProvider) ProvidePublisher

func (m *ProducerProvider) ProvidePublisher(topic string) (messagequeue.Publisher, error)

ProvidePublisher implements our interface.

type Publisher

type Publisher struct {
	mock.Mock
}

Publisher implements our interface.

func (*Publisher) Publish

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

Publish implements our interface.

func (*Publisher) Stop

func (m *Publisher) Stop()

Stop implements our interface.