v2testgogo

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: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthWrite        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWrite          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWrite = fmt.Errorf("proto: unexpected end of group")
)

Functions

func NewBenchmarkable 

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

func NewOptimizedBenchmarkable 

func NewOptimizedBenchmarkable(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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Sample) Descriptor 

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

func (*Sample) GetTimestamp 

func (m *Sample) GetTimestamp() int64

func (*Sample) GetValue 

func (m *Sample) GetValue() float64

func (*Sample) Marshal 

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

func (*Sample) MarshalTo 

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

func (*Sample) MarshalToSizedBuffer 

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

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) Reset 

func (m *Sample) Reset()

func (*Sample) Size 

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

func (*Sample) String 

func (m *Sample) String() string

func (*Sample) Unmarshal 

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

func (*Sample) XXX_DiscardUnknown 

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal 

func (m *Sample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Sample) XXX_Merge 

func (m *Sample) XXX_Merge(src proto.Message)

func (*Sample) XXX_Size 

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal 

func (m *Sample) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TimeSeries represents samples and labels for a single time series.

func (*TimeSeries) Descriptor 

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

func (*TimeSeries) GetLabelSymbols 

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

func (*TimeSeries) GetSamples 

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

func (*TimeSeries) Marshal 

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

func (*TimeSeries) MarshalTo 

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

func (*TimeSeries) MarshalToSizedBuffer 

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

func (*TimeSeries) OptimizedMarshalToSizedBuffer 

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

func (*TimeSeries) ProtoMessage 

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) Reset 

func (m *TimeSeries) Reset()

func (*TimeSeries) Size 

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

func (*TimeSeries) String 

func (m *TimeSeries) String() string

func (*TimeSeries) Unmarshal 

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

func (*TimeSeries) XXX_DiscardUnknown 

func (m *TimeSeries) XXX_DiscardUnknown()

func (*TimeSeries) XXX_Marshal 

func (m *TimeSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeSeries) XXX_Merge 

func (m *TimeSeries) XXX_Merge(src proto.Message)

func (*TimeSeries) XXX_Size 

func (m *TimeSeries) XXX_Size() int

func (*TimeSeries) XXX_Unmarshal 

func (m *TimeSeries) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetSymbols 

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

func (*WriteRequest) GetTimeseries 

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

func (*WriteRequest) Marshal 

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

func (*WriteRequest) MarshalTo 

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

func (*WriteRequest) MarshalToSizedBuffer 

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

func (*WriteRequest) OptimizedMarshal 

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

OptimizedMarshal is an optimized marshal to avoid extra allocs: github.com/bwplotka/go-proto-bench/prw/v2testgogo.(*TimeSeries).MarshalToSizedBuffer /Users/bwplotka/Repos/go-proto-bench/prw/v2testgogo/write.pb.go (allocs) 

Total:   328529070  328529070 (flat, cum) 99.55%
  313            .          .           			i--
  314            .          .           			dAtA[i] = 0x12
  315            .          .           		}
  316            .          .           	}
  317            .          .           	if len(m.LabelSymbols) > 0 {
  318    328529070  328529070           		dAtA2 := make([]byte, len(m.LabelSymbols)*10)
  319            .          .           		var j1 int
  320            .          .           		for _, num := range m.LabelSymbols {
  321            .          .           			for num >= 1<<7 {
  322            .          .           				dAtA2[j1] = uint8(uint64(num)&0x7f | 0x80)
  323            .          .           				num >>= 7

func (*WriteRequest) OptimizedMarshalToSizedBuffer 

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

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) Size 

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

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) Unmarshal 

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

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteRequest) XXX_Merge 

func (m *WriteRequest) XXX_Merge(src proto.Message)

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

func (m *WriteRequest) XXX_Unmarshal(b []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.