client

Oct 15, 2024 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Sep 3, 2024 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ func MatrixFromSeriesSet(set storage.SeriesSet) (model.Matrix, error)

+ type ClosableClientConn interface

+ Close func() error

type Config

+ MaxInflightPushRequests int64

type LabelNamesRequest

+ Limit int64

+ func (m *LabelNamesRequest) GetLimit() int64

type LabelValuesRequest

+ Limit int64

+ func (m *LabelValuesRequest) GetLimit() int64

type MetricsForLabelMatchersRequest

+ Limit int64

+ func (m *MetricsForLabelMatchersRequest) GetLimit() int64

type QueryResponse

+ func SeriesSetToQueryResponse(s storage.SeriesSet) (*QueryResponse, error)

Aug 16, 2024 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

May 21, 2024 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 30, 2024 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 28, 2024 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 25, 2024 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 24, 2024 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 19, 2023 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 16, 2023 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 9, 2023 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 23, 2023 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

May 10, 2023 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 27, 2023 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 19, 2023 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

type HealthAndIngesterClient

+ PushPreAlloc func(ctx context.Context, in *cortexpb.PreallocWriteRequest, ...) (*cortexpb.WriteResponse, error)

type QueryStreamResponse

+ func (m *QueryStreamResponse) SamplesCount() (count int)

type UserStatsResponse

+ ActiveSeries uint64

+ func (m *UserStatsResponse) GetActiveSeries() uint64

Apr 11, 2023 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 1, 2023 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 27, 2023 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Dec 18, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Dec 2, 2022 GO-2022-1175 +1 more

  GO-2022-1175: Exposure of local files in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 19, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 16, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Dec 18, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 4, 2022 GO-2022-1175 +1 more

  GO-2022-1175: Exposure of local files in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jul 15, 2022 GO-2022-1175 +1 more

  GO-2022-1175: Exposure of local files in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ func SendAsBatchToStream(totalItems int, streamBatchSize int, fn func(start, end int) error) error

+ func SendLabelNamesStream(s Ingester_LabelNamesStreamServer, l *LabelNamesStreamResponse) error

+ func SendLabelValuesStream(s Ingester_LabelValuesStreamServer, l *LabelValuesStreamResponse) error

+ func SendMetricsForLabelMatchersStream(s Ingester_MetricsForLabelMatchersStreamServer, ...) error

type IngesterClient

+ LabelNamesStream func(ctx context.Context, in *LabelNamesRequest, opts ...grpc.CallOption) (Ingester_LabelNamesStreamClient, error)

+ LabelValuesStream func(ctx context.Context, in *LabelValuesRequest, opts ...grpc.CallOption) (Ingester_LabelValuesStreamClient, error)

+ MetricsForLabelMatchersStream func(ctx context.Context, in *MetricsForLabelMatchersRequest, ...) (Ingester_MetricsForLabelMatchersStreamClient, error)

type IngesterServer

+ LabelNamesStream func(*LabelNamesRequest, Ingester_LabelNamesStreamServer) error

+ LabelValuesStream func(*LabelValuesRequest, Ingester_LabelValuesStreamServer) error

+ MetricsForLabelMatchersStream func(*MetricsForLabelMatchersRequest, Ingester_MetricsForLabelMatchersStreamServer) error

+ type Ingester_LabelNamesStreamClient interface

+ Recv func() (*LabelNamesStreamResponse, error)

+ type Ingester_LabelNamesStreamServer interface

+ Send func(*LabelNamesStreamResponse) error

+ type Ingester_LabelValuesStreamClient interface

+ Recv func() (*LabelValuesStreamResponse, error)

+ type Ingester_LabelValuesStreamServer interface

+ Send func(*LabelValuesStreamResponse) error

+ type Ingester_MetricsForLabelMatchersStreamClient interface

+ Recv func() (*MetricsForLabelMatchersStreamResponse, error)

+ type Ingester_MetricsForLabelMatchersStreamServer interface

+ Send func(*MetricsForLabelMatchersStreamResponse) error

+ type LabelNamesStreamResponse struct

+ LabelNames []string

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

+ func (*LabelNamesStreamResponse) ProtoMessage()

+ func (m *LabelNamesStreamResponse) GetLabelNames() []string

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

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

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

+ func (m *LabelNamesStreamResponse) Reset()

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

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

+ func (m *LabelNamesStreamResponse) XXX_DiscardUnknown()

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

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

+ func (m *LabelNamesStreamResponse) XXX_Size() int

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

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

+ func (this *LabelNamesStreamResponse) GoString() string

+ func (this *LabelNamesStreamResponse) String() string

+ type LabelValuesStreamResponse struct

+ LabelValues []string

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

+ func (*LabelValuesStreamResponse) ProtoMessage()

+ func (m *LabelValuesStreamResponse) GetLabelValues() []string

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

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

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

+ func (m *LabelValuesStreamResponse) Reset()

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

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

+ func (m *LabelValuesStreamResponse) XXX_DiscardUnknown()

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

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

+ func (m *LabelValuesStreamResponse) XXX_Size() int

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

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

+ func (this *LabelValuesStreamResponse) GoString() string

