Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewKafkaAdmin ¶
func NewKafkaAdmin(config *KafkaAdminConfig) *kafkaAdmin
Types ¶
type KafkaAdmin ¶
type KafkaAdminConfig ¶
type KafkaAdminConfig struct { BootstrapServers []string KafkaVersion sarama.KafkaVersion Logger log.Logger }
type MockKafkaAdmin ¶
type MockKafkaAdmin struct {
Topics *Topics
}
func (*MockKafkaAdmin) Close ¶
func (m *MockKafkaAdmin) Close()
func (*MockKafkaAdmin) CreateTopics ¶
func (m *MockKafkaAdmin) CreateTopics(topics map[string]*Topic) error
func (*MockKafkaAdmin) DeleteTopics ¶
func (m *MockKafkaAdmin) DeleteTopics(topics []string) (map[string]error, error)
type MockPartition ¶
func (*MockPartition) Latest ¶
func (p *MockPartition) Latest() int64
type MockTopic ¶
func (*MockTopic) AddPartition ¶
func (*MockTopic) Partitions ¶
func (tp *MockTopic) Partitions() []*MockPartition
Click to show internal directories.
Click to hide internal directories.