testing

Documentation

Index

• type MockConsumerGroup
  • func NewMockConsumerGroup(t *testing.T) *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 {
	Closed bool
	// contains filtered or unexported fields
}

Define The Mock ConsumerGroup

func NewMockConsumerGroup

func NewMockConsumerGroup(t *testing.T) *MockConsumerGroup

Mock ConsumerGroup Constructor

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