testing

Documentation

Index

• type MockKafkaClusterAdmin
  • func (m *MockKafkaClusterAdmin) AlterConfig(resourceType sarama.ConfigResourceType, name string, ...) error
  • func (m *MockKafkaClusterAdmin) AlterPartitionReassignments(topic string, assignment [][]int32) error
  • func (m *MockKafkaClusterAdmin) Close() error
  • func (m *MockKafkaClusterAdmin) CreateACL(resource sarama.Resource, acl sarama.Acl) error
  • func (m *MockKafkaClusterAdmin) CreatePartitions(topic string, count int32, assignment [][]int32, validateOnly bool) error
  • func (m *MockKafkaClusterAdmin) CreateTopic(topic string, detail *sarama.TopicDetail, validateOnly bool) error
  • func (m *MockKafkaClusterAdmin) DeleteACL(filter sarama.AclFilter, validateOnly bool) ([]sarama.MatchingAcl, error)
  • func (m *MockKafkaClusterAdmin) DeleteConsumerGroup(group string) error
  • func (m *MockKafkaClusterAdmin) DeleteRecords(topic string, partitionOffsets map[int32]int64) error
  • func (m *MockKafkaClusterAdmin) DeleteTopic(topic string) error
  • func (m *MockKafkaClusterAdmin) DescribeCluster() (brokers []*sarama.Broker, controllerID int32, err error)
  • func (m *MockKafkaClusterAdmin) DescribeConfig(resource sarama.ConfigResource) ([]sarama.ConfigEntry, error)
  • func (m *MockKafkaClusterAdmin) DescribeConsumerGroups(groups []string) ([]*sarama.GroupDescription, error)
  • func (m *MockKafkaClusterAdmin) DescribeLogDirs(brokers []int32) (map[int32][]sarama.DescribeLogDirsResponseDirMetadata, error)
  • func (m *MockKafkaClusterAdmin) DescribeTopics(topics []string) (metadata []*sarama.TopicMetadata, err error)
  • func (m *MockKafkaClusterAdmin) ListAcls(filter sarama.AclFilter) ([]sarama.ResourceAcls, error)
  • func (m *MockKafkaClusterAdmin) ListConsumerGroupOffsets(group string, topicPartitions map[string][]int32) (*sarama.OffsetFetchResponse, error)
  • func (m *MockKafkaClusterAdmin) ListConsumerGroups() (map[string]string, error)
  • func (m *MockKafkaClusterAdmin) ListPartitionReassignments(topics string, partitions []int32) (topicStatus map[string]map[int32]*sarama.PartitionReplicaReassignmentsStatus, ...)
  • func (m *MockKafkaClusterAdmin) ListTopics() (map[string]sarama.TopicDetail, error)

Types

type MockKafkaClusterAdmin

type MockKafkaClusterAdmin struct {
	// (Create|Delete)Topic
	ExpectedTopicName string

	// CreateTopic
	ExpectedTopicDetail sarama.TopicDetail
	ErrorOnCreateTopic  error

	// DeleteTopic
	ErrorOnDeleteTopic error

	ExpectedClose      bool
	ExpectedCloseError error

	// DescribeTopics
	ExpectedTopics                         []string
	ExpectedErrorOnDescribeTopics          error
	ExpectedTopicsMetadataOnDescribeTopics []*sarama.TopicMetadata

	T *testing.T
}

func (*MockKafkaClusterAdmin) AlterConfig

func (m *MockKafkaClusterAdmin) AlterConfig(resourceType sarama.ConfigResourceType, name string, entries map[string]*string, validateOnly bool) error

func (*MockKafkaClusterAdmin) AlterPartitionReassignments

func (m *MockKafkaClusterAdmin) AlterPartitionReassignments(topic string, assignment [][]int32) error

func (*MockKafkaClusterAdmin) Close

func (m *MockKafkaClusterAdmin) Close() error

func (*MockKafkaClusterAdmin) CreateACL

func (m *MockKafkaClusterAdmin) CreateACL(resource sarama.Resource, acl sarama.Acl) error

func (*MockKafkaClusterAdmin) CreatePartitions

func (m *MockKafkaClusterAdmin) CreatePartitions(topic string, count int32, assignment [][]int32, validateOnly bool) error

func (*MockKafkaClusterAdmin) CreateTopic

func (m *MockKafkaClusterAdmin) CreateTopic(topic string, detail *sarama.TopicDetail, validateOnly bool) error

func (*MockKafkaClusterAdmin) DeleteACL

func (m *MockKafkaClusterAdmin) DeleteACL(filter sarama.AclFilter, validateOnly bool) ([]sarama.MatchingAcl, error)

func (*MockKafkaClusterAdmin) DeleteConsumerGroup

func (m *MockKafkaClusterAdmin) DeleteConsumerGroup(group string) error

func (*MockKafkaClusterAdmin) DeleteRecords

func (m *MockKafkaClusterAdmin) DeleteRecords(topic string, partitionOffsets map[int32]int64) error

func (*MockKafkaClusterAdmin) DeleteTopic

func (m *MockKafkaClusterAdmin) DeleteTopic(topic string) error

func (*MockKafkaClusterAdmin) DescribeCluster

func (m *MockKafkaClusterAdmin) DescribeCluster() (brokers []*sarama.Broker, controllerID int32, err error)

func (*MockKafkaClusterAdmin) DescribeConfig

func (m *MockKafkaClusterAdmin) DescribeConfig(resource sarama.ConfigResource) ([]sarama.ConfigEntry, error)

func (*MockKafkaClusterAdmin) DescribeConsumerGroups

func (m *MockKafkaClusterAdmin) DescribeConsumerGroups(groups []string) ([]*sarama.GroupDescription, error)

func (*MockKafkaClusterAdmin) DescribeLogDirs

func (m *MockKafkaClusterAdmin) DescribeLogDirs(brokers []int32) (map[int32][]sarama.DescribeLogDirsResponseDirMetadata, error)

func (*MockKafkaClusterAdmin) DescribeTopics

func (m *MockKafkaClusterAdmin) DescribeTopics(topics []string) (metadata []*sarama.TopicMetadata, err error)

func (*MockKafkaClusterAdmin) ListAcls

func (m *MockKafkaClusterAdmin) ListAcls(filter sarama.AclFilter) ([]sarama.ResourceAcls, error)

func (*MockKafkaClusterAdmin) ListConsumerGroupOffsets

func (m *MockKafkaClusterAdmin) ListConsumerGroupOffsets(group string, topicPartitions map[string][]int32) (*sarama.OffsetFetchResponse, error)

func (*MockKafkaClusterAdmin) ListConsumerGroups

func (m *MockKafkaClusterAdmin) ListConsumerGroups() (map[string]string, error)

func (*MockKafkaClusterAdmin) ListPartitionReassignments

func (m *MockKafkaClusterAdmin) ListPartitionReassignments(topics string, partitions []int32) (topicStatus map[string]map[int32]*sarama.PartitionReplicaReassignmentsStatus, err error)

func (*MockKafkaClusterAdmin) ListTopics

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