Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Monitor ¶
type Monitor struct {
// contains filtered or unexported fields
}
Monitor represents a Kafka cluster connection.
func New ¶
func New(opts ...MonitorFunc) (*Monitor, error)
New creates and returns a new Monitor for a Kafka cluster.
type MonitorFunc ¶
type MonitorFunc func(c *Monitor)
MonitorFunc represents a function that configures the Monitor.
func Brokers ¶
func Brokers(brokers []string) MonitorFunc
Brokers configures the brokers on the Monitor.
func IgnoreGroups ¶
func IgnoreGroups(groups []string) MonitorFunc
IgnoreGroups configures the group patterns to be ignored on the Monitor.
func IgnoreTopics ¶
func IgnoreTopics(topics []string) MonitorFunc
IgnoreTopics configures the topic patterns to be ignored on the Monitor.
func StateChannel ¶
func StateChannel(ch chan interface{}) MonitorFunc
StateChannel configures the offset manager channel on the Monitor.
Click to show internal directories.
Click to hide internal directories.