processors

Documentation

Index

• type ContainerMetricProcessor
  • func NewContainerMetricProcessor() *ContainerMetricProcessor
  • func (p *ContainerMetricProcessor) Process(e *events.Envelope) []metrics.Metric
  • func (p *ContainerMetricProcessor) ProcessContainerMetricCPU(e *events.ContainerMetric) metrics.GaugeMetric
  • func (p *ContainerMetricProcessor) ProcessContainerMetricDisk(e *events.ContainerMetric) metrics.GaugeMetric
  • func (p *ContainerMetricProcessor) ProcessContainerMetricMemory(e *events.ContainerMetric) metrics.GaugeMetric
• type CounterProcessor
  • func NewCounterProcessor() *CounterProcessor
  • func (p *CounterProcessor) Process(e *events.Envelope) []metrics.Metric
  • func (p *CounterProcessor) ProcessCounter(event *events.CounterEvent) *metrics.CounterMetric
• type HeartbeatProcessor
  • func NewHeartbeatProcessor() *HeartbeatProcessor
  • func (p *HeartbeatProcessor) Process(e *events.Envelope) []metrics.Metric
  • func (p *HeartbeatProcessor) ProcessHeartbeatCount(e *events.Heartbeat, origin string) *metrics.CounterMetric
  • func (p *HeartbeatProcessor) ProcessHeartbeatEventsErrorCount(e *events.Heartbeat, origin string) *metrics.GaugeMetric
  • func (p *HeartbeatProcessor) ProcessHeartbeatEventsReceivedCount(e *events.Heartbeat, origin string) *metrics.GaugeMetric
  • func (p *HeartbeatProcessor) ProcessHeartbeatEventsSentCount(e *events.Heartbeat, origin string) *metrics.GaugeMetric
• type HttpStartStopProcessor
  • func NewHttpStartStopProcessor() *HttpStartStopProcessor
  • func (p *HttpStartStopProcessor) Process(e *events.Envelope) []metrics.Metric
  • func (p *HttpStartStopProcessor) ProcessHttpStartStopHttpErrorCount(event *events.HttpStartStop) *metrics.CounterMetric
  • func (p *HttpStartStopProcessor) ProcessHttpStartStopHttpRequestCount(event *events.HttpStartStop) *metrics.CounterMetric
  • func (p *HttpStartStopProcessor) ProcessHttpStartStopResponseTime(event *events.HttpStartStop) *metrics.TimingMetric
  • func (p *HttpStartStopProcessor) ProcessHttpStartStopStatusCodeCount(event *events.HttpStartStop) *metrics.CounterMetric
• type Processor
• type ValueMetricProcessor
  • func NewValueMetricProcessor() *ValueMetricProcessor
  • func (p *ValueMetricProcessor) Process(e *events.Envelope) []metrics.Metric
  • func (p *ValueMetricProcessor) ProcessValueMetric(event *events.ValueMetric, origin string) *metrics.FGaugeMetric

Types

type ContainerMetricProcessor

type ContainerMetricProcessor struct{}

func NewContainerMetricProcessor

func NewContainerMetricProcessor() *ContainerMetricProcessor

func (*ContainerMetricProcessor) Process

func (p *ContainerMetricProcessor) Process(e *events.Envelope) []metrics.Metric

func (*ContainerMetricProcessor) ProcessContainerMetricCPU

func (p *ContainerMetricProcessor) ProcessContainerMetricCPU(e *events.ContainerMetric) metrics.GaugeMetric

func (*ContainerMetricProcessor) ProcessContainerMetricDisk

func (p *ContainerMetricProcessor) ProcessContainerMetricDisk(e *events.ContainerMetric) metrics.GaugeMetric

func (*ContainerMetricProcessor) ProcessContainerMetricMemory

func (p *ContainerMetricProcessor) ProcessContainerMetricMemory(e *events.ContainerMetric) metrics.GaugeMetric

type CounterProcessor

type CounterProcessor struct{}

func NewCounterProcessor

func NewCounterProcessor() *CounterProcessor

func (*CounterProcessor) Process

func (p *CounterProcessor) Process(e *events.Envelope) []metrics.Metric

func (*CounterProcessor) ProcessCounter

func (p *CounterProcessor) ProcessCounter(event *events.CounterEvent) *metrics.CounterMetric

type HeartbeatProcessor

type HeartbeatProcessor struct{}

func NewHeartbeatProcessor

func NewHeartbeatProcessor() *HeartbeatProcessor

func (*HeartbeatProcessor) Process

func (p *HeartbeatProcessor) Process(e *events.Envelope) []metrics.Metric

func (*HeartbeatProcessor) ProcessHeartbeatCount

func (p *HeartbeatProcessor) ProcessHeartbeatCount(e *events.Heartbeat, origin string) *metrics.CounterMetric

func (*HeartbeatProcessor) ProcessHeartbeatEventsErrorCount

func (p *HeartbeatProcessor) ProcessHeartbeatEventsErrorCount(e *events.Heartbeat, origin string) *metrics.GaugeMetric

func (*HeartbeatProcessor) ProcessHeartbeatEventsReceivedCount

func (p *HeartbeatProcessor) ProcessHeartbeatEventsReceivedCount(e *events.Heartbeat, origin string) *metrics.GaugeMetric

func (*HeartbeatProcessor) ProcessHeartbeatEventsSentCount

func (p *HeartbeatProcessor) ProcessHeartbeatEventsSentCount(e *events.Heartbeat, origin string) *metrics.GaugeMetric

type HttpStartStopProcessor

type HttpStartStopProcessor struct{}

func NewHttpStartStopProcessor

func NewHttpStartStopProcessor() *HttpStartStopProcessor

func (*HttpStartStopProcessor) Process

func (p *HttpStartStopProcessor) Process(e *events.Envelope) []metrics.Metric

func (*HttpStartStopProcessor) ProcessHttpStartStopHttpErrorCount

func (p *HttpStartStopProcessor) ProcessHttpStartStopHttpErrorCount(event *events.HttpStartStop) *metrics.CounterMetric

func (*HttpStartStopProcessor) ProcessHttpStartStopHttpRequestCount

func (p *HttpStartStopProcessor) ProcessHttpStartStopHttpRequestCount(event *events.HttpStartStop) *metrics.CounterMetric

func (*HttpStartStopProcessor) ProcessHttpStartStopResponseTime

func (p *HttpStartStopProcessor) ProcessHttpStartStopResponseTime(event *events.HttpStartStop) *metrics.TimingMetric

func (*HttpStartStopProcessor) ProcessHttpStartStopStatusCodeCount

func (p *HttpStartStopProcessor) ProcessHttpStartStopStatusCodeCount(event *events.HttpStartStop) *metrics.CounterMetric

type Processor

type Processor interface {
	Process(e *events.Envelope) []metrics.Metric
}

type ValueMetricProcessor

type ValueMetricProcessor struct{}

func NewValueMetricProcessor

func NewValueMetricProcessor() *ValueMetricProcessor

func (*ValueMetricProcessor) Process

func (p *ValueMetricProcessor) Process(e *events.Envelope) []metrics.Metric

func (*ValueMetricProcessor) ProcessValueMetric

func (p *ValueMetricProcessor) ProcessValueMetric(event *events.ValueMetric, origin string) *metrics.FGaugeMetric