+ func (this *LabelValuesStreamResponse) String() string

+ type MetricsForLabelMatchersStreamResponse struct

+ Metric []*cortexpb.Metric

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

+ func (*MetricsForLabelMatchersStreamResponse) ProtoMessage()

+ func (m *MetricsForLabelMatchersStreamResponse) GetMetric() []*cortexpb.Metric

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

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

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

+ func (m *MetricsForLabelMatchersStreamResponse) Reset()

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

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

+ func (m *MetricsForLabelMatchersStreamResponse) XXX_DiscardUnknown()

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

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

+ func (m *MetricsForLabelMatchersStreamResponse) XXX_Size() int

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

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

+ func (this *MetricsForLabelMatchersStreamResponse) GoString() string

+ func (this *MetricsForLabelMatchersStreamResponse) String() string

type UnimplementedIngesterServer

+ func (*UnimplementedIngesterServer) LabelNamesStream(req *LabelNamesRequest, srv Ingester_LabelNamesStreamServer) error

+ func (*UnimplementedIngesterServer) LabelValuesStream(req *LabelValuesRequest, srv Ingester_LabelValuesStreamServer) error

+ func (*UnimplementedIngesterServer) MetricsForLabelMatchersStream(req *MetricsForLabelMatchersRequest, ...) error

Jul 6, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 23, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 17, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 8, 2022 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 25, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 4, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 4, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 3, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ func FromExemplarQueryRequest(req *ExemplarQueryRequest) (int64, int64, [][]*labels.Matcher, error)

+ func FromLabelMatchers(matchers []*LabelMatcher) ([]*labels.Matcher, error)

+ type ExemplarQueryRequest struct

+ EndTimestampMs int64

+ Matchers []*LabelMatchers

+ StartTimestampMs int64

+ func ToExemplarQueryRequest(from, to model.Time, matchers ...[]*labels.Matcher) (*ExemplarQueryRequest, error)

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

+ func (*ExemplarQueryRequest) ProtoMessage()

+ func (m *ExemplarQueryRequest) GetEndTimestampMs() int64

+ func (m *ExemplarQueryRequest) GetMatchers() []*LabelMatchers

+ func (m *ExemplarQueryRequest) GetStartTimestampMs() int64

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

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

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

+ func (m *ExemplarQueryRequest) Reset()

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

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

+ func (m *ExemplarQueryRequest) XXX_DiscardUnknown()

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

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

+ func (m *ExemplarQueryRequest) XXX_Size() int

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

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

+ func (this *ExemplarQueryRequest) GoString() string

+ func (this *ExemplarQueryRequest) String() string

+ type ExemplarQueryResponse struct

+ Timeseries []cortexpb.TimeSeries

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

+ func (*ExemplarQueryResponse) ProtoMessage()

+ func (m *ExemplarQueryResponse) GetTimeseries() []cortexpb.TimeSeries

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

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

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

+ func (m *ExemplarQueryResponse) Reset()

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

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

+ func (m *ExemplarQueryResponse) XXX_DiscardUnknown()

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

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

+ func (m *ExemplarQueryResponse) XXX_Size() int

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

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

+ func (this *ExemplarQueryResponse) GoString() string

+ func (this *ExemplarQueryResponse) String() string

type IngesterClient

+ QueryExemplars func(ctx context.Context, in *ExemplarQueryRequest, opts ...grpc.CallOption) (*ExemplarQueryResponse, error)

type IngesterServer

+ QueryExemplars func(context.Context, *ExemplarQueryRequest) (*ExemplarQueryResponse, error)

type QueryStreamResponse

+ func (m *QueryStreamResponse) ChunksCount() int

+ func (m *QueryStreamResponse) ChunksSize() int

type UnimplementedIngesterServer

+ func (*UnimplementedIngesterServer) QueryExemplars(ctx context.Context, req *ExemplarQueryRequest) (*ExemplarQueryResponse, error)

Jul 21, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 29, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

May 14, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 29, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 19, 2021 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 25, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

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

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

+ func FromLabelValuesRequest(req *LabelValuesRequest) (string, int64, int64, []*labels.Matcher, error)

type LabelValuesRequest

+ Matchers *LabelMatchers

+ func ToLabelValuesRequest(labelName model.LabelName, from, to model.Time, matchers []*labels.Matcher) (*LabelValuesRequest, error)

+ func (m *LabelValuesRequest) GetMatchers() *LabelMatchers

Mar 15, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 8, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 19, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Feb 23, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Feb 19, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Feb 14, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jan 21, 2021 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Dec 29, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

type LabelNamesRequest

+ EndTimestampMs int64

+ StartTimestampMs int64

+ func (m *LabelNamesRequest) GetEndTimestampMs() int64

+ func (m *LabelNamesRequest) GetStartTimestampMs() int64

type LabelValuesRequest

+ EndTimestampMs int64

+ StartTimestampMs int64

+ func (m *LabelValuesRequest) GetEndTimestampMs() int64

+ func (m *LabelValuesRequest) GetStartTimestampMs() int64

type MetricMetadata

+ MetricFamilyName string

