client

package

Go to main page

Versions in this module

v0

v0.2.0

Nov 2, 2021

v0.1.2

Oct 27, 2021

v0.1.1

Sep 6, 2021

Changes in this version

+ type DescribeLogDirsResponseDirMetadata struct

+ Error error

+ Path string

+ Topics []DescribeLogDirsResponseTopic

+ type DescribeLogDirsResponsePartition struct

+ IsTemporary bool

+ OffsetLag int64

+ PartitionID int32

+ Size int64

+ type DescribeLogDirsResponseTopic struct

+ Partitions []DescribeLogDirsResponsePartition

+ Topic string

type KafkaAPIClient

+ DescribeLogDirs func(brokerIDs []int32) (map[int32][]DescribeLogDirsResponseDirMetadata, error)

type Lister

+ ListTopicWithSizeLessThanOrEqualTo func(int64) ([]string, error)

type MockClusterAdmin

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

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

+ func (m *MockClusterAdmin) ListPartitionReassignments(topics string, partitions []int32) (topicStatus map[string]map[int32]*sarama.PartitionReplicaReassignmentsStatus, ...)

type MockKafkaAPIClient

+ func (m *MockKafkaAPIClient) DescribeLogDirs(brokerIDs []int32) (map[int32][]DescribeLogDirsResponseDirMetadata, error)

type MockLister

+ func (m *MockLister) ListTopicWithSizeLessThanOrEqualTo(size int64) ([]string, error)

+ type MockSSHClient struct

+ func (m *MockSSHClient) ListTopics(req ListTopicsRequest) ([]string, error)

type MockSaramaClient

+ func (m *MockSaramaClient) RefreshBrokers(addrs []string) error

+ func (m *MockSaramaClient) RefreshController() (*sarama.Broker, error)

type SaramaClient

+ func (s *SaramaClient) DescribeLogDirs(brokerIDs []int32) (map[int32][]DescribeLogDirsResponseDirMetadata, error)

v0.1.0

Mar 17, 2020

Changes in this version

+ type ConsumerLister interface

+ GetConsumerGroupsForTopic func([]string, string) (chan string, error)

+ ListConsumerGroups func() (map[string]string, error)

type SaramaClient

+ func (s *SaramaClient) GetConsumerGroupsForTopic(groups []string, topic string) (chan string, error)

+ func (s *SaramaClient) ListConsumerGroups() (map[string]string, error)

v0.0.15

Jan 17, 2020

Changes in this version

+ type ConfigEntry struct

+ Default bool

+ Name string

+ ReadOnly bool

+ Sensitive bool

+ Source string

+ Synonyms []*ConfigSynonym

+ Value string

+ type ConfigResource struct

+ ConfigNames []string

+ Name string

+ Type int

+ type ConfigSynonym struct

+ ConfigName string

+ ConfigValue string

+ Source string

+ type Configurer interface

+ GetConfig func(topic string) ([]ConfigEntry, error)

+ UpdateConfig func(topics []string, configMap map[string]*string, validateOnly bool) error

+ type Creator interface

+ Create func(topic string, detail TopicDetail, validateOnly bool) error

+ CreatePartitions func(topic string, count int32, assignment [][]int32, validateOnly bool) error

+ type Deleter interface

+ Delete func(topics []string) error

+ type Describer interface

+ Describe func(topics []string) ([]*TopicMetadata, error)

+ type KafkaAPIClient interface

+ CreatePartitions func(topic string, count int32, assignment [][]int32, validateOnly bool) error

+ CreateTopic func(topic string, detail TopicDetail, validateOnly bool) error

+ DeleteTopic func(topics []string) error

+ DescribeTopicMetadata func(topics []string) ([]*TopicMetadata, error)

+ GetConfig func(resource ConfigResource) ([]ConfigEntry, error)

+ GetTopicResourceType func() int

+ ListBrokers func() map[int]string

+ ListTopicDetails func() (map[string]TopicDetail, error)

+ UpdateConfig func(resourceType int, name string, entries map[string]*string, validateOnly bool) error

+ type KafkaSSHClient interface

+ ListTopics func(ListTopicsRequest) ([]string, error)

+ func NewKafkaRemoteClient(apiClient KafkaAPIClient, sshClient sshCli) (KafkaSSHClient, error)

+ type ListTopicsRequest struct

+ DataDir string

+ LastWritten int64

+ type Lister interface

+ List func() (map[string]TopicDetail, error)

+ ListLastWrittenTopics func(int64, string) ([]string, error)

+ ListOnly func(regex string, include bool) ([]string, error)

+ type MockClusterAdmin struct

+ func (m *MockClusterAdmin) AlterConfig(resourceType sarama.ConfigResourceType, name string, ...) error

+ func (m *MockClusterAdmin) Close() error

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

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

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

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

+ func (m *MockClusterAdmin) DeleteConsumerGroup(group string) error

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

+ func (m *MockClusterAdmin) DeleteTopic(topic string) error

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

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

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

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

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

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

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

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

+ type MockConfigurer struct

+ func (m *MockConfigurer) GetConfig(topic string) ([]ConfigEntry, error)

