Documentation ¶
Index ¶
- type MockConsumerGroupManager
- func (m *MockConsumerGroupManager) ClearNotifications()
- func (m *MockConsumerGroupManager) CloseConsumerGroup(groupId string) error
- func (m *MockConsumerGroupManager) Errors(groupId string) <-chan error
- func (m *MockConsumerGroupManager) GetNotificationChannel() <-chan consumer.ManagerEvent
- func (m *MockConsumerGroupManager) IsManaged(groupId string) bool
- func (m *MockConsumerGroupManager) IsStopped(groupId string) bool
- func (m *MockConsumerGroupManager) Reconfigure(brokers []string, config *sarama.Config) *consumer.ReconfigureError
- func (m *MockConsumerGroupManager) StartConsumerGroup(ctx context.Context, groupId string, topics []string, ...) error
- type MockKafkaConsumerGroupFactory
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockConsumerGroupManager ¶
type MockConsumerGroupManager struct { mock.Mock Groups map[string]sarama.ConsumerGroup }
MockConsumerGroupManager implements the KafkaConsumerGroupManager interface
func NewMockConsumerGroupManager ¶
func NewMockConsumerGroupManager() *MockConsumerGroupManager
func (*MockConsumerGroupManager) ClearNotifications ¶ added in v0.25.0
func (m *MockConsumerGroupManager) ClearNotifications()
func (*MockConsumerGroupManager) CloseConsumerGroup ¶
func (m *MockConsumerGroupManager) CloseConsumerGroup(groupId string) error
func (*MockConsumerGroupManager) Errors ¶
func (m *MockConsumerGroupManager) Errors(groupId string) <-chan error
func (*MockConsumerGroupManager) GetNotificationChannel ¶ added in v0.25.0
func (m *MockConsumerGroupManager) GetNotificationChannel() <-chan consumer.ManagerEvent
func (*MockConsumerGroupManager) IsManaged ¶
func (m *MockConsumerGroupManager) IsManaged(groupId string) bool
func (*MockConsumerGroupManager) IsStopped ¶ added in v0.25.0
func (m *MockConsumerGroupManager) IsStopped(groupId string) bool
func (*MockConsumerGroupManager) Reconfigure ¶
func (m *MockConsumerGroupManager) Reconfigure(brokers []string, config *sarama.Config) *consumer.ReconfigureError
func (*MockConsumerGroupManager) StartConsumerGroup ¶
func (m *MockConsumerGroupManager) StartConsumerGroup(ctx context.Context, groupId string, topics []string, handler consumer.KafkaConsumerHandler, channelRef types.NamespacedName, options ...consumer.SaramaConsumerHandlerOption) error
type MockKafkaConsumerGroupFactory ¶
type MockKafkaConsumerGroupFactory struct { // CreateErr will return an error when creating a consumer mock.Mock }
func (*MockKafkaConsumerGroupFactory) StartConsumerGroup ¶
func (c *MockKafkaConsumerGroupFactory) StartConsumerGroup(ctx context.Context, groupId string, topics []string, handler consumer.KafkaConsumerHandler, ref types.NamespacedName, options ...consumer.SaramaConsumerHandlerOption) (sarama.ConsumerGroup, error)
Click to show internal directories.
Click to hide internal directories.