+ func (m *MetricMetadata) GetMetricFamilyName() string

Dec 19, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Dec 9, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 9, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ func CopyLabels(input []labels.Label) labels.Labels

Oct 29, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Nov 3, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 29, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 2, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ func LabelsToKeyString(l labels.Labels) string

Sep 22, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Sep 16, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 21, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ func HashAdd32a(h uint32, s string) uint32

+ func HashAddByte32a(h uint32, b byte) uint32

+ func HashNew32a() uint32

type Config

+ func (cfg *Config) Validate(log log.Logger) error

Aug 17, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 10, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 5, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jul 1, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 26, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 24, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

May 21, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ var MetricMetadata_MetricType_name = map[int32]string

+ var MetricMetadata_MetricType_value = map[string]int32

+ func HashAddByte32(h uint32, b byte) uint32

+ func MetricMetadataMetricTypeToMetricType(mt MetricMetadata_MetricType) textparse.MetricType

type IngesterClient

+ MetricsMetadata func(ctx context.Context, in *MetricsMetadataRequest, opts ...grpc.CallOption) (*MetricsMetadataResponse, error)

type IngesterServer

+ MetricsMetadata func(context.Context, *MetricsMetadataRequest) (*MetricsMetadataResponse, error)

+ type MetricMetadata struct

+ Help string

+ MetricName string

+ Type MetricMetadata_MetricType

+ Unit string

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

+ func (*MetricMetadata) ProtoMessage()

+ func (m *MetricMetadata) GetHelp() string

+ func (m *MetricMetadata) GetMetricName() string

+ func (m *MetricMetadata) GetType() MetricMetadata_MetricType

+ func (m *MetricMetadata) GetUnit() string

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

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

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

+ func (m *MetricMetadata) Reset()

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

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

+ func (m *MetricMetadata) XXX_DiscardUnknown()

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

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

+ func (m *MetricMetadata) XXX_Size() int

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

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

+ func (this *MetricMetadata) GoString() string

+ func (this *MetricMetadata) String() string

+ type MetricMetadata_MetricType int32

+ const COUNTER

+ const GAUGE

+ const GAUGEHISTOGRAM

+ const HISTOGRAM

+ const INFO

+ const STATESET

+ const SUMMARY

+ const UNKNOWN

+ func (MetricMetadata_MetricType) EnumDescriptor() ([]byte, []int)

+ func (x MetricMetadata_MetricType) String() string

+ type MetricsMetadataRequest struct

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

+ func (*MetricsMetadataRequest) ProtoMessage()

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

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

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

+ func (m *MetricsMetadataRequest) Reset()

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

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

+ func (m *MetricsMetadataRequest) XXX_DiscardUnknown()

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

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

+ func (m *MetricsMetadataRequest) XXX_Size() int

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

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

+ func (this *MetricsMetadataRequest) GoString() string

+ func (this *MetricsMetadataRequest) String() string

+ type MetricsMetadataResponse struct

+ Metadata []*MetricMetadata

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

+ func (*MetricsMetadataResponse) ProtoMessage()

+ func (m *MetricsMetadataResponse) GetMetadata() []*MetricMetadata

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

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

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

+ func (m *MetricsMetadataResponse) Reset()

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

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

+ func (m *MetricsMetadataResponse) XXX_DiscardUnknown()

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

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

+ func (m *MetricsMetadataResponse) XXX_Size() int

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

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

+ func (this *MetricsMetadataResponse) GoString() string

+ func (this *MetricsMetadataResponse) String() string

type UnimplementedIngesterServer

+ func (*UnimplementedIngesterServer) MetricsMetadata(ctx context.Context, req *MetricsMetadataRequest) (*MetricsMetadataResponse, error)

type WriteRequest

+ Metadata []*MetricMetadata

+ func (m *WriteRequest) GetMetadata() []*MetricMetadata

May 13, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 23, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Apr 2, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ func SendQueryStream(s Ingester_QueryStreamServer, m *QueryStreamResponse) error

+ func SendTimeSeriesChunk(s Ingester_TransferChunksClient, m *TimeSeriesChunk) error

+ func SendTimeSeriesFile(s Ingester_TransferTSDBClient, m *TimeSeriesFile) error

Mar 31, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Mar 16, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

type Chunk

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

type LabelAdapter

+ func (bs *LabelAdapter) MarshalToSizedBuffer(buf []byte) (n int, err error)

type LabelMatcher

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

type LabelMatchers

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

type LabelNamesRequest

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

type LabelNamesResponse

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

type LabelPair

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

type LabelValuesRequest

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

type LabelValuesResponse

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

type Metric

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

type MetricsForLabelMatchersRequest

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

type MetricsForLabelMatchersResponse

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

type QueryRequest

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

type QueryResponse

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

type QueryStreamResponse

+ Chunkseries []TimeSeriesChunk

+ func (m *QueryStreamResponse) GetChunkseries() []TimeSeriesChunk

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

type ReadRequest

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

type ReadResponse

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

type Sample

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

type TimeSeries

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

type TimeSeriesChunk

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

type TimeSeriesFile

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

type TransferChunksResponse

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

type TransferTSDBResponse

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

