testing

Documentation

Index

• type MockConsumerGroup
  • func NewMockConsumerGroup() *MockConsumerGroup
  • func (m *MockConsumerGroup) Close() error
  • func (m *MockConsumerGroup) Consume(ctx context.Context, topics []string, handler sarama.ConsumerGroupHandler) error
  • func (m *MockConsumerGroup) Errors() <-chan error

Types

type MockConsumerGroup

type MockConsumerGroup struct {
	mock.Mock
	ErrorChan chan error
	// contains filtered or unexported fields
}

func NewMockConsumerGroup

func NewMockConsumerGroup() *MockConsumerGroup

func (*MockConsumerGroup) Close

func (m *MockConsumerGroup) Close() error

func (*MockConsumerGroup) Consume

func (m *MockConsumerGroup) Consume(ctx context.Context, topics []string, handler sarama.ConsumerGroupHandler) error

func (*MockConsumerGroup) Errors

func (m *MockConsumerGroup) Errors() <-chan error