Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type MessageMetrics ¶ added in v0.1.10
type MessageMetrics struct {
MessagesSent *prometheus.CounterVec
MessagesReceived *prometheus.CounterVec
MessagesSentBytes *prometheus.CounterVec
MessagesReceivedBytes *prometheus.CounterVec
}
MessageMetrics encapsulates the prometheus collectos used to record metrics about messages sent and received
func Message ¶ added in v0.1.10
func Message() MessageMetrics
Message returns the MessageMetrics for this firebolt application
type Metrics ¶
type Metrics struct {
AppMetricsPrefix string
// contains filtered or unexported fields
}
Metrics holds prometheus collectors for firebolt core, the configured source, and all configured nodes. This is managed as a singleton, do not create instances in your code. Use the Init() and Get() methods instead.
type NodeMetrics ¶
type NodeMetrics struct {
EventsReceived *prometheus.CounterVec
Successes *prometheus.CounterVec
Failures *prometheus.CounterVec
Filtered *prometheus.CounterVec
BufferedEvents *prometheus.GaugeVec
ProcessTime *prometheus.HistogramVec
DiscardedEvents *prometheus.CounterVec
BufferFullEvents *prometheus.CounterVec
}
NodeMetrics encapsulates the prometheus collectors used by firebolt to record metrics about each node
func Node ¶
func Node() NodeMetrics
Node returns the NodeMetrics for the node identified by 'nodeId'. If no metrics have been registered for this node they are lazy-initialized and returned.
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server is the HTTP server for prometheus metrics
type SourceMetrics ¶
type SourceMetrics struct {
EventsEmitted prometheus.Counter
}
SourceMetrics encapsulates the prometheus collectors used by firebolt to record metrics about the source
func Source ¶
func Source() SourceMetrics
Source returns the SourceMetrics for the configured source
Source Files