+ type UnimplementedIngesterServer struct

+ func (*UnimplementedIngesterServer) AllUserStats(ctx context.Context, req *UserStatsRequest) (*UsersStatsResponse, error)

+ func (*UnimplementedIngesterServer) LabelNames(ctx context.Context, req *LabelNamesRequest) (*LabelNamesResponse, error)

+ func (*UnimplementedIngesterServer) LabelValues(ctx context.Context, req *LabelValuesRequest) (*LabelValuesResponse, error)

+ func (*UnimplementedIngesterServer) MetricsForLabelMatchers(ctx context.Context, req *MetricsForLabelMatchersRequest) (*MetricsForLabelMatchersResponse, error)

+ func (*UnimplementedIngesterServer) Push(ctx context.Context, req *WriteRequest) (*WriteResponse, error)

+ func (*UnimplementedIngesterServer) Query(ctx context.Context, req *QueryRequest) (*QueryResponse, error)

+ func (*UnimplementedIngesterServer) QueryStream(req *QueryRequest, srv Ingester_QueryStreamServer) error

+ func (*UnimplementedIngesterServer) TransferChunks(srv Ingester_TransferChunksServer) error

+ func (*UnimplementedIngesterServer) TransferTSDB(srv Ingester_TransferTSDBServer) error

+ func (*UnimplementedIngesterServer) UserStats(ctx context.Context, req *UserStatsRequest) (*UserStatsResponse, error)

type UserIDStatsResponse

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

type UserStatsRequest

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

type UserStatsResponse

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

type UsersStatsResponse

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

type WriteRequest

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

type WriteResponse

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

Mar 9, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Feb 5, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jan 28, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ func FromLabelAdaptersToLabelsWithCopy(input []LabelAdapter) labels.Labels

Jan 22, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jan 15, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jan 8, 2020 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Dec 2, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

type IngesterClient

+ TransferTSDB func(ctx context.Context, opts ...grpc.CallOption) (Ingester_TransferTSDBClient, error)

type IngesterServer

+ TransferTSDB func(Ingester_TransferTSDBServer) error

+ type Ingester_TransferTSDBClient interface

+ CloseAndRecv func() (*TransferTSDBResponse, error)

+ Send func(*TimeSeriesFile) error

+ type Ingester_TransferTSDBServer interface

+ Recv func() (*TimeSeriesFile, error)

+ SendAndClose func(*TransferTSDBResponse) error

+ type TimeSeriesFile struct

+ Data []byte

+ Filename string

+ FromIngesterId string

+ UserId string

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

+ func (*TimeSeriesFile) ProtoMessage()

+ func (m *TimeSeriesFile) GetData() []byte

+ func (m *TimeSeriesFile) GetFilename() string

+ func (m *TimeSeriesFile) GetFromIngesterId() string

+ func (m *TimeSeriesFile) GetUserId() string

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

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

+ func (m *TimeSeriesFile) Reset()

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

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

+ func (m *TimeSeriesFile) XXX_DiscardUnknown()

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

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

+ func (m *TimeSeriesFile) XXX_Size() int

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

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

+ func (this *TimeSeriesFile) GoString() string

+ func (this *TimeSeriesFile) String() string

+ type TransferTSDBResponse struct

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

+ func (*TransferTSDBResponse) ProtoMessage()

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

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

+ func (m *TransferTSDBResponse) Reset()

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

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

+ func (m *TransferTSDBResponse) XXX_DiscardUnknown()

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

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

+ func (m *TransferTSDBResponse) XXX_Size() int

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

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

+ func (this *TransferTSDBResponse) GoString() string

+ func (this *TransferTSDBResponse) String() string

Nov 17, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Oct 11, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

type LabelAdapter

+ func FromLabelsToLabelAdapters(ls labels.Labels) []LabelAdapter

Oct 3, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Sep 5, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ func ReuseSlice(slice []PreallocTimeseries)

+ func ReuseTimeseries(ts TimeSeries)

Aug 30, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 7, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

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

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

+ var MatchType_name = map[int32]string

+ var MatchType_value = map[string]int32

+ var WriteRequest_SourceEnum_name = map[int32]string

+ var WriteRequest_SourceEnum_value = map[string]int32

+ func FastFingerprint(ls []LabelAdapter) model.Fingerprint

+ func Fingerprint(labels labels.Labels) model.Fingerprint

+ func FromLabelAdaptersToLabels(ls []LabelAdapter) labels.Labels

+ func FromLabelAdaptersToMetric(ls []LabelAdapter) model.Metric

+ func FromMetricsForLabelMatchersRequest(req *MetricsForLabelMatchersRequest) (model.Time, model.Time, [][]*labels.Matcher, error)

+ func FromMetricsForLabelMatchersResponse(resp *MetricsForLabelMatchersResponse) []model.Metric

+ func FromQueryRequest(req *QueryRequest) (model.Time, model.Time, []*labels.Matcher, error)

+ func FromQueryResponse(resp *QueryResponse) model.Matrix

+ func HashAdd32(h uint32, s string) uint32

+ func HashNew32() uint32

