prometheus

Documentation

Index

• func ParseStream(r io.Reader, defaultTimestamp int64, isGzipped bool, ...) error
• type Row
• type Rows
  • func (rs *Rows) Reset()
  • func (rs *Rows) Unmarshal(s string)
  • func (rs *Rows) UnmarshalWithErrLogger(s string, errLogger func(s string))
• type Tag

Functions

func ParseStream

func ParseStream(r io.Reader, defaultTimestamp int64, isGzipped bool, callback func(rows []Row) error) error

ParseStream parses lines with Prometheus exposition format from r and calls callback for the parsed rows.

The callback can be called concurrently multiple times for streamed data from r. It is guaranteed that the callback isn't called after ParseStream returns.

callback shouldn't hold rows after returning.

Types

type Row

type Row struct {
	Metric    string
	Tags      []Tag
	Value     float64
	Timestamp int64
}

Row is a single Prometheus row.

type Rows

type Rows struct {
	Rows []Row
	// contains filtered or unexported fields
}

Rows contains parsed Prometheus rows.

func (*Rows) Reset

func (rs *Rows) Reset()

Reset resets rs.

func (*Rows) Unmarshal

func (rs *Rows) Unmarshal(s string)

Unmarshal unmarshals Prometheus exposition text rows from s.

See https://github.com/prometheus/docs/blob/master/content/docs/instrumenting/exposition_formats.md#text-format-details

s shouldn't be modified while rs is in use.

func (*Rows) UnmarshalWithErrLogger

func (rs *Rows) UnmarshalWithErrLogger(s string, errLogger func(s string))

UnmarshalWithErrLogger unmarshal Prometheus exposition text rows from s.

It calls errLogger for logging parsing errors.

s shouldn't be modified while rs is in use.

type Tag

type Tag struct {
	Key   string
	Value string
}

Tag is a Prometheus tag.