querierpb

package
v1.20.0 Latest Latest
Warning

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

 Go to latest Published: Nov 10, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthQuerier = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuerier   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterQuerierServer 

func RegisterQuerierServer(s *grpc.Server, srv QuerierServer)

Types

type Label 

type Label struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

Label represents a key-value pair for series metadata

func (*Label) Descriptor 

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

func (*Label) Equal 

func (this *Label) Equal(that interface{}) bool

func (*Label) GetName 

func (m *Label) GetName() string

func (*Label) GetValue 

func (m *Label) GetValue() string

func (*Label) GoString 

func (this *Label) GoString() string

func (*Label) Marshal 

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

func (*Label) MarshalTo 

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

func (*Label) MarshalToSizedBuffer 

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

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) Reset 

func (m *Label) Reset()

func (*Label) Size 

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

func (*Label) String 

func (this *Label) String() string

func (*Label) Unmarshal 

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

func (*Label) XXX_DiscardUnknown 

func (m *Label) XXX_DiscardUnknown()

func (*Label) XXX_Marshal 

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

func (*Label) XXX_Merge 

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

func (*Label) XXX_Size 

func (m *Label) XXX_Size() int

func (*Label) XXX_Unmarshal 

func (m *Label) XXX_Unmarshal(b []byte) error

type NextRequest 

type NextRequest struct {
	QueryID    uint64 `protobuf:"varint,1,opt,name=queryID,proto3" json:"queryID,omitempty"`
	FragmentID uint64 `protobuf:"varint,2,opt,name=fragmentID,proto3" json:"fragmentID,omitempty"`
	Batchsize  int64  `protobuf:"varint,3,opt,name=batchsize,proto3" json:"batchsize,omitempty"`
}

NextRequest contains parameters for data streaming

func (*NextRequest) Descriptor 

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

func (*NextRequest) Equal 

func (this *NextRequest) Equal(that interface{}) bool

func (*NextRequest) GetBatchsize 

func (m *NextRequest) GetBatchsize() int64

func (*NextRequest) GetFragmentID 

func (m *NextRequest) GetFragmentID() uint64

func (*NextRequest) GetQueryID 

func (m *NextRequest) GetQueryID() uint64

func (*NextRequest) GoString 

func (this *NextRequest) GoString() string

func (*NextRequest) Marshal 

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

func (*NextRequest) MarshalTo 

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

func (*NextRequest) MarshalToSizedBuffer 

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

func (*NextRequest) ProtoMessage 

func (*NextRequest) ProtoMessage()

func (*NextRequest) Reset 

func (m *NextRequest) Reset()

func (*NextRequest) Size 

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

func (*NextRequest) String 

func (this *NextRequest) String() string

func (*NextRequest) Unmarshal 

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

func (*NextRequest) XXX_DiscardUnknown 

func (m *NextRequest) XXX_DiscardUnknown()

func (*NextRequest) XXX_Marshal 

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

func (*NextRequest) XXX_Merge 

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

func (*NextRequest) XXX_Size 

func (m *NextRequest) XXX_Size() int

func (*NextRequest) XXX_Unmarshal 

func (m *NextRequest) XXX_Unmarshal(b []byte) error

type OneSeries 

type OneSeries struct {
	Labels []*Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
}

OneSeries represents a single time series with its labels Used to describe the shape of incoming data

func (*OneSeries) Descriptor 

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

func (*OneSeries) Equal 

func (this *OneSeries) Equal(that interface{}) bool

func (*OneSeries) GetLabels 

func (m *OneSeries) GetLabels() []*Label

func (*OneSeries) GoString 

func (this *OneSeries) GoString() string

func (*OneSeries) Marshal 

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

func (*OneSeries) MarshalTo 

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

func (*OneSeries) MarshalToSizedBuffer 

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

func (*OneSeries) ProtoMessage 

func (*OneSeries) ProtoMessage()

func (*OneSeries) Reset 

func (m *OneSeries) Reset()

func (*OneSeries) Size 

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

func (*OneSeries) String 

func (this *OneSeries) String() string

func (*OneSeries) Unmarshal 

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

func (*OneSeries) XXX_DiscardUnknown 

func (m *OneSeries) XXX_DiscardUnknown()

func (*OneSeries) XXX_Marshal 

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

func (*OneSeries) XXX_Merge 

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

func (*OneSeries) XXX_Size 

func (m *OneSeries) XXX_Size() int

func (*OneSeries) XXX_Unmarshal 

func (m *OneSeries) XXX_Unmarshal(b []byte) error

type QuerierClient 