+ func RegisterIngesterServer(s *grpc.Server, srv IngesterServer)

+ type Chunk struct

+ Data []byte

+ Encoding int32

+ EndTimestampMs int64

+ StartTimestampMs int64

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

+ func (*Chunk) ProtoMessage()

+ func (m *Chunk) GetData() []byte

+ func (m *Chunk) GetEncoding() int32

+ func (m *Chunk) GetEndTimestampMs() int64

+ func (m *Chunk) GetStartTimestampMs() int64

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

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

+ func (m *Chunk) Reset()

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

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

+ func (m *Chunk) XXX_DiscardUnknown()

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

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

+ func (m *Chunk) XXX_Size() int

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

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

+ func (this *Chunk) GoString() string

+ func (this *Chunk) String() string

+ type Config struct

+ GRPCClientConfig grpcclient.Config

+ func (cfg *Config) RegisterFlags(f *flag.FlagSet)

+ type Factory func(addr string) (grpc_health_v1.HealthClient, error)

+ type HealthAndIngesterClient interface

+ Close func() error

+ func MakeIngesterClient(addr string, cfg Config) (HealthAndIngesterClient, error)

+ type IngesterClient interface

+ AllUserStats func(ctx context.Context, in *UserStatsRequest, opts ...grpc.CallOption) (*UsersStatsResponse, error)

+ LabelNames func(ctx context.Context, in *LabelNamesRequest, opts ...grpc.CallOption) (*LabelNamesResponse, error)

+ LabelValues func(ctx context.Context, in *LabelValuesRequest, opts ...grpc.CallOption) (*LabelValuesResponse, error)

+ MetricsForLabelMatchers func(ctx context.Context, in *MetricsForLabelMatchersRequest, ...) (*MetricsForLabelMatchersResponse, error)

+ Push func(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)

+ Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)

+ QueryStream func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Ingester_QueryStreamClient, error)

+ TransferChunks func(ctx context.Context, opts ...grpc.CallOption) (Ingester_TransferChunksClient, error)

+ UserStats func(ctx context.Context, in *UserStatsRequest, opts ...grpc.CallOption) (*UserStatsResponse, error)

+ func NewIngesterClient(cc *grpc.ClientConn) IngesterClient

+ type IngesterServer interface

+ AllUserStats func(context.Context, *UserStatsRequest) (*UsersStatsResponse, error)

+ LabelNames func(context.Context, *LabelNamesRequest) (*LabelNamesResponse, error)

+ LabelValues func(context.Context, *LabelValuesRequest) (*LabelValuesResponse, error)

+ MetricsForLabelMatchers func(context.Context, *MetricsForLabelMatchersRequest) (*MetricsForLabelMatchersResponse, error)

+ Push func(context.Context, *WriteRequest) (*WriteResponse, error)

+ Query func(context.Context, *QueryRequest) (*QueryResponse, error)

+ QueryStream func(*QueryRequest, Ingester_QueryStreamServer) error

+ TransferChunks func(Ingester_TransferChunksServer) error

+ UserStats func(context.Context, *UserStatsRequest) (*UserStatsResponse, error)

+ type Ingester_QueryStreamClient interface

+ Recv func() (*QueryStreamResponse, error)

+ type Ingester_QueryStreamServer interface

+ Send func(*QueryStreamResponse) error

+ type Ingester_TransferChunksClient interface

+ CloseAndRecv func() (*TransferChunksResponse, error)

+ Send func(*TimeSeriesChunk) error

+ type Ingester_TransferChunksServer interface

+ Recv func() (*TimeSeriesChunk, error)

+ SendAndClose func(*TransferChunksResponse) error

+ type LabelAdapter labels.Label

+ func FromLabelsToLabelAdapaters(ls labels.Labels) []LabelAdapter

+ func FromMetricsToLabelAdapters(metric model.Metric) []LabelAdapter

+ func (bs *LabelAdapter) Compare(other LabelAdapter) int

+ func (bs *LabelAdapter) Equal(other LabelAdapter) bool

+ func (bs *LabelAdapter) Marshal() ([]byte, error)

+ func (bs *LabelAdapter) MarshalTo(buf []byte) (n int, err error)

+ func (bs *LabelAdapter) Size() int

+ func (bs *LabelAdapter) Unmarshal(dAtA []byte) error

+ type LabelMatcher struct

+ Name string

+ Type MatchType

+ Value string

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

+ func (*LabelMatcher) ProtoMessage()

+ func (m *LabelMatcher) GetName() string

+ func (m *LabelMatcher) GetType() MatchType

+ func (m *LabelMatcher) GetValue() string

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

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

+ func (m *LabelMatcher) Reset()

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

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

+ func (m *LabelMatcher) XXX_DiscardUnknown()

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

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

+ func (m *LabelMatcher) XXX_Size() int

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

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

+ func (this *LabelMatcher) GoString() string

+ func (this *LabelMatcher) String() string

+ type LabelMatchers struct

+ Matchers []*LabelMatcher

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

+ func (*LabelMatchers) ProtoMessage()

+ func (m *LabelMatchers) GetMatchers() []*LabelMatcher

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

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

+ func (m *LabelMatchers) Reset()

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

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

