test

Documentation

Index

• func Compress(wr WriteRequest) ([]byte, error)
• func PopulateTimeTpl(b []byte, tGlobal time.Time) []byte
• func PopulateTimeTplString(s string, t time.Time) string
• type Label
  • func (m *Label) Marshal() (dAtA []byte, err error)
  • func (m *Label) MarshalTo(dAtA []byte) (int, error)
  • func (m *Label) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Label) Reset()
  • func (m *Label) Size() (n int)
• type Labels
  • func (m *Labels) Marshal() (dAtA []byte, err error)
  • func (m *Labels) MarshalTo(dAtA []byte) (int, error)
  • func (m *Labels) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Labels) Reset()
  • func (m *Labels) Size() (n int)
• type Sample
  • func (m *Sample) Marshal() (dAtA []byte, err error)
  • func (m *Sample) MarshalTo(dAtA []byte) (int, error)
  • func (m *Sample) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Sample) Reset()
  • func (m *Sample) Size() (n int)
• type TimeSeries
  • func (m *TimeSeries) Marshal() (dAtA []byte, err error)
  • func (m *TimeSeries) MarshalTo(dAtA []byte) (int, error)
  • func (m *TimeSeries) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *TimeSeries) Reset()
  • func (m *TimeSeries) Size() (n int)
• type WriteRequest
  • func (m *WriteRequest) Marshal() (dAtA []byte, err error)
  • func (m *WriteRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *WriteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *WriteRequest) Size() (n int)

Functions

func Compress

func Compress(wr WriteRequest) ([]byte, error)

Compress marshals and compresses wr.

func PopulateTimeTpl

func PopulateTimeTpl(b []byte, tGlobal time.Time) []byte

PopulateTimeTpl substitutes {TIME_*} with tGlobal in b and returns the result.

func PopulateTimeTplString

func PopulateTimeTplString(s string, t time.Time) string

PopulateTimeTplString substitutes {TIME_*} with t in s and returns the result.

Types

type Label

type Label struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

Label is time series label.

func (*Label) Marshal

func (m *Label) Marshal() (dAtA []byte, err error)

Marshal marshals m.

func (*Label) MarshalTo

func (m *Label) MarshalTo(dAtA []byte) (int, error)

MarshalTo marshals m to dAtA.

func (*Label) MarshalToSizedBuffer

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

MarshalToSizedBuffer marshals m to dAtA.

func (*Label) Reset

func (m *Label) Reset()

Reset resets m.

func (*Label) Size

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

Size returns the size of marshaled m.

type Labels

type Labels struct {
	Labels []Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"`
}

Labels is a set of labels.

func (*Labels) Marshal

func (m *Labels) Marshal() (dAtA []byte, err error)

Marshal marshals m.

func (*Labels) MarshalTo

func (m *Labels) MarshalTo(dAtA []byte) (int, error)

MarshalTo marshals m to dAtA.

func (*Labels) MarshalToSizedBuffer

func (m *Labels) MarshalToSizedBuffer(dAtA []byte) (int, error)

MarshalToSizedBuffer marshals m to dAtA.

func (*Labels) Reset

func (m *Labels) Reset()

Reset resets m.

func (*Labels) Size

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

Size returns the size of marshaled m.

type Sample

type Sample struct {
	Value     float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp int64   `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

Sample is time series sample.

func (*Sample) Marshal

func (m *Sample) Marshal() (dAtA []byte, err error)

Marshal marshals m.

func (*Sample) MarshalTo

func (m *Sample) MarshalTo(dAtA []byte) (int, error)

MarshalTo marshals m to dAtA.

func (*Sample) MarshalToSizedBuffer

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

MarshalToSizedBuffer marshals m to dAtA.

func (*Sample) Reset

func (m *Sample) Reset()

Reset resets m.

func (*Sample) Size

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

Size returns the size of marshaled m.

type TimeSeries

type TimeSeries struct {
	Labels  []Label  `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"`
	Samples []Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples"`
}

TimeSeries represents samples and labels for a single time series.

func (*TimeSeries) Marshal

func (m *TimeSeries) Marshal() (dAtA []byte, err error)

Marshal marshals m.

func (*TimeSeries) MarshalTo

func (m *TimeSeries) MarshalTo(dAtA []byte) (int, error)

MarshalTo marshals m to dAtA.

func (*TimeSeries) MarshalToSizedBuffer

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

MarshalToSizedBuffer marshals m to dAtA.

func (*TimeSeries) Reset

func (m *TimeSeries) Reset()

Reset resets m.

func (*TimeSeries) Size

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

Size returns the size of marshaled m.

type WriteRequest

type WriteRequest struct {
	Timeseries []TimeSeries `protobuf:"bytes,1,rep,name=timeseries,proto3" json:"timeseries"`
}

WriteRequest is write request

func (*WriteRequest) Marshal

func (m *WriteRequest) Marshal() (dAtA []byte, err error)

Marshal marshals m.

func (*WriteRequest) MarshalTo

func (m *WriteRequest) MarshalTo(dAtA []byte) (int, error)

MarshalTo marshals m to dAtA

func (*WriteRequest) MarshalToSizedBuffer

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

MarshalToSizedBuffer marshals m to dAtA.

func (*WriteRequest) Size

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

Size returns m size in bytes after marshaling.