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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.