+ func (m *LabelMatchers) XXX_DiscardUnknown()

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

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

+ func (m *LabelMatchers) XXX_Size() int

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

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

+ func (this *LabelMatchers) GoString() string

+ func (this *LabelMatchers) String() string

+ type LabelNamesRequest struct

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

+ func (*LabelNamesRequest) ProtoMessage()

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

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

+ func (m *LabelNamesRequest) Reset()

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

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

+ func (m *LabelNamesRequest) XXX_DiscardUnknown()

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

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

+ func (m *LabelNamesRequest) XXX_Size() int

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

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

+ func (this *LabelNamesRequest) GoString() string

+ func (this *LabelNamesRequest) String() string

+ type LabelNamesResponse struct

+ LabelNames []string

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

+ func (*LabelNamesResponse) ProtoMessage()

+ func (m *LabelNamesResponse) GetLabelNames() []string

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

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

+ func (m *LabelNamesResponse) Reset()

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

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

+ func (m *LabelNamesResponse) XXX_DiscardUnknown()

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

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

+ func (m *LabelNamesResponse) XXX_Size() int

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

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

+ func (this *LabelNamesResponse) GoString() string

+ func (this *LabelNamesResponse) String() string

+ type LabelPair struct

+ Name []byte

+ Value []byte

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

+ func (*LabelPair) ProtoMessage()

+ func (m *LabelPair) GetName() []byte

+ func (m *LabelPair) GetValue() []byte

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

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

+ func (m *LabelPair) Reset()

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

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

+ func (m *LabelPair) XXX_DiscardUnknown()

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

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

+ func (m *LabelPair) XXX_Size() int

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

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

+ func (this *LabelPair) GoString() string

+ func (this *LabelPair) String() string

+ type LabelValuesRequest struct

+ LabelName string

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

+ func (*LabelValuesRequest) ProtoMessage()

+ func (m *LabelValuesRequest) GetLabelName() string

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

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

+ func (m *LabelValuesRequest) Reset()

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

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

+ func (m *LabelValuesRequest) XXX_DiscardUnknown()

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

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

+ func (m *LabelValuesRequest) XXX_Size() int

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

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

+ func (this *LabelValuesRequest) GoString() string

+ func (this *LabelValuesRequest) String() string

+ type LabelValuesResponse struct

+ LabelValues []string

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

+ func (*LabelValuesResponse) ProtoMessage()

+ func (m *LabelValuesResponse) GetLabelValues() []string

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

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

+ func (m *LabelValuesResponse) Reset()

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

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

+ func (m *LabelValuesResponse) XXX_DiscardUnknown()

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

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

+ func (m *LabelValuesResponse) XXX_Size() int

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

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

+ func (this *LabelValuesResponse) GoString() string

+ func (this *LabelValuesResponse) String() string

+ type MatchType int32

+ const EQUAL

+ const NOT_EQUAL

+ const REGEX_MATCH

+ const REGEX_NO_MATCH

+ func (MatchType) EnumDescriptor() ([]byte, []int)

+ func (x MatchType) String() string

+ type Metric struct

+ Labels []LabelAdapter

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

+ func (*Metric) ProtoMessage()

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

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

+ func (m *Metric) Reset()

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

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

+ func (m *Metric) XXX_DiscardUnknown()

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

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

+ func (m *Metric) XXX_Size() int

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

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

+ func (this *Metric) GoString() string

+ func (this *Metric) String() string

+ type MetricsForLabelMatchersRequest struct

+ EndTimestampMs int64

+ MatchersSet []*LabelMatchers

+ StartTimestampMs int64

+ func ToMetricsForLabelMatchersRequest(from, to model.Time, matchers []*labels.Matcher) (*MetricsForLabelMatchersRequest, error)

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

+ func (*MetricsForLabelMatchersRequest) ProtoMessage()

+ func (m *MetricsForLabelMatchersRequest) GetEndTimestampMs() int64

+ func (m *MetricsForLabelMatchersRequest) GetMatchersSet() []*LabelMatchers

+ func (m *MetricsForLabelMatchersRequest) GetStartTimestampMs() int64

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

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

+ func (m *MetricsForLabelMatchersRequest) Reset()

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

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

+ func (m *MetricsForLabelMatchersRequest) XXX_DiscardUnknown()

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

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

+ func (m *MetricsForLabelMatchersRequest) XXX_Size() int

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

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

+ func (this *MetricsForLabelMatchersRequest) GoString() string

+ func (this *MetricsForLabelMatchersRequest) String() string

+ type MetricsForLabelMatchersResponse struct

+ Metric []*Metric

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

+ func (*MetricsForLabelMatchersResponse) ProtoMessage()

+ func (m *MetricsForLabelMatchersResponse) GetMetric() []*Metric

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

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

+ func (m *MetricsForLabelMatchersResponse) Reset()

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

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

+ func (m *MetricsForLabelMatchersResponse) XXX_DiscardUnknown()

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

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

+ func (m *MetricsForLabelMatchersResponse) XXX_Size() int

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

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

+ func (this *MetricsForLabelMatchersResponse) GoString() string

