mocks

Documentation

Index

• type MockKafkaAdmin
  • func (m *MockKafkaAdmin) Close() error
  • func (m *MockKafkaAdmin) DescribeConfig() ([]sarama.ConfigEntry, error)
  • func (m *MockKafkaAdmin) GetClusterKafkaMetadata() (*client.ClusterKafkaMetadata, error)
  • func (m *MockKafkaAdmin) ListTopics() (map[string]sarama.TopicDetail, error)

Types

type MockKafkaAdmin

type MockKafkaAdmin struct {
	ListTopicsFunc              func() (map[string]sarama.TopicDetail, error)
	GetClusterKafkaMetadataFunc func() (*client.ClusterKafkaMetadata, error)
	DescribeConfigFunc          func() ([]sarama.ConfigEntry, error)
	CloseFunc                   func() error
}

MockKafkaAdmin is a mock implementation of the KafkaAdmin interface

func (*MockKafkaAdmin) Close

func (m *MockKafkaAdmin) Close() error

func (*MockKafkaAdmin) DescribeConfig

func (m *MockKafkaAdmin) DescribeConfig() ([]sarama.ConfigEntry, error)

func (*MockKafkaAdmin) GetClusterKafkaMetadata

func (m *MockKafkaAdmin) GetClusterKafkaMetadata() (*client.ClusterKafkaMetadata, error)

func (*MockKafkaAdmin) ListTopics

func (m *MockKafkaAdmin) ListTopics() (map[string]sarama.TopicDetail, error)