event

package

v0.16.0 Latest Latest Go to latest Published: May 29, 2020 License: Apache-2.0 Imports: 5 Imported by: 3

Details

This section is empty.

This section is empty.

This section is empty.

type CounterEvent struct {
	CMetricName string
	CValue      float64
	CLabels     map[string]string
}

func (c *CounterEvent) Labels() map[string]string

func (c *CounterEvent) MetricName() string

func (c *CounterEvent) MetricType() mapper.MetricType

func (c *CounterEvent) Value() float64

type Event interface {
	MetricName() string
	Value() float64
	Labels() map[string]string
	MetricType() mapper.MetricType
}

type EventHandler interface {
	Queue(event Events)
}

type EventQueue struct {
	C chan Events
	// contains filtered or unexported fields
}

func NewEventQueue(c chan Events, flushThreshold int, flushInterval time.Duration, eventsFlushed prometheus.Counter) *EventQueue

func (eq *EventQueue) Flush()

func (eq *EventQueue) FlushUnlocked()

func (eq *EventQueue) Len() int

func (eq *EventQueue) Queue(events Events)

type Events []Event

type GaugeEvent struct {
	GMetricName string
	GValue      float64
	GRelative   bool
	GLabels     map[string]string
}

func (c *GaugeEvent) Labels() map[string]string

func (g *GaugeEvent) MetricName() string

func (c *GaugeEvent) MetricType() mapper.MetricType

func (g *GaugeEvent) Value() float64

type TimerEvent struct {
	TMetricName string
	TValue      float64
	TLabels     map[string]string
}

func (c *TimerEvent) Labels() map[string]string

func (t *TimerEvent) MetricName() string

func (c *TimerEvent) MetricType() mapper.MetricType

func (t *TimerEvent) Value() float64

type UnbufferedEventHandler struct {
	C chan Events
}

func (ueh *UnbufferedEventHandler) Queue(events Events)