prompbmarshal

Documentation

Index

• type Label
  • func (m *Label) MarshalToSizedBuffer(dst []byte) (int, error)
  • func (m *Label) Size() (n int)
• type Sample
  • func (m *Sample) MarshalToSizedBuffer(dst []byte) (int, error)
  • func (m *Sample) Size() (n int)
• type TimeSeries
  • func MustParsePromMetrics(s string, offsetMsecs int64) []TimeSeries
  • func ResetTimeSeries(tss []TimeSeries) []TimeSeries
  • func (m *TimeSeries) MarshalToSizedBuffer(dst []byte) (int, error)
  • func (m *TimeSeries) Size() (n int)
• type WriteRequest
  • func (wr *WriteRequest) MarshalProtobuf(dst []byte) []byte
  • func (m *WriteRequest) MarshalToSizedBuffer(dst []byte) (int, error)
  • func (wr *WriteRequest) Reset()
  • func (m *WriteRequest) Size() (n int)

Types

type Label

type Label struct {
	Name  string
	Value string
}

func (*Label) MarshalToSizedBuffer

func (m *Label) MarshalToSizedBuffer(dst []byte) (int, error)

func (*Label) Size

func (m *Label) Size() (n int)

type Sample

type Sample struct {
	Value     float64
	Timestamp int64
}

func (*Sample) MarshalToSizedBuffer

func (m *Sample) MarshalToSizedBuffer(dst []byte) (int, error)

func (*Sample) Size

func (m *Sample) Size() (n int)

type TimeSeries

type TimeSeries struct {
	Labels  []Label
	Samples []Sample
}

TimeSeries represents samples and labels for a single time series.

func MustParsePromMetrics

func MustParsePromMetrics(s string, offsetMsecs int64) []TimeSeries

MustParsePromMetrics parses metrics in Prometheus text exposition format from s and returns them.

Metrics must be delimited with newlines.

offsetMsecs is added to every timestamp in parsed metrics.

This function is for testing purposes only. Do not use it in non-test code.

func ResetTimeSeries

func ResetTimeSeries(tss []TimeSeries) []TimeSeries

ResetTimeSeries clears all the GC references from tss and returns an empty tss ready for further use.

func (*TimeSeries) MarshalToSizedBuffer

func (m *TimeSeries) MarshalToSizedBuffer(dst []byte) (int, error)

func (*TimeSeries) Size

func (m *TimeSeries) Size() (n int)

type WriteRequest

type WriteRequest struct {
	Timeseries []TimeSeries
}

func (*WriteRequest) MarshalProtobuf

func (wr *WriteRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf marshals wr to dst and returns the result.

func (*WriteRequest) MarshalToSizedBuffer

func (m *WriteRequest) MarshalToSizedBuffer(dst []byte) (int, error)

func (*WriteRequest) Reset

func (wr *WriteRequest) Reset()

Reset resets wr.

func (*WriteRequest) Size

func (m *WriteRequest) Size() (n int)