+ func (this *MetricsForLabelMatchersResponse) String() string

+ type Pool struct

+ func NewPool(cfg PoolConfig, ring ring.ReadRing, factory Factory, logger log.Logger) *Pool

+ func (p *Pool) Count() int

+ func (p *Pool) GetClientFor(addr string) (grpc_health_v1.HealthClient, error)

+ func (p *Pool) RegisteredAddresses() []string

+ func (p *Pool) RemoveClientFor(addr string)

+ func (p *Pool) Stop()

+ type PoolConfig struct

+ ClientCleanupPeriod time.Duration

+ HealthCheckIngesters bool

+ RemoteTimeout time.Duration

+ func (cfg *PoolConfig) RegisterFlags(f *flag.FlagSet)

+ type PreallocConfig struct

+ func (PreallocConfig) RegisterFlags(f *flag.FlagSet)

+ type PreallocTimeseries struct

+ func (p *PreallocTimeseries) Unmarshal(dAtA []byte) error

+ type PreallocWriteRequest struct

+ func (p *PreallocWriteRequest) Unmarshal(dAtA []byte) error

+ type QueryRequest struct

+ EndTimestampMs int64

+ Matchers []*LabelMatcher

+ StartTimestampMs int64

+ func ToQueryRequest(from, to model.Time, matchers []*labels.Matcher) (*QueryRequest, error)

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

+ func (*QueryRequest) ProtoMessage()

+ func (m *QueryRequest) GetEndTimestampMs() int64

+ func (m *QueryRequest) GetMatchers() []*LabelMatcher

+ func (m *QueryRequest) GetStartTimestampMs() int64

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

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

+ func (m *QueryRequest) Reset()

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

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

+ func (m *QueryRequest) XXX_DiscardUnknown()

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

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

+ func (m *QueryRequest) XXX_Size() int

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

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

+ func (this *QueryRequest) GoString() string

+ func (this *QueryRequest) String() string

+ type QueryResponse struct

+ Timeseries []TimeSeries

+ func ToQueryResponse(matrix model.Matrix) *QueryResponse

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

+ func (*QueryResponse) ProtoMessage()

+ func (m *QueryResponse) GetTimeseries() []TimeSeries

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

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

+ func (m *QueryResponse) Reset()

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

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

+ func (m *QueryResponse) XXX_DiscardUnknown()

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

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

+ func (m *QueryResponse) XXX_Size() int

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

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

+ func (this *QueryResponse) GoString() string

+ func (this *QueryResponse) String() string

+ type QueryStreamResponse struct

+ Timeseries []TimeSeriesChunk

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

+ func (*QueryStreamResponse) ProtoMessage()

+ func (m *QueryStreamResponse) GetTimeseries() []TimeSeriesChunk

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

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

+ func (m *QueryStreamResponse) Reset()

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

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

+ func (m *QueryStreamResponse) XXX_DiscardUnknown()

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

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

+ func (m *QueryStreamResponse) XXX_Size() int

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

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

+ func (this *QueryStreamResponse) GoString() string

+ func (this *QueryStreamResponse) String() string

+ type ReadRequest struct

+ Queries []*QueryRequest

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

+ func (*ReadRequest) ProtoMessage()

+ func (m *ReadRequest) GetQueries() []*QueryRequest

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

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

+ func (m *ReadRequest) Reset()

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

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

+ func (m *ReadRequest) XXX_DiscardUnknown()

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

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

+ func (m *ReadRequest) XXX_Size() int

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

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

+ func (this *ReadRequest) GoString() string

+ func (this *ReadRequest) String() string

+ type ReadResponse struct

+ Results []*QueryResponse

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

+ func (*ReadResponse) ProtoMessage()

+ func (m *ReadResponse) GetResults() []*QueryResponse

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

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

+ func (m *ReadResponse) Reset()

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

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

+ func (m *ReadResponse) XXX_DiscardUnknown()

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

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

+ func (m *ReadResponse) XXX_Size() int

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

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

+ func (this *ReadResponse) GoString() string

+ func (this *ReadResponse) String() string

+ type Sample struct

+ TimestampMs int64

+ Value float64

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

+ func (*Sample) ProtoMessage()

+ func (m *Sample) GetTimestampMs() int64

+ func (m *Sample) GetValue() float64

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

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

+ func (m *Sample) Reset()

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

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

+ func (m *Sample) XXX_DiscardUnknown()

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

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

+ func (m *Sample) XXX_Size() int

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

+ func (s *Sample) UnmarshalJSON(b []byte) error

+ func (s Sample) MarshalJSON() ([]byte, error)

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

+ func (this *Sample) GoString() string

+ func (this *Sample) String() string

+ type TimeSeries struct

+ Labels []LabelAdapter

+ Samples []Sample

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

+ func (*TimeSeries) ProtoMessage()

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

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

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

+ func (m *TimeSeries) Reset()

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

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

+ func (m *TimeSeries) XXX_DiscardUnknown()

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

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

+ func (m *TimeSeries) XXX_Size() int

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

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

+ func (this *TimeSeries) GoString() string

+ func (this *TimeSeries) String() string

