prodconcollect

Documentation

Overview

Package prodconcollect handles collection of Consumer and Producer metric data

Index

• func ConsumerWorker(consumerChan <-chan *args.JMXHost, wg *sync.WaitGroup, ...)
• func FeedWorkerPool(jmxHostChan chan<- *args.JMXHost, jmxHosts []*args.JMXHost)
• func ProducerWorker(producerChan <-chan *args.JMXHost, wg *sync.WaitGroup, ...)
• func StartWorkerPool(poolSize int, wg *sync.WaitGroup, integration *integration.Integration, ...) chan *args.JMXHost

Functions

func ConsumerWorker

func ConsumerWorker(consumerChan <-chan *args.JMXHost, wg *sync.WaitGroup, i *integration.Integration, collectedTopics []string)

ConsumerWorker collects information for consumers sent down the consumerChan

func FeedWorkerPool

func FeedWorkerPool(jmxHostChan chan<- *args.JMXHost, jmxHosts []*args.JMXHost)

FeedWorkerPool feeds the worker pool with jmxHost objects, which contain connection information for each producer/consumer to be collected

func ProducerWorker

func ProducerWorker(producerChan <-chan *args.JMXHost, wg *sync.WaitGroup, i *integration.Integration, collectedTopics []string)

ProducerWorker collect information for Producers sent down the producerChan

func StartWorkerPool

func StartWorkerPool(poolSize int, wg *sync.WaitGroup, integration *integration.Integration, collectedTopics []string,
	worker func(<-chan *args.JMXHost, *sync.WaitGroup, *integration.Integration, []string)) chan *args.JMXHost

StartWorkerPool starts a pool of workers to handle collecting data for wither Consumer or producer entities. The channel returned is to be closed by the user (or by feedWorkerPool)