kafkazk

package

Go to main page

Versions in this module

v4

v4.2.1

Feb 9, 2023

v4.2.0

Aug 12, 2022

Changes in this version

+ func LoadMetrics(zk Handler, bm mapper.BrokerMetaMap) []error

type Handler

+ GetBrokerMetrics func() (mapper.BrokerMetricsMap, error)

type ZKHandler

+ func (z *ZKHandler) GetBrokerMetrics() (mapper.BrokerMetricsMap, error)

v4.1.0

Aug 3, 2022

Changes in this version

type Reassignments

+ func (r Reassignments) List() []string

v4.0.0

May 17, 2022

Changes in this version

+ var ErrInvalidKafkaConfigType = errors.New("Invalid Kafka config type")

+ func PartitionMapFromZK(t []*regexp.Regexp, zk Handler) (*mapper.PartitionMap, error)

+ type Config struct

+ Connect string

+ MetricsPrefix string

+ Prefix string

+ type ErrNoNode struct

+ func (e ErrNoNode) Error() string

+ type Handler interface

+ GetAllBrokerMeta func(bool) (mapper.BrokerMetaMap, []error)

+ GetAllPartitionMeta func() (mapper.PartitionMetaMap, error)

+ GetPartitionMap func(string) (*mapper.PartitionMap, error)

+ GetPendingDeletion func() ([]string, error)

+ GetReassignments func() Reassignments

+ GetTopicConfig func(string) (*TopicConfig, error)

+ GetTopicMetadata func(string) (TopicMetadata, error)

+ GetTopicState func(string) (*mapper.TopicState, error)

+ GetTopicStateISR func(string) (TopicStateISR, error)

+ GetTopics func([]*regexp.Regexp) ([]string, error)

+ GetUnderReplicated func() ([]string, error)

+ ListReassignments func() (Reassignments, error)

+ MaxMetaAge func() (time.Duration, error)

+ UpdateKafkaConfig func(KafkaConfig) ([]bool, error)

+ func NewHandler(c *Config) (Handler, error)

+ type KafkaConfig struct

+ Configs []KafkaConfigKV

+ Name string

+ Type string

+ type KafkaConfigData struct

+ Config map[string]string

+ Version int

+ func NewKafkaConfigData() KafkaConfigData

+ type KafkaConfigKV [2]string

+ type PartitionState struct

+ ControllerEpoch int

+ ISR []int

+ Leader int

+ LeaderEpoch int

+ Version int

+ type Reassignments map[string]map[int][]int

+ type SimpleZooKeeperClient interface

+ Children func(string) ([]string, error)

+ Close func()

+ Create func(string, string) error

+ CreateSequential func(string, string) error

+ Delete func(string) error

+ Exists func(string) (bool, error)

+ Get func(string) ([]byte, error)

+ NextInt func(string) (int32, error)

+ Ready func() bool

+ Set func(string, string) error

+ type Stub struct

+ func NewZooKeeperStub() *Stub

+ func (zk *Stub) AddBrokers(b map[int]mapper.BrokerMeta)

+ func (zk *Stub) Children(p string) ([]string, error)

+ func (zk *Stub) Close()

+ func (zk *Stub) Create(p, d string) error

+ func (zk *Stub) CreateSequential(a, b string) error

+ func (zk *Stub) Delete(p string) error

+ func (zk *Stub) Exists(p string) (bool, error)

+ func (zk *Stub) Get(p string) ([]byte, error)

+ func (zk *Stub) GetAllBrokerMeta(withMetrics bool) (mapper.BrokerMetaMap, []error)

+ func (zk *Stub) GetAllPartitionMeta() (mapper.PartitionMetaMap, error)

+ func (zk *Stub) GetBrokerMetrics() (mapper.BrokerMetricsMap, error)

+ func (zk *Stub) GetPartitionMap(t string) (*mapper.PartitionMap, error)

+ func (zk *Stub) GetPendingDeletion() ([]string, error)

+ func (zk *Stub) GetReassignments() Reassignments

+ func (zk *Stub) GetTopicConfig(t string) (*TopicConfig, error)

+ func (zk *Stub) GetTopicMetadata(t string) (TopicMetadata, error)

+ func (zk *Stub) GetTopicState(t string) (*mapper.TopicState, error)

+ func (zk *Stub) GetTopicStateISR(t string) (TopicStateISR, error)

+ func (zk *Stub) GetTopics(ts []*regexp.Regexp) ([]string, error)

+ func (zk *Stub) GetUnderReplicated() ([]string, error)

+ func (zk *Stub) InitRawClient() error

+ func (zk *Stub) ListReassignments() (Reassignments, error)

+ func (zk *Stub) MaxMetaAge() (time.Duration, error)

+ func (zk *Stub) NextInt(p string) (int32, error)

+ func (zk *Stub) Ready() bool

+ func (zk *Stub) RemoveBrokers(ids []int)

+ func (zk *Stub) Set(p, d string) error

+ func (zk *Stub) UpdateKafkaConfig(c KafkaConfig) ([]bool, error)

+ type StubZnode struct

+ type TopicConfig struct

+ Config map[string]string

+ Version int

+ type TopicMetadata struct

+ AddingReplicas map[int][]int

+ Name string

+ Partitions map[int][]int

+ RemovingReplicas map[int][]int

+ TopicID string

+ Version int

+ func (tm TopicMetadata) Reassignments() Reassignments

+ type TopicStateISR map[string]PartitionState

+ type ZKHandler struct

+ Connect string

+ MetricsPrefix string

+ Prefix string

+ func (z *ZKHandler) Children(p string) ([]string, error)

+ func (z *ZKHandler) Close()

+ func (z *ZKHandler) Create(p string, d string) error

+ func (z *ZKHandler) CreateSequential(p string, d string) error

+ func (z *ZKHandler) Delete(p string) error

+ func (z *ZKHandler) Exists(p string) (bool, error)

+ func (z *ZKHandler) Get(p string) ([]byte, error)

+ func (z *ZKHandler) GetAllBrokerMeta(withMetrics bool) (mapper.BrokerMetaMap, []error)

+ func (z *ZKHandler) GetAllPartitionMeta() (mapper.PartitionMetaMap, error)

+ func (z *ZKHandler) GetPartitionMap(t string) (*mapper.PartitionMap, error)

+ func (z *ZKHandler) GetPendingDeletion() ([]string, error)

+ func (z *ZKHandler) GetReassignments() Reassignments

+ func (z *ZKHandler) GetTopicConfig(t string) (*TopicConfig, error)

+ func (z *ZKHandler) GetTopicMetadata(t string) (TopicMetadata, error)

+ func (z *ZKHandler) GetTopicState(t string) (*mapper.TopicState, error)

+ func (z *ZKHandler) GetTopicStateISR(t string) (TopicStateISR, error)

+ func (z *ZKHandler) GetTopics(ts []*regexp.Regexp) ([]string, error)

+ func (z *ZKHandler) GetUnderReplicated() ([]string, error)

+ func (z *ZKHandler) ListReassignments() (Reassignments, error)

+ func (z *ZKHandler) MaxMetaAge() (time.Duration, error)

+ func (z *ZKHandler) NextInt(p string) (int32, error)

+ func (z *ZKHandler) Ready() bool

+ func (z *ZKHandler) Set(p string, d string) error

+ func (z *ZKHandler) UpdateKafkaConfig(c KafkaConfig) ([]bool, error)

Other modules containing this package

github.com/DataDog/kafka-kit

github.com/DataDog/kafka-kit/v3

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