Documentation
¶
Overview ¶
Package extraction decodes Prometheus clients' data streams for consumers.
Index ¶
Constants ¶
This section is empty.
Variables ¶
var MetricFamilyProcessor = &metricFamilyProcessor{}
MetricFamilyProcessor decodes varint encoded record length-delimited streams of io.prometheus.client.MetricFamily.
See http://godoc.org/github.com/matttproud/golang_protobuf_extensions/ext for more details.
var Processor001 = &processor001{}
Processor001 is responsible for decoding payloads from protocol version 0.0.1.
var Processor002 = &processor002{}
Processor002 is responsible for decoding payloads from protocol version 0.0.2.
var Processor004 = &processor004{}
Processor004 s responsible for decoding payloads from the text based variety of protocol version 0.0.4.
Functions ¶
This section is empty.
Types ¶
type ProcessOptions ¶
type ProcessOptions struct {
// Timestamp is added to each value from the stream that has no explicit
// timestamp set.
Timestamp model.Timestamp
}
ProcessOptions dictates how the interpreted stream should be rendered for consumption.
type Processor ¶
type Processor interface {
// ProcessSingle treats the input as a single self-contained message body and
// transforms it accordingly. It has no support for streaming.
ProcessSingle(in io.Reader, out Ingester, o *ProcessOptions) error
}
Processor is responsible for decoding the actual message responses from stream into a format that can be consumed with the end result written to the results channel.
Notes ¶
Bugs ¶
Update other names to "quantile".
Source Files