isaka

package
v0.0.4 Latest Latest
Warning

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

Go to latest
Published: Jul 9, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type KafkaBrokerInfo

type KafkaBrokerInfo struct {
	ListenerSecurityProtocolMap map[string]string `json:"listener_security_protocol_map"`
	RawEndpoints                []string          `json:"endpoints"`
	Endpoints                   map[string]string
	JmxPort                     string
	Host                        string
	Timestamp                   string
	Port                        int
	Version                     int
}

func (*KafkaBrokerInfo) ParseEndpoint

func (k *KafkaBrokerInfo) ParseEndpoint()

type KafkaBrokers

type KafkaBrokers struct {
	Timeout int
	// contains filtered or unexported fields
}

func NewKafkaBrokers

func NewKafkaBrokers(brokerEndpoints []string, timeout int, ca, cert, key string) (*KafkaBrokers, error)

func (*KafkaBrokers) Reader

func (k *KafkaBrokers) Reader(topic, groupID string, tail int64) (*kafka.Reader, error)

type KafkaBrokersInfo

type KafkaBrokersInfo []KafkaBrokerInfo

func (KafkaBrokersInfo) BrokerEndpoints

func (ks KafkaBrokersInfo) BrokerEndpoints(listener string) []string

type Zookeeper

type Zookeeper struct {
	// contains filtered or unexported fields
}

func NewZookeeper

func NewZookeeper(host, clusterName string, timeout time.Duration) (*Zookeeper, error)

func (*Zookeeper) BrokerList

func (z *Zookeeper) BrokerList() (KafkaBrokersInfo, error)

func (*Zookeeper) TopicList

func (z *Zookeeper) TopicList() ([]string, error)

Jump to

Keyboard shortcuts

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