event

Documentation

Index

• type CounterEvent
  • 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
• type EventHandler
• type EventQueue
  • func NewEventQueue(c chan Events, flushThreshold int, flushInterval time.Duration, ...) *EventQueue
  • func (eq *EventQueue) Flush()
  • func (eq *EventQueue) FlushUnlocked()
  • func (eq *EventQueue) Len() int
  • func (eq *EventQueue) Queue(events Events)
• type Events
• type GaugeEvent
  • func (g *GaugeEvent) Labels() map[string]string
  • func (g *GaugeEvent) MetricName() string
  • func (g *GaugeEvent) MetricType() mapper.MetricType
  • func (g *GaugeEvent) Value() float64
• type ObserverEvent
  • func (o *ObserverEvent) Labels() map[string]string
  • func (o *ObserverEvent) MetricName() string
  • func (o *ObserverEvent) MetricType() mapper.MetricType
  • func (o *ObserverEvent) Value() float64
• type UnbufferedEventHandler
  • func (ueh *UnbufferedEventHandler) Queue(events Events)

Types

type CounterEvent

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

func (*CounterEvent) Labels

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

func (*CounterEvent) MetricName

func (c *CounterEvent) MetricName() string

func (*CounterEvent) MetricType

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

func (*CounterEvent) Value

func (c *CounterEvent) Value() float64

type Event

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

type EventHandler

type EventHandler interface {
	Queue(event Events)
}

type EventQueue

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

func NewEventQueue

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

func (*EventQueue) Flush

func (eq *EventQueue) Flush()

func (*EventQueue) FlushUnlocked

func (eq *EventQueue) FlushUnlocked()

func (*EventQueue) Len

func (eq *EventQueue) Len() int

func (*EventQueue) Queue

func (eq *EventQueue) Queue(events Events)

type Events

type Events []Event

type GaugeEvent

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

func (*GaugeEvent) Labels

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

func (*GaugeEvent) MetricName

func (g *GaugeEvent) MetricName() string

func (*GaugeEvent) MetricType

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

func (*GaugeEvent) Value

func (g *GaugeEvent) Value() float64

type ObserverEvent

type ObserverEvent struct {
	OMetricName string
	OValue      float64
	OLabels     map[string]string
}

func (*ObserverEvent) Labels

func (o *ObserverEvent) Labels() map[string]string

func (*ObserverEvent) MetricName

func (o *ObserverEvent) MetricName() string

func (*ObserverEvent) MetricType

func (o *ObserverEvent) MetricType() mapper.MetricType

func (*ObserverEvent) Value

func (o *ObserverEvent) Value() float64

type UnbufferedEventHandler

type UnbufferedEventHandler struct {
	C chan Events
}

func (*UnbufferedEventHandler) Queue

func (ueh *UnbufferedEventHandler) Queue(events Events)