type QuerierClient interface {
	Series(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (Querier_SeriesClient, error)
	Next(ctx context.Context, in *NextRequest, opts ...grpc.CallOption) (Querier_NextClient, error)
}

QuerierClient is the client API for Querier service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQuerierClient 

func NewQuerierClient(cc *grpc.ClientConn) QuerierClient

type QuerierServer 

type QuerierServer interface {
	Series(*SeriesRequest, Querier_SeriesServer) error
	Next(*NextRequest, Querier_NextServer) error
}

QuerierServer is the server API for Querier service.

type Querier_NextClient 

type Querier_NextClient interface {
	Recv() (*StepVectorBatch, error)
	grpc.ClientStream
}

type Querier_NextServer 

type Querier_NextServer interface {
	Send(*StepVectorBatch) error
	grpc.ServerStream
}

type Querier_SeriesClient 

type Querier_SeriesClient interface {
	Recv() (*SeriesBatch, error)
	grpc.ClientStream
}

type Querier_SeriesServer 

type Querier_SeriesServer interface {
	Send(*SeriesBatch) error
	grpc.ServerStream
}

type SeriesBatch 

type SeriesBatch struct {
	OneSeries []*OneSeries `protobuf:"bytes,1,rep,name=OneSeries,proto3" json:"OneSeries,omitempty"`
}

SeriesBatch contains a collection of series metadata

func (*SeriesBatch) Descriptor 

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

func (*SeriesBatch) Equal 

func (this *SeriesBatch) Equal(that interface{}) bool

func (*SeriesBatch) GetOneSeries 

func (m *SeriesBatch) GetOneSeries() []*OneSeries

func (*SeriesBatch) GoString 

func (this *SeriesBatch) GoString() string

func (*SeriesBatch) Marshal 

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

func (*SeriesBatch) MarshalTo 

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

func (*SeriesBatch) MarshalToSizedBuffer 

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

func (*SeriesBatch) ProtoMessage 

func (*SeriesBatch) ProtoMessage()

func (*SeriesBatch) Reset 

func (m *SeriesBatch) Reset()

func (*SeriesBatch) Size 

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

func (*SeriesBatch) String 

func (this *SeriesBatch) String() string

func (*SeriesBatch) Unmarshal 

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

func (*SeriesBatch) XXX_DiscardUnknown 

func (m *SeriesBatch) XXX_DiscardUnknown()

func (*SeriesBatch) XXX_Marshal 

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

func (*SeriesBatch) XXX_Merge 

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

func (*SeriesBatch) XXX_Size 

func (m *SeriesBatch) XXX_Size() int

func (*SeriesBatch) XXX_Unmarshal 

func (m *SeriesBatch) XXX_Unmarshal(b []byte) error

type SeriesRequest 

type SeriesRequest struct {
	QueryID    uint64 `protobuf:"varint,1,opt,name=queryID,proto3" json:"queryID,omitempty"`
	FragmentID uint64 `protobuf:"varint,2,opt,name=fragmentID,proto3" json:"fragmentID,omitempty"`
	Batchsize  int64  `protobuf:"varint,3,opt,name=batchsize,proto3" json:"batchsize,omitempty"`
}

SeriesRequest contains parameters for series streaming

func (*SeriesRequest) Descriptor 

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

func (*SeriesRequest) Equal 

func (this *SeriesRequest) Equal(that interface{}) bool

func (*SeriesRequest) GetBatchsize 

func (m *SeriesRequest) GetBatchsize() int64

func (*SeriesRequest) GetFragmentID 

func (m *SeriesRequest) GetFragmentID() uint64

func (*SeriesRequest) GetQueryID 

func (m *SeriesRequest) GetQueryID() uint64

func (*SeriesRequest) GoString 

func (this *SeriesRequest) GoString() string

func (*SeriesRequest) Marshal 

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

func (*SeriesRequest) MarshalTo 

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

func (*SeriesRequest) MarshalToSizedBuffer 

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

func (*SeriesRequest) ProtoMessage 

func (*SeriesRequest) ProtoMessage()

func (*SeriesRequest) Reset 

func (m *SeriesRequest) Reset()

func (*SeriesRequest) Size 

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

func (*SeriesRequest) String 

func (this *SeriesRequest) String() string

func (*SeriesRequest) Unmarshal 

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

func (*SeriesRequest) XXX_DiscardUnknown 

func (m *SeriesRequest) XXX_DiscardUnknown()

func (*SeriesRequest) XXX_Marshal 

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

func (*SeriesRequest) XXX_Merge 

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

func (*SeriesRequest) XXX_Size 

func (m *SeriesRequest) XXX_Size() int

func (*SeriesRequest) XXX_Unmarshal 

func (m *SeriesRequest) XXX_Unmarshal(b []byte) error

type StepVector 

type StepVector struct {
	T             int64                `protobuf:"varint,1,opt,name=t,proto3" json:"t,omitempty"`
	Sample_IDs    []uint64             `protobuf:"varint,2,rep,packed,name=sample_IDs,json=sampleIDs,proto3" json:"sample_IDs,omitempty"`
	Samples       []float64            `protobuf:"fixed64,3,rep,packed,name=samples,proto3" json:"samples,omitempty"`
	Histogram_IDs []uint64             `protobuf:"varint,4,rep,packed,name=histogram_IDs,json=histogramIDs,proto3" json:"histogram_IDs,omitempty"`
	Histograms    []cortexpb.Histogram `protobuf:"bytes,5,rep,name=histograms,proto3" json:"histograms"`
}

StepVector represents data points at a specific timestamp

func (*StepVector) Descriptor 

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

func (*StepVector) Equal 

func (this *StepVector) Equal(that interface{}) bool

func (*StepVector) GetHistogram_IDs 

func (m *StepVector) GetHistogram_IDs() []uint64

func (*StepVector) GetHistograms 

func (m *StepVector) GetHistograms() []cortexpb.Histogram

func (*StepVector) GetSample_IDs 

func (m *StepVector) GetSample_IDs() []uint64

func (*StepVector) GetSamples 

func (m *StepVector) GetSamples() []float64

func (*StepVector) GetT 

func (m *StepVector) GetT() int64

func (*StepVector) GoString 

func (this *StepVector) GoString() string

func (*StepVector) Marshal 

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

func (*StepVector) MarshalTo 

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

func (*StepVector) MarshalToSizedBuffer 

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

func (*StepVector) ProtoMessage 

func (*StepVector) ProtoMessage()

func (*StepVector) Reset 

func (m *StepVector) Reset()

func (*StepVector) Size 

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

func (*StepVector) String 

func (this *StepVector) String() string

func (*StepVector) Unmarshal 

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

func (*StepVector) XXX_DiscardUnknown 

func (m *StepVector) XXX_DiscardUnknown()

func (*StepVector) XXX_Marshal 

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

func (*StepVector) XXX_Merge 

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

func (*StepVector) XXX_Size 

func (m *StepVector) XXX_Size() int

func (*StepVector) XXX_Unmarshal 

func (m *StepVector) XXX_Unmarshal(b []byte) error

type StepVectorBatch 

type StepVectorBatch struct {
	StepVectors []*StepVector `protobuf:"bytes,1,rep,name=step_vectors,json=stepVectors,proto3" json:"step_vectors,omitempty"`
}

StepVectorBatch contains a collection of step vectors

func (*StepVectorBatch) Descriptor 

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

func (*StepVectorBatch) Equal 

func (this *StepVectorBatch) Equal(that interface{}) bool

func (*StepVectorBatch) GetStepVectors 

func (m *StepVectorBatch) GetStepVectors() []*StepVector

func (*StepVectorBatch) GoString 

func (this *StepVectorBatch) GoString() string

func (*StepVectorBatch) Marshal 

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

func (*StepVectorBatch) MarshalTo 

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

func (*StepVectorBatch) MarshalToSizedBuffer 

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

func (*StepVectorBatch) ProtoMessage 

func (*StepVectorBatch) ProtoMessage()

func (*StepVectorBatch) Reset 

func (m *StepVectorBatch) Reset()

func (*StepVectorBatch) Size 

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

func (*StepVectorBatch) String 

func (this *StepVectorBatch) String() string

func (*StepVectorBatch) Unmarshal 

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

func (*StepVectorBatch) XXX_DiscardUnknown 

func (m *StepVectorBatch) XXX_DiscardUnknown()

func (*StepVectorBatch) XXX_Marshal 

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

func (*StepVectorBatch) XXX_Merge 

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

func (*StepVectorBatch) XXX_Size 

func (m *StepVectorBatch) XXX_Size() int

func (*StepVectorBatch) XXX_Unmarshal 

func (m *StepVectorBatch) XXX_Unmarshal(b []byte) error

type UnimplementedQuerierServer 

type UnimplementedQuerierServer struct {
}

UnimplementedQuerierServer can be embedded to have forward compatible implementations.

func (*UnimplementedQuerierServer) Next 

func (*UnimplementedQuerierServer) Next(req *NextRequest, srv Querier_NextServer) error

func (*UnimplementedQuerierServer) Series 

func (*UnimplementedQuerierServer) Series(req *SeriesRequest, srv Querier_SeriesServer) 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.