emitters

Documentation

Index

• type CounterEmitter
  • func NewCounterEmitter(client *loggregator.IngressClient) *CounterEmitter
  • func (e CounterEmitter) EmitCounter() http.HandlerFunc
  • func (e CounterEmitter) SendCounter(counter CounterMetric)
• type CounterMetric
• type GaugeEmitter
  • func NewGaugeEmitter(client *loggregator.IngressClient) *GaugeEmitter
  • func (e GaugeEmitter) EmitGauge() http.HandlerFunc
  • func (e GaugeEmitter) SendGauge(gauge GaugeMetric)
• type GaugeMetric
• type GaugeValue
• type TimerEmitter
  • func NewTimerEmitter(client *loggregator.IngressClient) *TimerEmitter
  • func (e TimerEmitter) EmitTimer() http.HandlerFunc
  • func (e TimerEmitter) SendTimer(timer TimerMetric)
• type TimerMetric
• type TimerValue

Types

type CounterEmitter

type CounterEmitter struct {
	// contains filtered or unexported fields
}

func NewCounterEmitter

func NewCounterEmitter(client *loggregator.IngressClient) *CounterEmitter

func (CounterEmitter) EmitCounter

func (e CounterEmitter) EmitCounter() http.HandlerFunc

func (CounterEmitter) SendCounter

func (e CounterEmitter) SendCounter(counter CounterMetric)

type CounterMetric

type CounterMetric struct {
	Name       string            `json:"name"`
	SourceId   string            `json:"source_id"`
	InstanceId string            `json:"instance_id"`
	Tags       map[string]string `json:"tags"`
}

type GaugeEmitter

type GaugeEmitter struct {
	// contains filtered or unexported fields
}

func NewGaugeEmitter

func NewGaugeEmitter(client *loggregator.IngressClient) *GaugeEmitter

func (GaugeEmitter) EmitGauge

func (e GaugeEmitter) EmitGauge() http.HandlerFunc

func (GaugeEmitter) SendGauge

func (e GaugeEmitter) SendGauge(gauge GaugeMetric)

type GaugeMetric

type GaugeMetric struct {
	SourceId   string
	InstanceId string
	Tags       map[string]string
	Values     []GaugeValue
}

type GaugeValue

type GaugeValue struct {
	Name  string  `json:"name"`
	Value float64 `json:"value"`
	Unit  string  `json:"unit"`
}

type TimerEmitter

type TimerEmitter struct {
	// contains filtered or unexported fields
}

func NewTimerEmitter

func NewTimerEmitter(client *loggregator.IngressClient) *TimerEmitter

func (TimerEmitter) EmitTimer

func (e TimerEmitter) EmitTimer() http.HandlerFunc

func (TimerEmitter) SendTimer

func (e TimerEmitter) SendTimer(timer TimerMetric)

type TimerMetric

type TimerMetric struct {
	SourceId   string
	InstanceId string
	Tags       map[string]string
	Value      TimerValue
}

type TimerValue

type TimerValue struct {
	Name  string    `json:"name"`
	Start time.Time `json:"start"`
	End   time.Time `json:"end"`
}