v2testvtproto

package
v0.0.0-...-3e95e29 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 29, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

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 (m *Sample) CloneMessageVT() proto.Message

func (*Sample) CloneVT 

func (m *Sample) CloneVT() *Sample

func (*Sample) Descriptor deprecated 

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) MarshalToSizedBufferVT 

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

func (*Sample) MarshalToVT 

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

func (*Sample) MarshalVT 

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

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) ProtoReflect 

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

func (*Sample) Reset 

func (x *Sample) Reset()

func (*Sample) SizeVT 

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

func (*Sample) String 

func (x *Sample) String() string

func (*Sample) UnmarshalVT 

func (m *Sample) UnmarshalVT(dAtA []byte) error

func (*Sample) UnmarshalVTUnsafe 

func (m *Sample) UnmarshalVTUnsafe(dAtA []byte) error

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.