processor

Documentation

Index

• type Processor
  • func NewProcessor(pm chan<- []metric.MetricPackage, customTags []string, environment string, ...) (*Processor, bool)
  • func (p *Processor) ProcessMetric(envelope *loggregator_v2.Envelope)
  • func (p *Processor) StopAppMetrics()

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