Documentation ¶
Index ¶
- Variables
- func NewBenchmarkable(tb testing.TB, wr *base.WriteRequest) base.Benchmarkable
- type Sample
- func (m *Sample) CloneMessageVT() proto.Message
- func (m *Sample) CloneVT() *Sample
- func (*Sample) Descriptor() ([]byte, []int)deprecated
- func (x *Sample) GetTimestamp() int64
- func (x *Sample) GetValue() float64
- func (m *Sample) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Sample) MarshalToVT(dAtA []byte) (int, error)
- func (m *Sample) MarshalVT() (dAtA []byte, err error)
- func (*Sample) ProtoMessage()
- func (x *Sample) ProtoReflect() protoreflect.Message
- func (x *Sample) Reset()
- func (m *Sample) SizeVT() (n int)
- func (x *Sample) String() string
- func (m *Sample) UnmarshalVT(dAtA []byte) error
- func (m *Sample) UnmarshalVTUnsafe(dAtA []byte) error
- type TimeSeries
- func (m *TimeSeries) CloneMessageVT() proto.Message
- func (m *TimeSeries) CloneVT() *TimeSeries
- func (*TimeSeries) Descriptor() ([]byte, []int)deprecated
- func (x *TimeSeries) GetLabelSymbols() []uint32
- func (x *TimeSeries) GetSamples() []*Sample
- func (m *TimeSeries) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TimeSeries) MarshalToVT(dAtA []byte) (int, error)
- func (m *TimeSeries) MarshalVT() (dAtA []byte, err error)
- func (*TimeSeries) ProtoMessage()
- func (x *TimeSeries) ProtoReflect() protoreflect.Message
- func (x *TimeSeries) Reset()
- func (m *TimeSeries) SizeVT() (n int)
- func (x *TimeSeries) String() string
- func (m *TimeSeries) UnmarshalVT(dAtA []byte) error
- func (m *TimeSeries) UnmarshalVTUnsafe(dAtA []byte) error
- type WriteRequest
- func (m *WriteRequest) CloneMessageVT() proto.Message
- func (m *WriteRequest) CloneVT() *WriteRequest
- func (*WriteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WriteRequest) GetSymbols() []string
- func (x *WriteRequest) GetTimeseries() []*TimeSeries
- func (m *WriteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *WriteRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *WriteRequest) MarshalVT() (dAtA []byte, err error)
- func (*WriteRequest) ProtoMessage()
- func (x *WriteRequest) ProtoReflect() protoreflect.Message
- func (x *WriteRequest) Reset()
- func (x *WriteRequest) Size() int
- func (m *WriteRequest) SizeVT() (n int)
- func (x *WriteRequest) String() string
- func (m *WriteRequest) UnmarshalVT(dAtA []byte) error
- func (m *WriteRequest) UnmarshalVTUnsafe(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflow = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") )
View Source
var File_prw_v2testvtproto_write_proto protoreflect.FileDescriptor
Functions ¶
func NewBenchmarkable ¶
func NewBenchmarkable(tb testing.TB, wr *base.WriteRequest) base.Benchmarkable
TODO(bwplotka): Try with pooling
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) CloneMessageVT ¶
func (*Sample) Descriptor
deprecated
func (*Sample) GetTimestamp ¶
func (*Sample) MarshalToSizedBufferVT ¶
func (*Sample) ProtoMessage ¶
func (*Sample) ProtoMessage()
func (*Sample) ProtoReflect ¶
func (x *Sample) ProtoReflect() protoreflect.Message
func (*Sample) UnmarshalVT ¶
func (*Sample) UnmarshalVTUnsafe ¶
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) CloneMessageVT ¶
func (m *TimeSeries) CloneMessageVT() proto.Message
func (*TimeSeries) CloneVT ¶
func (m *TimeSeries) CloneVT() *TimeSeries
func (*TimeSeries) Descriptor
deprecated
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) MarshalToSizedBufferVT ¶
func (m *TimeSeries) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*TimeSeries) MarshalToVT ¶
func (m *TimeSeries) MarshalToVT(dAtA []byte) (int, error)
func (*TimeSeries) MarshalVT ¶
func (m *TimeSeries) MarshalVT() (dAtA []byte, err error)
func (*TimeSeries) ProtoMessage ¶
func (*TimeSeries) ProtoMessage()
func (*TimeSeries) ProtoReflect ¶
func (x *TimeSeries) ProtoReflect() protoreflect.Message
func (*TimeSeries) Reset ¶
func (x *TimeSeries) Reset()
func (*TimeSeries) SizeVT ¶
func (m *TimeSeries) SizeVT() (n int)
func (*TimeSeries) String ¶
func (x *TimeSeries) String() string
func (*TimeSeries) UnmarshalVT ¶
func (m *TimeSeries) UnmarshalVT(dAtA []byte) error
func (*TimeSeries) UnmarshalVTUnsafe ¶
func (m *TimeSeries) UnmarshalVTUnsafe(dAtA []byte) error
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) CloneMessageVT ¶
func (m *WriteRequest) CloneMessageVT() proto.Message
func (*WriteRequest) CloneVT ¶
func (m *WriteRequest) CloneVT() *WriteRequest
func (*WriteRequest) Descriptor
deprecated
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) MarshalToSizedBufferVT ¶
func (m *WriteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*WriteRequest) MarshalToVT ¶
func (m *WriteRequest) MarshalToVT(dAtA []byte) (int, error)
func (*WriteRequest) MarshalVT ¶
func (m *WriteRequest) MarshalVT() (dAtA []byte, err error)
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 (x *WriteRequest) Size() int
func (*WriteRequest) SizeVT ¶
func (m *WriteRequest) SizeVT() (n int)
func (*WriteRequest) String ¶
func (x *WriteRequest) String() string
func (*WriteRequest) UnmarshalVT ¶
func (m *WriteRequest) UnmarshalVT(dAtA []byte) error
func (*WriteRequest) UnmarshalVTUnsafe ¶
func (m *WriteRequest) UnmarshalVTUnsafe(dAtA []byte) error
Click to show internal directories.
Click to hide internal directories.