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
  • func (m *MockConsumerGroup) Pause(partitions map[string][]int32)
  • func (m *MockConsumerGroup) PauseAll()
  • func (m *MockConsumerGroup) Resume(partitions map[string][]int32)
  • func (m *MockConsumerGroup) ResumeAll()

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

func (*MockConsumerGroup) Pause

func (m *MockConsumerGroup) Pause(partitions map[string][]int32)

func (*MockConsumerGroup) PauseAll

func (m *MockConsumerGroup) PauseAll()

func (*MockConsumerGroup) Resume

func (m *MockConsumerGroup) Resume(partitions map[string][]int32)

func (*MockConsumerGroup) ResumeAll

func (m *MockConsumerGroup) ResumeAll()