testing

Documentation

Index

• type MockConsumerGroupManager
  • func NewMockConsumerGroupManager() *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
  • func (c *MockKafkaConsumerGroupFactory) StartConsumerGroup(ctx context.Context, groupId string, topics []string, ...) (sarama.ConsumerGroup, error)

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

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

func (m *MockConsumerGroupManager) GetNotificationChannel() <-chan consumer.ManagerEvent

func (*MockConsumerGroupManager) IsManaged

func (m *MockConsumerGroupManager) IsManaged(groupId string) bool

func (*MockConsumerGroupManager) IsStopped

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)