Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
Processor extracts metrics from envelopes
func NewProcessor ¶
func NewProcessor( pm chan<- []metric.MetricPackage, customTags []string, environment string, parseAppMetricsEnable bool, cfClient *cloudfoundry.CFClient, numCacheWorkers int, grabInterval int, log *gosteno.Logger, ) (*Processor, bool)
NewProcessor creates a new processor
func (*Processor) ProcessMetric ¶
func (p *Processor) ProcessMetric(envelope *loggregator_v2.Envelope)
ProcessMetric takes an envelope, parses it and sends the processed metrics to the nozzle
func (*Processor) StopAppMetrics ¶
func (p *Processor) StopAppMetrics()
StopAppMetrics stops the goroutine refreshing the apps cache
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.