broker

package
v2.13.2+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 12, 2020 License: MIT Imports: 13 Imported by: 0

Documentation

Overview

Package broker handles collection of Broker inventory and metric data

Index

Constants

This section is empty.

Variables

This section is empty.

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)

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL