testing

package
v0.28.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 16, 2021 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockKafkaClient added in v0.28.0 

type MockKafkaClient struct {
	CloseError error
	IsClosed   bool
}

func (MockKafkaClient) Broker added in v0.28.0 

func (m MockKafkaClient) Broker(brokerID int32) (*sarama.Broker, error)

func (MockKafkaClient) Brokers added in v0.28.0 

func (m MockKafkaClient) Brokers() []*sarama.Broker

func (*MockKafkaClient) Close added in v0.28.0 

func (m *MockKafkaClient) Close() error

func (MockKafkaClient) Closed added in v0.28.0 

func (m MockKafkaClient) Closed() bool

func (MockKafkaClient) Config added in v0.28.0 

func (m MockKafkaClient) Config() *sarama.Config

func (MockKafkaClient) Controller added in v0.28.0 

func (m MockKafkaClient) Controller() (*sarama.Broker, error)

func (MockKafkaClient) Coordinator added in v0.28.0 

func (m MockKafkaClient) Coordinator(consumerGroup string) (*sarama.Broker, error)

func (MockKafkaClient) GetOffset added in v0.28.0 

func (m MockKafkaClient) GetOffset(topic string, partitionID int32, time int64) (int64, error)

func (MockKafkaClient) InSyncReplicas added in v0.28.0 

func (m MockKafkaClient) InSyncReplicas(topic string, partitionID int32) ([]int32, error)

func (MockKafkaClient) InitProducerID added in v0.28.0 

func (m MockKafkaClient) InitProducerID() (*sarama.InitProducerIDResponse, error)

func (MockKafkaClient) Leader added in v0.28.0 

func (m MockKafkaClient) Leader(topic string, partitionID int32) (*sarama.Broker, error)

func (MockKafkaClient) OfflineReplicas added in v0.28.0 

func (m MockKafkaClient) OfflineReplicas(topic string, partitionID int32) ([]int32, error)

func (MockKafkaClient) Partitions added in v0.28.0 

func (m MockKafkaClient) Partitions(topic string) ([]int32, error)

func (MockKafkaClient) RefreshBrokers added in v0.28.0 

func (m MockKafkaClient) RefreshBrokers(addrs []string) error

func (MockKafkaClient) RefreshController added in v0.28.0 

func (m MockKafkaClient) RefreshController() (*sarama.Broker, error)

func (MockKafkaClient) RefreshCoordinator added in v0.28.0 

func (m MockKafkaClient) RefreshCoordinator(consumerGroup string) error

func (MockKafkaClient) RefreshMetadata added in v0.28.0 

func (m MockKafkaClient) RefreshMetadata(topics ...string) error

func (MockKafkaClient) Replicas added in v0.28.0 

func (m MockKafkaClient) Replicas(topic string, partitionID int32) ([]int32, error)

func (MockKafkaClient) Topics added in v0.28.0 

func (m MockKafkaClient) Topics() ([]string, error)

func (MockKafkaClient) WritablePartitions added in v0.28.0 

func (m MockKafkaClient) WritablePartitions(topic string) ([]int32, error)

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) AlterClientQuotas added in v0.28.0 

func (m *MockKafkaClusterAdmin) AlterClientQuotas(entity []sarama.QuotaEntityComponent, op sarama.ClientQuotasOp, validateOnly bool) error

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) Controller added in v0.28.0 

func (m *MockKafkaClusterAdmin) Controller() (*sarama.Broker, 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) DeleteConsumerGroupOffset added in v0.28.0 

func (m *MockKafkaClusterAdmin) DeleteConsumerGroupOffset(group string, topic string, partition int32) 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) DeleteUserScramCredentials added in v0.26.0 

func (m *MockKafkaClusterAdmin) DeleteUserScramCredentials(delete []sarama.AlterUserScramCredentialsDelete) ([]*sarama.AlterUserScramCredentialsResult, error)

func (*MockKafkaClusterAdmin) DescribeClientQuotas added in v0.28.0 

func (m *MockKafkaClusterAdmin) DescribeClientQuotas(components []sarama.QuotaFilterComponent, strict bool) ([]sarama.DescribeClientQuotasEntry, 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) DescribeUserScramCredentials added in v0.26.0 

func (m *MockKafkaClusterAdmin) DescribeUserScramCredentials(users []string) ([]*sarama.DescribeUserScramCredentialsResult, 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)

func (*MockKafkaClusterAdmin) UpsertUserScramCredentials added in v0.26.0 

func (m *MockKafkaClusterAdmin) UpsertUserScramCredentials(upsert []sarama.AlterUserScramCredentialsUpsert) ([]*sarama.AlterUserScramCredentialsResult, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.