client

Documentation

Overview

Package client handles collection of Consumer and Producer client 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)

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)

ProducerWorker collect information for Producers sent down the producerChan

func StartWorkerPool

func StartWorkerPool(
	poolSize int,
	wg *sync.WaitGroup,
	integration *integration.Integration,
	worker func(<-chan *args.JMXHost, *sync.WaitGroup, *integration.Integration),
) 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)