testing

Documentation

Index

• func NonValidatingNewConsumerGroupFn(mockConsumerGroup sarama.ConsumerGroup) wrapper.NewConsumerGroupFnType
• func RestoreNewConsumerGroupFn()
• func StubNewConsumerGroupFn(stubNewConsumerGroupFn wrapper.NewConsumerGroupFnType)
• func ValidatingNewConsumerGroupFn(t *testing.T, expectedBrokers []string, expectedGroupId string, ...) wrapper.NewConsumerGroupFnType
• type MockConsumerGroup
  • func NewMockConsumerGroup() *MockConsumerGroup
  • func (m *MockConsumerGroup) Close() error
  • func (m *MockConsumerGroup) Consume(_ context.Context, _ []string, _ sarama.ConsumerGroupHandler) error
  • func (m *MockConsumerGroup) Errors() <-chan error

Functions

func NonValidatingNewConsumerGroupFn

func NonValidatingNewConsumerGroupFn(mockConsumerGroup sarama.ConsumerGroup) wrapper.NewConsumerGroupFnType

Non-Validating NewConsumerGroup Function

func RestoreNewConsumerGroupFn

func RestoreNewConsumerGroupFn()

Restore The NewConsumerGroupFn To Official Production Value

func StubNewConsumerGroupFn

func StubNewConsumerGroupFn(stubNewConsumerGroupFn wrapper.NewConsumerGroupFnType)

Replace The NewConsumerGroupFn With Specified Mock / Test Value

func ValidatingNewConsumerGroupFn

func ValidatingNewConsumerGroupFn(t *testing.T,
	expectedBrokers []string,
	expectedGroupId string,
	expectedConfig *sarama.Config,
	mockConsumerGroup sarama.ConsumerGroup) wrapper.NewConsumerGroupFnType

Validating NewConsumerGroup Function

Types

type MockConsumerGroup

type MockConsumerGroup struct {
	Closed bool
	// 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(_ context.Context, _ []string, _ sarama.ConsumerGroupHandler) error

func (*MockConsumerGroup) Errors

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