+ func (m *MockConfigurer) UpdateConfig(topics []string, configMap map[string]*string, validateOnly bool) error

+ type MockCreator struct

+ func (m *MockCreator) Create(topic string, detail TopicDetail, validateOnly bool) error

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

+ type MockDeleter struct

+ func (m *MockDeleter) Delete(topics []string) error

+ type MockDescriber struct

+ func (m *MockDescriber) Describe(topics []string) ([]*TopicMetadata, error)

+ type MockKafkaAPIClient struct

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

+ func (m *MockKafkaAPIClient) CreateTopic(topic string, detail TopicDetail, validateOnly bool) error

+ func (m *MockKafkaAPIClient) DeleteTopic(topics []string) error

+ func (m *MockKafkaAPIClient) DescribeTopicMetadata(topics []string) ([]*TopicMetadata, error)

+ func (m *MockKafkaAPIClient) GetConfig(resource ConfigResource) ([]ConfigEntry, error)

+ func (m *MockKafkaAPIClient) GetTopicResourceType() int

+ func (m *MockKafkaAPIClient) ListBrokers() map[int]string

+ func (m *MockKafkaAPIClient) ListTopicDetails() (map[string]TopicDetail, error)

+ func (m *MockKafkaAPIClient) UpdateConfig(resourceType int, name string, entries map[string]*string, validateOnly bool) error

+ type MockLister struct

+ func (m *MockLister) List() (map[string]TopicDetail, error)

+ func (m *MockLister) ListLastWrittenTopics(lastWrittenEpoch int64, dataDir string) ([]string, error)

+ func (m *MockLister) ListOnly(regex string, include bool) ([]string, error)

+ type MockPartitioner struct

+ func (m *MockPartitioner) IncreaseReplication(topicsMetadata []*TopicMetadata, ...) error

+ func (m *MockPartitioner) ReassignPartitions(topics []string, brokerList string, ...) error

+ type MockSSHCli struct

+ func (m *MockSSHCli) DialAndExecute(address string, commands ...shellCmd) (*bytes.Buffer, error)

+ type MockSaramaClient struct

+ func (m *MockSaramaClient) Brokers() []*sarama.Broker

+ func (m *MockSaramaClient) Close() error

+ func (m *MockSaramaClient) Closed() bool

+ func (m *MockSaramaClient) Config() *sarama.Config

+ func (m *MockSaramaClient) Controller() (*sarama.Broker, error)

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

+ func (m *MockSaramaClient) GetOffset(topic string, partitionID int32, time int64) (int64, error)

+ func (m *MockSaramaClient) InSyncReplicas(topic string, partitionID int32) ([]int32, error)

+ func (m *MockSaramaClient) InitProducerID() (*sarama.InitProducerIDResponse, error)

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

+ func (m *MockSaramaClient) OfflineReplicas(topic string, partitionID int32) ([]int32, error)

+ func (m *MockSaramaClient) Partitions(topic string) ([]int32, error)

+ func (m *MockSaramaClient) RefreshCoordinator(consumerGroup string) error

+ func (m *MockSaramaClient) RefreshMetadata(topics ...string) error

+ func (m *MockSaramaClient) Replicas(topic string, partitionID int32) ([]int32, error)

+ func (m *MockSaramaClient) Topics() ([]string, error)

+ func (m *MockSaramaClient) WritablePartitions(topic string) ([]int32, error)

+ type PartitionMetadata struct

+ Err error

+ ID int32

+ Isr []int32

+ Leader int32

+ OfflineReplicas []int32

+ Replicas []int32

+ type Partitioner interface

+ IncreaseReplication func(topicsMetadata []*TopicMetadata, ...) error

+ ReassignPartitions func(topics []string, brokerList string, ...) error

+ type SSHClient struct

+ func NewSSHClient(user, port, keyfile string) (*SSHClient, error)

+ func (s *SSHClient) DialAndExecute(address string, commands ...shellCmd) (*bytes.Buffer, error)

+ type SaramaClient struct

+ func NewSaramaClient(addr []string) *SaramaClient

+ func (s *SaramaClient) CreatePartitions(topic string, count int32, assignment [][]int32, validateOnly bool) error

+ func (s *SaramaClient) CreateTopic(topic string, detail TopicDetail, validateOnly bool) error

+ func (s *SaramaClient) DeleteTopic(topics []string) error

+ func (s *SaramaClient) DescribeTopicMetadata(topics []string) ([]*TopicMetadata, error)

+ func (s *SaramaClient) GetConfig(resource ConfigResource) ([]ConfigEntry, error)

+ func (s *SaramaClient) GetTopicResourceType() int

+ func (s *SaramaClient) ListBrokers() map[int]string

+ func (s *SaramaClient) ListTopicDetails() (map[string]TopicDetail, error)

+ func (s *SaramaClient) UpdateConfig(resourceType int, name string, entries map[string]*string, validateOnly bool) error

+ type TopicDetail struct

+ Config map[string]*string

+ NumPartitions int32

+ ReplicaAssignment map[int32][]int32

+ ReplicationFactor int16

+ type TopicMetadata struct

+ Err error

+ IsInternal bool

+ Name string

+ Partitions []*PartitionMetadata

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL