Documentation
¶
Index ¶
- func BrokerHealthCheck(broker, token string) error
- func BrokerTopicsQuery(brokerBaseURL, token string) ([]string, error)
- func GetBrokers(restBaseURL, clusterName, token string) ([]string, error)
- func QueryTopicStats(url, token string) error
- func TestBrokers(urlPrefix, clusterName, token string) (int, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BrokerHealthCheck ¶
BrokerHealthCheck calls broker's health endpoint
func BrokerTopicsQuery ¶
BrokerTopicsQuery returns a map of broker and topic full name, or error of this operation
func GetBrokers ¶
GetBrokers gets a list of brokers and ports
func QueryTopicStats ¶
QueryTopicStats query a single topic stats
func TestBrokers ¶
TestBrokers evaluates all brokers' health
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.