Versions in this module Expand all Collapse all v1 v1.20.0 Nov 10, 2025 GO-2024-3036 GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex 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 GO-2024-3036 GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex v1.20.0-rc.0 Oct 31, 2025 GO-2024-3036 GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex