package
0.0.0-20210621012306-d5049b0385c5
Repository: https://github.com/kafkaesque-io/pulsar-monitor.git
Documentation: pkg.go.dev

# Functions

BrokerHealthCheck calls broker's health endpoint.
BrokerTopicsQuery returns a map of broker and topic full name, or error of this operation.
GetBrokers gets a list of brokers and ports.
QueryTopicStats query a single topic stats.
TestBrokers evaluates all brokers' health.