+ type TimeSeriesChunk struct

+ Chunks []Chunk

+ FromIngesterId string

+ Labels []LabelAdapter

+ UserId string

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

+ func (*TimeSeriesChunk) ProtoMessage()

+ func (m *TimeSeriesChunk) GetChunks() []Chunk

+ func (m *TimeSeriesChunk) GetFromIngesterId() string

+ func (m *TimeSeriesChunk) GetUserId() string

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

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

+ func (m *TimeSeriesChunk) Reset()

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

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

+ func (m *TimeSeriesChunk) XXX_DiscardUnknown()

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

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

+ func (m *TimeSeriesChunk) XXX_Size() int

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

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

+ func (this *TimeSeriesChunk) GoString() string

+ func (this *TimeSeriesChunk) String() string

+ type TransferChunksResponse struct

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

+ func (*TransferChunksResponse) ProtoMessage()

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

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

+ func (m *TransferChunksResponse) Reset()

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

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

+ func (m *TransferChunksResponse) XXX_DiscardUnknown()

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

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

+ func (m *TransferChunksResponse) XXX_Size() int

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

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

+ func (this *TransferChunksResponse) GoString() string

+ func (this *TransferChunksResponse) String() string

+ type UserIDStatsResponse struct

+ Data *UserStatsResponse

+ UserId string

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

+ func (*UserIDStatsResponse) ProtoMessage()

+ func (m *UserIDStatsResponse) GetData() *UserStatsResponse

+ func (m *UserIDStatsResponse) GetUserId() string

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

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

+ func (m *UserIDStatsResponse) Reset()

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

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

+ func (m *UserIDStatsResponse) XXX_DiscardUnknown()

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

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

+ func (m *UserIDStatsResponse) XXX_Size() int

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

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

+ func (this *UserIDStatsResponse) GoString() string

+ func (this *UserIDStatsResponse) String() string

+ type UserStatsRequest struct

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

+ func (*UserStatsRequest) ProtoMessage()

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

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

+ func (m *UserStatsRequest) Reset()

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

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

+ func (m *UserStatsRequest) XXX_DiscardUnknown()

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

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

+ func (m *UserStatsRequest) XXX_Size() int

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

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

+ func (this *UserStatsRequest) GoString() string

+ func (this *UserStatsRequest) String() string

+ type UserStatsResponse struct

+ ApiIngestionRate float64

+ IngestionRate float64

+ NumSeries uint64

+ RuleIngestionRate float64

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

+ func (*UserStatsResponse) ProtoMessage()

+ func (m *UserStatsResponse) GetApiIngestionRate() float64

+ func (m *UserStatsResponse) GetIngestionRate() float64

+ func (m *UserStatsResponse) GetNumSeries() uint64

+ func (m *UserStatsResponse) GetRuleIngestionRate() float64

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

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

+ func (m *UserStatsResponse) Reset()

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

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

+ func (m *UserStatsResponse) XXX_DiscardUnknown()

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

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

+ func (m *UserStatsResponse) XXX_Size() int

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

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

+ func (this *UserStatsResponse) GoString() string

+ func (this *UserStatsResponse) String() string

+ type UsersStatsResponse struct

+ Stats []*UserIDStatsResponse

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

+ func (*UsersStatsResponse) ProtoMessage()

+ func (m *UsersStatsResponse) GetStats() []*UserIDStatsResponse

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

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

+ func (m *UsersStatsResponse) Reset()

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

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

+ func (m *UsersStatsResponse) XXX_DiscardUnknown()

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

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

+ func (m *UsersStatsResponse) XXX_Size() int

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

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

+ func (this *UsersStatsResponse) GoString() string

+ func (this *UsersStatsResponse) String() string

+ type WriteRequest struct

+ Source WriteRequest_SourceEnum

+ Timeseries []PreallocTimeseries

+ func ToWriteRequest(samples []model.Sample, source WriteRequest_SourceEnum) *WriteRequest

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

+ func (*WriteRequest) ProtoMessage()

+ func (m *WriteRequest) GetSource() WriteRequest_SourceEnum

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

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

+ func (m *WriteRequest) Reset()

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

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

+ func (m *WriteRequest) XXX_DiscardUnknown()

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

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

+ func (m *WriteRequest) XXX_Size() int

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

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

+ func (this *WriteRequest) GoString() string

+ func (this *WriteRequest) String() string

+ type WriteRequest_SourceEnum int32

+ const API

+ const RULE

+ func (WriteRequest_SourceEnum) EnumDescriptor() ([]byte, []int)

+ func (x WriteRequest_SourceEnum) String() string

+ type WriteResponse struct

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

+ func (*WriteResponse) ProtoMessage()

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

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

+ func (m *WriteResponse) Reset()

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

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

+ func (m *WriteResponse) XXX_DiscardUnknown()

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

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

+ func (m *WriteResponse) XXX_Size() int

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

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

+ func (this *WriteResponse) GoString() string

+ func (this *WriteResponse) String() string

Aug 1, 2019 GO-2022-0915 +1 more

  GO-2022-0915: Improper input validation in CNCF Cortex in github.com/cortexproject/cortex

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex