Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

querierpb

package

Go to main page

Versions in this module

v1

v1.21.0-rc.1

Apr 18, 2026

v1.21.0-rc.0

Mar 13, 2026

v1.20.1

Dec 3, 2025

v1.20.0

Nov 10, 2025

Changes in this version

+ var ErrIntOverflowQuerier = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthQuerier = fmt.Errorf("proto: negative length found during unmarshaling")

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

+ type Label struct

+ Name string

+ Value string

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

+ func (*Label) ProtoMessage()

+ func (m *Label) GetName() string

+ func (m *Label) GetValue() string

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

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

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

+ func (m *Label) Reset()

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

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

+ func (m *Label) XXX_DiscardUnknown()

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

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

+ func (m *Label) XXX_Size() int

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

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

+ func (this *Label) GoString() string

+ func (this *Label) String() string

+ type NextRequest struct

+ Batchsize int64

+ FragmentID uint64

+ QueryID uint64

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

+ func (*NextRequest) ProtoMessage()

+ func (m *NextRequest) GetBatchsize() int64

+ func (m *NextRequest) GetFragmentID() uint64

+ func (m *NextRequest) GetQueryID() uint64

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

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

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

+ func (m *NextRequest) Reset()

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

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

+ func (m *NextRequest) XXX_DiscardUnknown()

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

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

+ func (m *NextRequest) XXX_Size() int

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

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

+ func (this *NextRequest) GoString() string

+ func (this *NextRequest) String() string

+ type OneSeries struct

+ Labels []*Label

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

+ func (*OneSeries) ProtoMessage()

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

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

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

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

+ func (m *OneSeries) Reset()

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

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

+ func (m *OneSeries) XXX_DiscardUnknown()

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

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

+ func (m *OneSeries) XXX_Size() int

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

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

+ func (this *OneSeries) GoString() string

+ func (this *OneSeries) String() string

+ type QuerierClient interface

+ Next func(ctx context.Context, in *NextRequest, opts ...grpc.CallOption) (Querier_NextClient, error)

+ Series func(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (Querier_SeriesClient, error)

+ func NewQuerierClient(cc *grpc.ClientConn) QuerierClient

+ type QuerierServer interface

+ Next func(*NextRequest, Querier_NextServer) error

+ Series func(*SeriesRequest, Querier_SeriesServer) error

+ type Querier_NextClient interface

+ Recv func() (*StepVectorBatch, error)

+ type Querier_NextServer interface

+ Send func(*StepVectorBatch) error

+ type Querier_SeriesClient interface

+ Recv func() (*SeriesBatch, error)

+ type Querier_SeriesServer interface

+ Send func(*SeriesBatch) error

+ type SeriesBatch struct

+ OneSeries []*OneSeries

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

+ func (*SeriesBatch) ProtoMessage()

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

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

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

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

+ func (m *SeriesBatch) Reset()

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

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

+ func (m *SeriesBatch) XXX_DiscardUnknown()

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

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

+ func (m *SeriesBatch) XXX_Size() int

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

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

+ func (this *SeriesBatch) GoString() string

+ func (this *SeriesBatch) String() string

+ type SeriesRequest struct

+ Batchsize int64

+ FragmentID uint64

+ QueryID uint64

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

+ func (*SeriesRequest) ProtoMessage()

+ func (m *SeriesRequest) GetBatchsize() int64

+ func (m *SeriesRequest) GetFragmentID() uint64

+ func (m *SeriesRequest) GetQueryID() uint64

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

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

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

+ func (m *SeriesRequest) Reset()

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

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

+ func (m *SeriesRequest) XXX_DiscardUnknown()

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

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

+ func (m *SeriesRequest) XXX_Size() int

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

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

+ func (this *SeriesRequest) GoString() string

+ func (this *SeriesRequest) String() string

+ type StepVector struct

+ Histogram_IDs []uint64

+ Histograms []cortexpb.Histogram

+ Sample_IDs []uint64

+ Samples []float64

+ T int64

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

+ func (*StepVector) ProtoMessage()

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

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

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

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

+ func (m *StepVector) GetT() int64

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

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

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

+ func (m *StepVector) Reset()

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

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

+ func (m *StepVector) XXX_DiscardUnknown()

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

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

+ func (m *StepVector) XXX_Size() int

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

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

+ func (this *StepVector) GoString() string

+ func (this *StepVector) String() string

+ type StepVectorBatch struct

+ StepVectors []*StepVector

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

+ func (*StepVectorBatch) ProtoMessage()

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

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

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

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

+ func (m *StepVectorBatch) Reset()

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

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

+ func (m *StepVectorBatch) XXX_DiscardUnknown()

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

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

+ func (m *StepVectorBatch) XXX_Size() int

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

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

+ func (this *StepVectorBatch) GoString() string

+ func (this *StepVectorBatch) String() string

+ type UnimplementedQuerierServer struct

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

+ func (*UnimplementedQuerierServer) Series(req *SeriesRequest, srv Querier_SeriesServer) error

v1.20.0-rc.1

Nov 4, 2025

v1.20.0-rc.0

Oct 31, 2025