receive

Documentation

Overview

Package prompb is a generated protocol buffer package.

It is generated from these files:

remote.proto

It has these top-level messages:

ReadRequest
ReadResponse
Query
QueryResult
Sample
TimeSeries
Label
LabelMatcher

Index

• Variables
• type Appendable
• type PartialTimeSeries
  • func (m *PartialTimeSeries) Unmarshal(dAtA []byte) error
  • func (m *PartialTimeSeries) UnmarshalLabels() error
• type PartialWriteRequest
  • func (m *PartialWriteRequest) Unmarshal(dAtA []byte) error
• type Receiver
  • func NewReceiver(logger log.Logger, app Appendable) *Receiver
  • func (r *Receiver) Receive(wreq *PartialWriteRequest) error

Variables

var (
	ErrInvalidLengthRemote = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRemote   = fmt.Errorf("proto: integer overflow")
)

Types

type Appendable

type Appendable interface {
	Appender() (storage.Appender, error)
}

Appendable returns an Appender.

type PartialTimeSeries

type PartialTimeSeries struct {
	LabelBytes [][]byte
	Labels     []prompb.Label  `protobuf:"bytes,1,rep,name=labels" json:"labels"`
	Samples    []prompb.Sample `protobuf:"bytes,2,rep,name=samples" json:"samples"`
}

func (*PartialTimeSeries) Unmarshal

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

func (*PartialTimeSeries) UnmarshalLabels

func (m *PartialTimeSeries) UnmarshalLabels() error

type PartialWriteRequest

type PartialWriteRequest struct {
	Timeseries []*PartialTimeSeries `protobuf:"bytes,1,rep,name=timeseries" json:"timeseries,omitempty"`
}

func (*PartialWriteRequest) Unmarshal

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

type Receiver

type Receiver struct {
	// contains filtered or unexported fields
}

func NewReceiver

func NewReceiver(logger log.Logger, app Appendable) *Receiver

func (*Receiver) Receive

func (r *Receiver) Receive(wreq *PartialWriteRequest) error