v2testcsproto

Documentation

Index

• Variables
• func NewBenchmarkable(tb testing.TB, wr *base.WriteRequest) base.Benchmarkable
• type Sample
  • func (*Sample) Descriptor() ([]byte, []int)
  • func (x *Sample) GetTimestamp() int64
  • func (x *Sample) GetValue() float64
  • func (m *Sample) Marshal() ([]byte, error)
  • func (m *Sample) MarshalTo(dest []byte) error
  • func (*Sample) ProtoMessage()
  • func (x *Sample) ProtoReflect() protoreflect.Message
  • func (x *Sample) Reset()
  • func (m *Sample) Size() int
  • func (x *Sample) String() string
  • func (m *Sample) Unmarshal(p []byte) error
• type TimeSeries
  • func (*TimeSeries) Descriptor() ([]byte, []int)
  • func (x *TimeSeries) GetLabelSymbols() []uint32
  • func (x *TimeSeries) GetSamples() []*Sample
  • func (m *TimeSeries) Marshal() ([]byte, error)
  • func (m *TimeSeries) MarshalTo(dest []byte) error
  • func (*TimeSeries) ProtoMessage()
  • func (x *TimeSeries) ProtoReflect() protoreflect.Message
  • func (x *TimeSeries) Reset()
  • func (m *TimeSeries) Size() int
  • func (x *TimeSeries) String() string
  • func (m *TimeSeries) Unmarshal(p []byte) error
• type WriteRequest
  • func (*WriteRequest) Descriptor() ([]byte, []int)
  • func (x *WriteRequest) GetSymbols() []string
  • func (x *WriteRequest) GetTimeseries() []*TimeSeries
  • func (m *WriteRequest) Marshal() ([]byte, error)
  • func (m *WriteRequest) MarshalTo(dest []byte) error
  • func (*WriteRequest) ProtoMessage()
  • func (x *WriteRequest) ProtoReflect() protoreflect.Message
  • func (x *WriteRequest) Reset()
  • func (m *WriteRequest) Size() int
  • func (x *WriteRequest) String() string
  • func (m *WriteRequest) Unmarshal(p []byte) error

Variables

var File_prw_v2testcsproto_write_proto protoreflect.FileDescriptor

Functions

func NewBenchmarkable

func NewBenchmarkable(tb testing.TB, wr *base.WriteRequest) base.Benchmarkable

Types

type Sample

type Sample struct {
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	// timestamp is in ms format, see model/timestamp/timestamp.go for
	// conversion from time.Time to Prometheus timestamp.
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Sample) Descriptor

func (*Sample) Descriptor() ([]byte, []int)

Deprecated: Use Sample.ProtoReflect.Descriptor instead.

func (*Sample) GetTimestamp

func (x *Sample) GetTimestamp() int64

func (*Sample) GetValue

func (x *Sample) GetValue() float64

func (*Sample) Marshal

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

Marshal converts the contents of m to the Protobuf binary encoding and returns the result or an error.

func (*Sample) MarshalTo

func (m *Sample) MarshalTo(dest []byte) error

MarshalTo converts the contents of m to the Protobuf binary encoding and writes the result to dest.

func (*Sample) ProtoMessage

func (*Sample) ProtoMessage()

func (*Sample) ProtoReflect

func (x *Sample) ProtoReflect() protoreflect.Message

func (*Sample) Reset

func (x *Sample) Reset()

func (*Sample) Size

func (m *Sample) Size() int

Size calculates and returns the size, in bytes, required to hold the contents of m using the Protobuf binary encoding.

func (*Sample) String

func (x *Sample) String() string

func (*Sample) Unmarshal

func (m *Sample) Unmarshal(p []byte) error

Unmarshal decodes a binary encoded Protobuf message from p and populates m with the result.

type TimeSeries

type TimeSeries struct {

	// Sorted list of label name-value pair references. This list's len is always multiple of 2,
	// packing tuples of (label name ref, label value ref) refs to WriteRequests.symbols.
	LabelSymbols []uint32 `protobuf:"varint,1,rep,packed,name=label_symbols,json=labelSymbols,proto3" json:"label_symbols,omitempty"`
	// Sorted by time, oldest sample first.
	Samples []*Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"`
	// contains filtered or unexported fields
}

TimeSeries represents samples and labels for a single time series.

func (*TimeSeries) Descriptor

func (*TimeSeries) Descriptor() ([]byte, []int)

Deprecated: Use TimeSeries.ProtoReflect.Descriptor instead.

func (*TimeSeries) GetLabelSymbols

func (x *TimeSeries) GetLabelSymbols() []uint32

func (*TimeSeries) GetSamples

func (x *TimeSeries) GetSamples() []*Sample

func (*TimeSeries) Marshal

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

Marshal converts the contents of m to the Protobuf binary encoding and returns the result or an error.

func (*TimeSeries) MarshalTo

func (m *TimeSeries) MarshalTo(dest []byte) error

MarshalTo converts the contents of m to the Protobuf binary encoding and writes the result to dest.

func (*TimeSeries) ProtoMessage

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) ProtoReflect

func (x *TimeSeries) ProtoReflect() protoreflect.Message

func (*TimeSeries) Reset

func (x *TimeSeries) Reset()

func (*TimeSeries) Size

func (m *TimeSeries) Size() int

Size calculates and returns the size, in bytes, required to hold the contents of m using the Protobuf binary encoding.

func (*TimeSeries) String

func (x *TimeSeries) String() string

func (*TimeSeries) Unmarshal

func (m *TimeSeries) Unmarshal(p []byte) error

Unmarshal decodes a binary encoded Protobuf message from p and populates m with the result.

type WriteRequest

type WriteRequest struct {

	// The symbols table for all strings used in WriteRequest message.
	Symbols    []string      `protobuf:"bytes,1,rep,name=symbols,proto3" json:"symbols,omitempty"`
	Timeseries []*TimeSeries `protobuf:"bytes,2,rep,name=timeseries,proto3" json:"timeseries,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteRequest) Descriptor

func (*WriteRequest) Descriptor() ([]byte, []int)

Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.

func (*WriteRequest) GetSymbols

func (x *WriteRequest) GetSymbols() []string

func (*WriteRequest) GetTimeseries

func (x *WriteRequest) GetTimeseries() []*TimeSeries

func (*WriteRequest) Marshal

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

Marshal converts the contents of m to the Protobuf binary encoding and returns the result or an error.

func (*WriteRequest) MarshalTo

func (m *WriteRequest) MarshalTo(dest []byte) error

MarshalTo converts the contents of m to the Protobuf binary encoding and writes the result to dest.

func (*WriteRequest) ProtoMessage

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) ProtoReflect

func (x *WriteRequest) ProtoReflect() protoreflect.Message

func (*WriteRequest) Reset

func (x *WriteRequest) Reset()

func (*WriteRequest) Size

func (m *WriteRequest) Size() int

Size calculates and returns the size, in bytes, required to hold the contents of m using the Protobuf binary encoding.

func (*WriteRequest) String

func (x *WriteRequest) String() string

func (*WriteRequest) Unmarshal

func (m *WriteRequest) Unmarshal(p []byte) error

Unmarshal decodes a binary encoded Protobuf message from p and populates m with the result.