broker

Documentation

Overview

Package broker handles collection of Broker inventory and metric data

Index

• func FeedBrokerPool(brokers []*connection.Broker, brokerChan chan<- *connection.Broker)
• func StartBrokerPool(poolSize int, wg *sync.WaitGroup, integration *integration.Integration, ...) chan *connection.Broker

Functions

func FeedBrokerPool

func FeedBrokerPool(brokers []*connection.Broker, brokerChan chan<- *connection.Broker)

FeedBrokerPool collects a list of brokerIDs from ZooKeeper and feeds them into a channel to be read by a broker worker pool.

func StartBrokerPool

func StartBrokerPool(poolSize int, wg *sync.WaitGroup, integration *integration.Integration, collectedTopics []string) chan *connection.Broker

StartBrokerPool starts a pool of brokerWorkers to handle collecting data for Broker entities. The returned channel can be fed brokerIDs to collect, and is to be closed by the user (or closed by feedBrokerPool)