brokercollect

Documentation

Overview

Package brokercollect handles collection of Broker inventory and metric data

Index

• func FeedBrokerPool(zkConn zookeeper.Connection, brokerChan chan<- int) error
• func StartBrokerPool(poolSize int, wg *sync.WaitGroup, zkConn zookeeper.Connection, ...) chan int

Functions

func FeedBrokerPool

func FeedBrokerPool(zkConn zookeeper.Connection, brokerChan chan<- int) error

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, zkConn zookeeper.Connection, integration *integration.Integration, collectedTopics []string) chan int

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)