Versions in this module Expand all Collapse all v3 v3.0.0 Apr 8, 2024 Changes in this version + var Direction_name = map[int32]string + var Direction_value = map[string]int32 + var ErrIntOverflowBloomgateway = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowIndexgateway = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowLogproto = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowMetrics = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowPattern = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowSketch = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthBloomgateway = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthIndexgateway = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthLogproto = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthMetrics = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthPattern = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthSketch = fmt.Errorf("proto: negative length found during unmarshaling") + var MetricMetadata_MetricType_name = map[int32]string + var MetricMetadata_MetricType_value = map[string]int32 + var WriteRequest_SourceEnum_name = map[int32]string + var WriteRequest_SourceEnum_value = map[string]int32 + func FromLabelAdaptersToLabels(ls []LabelAdapter) labels.Labels + func FromLabelAdaptersToMetric(ls []LabelAdapter) model.Metric + func RegisterBloomGatewayServer(s *grpc.Server, srv BloomGatewayServer) + func RegisterIndexGatewayServer(s *grpc.Server, srv IndexGatewayServer) + func RegisterPatternServer(s *grpc.Server, srv PatternServer) + func RegisterPusherServer(s *grpc.Server, srv PusherServer) + func RegisterQuerierServer(s *grpc.Server, srv QuerierServer) + func RegisterStreamDataServer(s *grpc.Server, srv StreamDataServer) + func ReuseSlice(ts []PreallocTimeseries) + func ReuseTimeseries(ts *TimeSeries) + func SampleJsoniterDecode(ptr unsafe.Pointer, iter *jsoniter.Iterator) + func SampleJsoniterEncode(ptr unsafe.Pointer, stream *jsoniter.Stream) + type BloomGatewayClient interface + FilterChunkRefs func(ctx context.Context, in *FilterChunkRefRequest, opts ...grpc.CallOption) (*FilterChunkRefResponse, error) + func NewBloomGatewayClient(cc *grpc.ClientConn) BloomGatewayClient + type BloomGatewayServer interface + FilterChunkRefs func(context.Context, *FilterChunkRefRequest) (*FilterChunkRefResponse, error) + type Chunk struct + Data []byte + func (*Chunk) Descriptor() ([]byte, []int) + func (*Chunk) ProtoMessage() + func (m *Chunk) GetData() []byte + func (m *Chunk) Marshal() (dAtA []byte, err error) + func (m *Chunk) MarshalTo(dAtA []byte) (int, error) + func (m *Chunk) MarshalToSizedBuffer(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 ChunkRef struct + Checksum uint32 + Fingerprint uint64 + From github_com_prometheus_common_model.Time + Through github_com_prometheus_common_model.Time + UserID string + func (*ChunkRef) Descriptor() ([]byte, []int) + func (*ChunkRef) ProtoMessage() + func (c *ChunkRef) FingerprintModel() model.Fingerprint + func (m *ChunkRef) GetChecksum() uint32 + func (m *ChunkRef) GetFingerprint() uint64 + func (m *ChunkRef) GetUserID() string + func (m *ChunkRef) Marshal() (dAtA []byte, err error) + func (m *ChunkRef) MarshalTo(dAtA []byte) (int, error) + func (m *ChunkRef) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChunkRef) Reset() + func (m *ChunkRef) Size() (n int) + func (m *ChunkRef) Unmarshal(dAtA []byte) error + func (m *ChunkRef) XXX_DiscardUnknown() + func (m *ChunkRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChunkRef) XXX_Merge(src proto.Message) + func (m *ChunkRef) XXX_Size() int + func (m *ChunkRef) XXX_Unmarshal(b []byte) error + func (this *ChunkRef) Equal(that interface{}) bool + func (this *ChunkRef) GoString() string + func (this *ChunkRef) String() string + type CountMinSketch struct + Counters []uint32 + Depth uint32 + Width uint32 + func (*CountMinSketch) Descriptor() ([]byte, []int) + func (*CountMinSketch) ProtoMessage() + func (m *CountMinSketch) GetCounters() []uint32 + func (m *CountMinSketch) GetDepth() uint32 + func (m *CountMinSketch) GetWidth() uint32 + func (m *CountMinSketch) Marshal() (dAtA []byte, err error) + func (m *CountMinSketch) MarshalTo(dAtA []byte) (int, error) + func (m *CountMinSketch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CountMinSketch) Reset() + func (m *CountMinSketch) Size() (n int) + func (m *CountMinSketch) Unmarshal(dAtA []byte) error + func (m *CountMinSketch) XXX_DiscardUnknown() + func (m *CountMinSketch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CountMinSketch) XXX_Merge(src proto.Message) + func (m *CountMinSketch) XXX_Size() int + func (m *CountMinSketch) XXX_Unmarshal(b []byte) error + func (this *CountMinSketch) Equal(that interface{}) bool + func (this *CountMinSketch) GoString() string + func (this *CountMinSketch) String() string + type Delete struct + End int64 + Selector string + Start int64 + func (*Delete) Descriptor() ([]byte, []int) + func (*Delete) ProtoMessage() + func (m *Delete) GetEnd() int64 + func (m *Delete) GetSelector() string + func (m *Delete) GetStart() int64 + func (m *Delete) Marshal() (dAtA []byte, err error) + func (m *Delete) MarshalTo(dAtA []byte) (int, error) + func (m *Delete) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Delete) Reset() + func (m *Delete) Size() (n int) + func (m *Delete) Unmarshal(dAtA []byte) error + func (m *Delete) XXX_DiscardUnknown() + func (m *Delete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Delete) XXX_Merge(src proto.Message) + func (m *Delete) XXX_Size() int + func (m *Delete) XXX_Unmarshal(b []byte) error + func (this *Delete) Equal(that interface{}) bool + func (this *Delete) GoString() string + func (this *Delete) String() string + type DetectedField struct + Cardinality uint64 + Label string + Type DetectedFieldType + func (*DetectedField) Descriptor() ([]byte, []int) + func (*DetectedField) ProtoMessage() + func (m *DetectedField) GetCardinality() uint64 + func (m *DetectedField) GetLabel() string + func (m *DetectedField) GetType() DetectedFieldType + func (m *DetectedField) Marshal() (dAtA []byte, err error) + func (m *DetectedField) MarshalTo(dAtA []byte) (int, error) + func (m *DetectedField) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DetectedField) Reset() + func (m *DetectedField) Size() (n int) + func (m *DetectedField) Unmarshal(dAtA []byte) error + func (m *DetectedField) XXX_DiscardUnknown() + func (m *DetectedField) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DetectedField) XXX_Merge(src proto.Message) + func (m *DetectedField) XXX_Size() int + func (m *DetectedField) XXX_Unmarshal(b []byte) error + func (this *DetectedField) Equal(that interface{}) bool + func (this *DetectedField) GoString() string + func (this *DetectedField) String() string + type DetectedFieldType string + const DetectedFieldBoolean + const DetectedFieldBytes + const DetectedFieldDuration + const DetectedFieldFloat + const DetectedFieldInt + const DetectedFieldString + func (d DetectedFieldType) String() string + type DetectedFieldsRequest struct + End time.Time + FieldLimit uint32 + LineLimit uint32 + Query string + Start time.Time + Step int64 + func (*DetectedFieldsRequest) Descriptor() ([]byte, []int) + func (*DetectedFieldsRequest) ProtoMessage() + func (m *DetectedFieldsRequest) GetEnd() time.Time + func (m *DetectedFieldsRequest) GetFieldLimit() uint32 + func (m *DetectedFieldsRequest) GetLineLimit() uint32 + func (m *DetectedFieldsRequest) GetQuery() string + func (m *DetectedFieldsRequest) GetStart() time.Time + func (m *DetectedFieldsRequest) GetStep() int64 + func (m *DetectedFieldsRequest) Marshal() (dAtA []byte, err error) + func (m *DetectedFieldsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DetectedFieldsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DetectedFieldsRequest) Reset() + func (m *DetectedFieldsRequest) Size() (n int) + func (m *DetectedFieldsRequest) Unmarshal(dAtA []byte) error + func (m *DetectedFieldsRequest) XXX_DiscardUnknown() + func (m *DetectedFieldsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DetectedFieldsRequest) XXX_Merge(src proto.Message) + func (m *DetectedFieldsRequest) XXX_Size() int + func (m *DetectedFieldsRequest) XXX_Unmarshal(b []byte) error + func (this *DetectedFieldsRequest) Equal(that interface{}) bool + func (this *DetectedFieldsRequest) GoString() string + func (this *DetectedFieldsRequest) String() string + type DetectedFieldsResponse struct + Fields []*DetectedField + func (*DetectedFieldsResponse) Descriptor() ([]byte, []int) + func (*DetectedFieldsResponse) ProtoMessage() + func (m *DetectedFieldsResponse) GetFields() []*DetectedField + func (m *DetectedFieldsResponse) Marshal() (dAtA []byte, err error) + func (m *DetectedFieldsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DetectedFieldsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DetectedFieldsResponse) Reset() + func (m *DetectedFieldsResponse) Size() (n int) + func (m *DetectedFieldsResponse) Unmarshal(dAtA []byte) error + func (m *DetectedFieldsResponse) XXX_DiscardUnknown() + func (m *DetectedFieldsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DetectedFieldsResponse) XXX_Merge(src proto.Message) + func (m *DetectedFieldsResponse) XXX_Size() int + func (m *DetectedFieldsResponse) XXX_Unmarshal(b []byte) error + func (this *DetectedFieldsResponse) Equal(that interface{}) bool + func (this *DetectedFieldsResponse) GoString() string + func (this *DetectedFieldsResponse) String() string + type DetectedLabel struct + Cardinality uint64 + Label string + func (*DetectedLabel) Descriptor() ([]byte, []int) + func (*DetectedLabel) ProtoMessage() + func (m *DetectedLabel) GetCardinality() uint64 + func (m *DetectedLabel) GetLabel() string + func (m *DetectedLabel) Marshal() (dAtA []byte, err error) + func (m *DetectedLabel) MarshalTo(dAtA []byte) (int, error) + func (m *DetectedLabel) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DetectedLabel) Reset() + func (m *DetectedLabel) Size() (n int) + func (m *DetectedLabel) Unmarshal(dAtA []byte) error + func (m *DetectedLabel) XXX_DiscardUnknown() + func (m *DetectedLabel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DetectedLabel) XXX_Merge(src proto.Message) + func (m *DetectedLabel) XXX_Size() int + func (m *DetectedLabel) XXX_Unmarshal(b []byte) error + func (this *DetectedLabel) Equal(that interface{}) bool + func (this *DetectedLabel) GoString() string + func (this *DetectedLabel) String() string + type DetectedLabelsRequest struct + End *time.Time + Query string + Start *time.Time + func (*DetectedLabelsRequest) Descriptor() ([]byte, []int) + func (*DetectedLabelsRequest) ProtoMessage() + func (m *DetectedLabelsRequest) GetEnd() *time.Time + func (m *DetectedLabelsRequest) GetQuery() string + func (m *DetectedLabelsRequest) GetStart() *time.Time + func (m *DetectedLabelsRequest) Marshal() (dAtA []byte, err error) + func (m *DetectedLabelsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DetectedLabelsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DetectedLabelsRequest) Reset() + func (m *DetectedLabelsRequest) Size() (n int) + func (m *DetectedLabelsRequest) Unmarshal(dAtA []byte) error + func (m *DetectedLabelsRequest) XXX_DiscardUnknown() + func (m *DetectedLabelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DetectedLabelsRequest) XXX_Merge(src proto.Message) + func (m *DetectedLabelsRequest) XXX_Size() int + func (m *DetectedLabelsRequest) XXX_Unmarshal(b []byte) error + func (this *DetectedLabelsRequest) Equal(that interface{}) bool + func (this *DetectedLabelsRequest) GoString() string + func (this *DetectedLabelsRequest) String() string + type DetectedLabelsResponse struct + DetectedLabels []*DetectedLabel + func (*DetectedLabelsResponse) Descriptor() ([]byte, []int) + func (*DetectedLabelsResponse) ProtoMessage() + func (m *DetectedLabelsResponse) GetDetectedLabels() []*DetectedLabel + func (m *DetectedLabelsResponse) Marshal() (dAtA []byte, err error) + func (m *DetectedLabelsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DetectedLabelsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DetectedLabelsResponse) Reset() + func (m *DetectedLabelsResponse) Size() (n int) + func (m *DetectedLabelsResponse) Unmarshal(dAtA []byte) error + func (m *DetectedLabelsResponse) XXX_DiscardUnknown() + func (m *DetectedLabelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DetectedLabelsResponse) XXX_Merge(src proto.Message) + func (m *DetectedLabelsResponse) XXX_Size() int + func (m *DetectedLabelsResponse) XXX_Unmarshal(b []byte) error + func (this *DetectedLabelsResponse) Equal(that interface{}) bool + func (this *DetectedLabelsResponse) GoString() string + func (this *DetectedLabelsResponse) String() string + type Direction int32 + const BACKWARD + const FORWARD + func (Direction) EnumDescriptor() ([]byte, []int) + func (x Direction) String() string + type DroppedStream struct + From time.Time + Labels string + To time.Time + func (*DroppedStream) Descriptor() ([]byte, []int) + func (*DroppedStream) ProtoMessage() + func (m *DroppedStream) GetFrom() time.Time + func (m *DroppedStream) GetLabels() string + func (m *DroppedStream) GetTo() time.Time + func (m *DroppedStream) Marshal() (dAtA []byte, err error) + func (m *DroppedStream) MarshalTo(dAtA []byte) (int, error) + func (m *DroppedStream) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DroppedStream) Reset() + func (m *DroppedStream) Size() (n int) + func (m *DroppedStream) Unmarshal(dAtA []byte) error + func (m *DroppedStream) XXX_DiscardUnknown() + func (m *DroppedStream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DroppedStream) XXX_Merge(src proto.Message) + func (m *DroppedStream) XXX_Size() int + func (m *DroppedStream) XXX_Unmarshal(b []byte) error + func (this *DroppedStream) Equal(that interface{}) bool + func (this *DroppedStream) GoString() string + func (this *DroppedStream) String() string + type Entry = push.Entry + type FPBounds struct + Max github_com_prometheus_common_model.Fingerprint + Min github_com_prometheus_common_model.Fingerprint + func (*FPBounds) Descriptor() ([]byte, []int) + func (*FPBounds) ProtoMessage() + func (m *FPBounds) GetMax() github_com_prometheus_common_model.Fingerprint + func (m *FPBounds) GetMin() github_com_prometheus_common_model.Fingerprint + func (m *FPBounds) Marshal() (dAtA []byte, err error) + func (m *FPBounds) MarshalTo(dAtA []byte) (int, error) + func (m *FPBounds) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FPBounds) Reset() + func (m *FPBounds) Size() (n int) + func (m *FPBounds) Unmarshal(dAtA []byte) error + func (m *FPBounds) XXX_DiscardUnknown() + func (m *FPBounds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FPBounds) XXX_Merge(src proto.Message) + func (m *FPBounds) XXX_Size() int + func (m *FPBounds) XXX_Unmarshal(b []byte) error + func (this *FPBounds) Equal(that interface{}) bool + func (this *FPBounds) GoString() string + func (this *FPBounds) String() string + type FilterChunkRefRequest struct + Filters []github_com_grafana_loki_v3_pkg_logql_syntax.LineFilter + From github_com_prometheus_common_model.Time + Plan github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan + Refs []*GroupedChunkRefs + Through github_com_prometheus_common_model.Time + func (*FilterChunkRefRequest) Descriptor() ([]byte, []int) + func (*FilterChunkRefRequest) ProtoMessage() + func (m *FilterChunkRefRequest) GetCachingOptions() (res resultscache.CachingOptions) + func (m *FilterChunkRefRequest) GetEnd() time.Time + func (m *FilterChunkRefRequest) GetQuery() string + func (m *FilterChunkRefRequest) GetRefs() []*GroupedChunkRefs + func (m *FilterChunkRefRequest) GetStart() time.Time + func (m *FilterChunkRefRequest) GetStep() int64 + func (m *FilterChunkRefRequest) Marshal() (dAtA []byte, err error) + func (m *FilterChunkRefRequest) MarshalTo(dAtA []byte) (int, error) + func (m *FilterChunkRefRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FilterChunkRefRequest) Reset() + func (m *FilterChunkRefRequest) Size() (n int) + func (m *FilterChunkRefRequest) Unmarshal(dAtA []byte) error + func (m *FilterChunkRefRequest) WithStartEndForCache(start, end time.Time) resultscache.Request + func (m *FilterChunkRefRequest) XXX_DiscardUnknown() + func (m *FilterChunkRefRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FilterChunkRefRequest) XXX_Merge(src proto.Message) + func (m *FilterChunkRefRequest) XXX_Size() int + func (m *FilterChunkRefRequest) XXX_Unmarshal(b []byte) error + func (this *FilterChunkRefRequest) Equal(that interface{}) bool + func (this *FilterChunkRefRequest) GoString() string + func (this *FilterChunkRefRequest) String() string + type FilterChunkRefResponse struct + ChunkRefs []*GroupedChunkRefs + func (*FilterChunkRefResponse) Descriptor() ([]byte, []int) + func (*FilterChunkRefResponse) ProtoMessage() + func (m *FilterChunkRefResponse) GetChunkRefs() []*GroupedChunkRefs + func (m *FilterChunkRefResponse) Marshal() (dAtA []byte, err error) + func (m *FilterChunkRefResponse) MarshalTo(dAtA []byte) (int, error) + func (m *FilterChunkRefResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FilterChunkRefResponse) Reset() + func (m *FilterChunkRefResponse) Size() (n int) + func (m *FilterChunkRefResponse) Unmarshal(dAtA []byte) error + func (m *FilterChunkRefResponse) XXX_DiscardUnknown() + func (m *FilterChunkRefResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FilterChunkRefResponse) XXX_Merge(src proto.Message) + func (m *FilterChunkRefResponse) XXX_Size() int + func (m *FilterChunkRefResponse) XXX_Unmarshal(b []byte) error + func (this *FilterChunkRefResponse) Equal(that interface{}) bool + func (this *FilterChunkRefResponse) GoString() string + func (this *FilterChunkRefResponse) String() string + type GetChunkIDsRequest struct + End time.Time + Matchers string + Start time.Time + func (*GetChunkIDsRequest) Descriptor() ([]byte, []int) + func (*GetChunkIDsRequest) ProtoMessage() + func (m *GetChunkIDsRequest) GetEnd() time.Time + func (m *GetChunkIDsRequest) GetMatchers() string + func (m *GetChunkIDsRequest) GetStart() time.Time + func (m *GetChunkIDsRequest) Marshal() (dAtA []byte, err error) + func (m *GetChunkIDsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetChunkIDsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetChunkIDsRequest) Reset() + func (m *GetChunkIDsRequest) Size() (n int) + func (m *GetChunkIDsRequest) Unmarshal(dAtA []byte) error + func (m *GetChunkIDsRequest) XXX_DiscardUnknown() + func (m *GetChunkIDsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetChunkIDsRequest) XXX_Merge(src proto.Message) + func (m *GetChunkIDsRequest) XXX_Size() int + func (m *GetChunkIDsRequest) XXX_Unmarshal(b []byte) error + func (this *GetChunkIDsRequest) Equal(that interface{}) bool + func (this *GetChunkIDsRequest) GoString() string + func (this *GetChunkIDsRequest) String() string + type GetChunkIDsResponse struct + ChunkIDs []string + func (*GetChunkIDsResponse) Descriptor() ([]byte, []int) + func (*GetChunkIDsResponse) ProtoMessage() + func (m *GetChunkIDsResponse) GetChunkIDs() []string + func (m *GetChunkIDsResponse) Marshal() (dAtA []byte, err error) + func (m *GetChunkIDsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetChunkIDsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetChunkIDsResponse) Reset() + func (m *GetChunkIDsResponse) Size() (n int) + func (m *GetChunkIDsResponse) Unmarshal(dAtA []byte) error + func (m *GetChunkIDsResponse) XXX_DiscardUnknown() + func (m *GetChunkIDsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetChunkIDsResponse) XXX_Merge(src proto.Message) + func (m *GetChunkIDsResponse) XXX_Size() int + func (m *GetChunkIDsResponse) XXX_Unmarshal(b []byte) error + func (this *GetChunkIDsResponse) Equal(that interface{}) bool + func (this *GetChunkIDsResponse) GoString() string + func (this *GetChunkIDsResponse) String() string + type GetChunkRefRequest struct + Filters []github_com_grafana_loki_v3_pkg_logql_syntax.LineFilter + From github_com_prometheus_common_model.Time + Matchers string + Plan github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan + Through github_com_prometheus_common_model.Time + func (*GetChunkRefRequest) Descriptor() ([]byte, []int) + func (*GetChunkRefRequest) ProtoMessage() + func (m *GetChunkRefRequest) GetMatchers() string + func (m *GetChunkRefRequest) Marshal() (dAtA []byte, err error) + func (m *GetChunkRefRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetChunkRefRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetChunkRefRequest) Reset() + func (m *GetChunkRefRequest) Size() (n int) + func (m *GetChunkRefRequest) Unmarshal(dAtA []byte) error + func (m *GetChunkRefRequest) XXX_DiscardUnknown() + func (m *GetChunkRefRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetChunkRefRequest) XXX_Merge(src proto.Message) + func (m *GetChunkRefRequest) XXX_Size() int + func (m *GetChunkRefRequest) XXX_Unmarshal(b []byte) error + func (this *GetChunkRefRequest) Equal(that interface{}) bool + func (this *GetChunkRefRequest) GoString() string + func (this *GetChunkRefRequest) String() string + type GetChunkRefResponse struct + Refs []*ChunkRef + func (*GetChunkRefResponse) Descriptor() ([]byte, []int) + func (*GetChunkRefResponse) ProtoMessage() + func (m *GetChunkRefResponse) GetRefs() []*ChunkRef + func (m *GetChunkRefResponse) Marshal() (dAtA []byte, err error) + func (m *GetChunkRefResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetChunkRefResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetChunkRefResponse) Reset() + func (m *GetChunkRefResponse) Size() (n int) + func (m *GetChunkRefResponse) Unmarshal(dAtA []byte) error + func (m *GetChunkRefResponse) XXX_DiscardUnknown() + func (m *GetChunkRefResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetChunkRefResponse) XXX_Merge(src proto.Message) + func (m *GetChunkRefResponse) XXX_Size() int + func (m *GetChunkRefResponse) XXX_Unmarshal(b []byte) error + func (this *GetChunkRefResponse) Equal(that interface{}) bool + func (this *GetChunkRefResponse) GoString() string + func (this *GetChunkRefResponse) String() string + type GetSeriesRequest struct + From github_com_prometheus_common_model.Time + Matchers string + Through github_com_prometheus_common_model.Time + func (*GetSeriesRequest) Descriptor() ([]byte, []int) + func (*GetSeriesRequest) ProtoMessage() + func (m *GetSeriesRequest) GetMatchers() string + func (m *GetSeriesRequest) Marshal() (dAtA []byte, err error) + func (m *GetSeriesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetSeriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetSeriesRequest) Reset() + func (m *GetSeriesRequest) Size() (n int) + func (m *GetSeriesRequest) Unmarshal(dAtA []byte) error + func (m *GetSeriesRequest) XXX_DiscardUnknown() + func (m *GetSeriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetSeriesRequest) XXX_Merge(src proto.Message) + func (m *GetSeriesRequest) XXX_Size() int + func (m *GetSeriesRequest) XXX_Unmarshal(b []byte) error + func (this *GetSeriesRequest) Equal(that interface{}) bool + func (this *GetSeriesRequest) GoString() string + func (this *GetSeriesRequest) String() string + type GetSeriesResponse struct + Series []IndexSeries + func (*GetSeriesResponse) Descriptor() ([]byte, []int) + func (*GetSeriesResponse) ProtoMessage() + func (m *GetSeriesResponse) GetSeries() []IndexSeries + func (m *GetSeriesResponse) Marshal() (dAtA []byte, err error) + func (m *GetSeriesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetSeriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetSeriesResponse) Reset() + func (m *GetSeriesResponse) Size() (n int) + func (m *GetSeriesResponse) Unmarshal(dAtA []byte) error + func (m *GetSeriesResponse) XXX_DiscardUnknown() + func (m *GetSeriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetSeriesResponse) XXX_Merge(src proto.Message) + func (m *GetSeriesResponse) XXX_Size() int + func (m *GetSeriesResponse) XXX_Unmarshal(b []byte) error + func (this *GetSeriesResponse) Equal(that interface{}) bool + func (this *GetSeriesResponse) GoString() string + func (this *GetSeriesResponse) String() string + type GroupedChunkRefs struct + Fingerprint uint64 + Refs []*ShortRef + Tenant string + func (*GroupedChunkRefs) Descriptor() ([]byte, []int) + func (*GroupedChunkRefs) ProtoMessage() + func (m *GroupedChunkRefs) GetFingerprint() uint64 + func (m *GroupedChunkRefs) GetRefs() []*ShortRef + func (m *GroupedChunkRefs) GetTenant() string + func (m *GroupedChunkRefs) Marshal() (dAtA []byte, err error) + func (m *GroupedChunkRefs) MarshalTo(dAtA []byte) (int, error) + func (m *GroupedChunkRefs) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GroupedChunkRefs) Reset() + func (m *GroupedChunkRefs) Size() (n int) + func (m *GroupedChunkRefs) Unmarshal(dAtA []byte) error + func (m *GroupedChunkRefs) XXX_DiscardUnknown() + func (m *GroupedChunkRefs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GroupedChunkRefs) XXX_Merge(src proto.Message) + func (m *GroupedChunkRefs) XXX_Size() int + func (m *GroupedChunkRefs) XXX_Unmarshal(b []byte) error + func (this *GroupedChunkRefs) Equal(that interface{}) bool + func (this *GroupedChunkRefs) GoString() string + func (this *GroupedChunkRefs) String() string + type IndexGatewayClient interface + GetChunkRef func(ctx context.Context, in *GetChunkRefRequest, opts ...grpc.CallOption) (*GetChunkRefResponse, error) + GetSeries func(ctx context.Context, in *GetSeriesRequest, opts ...grpc.CallOption) (*GetSeriesResponse, error) + GetShards func(ctx context.Context, in *ShardsRequest, opts ...grpc.CallOption) (IndexGateway_GetShardsClient, error) + GetStats func(ctx context.Context, in *IndexStatsRequest, opts ...grpc.CallOption) (*IndexStatsResponse, error) + GetVolume func(ctx context.Context, in *VolumeRequest, opts ...grpc.CallOption) (*VolumeResponse, error) + LabelNamesForMetricName func(ctx context.Context, in *LabelNamesForMetricNameRequest, ...) (*LabelResponse, error) + LabelValuesForMetricName func(ctx context.Context, in *LabelValuesForMetricNameRequest, ...) (*LabelResponse, error) + QueryIndex func(ctx context.Context, in *QueryIndexRequest, opts ...grpc.CallOption) (IndexGateway_QueryIndexClient, error) + func NewIndexGatewayClient(cc *grpc.ClientConn) IndexGatewayClient + type IndexGatewayServer interface + GetChunkRef func(context.Context, *GetChunkRefRequest) (*GetChunkRefResponse, error) + GetSeries func(context.Context, *GetSeriesRequest) (*GetSeriesResponse, error) + GetShards func(*ShardsRequest, IndexGateway_GetShardsServer) error + GetStats func(context.Context, *IndexStatsRequest) (*IndexStatsResponse, error) + GetVolume func(context.Context, *VolumeRequest) (*VolumeResponse, error) + LabelNamesForMetricName func(context.Context, *LabelNamesForMetricNameRequest) (*LabelResponse, error) + LabelValuesForMetricName func(context.Context, *LabelValuesForMetricNameRequest) (*LabelResponse, error) + QueryIndex func(*QueryIndexRequest, IndexGateway_QueryIndexServer) error + type IndexGateway_GetShardsClient interface + Recv func() (*ShardsResponse, error) + type IndexGateway_GetShardsServer interface + Send func(*ShardsResponse) error + type IndexGateway_QueryIndexClient interface + Recv func() (*QueryIndexResponse, error) + type IndexGateway_QueryIndexServer interface + Send func(*QueryIndexResponse) error + type IndexQuery struct + HashValue string + RangeValuePrefix []byte + RangeValueStart []byte + TableName string + ValueEqual []byte + func (*IndexQuery) Descriptor() ([]byte, []int) + func (*IndexQuery) ProtoMessage() + func (m *IndexQuery) GetHashValue() string + func (m *IndexQuery) GetRangeValuePrefix() []byte + func (m *IndexQuery) GetRangeValueStart() []byte + func (m *IndexQuery) GetTableName() string + func (m *IndexQuery) GetValueEqual() []byte + func (m *IndexQuery) Marshal() (dAtA []byte, err error) + func (m *IndexQuery) MarshalTo(dAtA []byte) (int, error) + func (m *IndexQuery) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IndexQuery) Reset() + func (m *IndexQuery) Size() (n int) + func (m *IndexQuery) Unmarshal(dAtA []byte) error + func (m *IndexQuery) XXX_DiscardUnknown() + func (m *IndexQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexQuery) XXX_Merge(src proto.Message) + func (m *IndexQuery) XXX_Size() int + func (m *IndexQuery) XXX_Unmarshal(b []byte) error + func (this *IndexQuery) Equal(that interface{}) bool + func (this *IndexQuery) GoString() string + func (this *IndexQuery) String() string + type IndexSeries struct + Labels []LabelAdapter + func (*IndexSeries) Descriptor() ([]byte, []int) + func (*IndexSeries) ProtoMessage() + func (m *IndexSeries) Marshal() (dAtA []byte, err error) + func (m *IndexSeries) MarshalTo(dAtA []byte) (int, error) + func (m *IndexSeries) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IndexSeries) Reset() + func (m *IndexSeries) Size() (n int) + func (m *IndexSeries) Unmarshal(dAtA []byte) error + func (m *IndexSeries) XXX_DiscardUnknown() + func (m *IndexSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexSeries) XXX_Merge(src proto.Message) + func (m *IndexSeries) XXX_Size() int + func (m *IndexSeries) XXX_Unmarshal(b []byte) error + func (this *IndexSeries) Equal(that interface{}) bool + func (this *IndexSeries) GoString() string + func (this *IndexSeries) String() string + type IndexStatsRequest struct + From github_com_prometheus_common_model.Time + Matchers string + Through github_com_prometheus_common_model.Time + func (*IndexStatsRequest) Descriptor() ([]byte, []int) + func (*IndexStatsRequest) ProtoMessage() + func (m *IndexStatsRequest) GetCachingOptions() (res definitions.CachingOptions) + func (m *IndexStatsRequest) GetEnd() time.Time + func (m *IndexStatsRequest) GetMatchers() string + func (m *IndexStatsRequest) GetQuery() string + func (m *IndexStatsRequest) GetStart() time.Time + func (m *IndexStatsRequest) GetStep() int64 + func (m *IndexStatsRequest) LogToSpan(sp opentracing.Span) + func (m *IndexStatsRequest) Marshal() (dAtA []byte, err error) + func (m *IndexStatsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *IndexStatsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IndexStatsRequest) Reset() + func (m *IndexStatsRequest) Size() (n int) + func (m *IndexStatsRequest) Unmarshal(dAtA []byte) error + func (m *IndexStatsRequest) WithQuery(query string) definitions.Request + func (m *IndexStatsRequest) WithStartEnd(start, end time.Time) definitions.Request + func (m *IndexStatsRequest) WithStartEndForCache(start, end time.Time) resultscache.Request + func (m *IndexStatsRequest) XXX_DiscardUnknown() + func (m *IndexStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexStatsRequest) XXX_Merge(src proto.Message) + func (m *IndexStatsRequest) XXX_Size() int + func (m *IndexStatsRequest) XXX_Unmarshal(b []byte) error + func (this *IndexStatsRequest) Equal(that interface{}) bool + func (this *IndexStatsRequest) GoString() string + func (this *IndexStatsRequest) String() string + type IndexStatsResponse struct + Bytes uint64 + Chunks uint64 + Entries uint64 + Streams uint64 + func (*IndexStatsResponse) Descriptor() ([]byte, []int) + func (*IndexStatsResponse) ProtoMessage() + func (i *IndexStatsResponse) GetHeaders() []*definitions.PrometheusResponseHeader + func (m *IndexStatsResponse) AddChunkStats(s index.ChunkStats) + func (m *IndexStatsResponse) AddStream(_ model.Fingerprint) + func (m *IndexStatsResponse) GetBytes() uint64 + func (m *IndexStatsResponse) GetChunks() uint64 + func (m *IndexStatsResponse) GetEntries() uint64 + func (m *IndexStatsResponse) GetStreams() uint64 + func (m *IndexStatsResponse) LoggingKeyValues() []interface{} + func (m *IndexStatsResponse) Marshal() (dAtA []byte, err error) + func (m *IndexStatsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *IndexStatsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IndexStatsResponse) Reset() + func (m *IndexStatsResponse) Size() (n int) + func (m *IndexStatsResponse) Stats() IndexStatsResponse + func (m *IndexStatsResponse) Unmarshal(dAtA []byte) error + func (m *IndexStatsResponse) XXX_DiscardUnknown() + func (m *IndexStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexStatsResponse) XXX_Merge(src proto.Message) + func (m *IndexStatsResponse) XXX_Size() int + func (m *IndexStatsResponse) XXX_Unmarshal(b []byte) error + func (this *IndexStatsResponse) Equal(that interface{}) bool + func (this *IndexStatsResponse) GoString() string + func (this *IndexStatsResponse) String() string + type LabelAdapter = push.LabelAdapter + func FromLabelsToLabelAdapters(ls labels.Labels) []LabelAdapter + func FromMetricsToLabelAdapters(metric model.Metric) []LabelAdapter + type LabelNamesForMetricNameRequest struct + From github_com_prometheus_common_model.Time + MetricName string + Through github_com_prometheus_common_model.Time + func (*LabelNamesForMetricNameRequest) Descriptor() ([]byte, []int) + func (*LabelNamesForMetricNameRequest) ProtoMessage() + func (m *LabelNamesForMetricNameRequest) GetMetricName() string + func (m *LabelNamesForMetricNameRequest) Marshal() (dAtA []byte, err error) + func (m *LabelNamesForMetricNameRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LabelNamesForMetricNameRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LabelNamesForMetricNameRequest) Reset() + func (m *LabelNamesForMetricNameRequest) Size() (n int) + func (m *LabelNamesForMetricNameRequest) Unmarshal(dAtA []byte) error + func (m *LabelNamesForMetricNameRequest) XXX_DiscardUnknown() + func (m *LabelNamesForMetricNameRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LabelNamesForMetricNameRequest) XXX_Merge(src proto.Message) + func (m *LabelNamesForMetricNameRequest) XXX_Size() int + func (m *LabelNamesForMetricNameRequest) XXX_Unmarshal(b []byte) error + func (this *LabelNamesForMetricNameRequest) Equal(that interface{}) bool + func (this *LabelNamesForMetricNameRequest) GoString() string + func (this *LabelNamesForMetricNameRequest) String() string + type LabelPair struct + Name string + Value string + func (*LabelPair) Descriptor() ([]byte, []int) + func (*LabelPair) ProtoMessage() + func (m *LabelPair) GetName() string + func (m *LabelPair) GetValue() string + func (m *LabelPair) Marshal() (dAtA []byte, err error) + func (m *LabelPair) MarshalTo(dAtA []byte) (int, error) + func (m *LabelPair) MarshalToSizedBuffer(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 LabelRequest struct + End *time.Time + Name string + Query string + Start *time.Time + Values bool + func (*LabelRequest) Descriptor() ([]byte, []int) + func (*LabelRequest) ProtoMessage() + func (m *LabelRequest) GetEnd() *time.Time + func (m *LabelRequest) GetName() string + func (m *LabelRequest) GetQuery() string + func (m *LabelRequest) GetStart() *time.Time + func (m *LabelRequest) GetValues() bool + func (m *LabelRequest) Marshal() (dAtA []byte, err error) + func (m *LabelRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LabelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LabelRequest) Reset() + func (m *LabelRequest) Size() (n int) + func (m *LabelRequest) Unmarshal(dAtA []byte) error + func (m *LabelRequest) XXX_DiscardUnknown() + func (m *LabelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LabelRequest) XXX_Merge(src proto.Message) + func (m *LabelRequest) XXX_Size() int + func (m *LabelRequest) XXX_Unmarshal(b []byte) error + func (this *LabelRequest) Equal(that interface{}) bool + func (this *LabelRequest) GoString() string + func (this *LabelRequest) String() string + type LabelResponse struct + Values []string + func MergeLabelResponses(responses []*LabelResponse) (*LabelResponse, error) + func (*LabelResponse) Descriptor() ([]byte, []int) + func (*LabelResponse) ProtoMessage() + func (m *LabelResponse) GetValues() []string + func (m *LabelResponse) Marshal() (dAtA []byte, err error) + func (m *LabelResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LabelResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LabelResponse) Reset() + func (m *LabelResponse) Size() (n int) + func (m *LabelResponse) Unmarshal(dAtA []byte) error + func (m *LabelResponse) XXX_DiscardUnknown() + func (m *LabelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LabelResponse) XXX_Merge(src proto.Message) + func (m *LabelResponse) XXX_Size() int + func (m *LabelResponse) XXX_Unmarshal(b []byte) error + func (this *LabelResponse) Equal(that interface{}) bool + func (this *LabelResponse) GoString() string + func (this *LabelResponse) String() string + type LabelToValuesResponse struct + Labels map[string]*UniqueLabelValues + func (*LabelToValuesResponse) Descriptor() ([]byte, []int) + func (*LabelToValuesResponse) ProtoMessage() + func (m *LabelToValuesResponse) GetLabels() map[string]*UniqueLabelValues + func (m *LabelToValuesResponse) Marshal() (dAtA []byte, err error) + func (m *LabelToValuesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LabelToValuesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LabelToValuesResponse) Reset() + func (m *LabelToValuesResponse) Size() (n int) + func (m *LabelToValuesResponse) Unmarshal(dAtA []byte) error + func (m *LabelToValuesResponse) XXX_DiscardUnknown() + func (m *LabelToValuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LabelToValuesResponse) XXX_Merge(src proto.Message) + func (m *LabelToValuesResponse) XXX_Size() int + func (m *LabelToValuesResponse) XXX_Unmarshal(b []byte) error + func (this *LabelToValuesResponse) Equal(that interface{}) bool + func (this *LabelToValuesResponse) GoString() string + func (this *LabelToValuesResponse) String() string + type LabelValuesForMetricNameRequest struct + From github_com_prometheus_common_model.Time + LabelName string + Matchers string + MetricName string + Through github_com_prometheus_common_model.Time + func (*LabelValuesForMetricNameRequest) Descriptor() ([]byte, []int) + func (*LabelValuesForMetricNameRequest) ProtoMessage() + func (m *LabelValuesForMetricNameRequest) GetLabelName() string + func (m *LabelValuesForMetricNameRequest) GetMatchers() string + func (m *LabelValuesForMetricNameRequest) GetMetricName() string + func (m *LabelValuesForMetricNameRequest) Marshal() (dAtA []byte, err error) + func (m *LabelValuesForMetricNameRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LabelValuesForMetricNameRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LabelValuesForMetricNameRequest) Reset() + func (m *LabelValuesForMetricNameRequest) Size() (n int) + func (m *LabelValuesForMetricNameRequest) Unmarshal(dAtA []byte) error + func (m *LabelValuesForMetricNameRequest) XXX_DiscardUnknown() + func (m *LabelValuesForMetricNameRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LabelValuesForMetricNameRequest) XXX_Merge(src proto.Message) + func (m *LabelValuesForMetricNameRequest) XXX_Size() int + func (m *LabelValuesForMetricNameRequest) XXX_Unmarshal(b []byte) error + func (this *LabelValuesForMetricNameRequest) Equal(that interface{}) bool + func (this *LabelValuesForMetricNameRequest) GoString() string + func (this *LabelValuesForMetricNameRequest) String() string + type LegacyLabelPair struct + Name []byte + Value []byte + func (*LegacyLabelPair) Descriptor() ([]byte, []int) + func (*LegacyLabelPair) ProtoMessage() + func (m *LegacyLabelPair) GetName() []byte + func (m *LegacyLabelPair) GetValue() []byte + func (m *LegacyLabelPair) Marshal() (dAtA []byte, err error) + func (m *LegacyLabelPair) MarshalTo(dAtA []byte) (int, error) + func (m *LegacyLabelPair) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LegacyLabelPair) Reset() + func (m *LegacyLabelPair) Size() (n int) + func (m *LegacyLabelPair) Unmarshal(dAtA []byte) error + func (m *LegacyLabelPair) XXX_DiscardUnknown() + func (m *LegacyLabelPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LegacyLabelPair) XXX_Merge(src proto.Message) + func (m *LegacyLabelPair) XXX_Size() int + func (m *LegacyLabelPair) XXX_Unmarshal(b []byte) error + func (this *LegacyLabelPair) Equal(that interface{}) bool + func (this *LegacyLabelPair) GoString() string + func (this *LegacyLabelPair) String() string + type LegacySample struct + TimestampMs int64 + Value float64 + func (*LegacySample) Descriptor() ([]byte, []int) + func (*LegacySample) ProtoMessage() + func (m *LegacySample) GetTimestampMs() int64 + func (m *LegacySample) GetValue() float64 + func (m *LegacySample) Marshal() (dAtA []byte, err error) + func (m *LegacySample) MarshalTo(dAtA []byte) (int, error) + func (m *LegacySample) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LegacySample) Reset() + func (m *LegacySample) Size() (n int) + func (m *LegacySample) Unmarshal(dAtA []byte) error + func (m *LegacySample) XXX_DiscardUnknown() + func (m *LegacySample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LegacySample) XXX_Merge(src proto.Message) + func (m *LegacySample) XXX_Size() int + func (m *LegacySample) XXX_Unmarshal(b []byte) error + func (s *LegacySample) UnmarshalJSON(b []byte) error + func (s LegacySample) MarshalJSON() ([]byte, error) + func (this *LegacySample) Equal(that interface{}) bool + func (this *LegacySample) GoString() string + func (this *LegacySample) String() string + type LineFilter struct + Raw []byte + func (*LineFilter) Descriptor() ([]byte, []int) + func (*LineFilter) ProtoMessage() + func (m *LineFilter) GetRaw() []byte + func (m *LineFilter) Marshal() (dAtA []byte, err error) + func (m *LineFilter) MarshalTo(dAtA []byte) (int, error) + func (m *LineFilter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LineFilter) Reset() + func (m *LineFilter) Size() (n int) + func (m *LineFilter) Unmarshal(dAtA []byte) error + func (m *LineFilter) XXX_DiscardUnknown() + func (m *LineFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LineFilter) XXX_Merge(src proto.Message) + func (m *LineFilter) XXX_Size() int + func (m *LineFilter) XXX_Unmarshal(b []byte) error + func (this *LineFilter) Equal(that interface{}) bool + func (this *LineFilter) GoString() string + func (this *LineFilter) 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) MarshalToSizedBuffer(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 MetricMetadata struct + Help string + MetricFamilyName string + Type MetricMetadata_MetricType + Unit string + func (*MetricMetadata) Descriptor() ([]byte, []int) + func (*MetricMetadata) ProtoMessage() + func (m *MetricMetadata) GetHelp() string + func (m *MetricMetadata) GetMetricFamilyName() 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 PatternClient interface + Push func(ctx context.Context, in *push.PushRequest, opts ...grpc.CallOption) (*push.PushResponse, error) + Query func(ctx context.Context, in *QueryPatternsRequest, opts ...grpc.CallOption) (Pattern_QueryClient, error) + func NewPatternClient(cc *grpc.ClientConn) PatternClient + type PatternSample struct + Timestamp github_com_prometheus_common_model.Time + Value int64 + func (*PatternSample) Descriptor() ([]byte, []int) + func (*PatternSample) ProtoMessage() + func (m *PatternSample) GetValue() int64 + func (m *PatternSample) Marshal() (dAtA []byte, err error) + func (m *PatternSample) MarshalTo(dAtA []byte) (int, error) + func (m *PatternSample) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PatternSample) Reset() + func (m *PatternSample) Size() (n int) + func (m *PatternSample) Unmarshal(dAtA []byte) error + func (m *PatternSample) XXX_DiscardUnknown() + func (m *PatternSample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PatternSample) XXX_Merge(src proto.Message) + func (m *PatternSample) XXX_Size() int + func (m *PatternSample) XXX_Unmarshal(b []byte) error + func (this *PatternSample) Equal(that interface{}) bool + func (this *PatternSample) GoString() string + func (this *PatternSample) String() string + type PatternSeries struct + Pattern string + Samples []*PatternSample + func (*PatternSeries) Descriptor() ([]byte, []int) + func (*PatternSeries) ProtoMessage() + func (m *PatternSeries) GetPattern() string + func (m *PatternSeries) GetSamples() []*PatternSample + func (m *PatternSeries) Marshal() (dAtA []byte, err error) + func (m *PatternSeries) MarshalTo(dAtA []byte) (int, error) + func (m *PatternSeries) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PatternSeries) Reset() + func (m *PatternSeries) Size() (n int) + func (m *PatternSeries) Unmarshal(dAtA []byte) error + func (m *PatternSeries) XXX_DiscardUnknown() + func (m *PatternSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PatternSeries) XXX_Merge(src proto.Message) + func (m *PatternSeries) XXX_Size() int + func (m *PatternSeries) XXX_Unmarshal(b []byte) error + func (this *PatternSeries) Equal(that interface{}) bool + func (this *PatternSeries) GoString() string + func (this *PatternSeries) String() string + type PatternServer interface + Push func(context.Context, *push.PushRequest) (*push.PushResponse, error) + Query func(*QueryPatternsRequest, Pattern_QueryServer) error + type Pattern_QueryClient interface + Recv func() (*QueryPatternsResponse, error) + type Pattern_QueryServer interface + Send func(*QueryPatternsResponse) error + type Plan struct + Raw []byte + func (*Plan) Descriptor() ([]byte, []int) + func (*Plan) ProtoMessage() + func (m *Plan) GetRaw() []byte + func (m *Plan) Marshal() (dAtA []byte, err error) + func (m *Plan) MarshalTo(dAtA []byte) (int, error) + func (m *Plan) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Plan) Reset() + func (m *Plan) Size() (n int) + func (m *Plan) Unmarshal(dAtA []byte) error + func (m *Plan) XXX_DiscardUnknown() + func (m *Plan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Plan) XXX_Merge(src proto.Message) + func (m *Plan) XXX_Size() int + func (m *Plan) XXX_Unmarshal(b []byte) error + func (this *Plan) Equal(that interface{}) bool + func (this *Plan) GoString() string + func (this *Plan) String() string + type PreallocConfig struct + func (PreallocConfig) RegisterFlags(f *flag.FlagSet) + type PreallocTimeseries struct + func PreallocTimeseriesSliceFromPool() []PreallocTimeseries + func (p *PreallocTimeseries) Unmarshal(dAtA []byte) error + type PreallocWriteRequest struct + func (p *PreallocWriteRequest) Unmarshal(dAtA []byte) error + type PushRequest = push.PushRequest + type PushResponse = push.PushResponse + type PusherClient = push.PusherClient + func NewPusherClient(cc *grpc.ClientConn) PusherClient + type PusherServer = push.PusherServer + type QuantileSketch struct + Sketch isQuantileSketch_Sketch + func (*QuantileSketch) Descriptor() ([]byte, []int) + func (*QuantileSketch) ProtoMessage() + func (*QuantileSketch) XXX_OneofWrappers() []interface{} + func (m *QuantileSketch) GetDdsketch() []byte + func (m *QuantileSketch) GetSketch() isQuantileSketch_Sketch + func (m *QuantileSketch) GetTdigest() *TDigest + func (m *QuantileSketch) Marshal() (dAtA []byte, err error) + func (m *QuantileSketch) MarshalTo(dAtA []byte) (int, error) + func (m *QuantileSketch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QuantileSketch) Reset() + func (m *QuantileSketch) Size() (n int) + func (m *QuantileSketch) Unmarshal(dAtA []byte) error + func (m *QuantileSketch) XXX_DiscardUnknown() + func (m *QuantileSketch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QuantileSketch) XXX_Merge(src proto.Message) + func (m *QuantileSketch) XXX_Size() int + func (m *QuantileSketch) XXX_Unmarshal(b []byte) error + func (this *QuantileSketch) Equal(that interface{}) bool + func (this *QuantileSketch) GoString() string + func (this *QuantileSketch) String() string + type QuantileSketchMatrix struct + Values []*QuantileSketchVector + func (*QuantileSketchMatrix) Descriptor() ([]byte, []int) + func (*QuantileSketchMatrix) ProtoMessage() + func (m *QuantileSketchMatrix) GetValues() []*QuantileSketchVector + func (m *QuantileSketchMatrix) Marshal() (dAtA []byte, err error) + func (m *QuantileSketchMatrix) MarshalTo(dAtA []byte) (int, error) + func (m *QuantileSketchMatrix) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QuantileSketchMatrix) Reset() + func (m *QuantileSketchMatrix) Size() (n int) + func (m *QuantileSketchMatrix) Unmarshal(dAtA []byte) error + func (m *QuantileSketchMatrix) XXX_DiscardUnknown() + func (m *QuantileSketchMatrix) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QuantileSketchMatrix) XXX_Merge(src proto.Message) + func (m *QuantileSketchMatrix) XXX_Size() int + func (m *QuantileSketchMatrix) XXX_Unmarshal(b []byte) error + func (this *QuantileSketchMatrix) Equal(that interface{}) bool + func (this *QuantileSketchMatrix) GoString() string + func (this *QuantileSketchMatrix) String() string + type QuantileSketchSample struct + F *QuantileSketch + Metric []*LabelPair + TimestampMs int64 + func (*QuantileSketchSample) Descriptor() ([]byte, []int) + func (*QuantileSketchSample) ProtoMessage() + func (m *QuantileSketchSample) GetF() *QuantileSketch + func (m *QuantileSketchSample) GetMetric() []*LabelPair + func (m *QuantileSketchSample) GetTimestampMs() int64 + func (m *QuantileSketchSample) Marshal() (dAtA []byte, err error) + func (m *QuantileSketchSample) MarshalTo(dAtA []byte) (int, error) + func (m *QuantileSketchSample) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QuantileSketchSample) Reset() + func (m *QuantileSketchSample) Size() (n int) + func (m *QuantileSketchSample) Unmarshal(dAtA []byte) error + func (m *QuantileSketchSample) XXX_DiscardUnknown() + func (m *QuantileSketchSample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QuantileSketchSample) XXX_Merge(src proto.Message) + func (m *QuantileSketchSample) XXX_Size() int + func (m *QuantileSketchSample) XXX_Unmarshal(b []byte) error + func (this *QuantileSketchSample) Equal(that interface{}) bool + func (this *QuantileSketchSample) GoString() string + func (this *QuantileSketchSample) String() string + type QuantileSketchVector struct + Samples []*QuantileSketchSample + func (*QuantileSketchVector) Descriptor() ([]byte, []int) + func (*QuantileSketchVector) ProtoMessage() + func (m *QuantileSketchVector) GetSamples() []*QuantileSketchSample + func (m *QuantileSketchVector) Marshal() (dAtA []byte, err error) + func (m *QuantileSketchVector) MarshalTo(dAtA []byte) (int, error) + func (m *QuantileSketchVector) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QuantileSketchVector) Reset() + func (m *QuantileSketchVector) Size() (n int) + func (m *QuantileSketchVector) Unmarshal(dAtA []byte) error + func (m *QuantileSketchVector) XXX_DiscardUnknown() + func (m *QuantileSketchVector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QuantileSketchVector) XXX_Merge(src proto.Message) + func (m *QuantileSketchVector) XXX_Size() int + func (m *QuantileSketchVector) XXX_Unmarshal(b []byte) error + func (this *QuantileSketchVector) Equal(that interface{}) bool + func (this *QuantileSketchVector) GoString() string + func (this *QuantileSketchVector) String() string + type QuantileSketch_Ddsketch struct + Ddsketch []byte + func (m *QuantileSketch_Ddsketch) MarshalTo(dAtA []byte) (int, error) + func (m *QuantileSketch_Ddsketch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QuantileSketch_Ddsketch) Size() (n int) + func (this *QuantileSketch_Ddsketch) Equal(that interface{}) bool + func (this *QuantileSketch_Ddsketch) GoString() string + func (this *QuantileSketch_Ddsketch) String() string + type QuantileSketch_Tdigest struct + Tdigest *TDigest + func (m *QuantileSketch_Tdigest) MarshalTo(dAtA []byte) (int, error) + func (m *QuantileSketch_Tdigest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QuantileSketch_Tdigest) Size() (n int) + func (this *QuantileSketch_Tdigest) Equal(that interface{}) bool + func (this *QuantileSketch_Tdigest) GoString() string + func (this *QuantileSketch_Tdigest) String() string + type QuerierClient interface + GetChunkIDs func(ctx context.Context, in *GetChunkIDsRequest, opts ...grpc.CallOption) (*GetChunkIDsResponse, error) + GetDetectedFields func(ctx context.Context, in *DetectedFieldsRequest, opts ...grpc.CallOption) (*DetectedFieldsResponse, error) + GetDetectedLabels func(ctx context.Context, in *DetectedLabelsRequest, opts ...grpc.CallOption) (*LabelToValuesResponse, error) + GetStats func(ctx context.Context, in *IndexStatsRequest, opts ...grpc.CallOption) (*IndexStatsResponse, error) + GetVolume func(ctx context.Context, in *VolumeRequest, opts ...grpc.CallOption) (*VolumeResponse, error) + Label func(ctx context.Context, in *LabelRequest, opts ...grpc.CallOption) (*LabelResponse, error) + Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Querier_QueryClient, error) + QuerySample func(ctx context.Context, in *SampleQueryRequest, opts ...grpc.CallOption) (Querier_QuerySampleClient, error) + Series func(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (*SeriesResponse, error) + Tail func(ctx context.Context, in *TailRequest, opts ...grpc.CallOption) (Querier_TailClient, error) + TailersCount func(ctx context.Context, in *TailersCountRequest, opts ...grpc.CallOption) (*TailersCountResponse, error) + func NewQuerierClient(cc *grpc.ClientConn) QuerierClient + type QuerierServer interface + GetChunkIDs func(context.Context, *GetChunkIDsRequest) (*GetChunkIDsResponse, error) + GetDetectedFields func(context.Context, *DetectedFieldsRequest) (*DetectedFieldsResponse, error) + GetDetectedLabels func(context.Context, *DetectedLabelsRequest) (*LabelToValuesResponse, error) + GetStats func(context.Context, *IndexStatsRequest) (*IndexStatsResponse, error) + GetVolume func(context.Context, *VolumeRequest) (*VolumeResponse, error) + Label func(context.Context, *LabelRequest) (*LabelResponse, error) + Query func(*QueryRequest, Querier_QueryServer) error + QuerySample func(*SampleQueryRequest, Querier_QuerySampleServer) error + Series func(context.Context, *SeriesRequest) (*SeriesResponse, error) + Tail func(*TailRequest, Querier_TailServer) error + TailersCount func(context.Context, *TailersCountRequest) (*TailersCountResponse, error) + type Querier_QueryClient interface + Recv func() (*QueryResponse, error) + type Querier_QuerySampleClient interface + Recv func() (*SampleQueryResponse, error) + type Querier_QuerySampleServer interface + Send func(*SampleQueryResponse) error + type Querier_QueryServer interface + Send func(*QueryResponse) error + type Querier_TailClient interface + Recv func() (*TailResponse, error) + type Querier_TailServer interface + Send func(*TailResponse) error + type QueryIndexRequest struct + Queries []*IndexQuery + func (*QueryIndexRequest) Descriptor() ([]byte, []int) + func (*QueryIndexRequest) ProtoMessage() + func (m *QueryIndexRequest) GetQueries() []*IndexQuery + func (m *QueryIndexRequest) Marshal() (dAtA []byte, err error) + func (m *QueryIndexRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryIndexRequest) Reset() + func (m *QueryIndexRequest) Size() (n int) + func (m *QueryIndexRequest) Unmarshal(dAtA []byte) error + func (m *QueryIndexRequest) XXX_DiscardUnknown() + func (m *QueryIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryIndexRequest) XXX_Merge(src proto.Message) + func (m *QueryIndexRequest) XXX_Size() int + func (m *QueryIndexRequest) XXX_Unmarshal(b []byte) error + func (this *QueryIndexRequest) Equal(that interface{}) bool + func (this *QueryIndexRequest) GoString() string + func (this *QueryIndexRequest) String() string + type QueryIndexResponse struct + QueryKey string + Rows []*Row + func (*QueryIndexResponse) Descriptor() ([]byte, []int) + func (*QueryIndexResponse) ProtoMessage() + func (m *QueryIndexResponse) GetQueryKey() string + func (m *QueryIndexResponse) GetRows() []*Row + func (m *QueryIndexResponse) Marshal() (dAtA []byte, err error) + func (m *QueryIndexResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryIndexResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryIndexResponse) Reset() + func (m *QueryIndexResponse) Size() (n int) + func (m *QueryIndexResponse) Unmarshal(dAtA []byte) error + func (m *QueryIndexResponse) XXX_DiscardUnknown() + func (m *QueryIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryIndexResponse) XXX_Merge(src proto.Message) + func (m *QueryIndexResponse) XXX_Size() int + func (m *QueryIndexResponse) XXX_Unmarshal(b []byte) error + func (this *QueryIndexResponse) Equal(that interface{}) bool + func (this *QueryIndexResponse) GoString() string + func (this *QueryIndexResponse) String() string + type QueryPatternsRequest struct + End time.Time + Query string + Start time.Time + func (*QueryPatternsRequest) Descriptor() ([]byte, []int) + func (*QueryPatternsRequest) ProtoMessage() + func (m *QueryPatternsRequest) GetCachingOptions() (res definitions.CachingOptions) + func (m *QueryPatternsRequest) GetEnd() time.Time + func (m *QueryPatternsRequest) GetQuery() string + func (m *QueryPatternsRequest) GetStart() time.Time + func (m *QueryPatternsRequest) GetStep() int64 + func (m *QueryPatternsRequest) LogToSpan(sp opentracing.Span) + func (m *QueryPatternsRequest) Marshal() (dAtA []byte, err error) + func (m *QueryPatternsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryPatternsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryPatternsRequest) Reset() + func (m *QueryPatternsRequest) Size() (n int) + func (m *QueryPatternsRequest) Unmarshal(dAtA []byte) error + func (m *QueryPatternsRequest) WithQuery(query string) definitions.Request + func (m *QueryPatternsRequest) WithStartEnd(start, end time.Time) definitions.Request + func (m *QueryPatternsRequest) WithStartEndForCache(start, end time.Time) resultscache.Request + func (m *QueryPatternsRequest) XXX_DiscardUnknown() + func (m *QueryPatternsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryPatternsRequest) XXX_Merge(src proto.Message) + func (m *QueryPatternsRequest) XXX_Size() int + func (m *QueryPatternsRequest) XXX_Unmarshal(b []byte) error + func (this *QueryPatternsRequest) Equal(that interface{}) bool + func (this *QueryPatternsRequest) GoString() string + func (this *QueryPatternsRequest) String() string + type QueryPatternsResponse struct + Series []*PatternSeries + func (*QueryPatternsResponse) Descriptor() ([]byte, []int) + func (*QueryPatternsResponse) ProtoMessage() + func (m *QueryPatternsResponse) GetSeries() []*PatternSeries + func (m *QueryPatternsResponse) Marshal() (dAtA []byte, err error) + func (m *QueryPatternsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryPatternsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryPatternsResponse) Reset() + func (m *QueryPatternsResponse) Size() (n int) + func (m *QueryPatternsResponse) Unmarshal(dAtA []byte) error + func (m *QueryPatternsResponse) XXX_DiscardUnknown() + func (m *QueryPatternsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryPatternsResponse) XXX_Merge(src proto.Message) + func (m *QueryPatternsResponse) XXX_Size() int + func (m *QueryPatternsResponse) XXX_Unmarshal(b []byte) error + func (r *QueryPatternsResponse) UnmarshalJSON(data []byte) error + func (this *QueryPatternsResponse) Equal(that interface{}) bool + func (this *QueryPatternsResponse) GoString() string + func (this *QueryPatternsResponse) String() string + type QueryRequest struct + Deletes []*Delete + Direction Direction + End time.Time + Limit uint32 + Plan *github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan + Selector string + Shards []string + Start time.Time + func (*QueryRequest) Descriptor() ([]byte, []int) + func (*QueryRequest) ProtoMessage() + func (m *QueryRequest) GetDeletes() []*Delete + func (m *QueryRequest) GetDirection() Direction + func (m *QueryRequest) GetEnd() time.Time + func (m *QueryRequest) GetLimit() uint32 + func (m *QueryRequest) GetSelector() string + func (m *QueryRequest) GetShards() []string + func (m *QueryRequest) GetStart() time.Time + func (m *QueryRequest) Marshal() (dAtA []byte, err error) + func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest) MarshalToSizedBuffer(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 + Stats stats.Ingester + Streams []github_com_grafana_loki_pkg_push.Stream + Warnings []string + func (*QueryResponse) Descriptor() ([]byte, []int) + func (*QueryResponse) ProtoMessage() + func (m *QueryResponse) GetStats() stats.Ingester + func (m *QueryResponse) GetWarnings() []string + func (m *QueryResponse) Marshal() (dAtA []byte, err error) + func (m *QueryResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse) MarshalToSizedBuffer(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 Row struct + RangeValue []byte + Value []byte + func (*Row) Descriptor() ([]byte, []int) + func (*Row) ProtoMessage() + func (m *Row) GetRangeValue() []byte + func (m *Row) GetValue() []byte + func (m *Row) Marshal() (dAtA []byte, err error) + func (m *Row) MarshalTo(dAtA []byte) (int, error) + func (m *Row) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Row) Reset() + func (m *Row) Size() (n int) + func (m *Row) Unmarshal(dAtA []byte) error + func (m *Row) XXX_DiscardUnknown() + func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Row) XXX_Merge(src proto.Message) + func (m *Row) XXX_Size() int + func (m *Row) XXX_Unmarshal(b []byte) error + func (this *Row) Equal(that interface{}) bool + func (this *Row) GoString() string + func (this *Row) String() string + type Sample struct + Hash uint64 + Timestamp int64 + Value float64 + func (*Sample) Descriptor() ([]byte, []int) + func (*Sample) ProtoMessage() + func (m *Sample) GetHash() uint64 + func (m *Sample) GetTimestamp() 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) MarshalToSizedBuffer(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 (this *Sample) Equal(that interface{}) bool + func (this *Sample) GoString() string + func (this *Sample) String() string + type SampleQueryRequest struct + Deletes []*Delete + End time.Time + Plan *github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan + Selector string + Shards []string + Start time.Time + func (*SampleQueryRequest) Descriptor() ([]byte, []int) + func (*SampleQueryRequest) ProtoMessage() + func (m *SampleQueryRequest) GetDeletes() []*Delete + func (m *SampleQueryRequest) GetEnd() time.Time + func (m *SampleQueryRequest) GetSelector() string + func (m *SampleQueryRequest) GetShards() []string + func (m *SampleQueryRequest) GetStart() time.Time + func (m *SampleQueryRequest) Marshal() (dAtA []byte, err error) + func (m *SampleQueryRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SampleQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SampleQueryRequest) Reset() + func (m *SampleQueryRequest) Size() (n int) + func (m *SampleQueryRequest) Unmarshal(dAtA []byte) error + func (m *SampleQueryRequest) XXX_DiscardUnknown() + func (m *SampleQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SampleQueryRequest) XXX_Merge(src proto.Message) + func (m *SampleQueryRequest) XXX_Size() int + func (m *SampleQueryRequest) XXX_Unmarshal(b []byte) error + func (this *SampleQueryRequest) Equal(that interface{}) bool + func (this *SampleQueryRequest) GoString() string + func (this *SampleQueryRequest) String() string + type SampleQueryResponse struct + Series []Series + Stats stats.Ingester + Warnings []string + func (*SampleQueryResponse) Descriptor() ([]byte, []int) + func (*SampleQueryResponse) ProtoMessage() + func (m *SampleQueryResponse) GetStats() stats.Ingester + func (m *SampleQueryResponse) GetWarnings() []string + func (m *SampleQueryResponse) Marshal() (dAtA []byte, err error) + func (m *SampleQueryResponse) MarshalTo(dAtA []byte) (int, error) + func (m *SampleQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SampleQueryResponse) Reset() + func (m *SampleQueryResponse) Size() (n int) + func (m *SampleQueryResponse) Unmarshal(dAtA []byte) error + func (m *SampleQueryResponse) XXX_DiscardUnknown() + func (m *SampleQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SampleQueryResponse) XXX_Merge(src proto.Message) + func (m *SampleQueryResponse) XXX_Size() int + func (m *SampleQueryResponse) XXX_Unmarshal(b []byte) error + func (this *SampleQueryResponse) Equal(that interface{}) bool + func (this *SampleQueryResponse) GoString() string + func (this *SampleQueryResponse) String() string + type Series struct + Labels string + Samples []Sample + StreamHash uint64 + func (*Series) Descriptor() ([]byte, []int) + func (*Series) ProtoMessage() + func (m *Series) GetLabels() string + func (m *Series) GetSamples() []Sample + func (m *Series) GetStreamHash() uint64 + func (m *Series) Marshal() (dAtA []byte, err error) + func (m *Series) MarshalTo(dAtA []byte) (int, error) + func (m *Series) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Series) Reset() + func (m *Series) Size() (n int) + func (m *Series) Unmarshal(dAtA []byte) error + func (m *Series) XXX_DiscardUnknown() + func (m *Series) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Series) XXX_Merge(src proto.Message) + func (m *Series) XXX_Size() int + func (m *Series) XXX_Unmarshal(b []byte) error + func (s Series) Len() int + func (s Series) Less(i, j int) bool + func (s Series) Swap(i, j int) + func (this *Series) Equal(that interface{}) bool + func (this *Series) GoString() string + func (this *Series) String() string + type SeriesIdentifier struct + Labels []SeriesIdentifier_LabelsEntry + func SeriesIdentifierFromLabels(in labels.Labels) SeriesIdentifier + func SeriesIdentifierFromMap(in map[string]string) SeriesIdentifier + func (*SeriesIdentifier) Descriptor() ([]byte, []int) + func (*SeriesIdentifier) ProtoMessage() + func (id SeriesIdentifier) Get(key string) string + func (id SeriesIdentifier) Hash(b []byte) uint64 + func (id SeriesIdentifier) Len() int + func (id SeriesIdentifier) Less(i, j int) bool + func (id SeriesIdentifier) Swap(i, j int) + func (m *SeriesIdentifier) GetLabels() []SeriesIdentifier_LabelsEntry + func (m *SeriesIdentifier) Marshal() (dAtA []byte, err error) + func (m *SeriesIdentifier) MarshalTo(dAtA []byte) (int, error) + func (m *SeriesIdentifier) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SeriesIdentifier) Reset() + func (m *SeriesIdentifier) Size() (n int) + func (m *SeriesIdentifier) Unmarshal(dAtA []byte) error + func (m *SeriesIdentifier) XXX_DiscardUnknown() + func (m *SeriesIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SeriesIdentifier) XXX_Merge(src proto.Message) + func (m *SeriesIdentifier) XXX_Size() int + func (m *SeriesIdentifier) XXX_Unmarshal(b []byte) error + func (this *SeriesIdentifier) Equal(that interface{}) bool + func (this *SeriesIdentifier) GoString() string + func (this *SeriesIdentifier) String() string + type SeriesIdentifier_LabelsEntry struct + Key string + Value string + func MustNewSeriesEntries(labels ...string) []SeriesIdentifier_LabelsEntry + func (*SeriesIdentifier_LabelsEntry) Descriptor() ([]byte, []int) + func (*SeriesIdentifier_LabelsEntry) ProtoMessage() + func (m *SeriesIdentifier_LabelsEntry) GetKey() string + func (m *SeriesIdentifier_LabelsEntry) GetValue() string + func (m *SeriesIdentifier_LabelsEntry) Marshal() (dAtA []byte, err error) + func (m *SeriesIdentifier_LabelsEntry) MarshalTo(dAtA []byte) (int, error) + func (m *SeriesIdentifier_LabelsEntry) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SeriesIdentifier_LabelsEntry) Reset() + func (m *SeriesIdentifier_LabelsEntry) Size() (n int) + func (m *SeriesIdentifier_LabelsEntry) Unmarshal(dAtA []byte) error + func (m *SeriesIdentifier_LabelsEntry) XXX_DiscardUnknown() + func (m *SeriesIdentifier_LabelsEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SeriesIdentifier_LabelsEntry) XXX_Merge(src proto.Message) + func (m *SeriesIdentifier_LabelsEntry) XXX_Size() int + func (m *SeriesIdentifier_LabelsEntry) XXX_Unmarshal(b []byte) error + func (this *SeriesIdentifier_LabelsEntry) Equal(that interface{}) bool + func (this *SeriesIdentifier_LabelsEntry) GoString() string + func (this *SeriesIdentifier_LabelsEntry) String() string + type SeriesRequest struct + End time.Time + Groups []string + Shards []string + Start time.Time + func (*SeriesRequest) Descriptor() ([]byte, []int) + func (*SeriesRequest) ProtoMessage() + func (m *SeriesRequest) GetEnd() time.Time + func (m *SeriesRequest) GetGroups() []string + func (m *SeriesRequest) GetShards() []string + func (m *SeriesRequest) GetStart() time.Time + 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 SeriesResponse struct + Series []SeriesIdentifier + func MergeSeriesResponses(responses []*SeriesResponse) (*SeriesResponse, error) + func (*SeriesResponse) Descriptor() ([]byte, []int) + func (*SeriesResponse) ProtoMessage() + func (m *SeriesResponse) GetSeries() []SeriesIdentifier + func (m *SeriesResponse) Marshal() (dAtA []byte, err error) + func (m *SeriesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *SeriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SeriesResponse) Reset() + func (m *SeriesResponse) Size() (n int) + func (m *SeriesResponse) Unmarshal(dAtA []byte) error + func (m *SeriesResponse) XXX_DiscardUnknown() + func (m *SeriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SeriesResponse) XXX_Merge(src proto.Message) + func (m *SeriesResponse) XXX_Size() int + func (m *SeriesResponse) XXX_Unmarshal(b []byte) error + func (this *SeriesResponse) Equal(that interface{}) bool + func (this *SeriesResponse) GoString() string + func (this *SeriesResponse) String() string + type Shard struct + Bounds FPBounds + Stats *IndexStatsResponse + func (*Shard) Descriptor() ([]byte, []int) + func (*Shard) ProtoMessage() + func (m *Shard) GetBounds() FPBounds + func (m *Shard) GetStats() *IndexStatsResponse + func (m *Shard) Marshal() (dAtA []byte, err error) + func (m *Shard) MarshalTo(dAtA []byte) (int, error) + func (m *Shard) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Shard) Reset() + func (m *Shard) Size() (n int) + func (m *Shard) SpaceFor(stats *IndexStatsResponse, targetShardBytes uint64) bool + func (m *Shard) Unmarshal(dAtA []byte) error + func (m *Shard) XXX_DiscardUnknown() + func (m *Shard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Shard) XXX_Merge(src proto.Message) + func (m *Shard) XXX_Size() int + func (m *Shard) XXX_Unmarshal(b []byte) error + func (this *Shard) Equal(that interface{}) bool + func (this *Shard) GoString() string + func (this *Shard) String() string + type ShardsRequest struct + From github_com_prometheus_common_model.Time + Query string + TargetBytesPerShard uint64 + Through github_com_prometheus_common_model.Time + func (*ShardsRequest) Descriptor() ([]byte, []int) + func (*ShardsRequest) ProtoMessage() + func (m *ShardsRequest) GetCachingOptions() (res definitions.CachingOptions) + func (m *ShardsRequest) GetEnd() time.Time + func (m *ShardsRequest) GetQuery() string + func (m *ShardsRequest) GetStart() time.Time + func (m *ShardsRequest) GetStep() int64 + func (m *ShardsRequest) GetTargetBytesPerShard() uint64 + func (m *ShardsRequest) LogToSpan(sp opentracing.Span) + func (m *ShardsRequest) Marshal() (dAtA []byte, err error) + func (m *ShardsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ShardsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShardsRequest) Reset() + func (m *ShardsRequest) Size() (n int) + func (m *ShardsRequest) Unmarshal(dAtA []byte) error + func (m *ShardsRequest) WithQuery(query string) definitions.Request + func (m *ShardsRequest) WithStartEnd(start, end time.Time) definitions.Request + func (m *ShardsRequest) WithStartEndForCache(start, end time.Time) resultscache.Request + func (m *ShardsRequest) XXX_DiscardUnknown() + func (m *ShardsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardsRequest) XXX_Merge(src proto.Message) + func (m *ShardsRequest) XXX_Size() int + func (m *ShardsRequest) XXX_Unmarshal(b []byte) error + func (this *ShardsRequest) Equal(that interface{}) bool + func (this *ShardsRequest) GoString() string + func (this *ShardsRequest) String() string + type ShardsResponse struct + Shards []Shard + Statistics stats.Result + func (*ShardsResponse) Descriptor() ([]byte, []int) + func (*ShardsResponse) ProtoMessage() + func (m *ShardsResponse) GetShards() []Shard + func (m *ShardsResponse) GetStatistics() stats.Result + func (m *ShardsResponse) Marshal() (dAtA []byte, err error) + func (m *ShardsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ShardsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShardsResponse) Reset() + func (m *ShardsResponse) Size() (n int) + func (m *ShardsResponse) Unmarshal(dAtA []byte) error + func (m *ShardsResponse) XXX_DiscardUnknown() + func (m *ShardsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardsResponse) XXX_Merge(src proto.Message) + func (m *ShardsResponse) XXX_Size() int + func (m *ShardsResponse) XXX_Unmarshal(b []byte) error + func (this *ShardsResponse) Equal(that interface{}) bool + func (this *ShardsResponse) GoString() string + func (this *ShardsResponse) String() string + type ShortRef struct + Checksum uint32 + From github_com_prometheus_common_model.Time + Through github_com_prometheus_common_model.Time + func (*ShortRef) Descriptor() ([]byte, []int) + func (*ShortRef) ProtoMessage() + func (m *ShortRef) GetChecksum() uint32 + func (m *ShortRef) Marshal() (dAtA []byte, err error) + func (m *ShortRef) MarshalTo(dAtA []byte) (int, error) + func (m *ShortRef) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShortRef) Reset() + func (m *ShortRef) Size() (n int) + func (m *ShortRef) Unmarshal(dAtA []byte) error + func (m *ShortRef) XXX_DiscardUnknown() + func (m *ShortRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShortRef) XXX_Merge(src proto.Message) + func (m *ShortRef) XXX_Size() int + func (m *ShortRef) XXX_Unmarshal(b []byte) error + func (this *ShortRef) Equal(that interface{}) bool + func (this *ShortRef) GoString() string + func (this *ShortRef) String() string + type Stream = push.Stream + type StreamDataClient interface + GetStreamRates func(ctx context.Context, in *StreamRatesRequest, opts ...grpc.CallOption) (*StreamRatesResponse, error) + func NewStreamDataClient(cc *grpc.ClientConn) StreamDataClient + type StreamDataServer interface + GetStreamRates func(context.Context, *StreamRatesRequest) (*StreamRatesResponse, error) + type StreamRate struct + Pushes uint32 + Rate int64 + StreamHash uint64 + StreamHashNoShard uint64 + Tenant string + func (*StreamRate) Descriptor() ([]byte, []int) + func (*StreamRate) ProtoMessage() + func (m *StreamRate) GetPushes() uint32 + func (m *StreamRate) GetRate() int64 + func (m *StreamRate) GetStreamHash() uint64 + func (m *StreamRate) GetStreamHashNoShard() uint64 + func (m *StreamRate) GetTenant() string + func (m *StreamRate) Marshal() (dAtA []byte, err error) + func (m *StreamRate) MarshalTo(dAtA []byte) (int, error) + func (m *StreamRate) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StreamRate) Reset() + func (m *StreamRate) Size() (n int) + func (m *StreamRate) Unmarshal(dAtA []byte) error + func (m *StreamRate) XXX_DiscardUnknown() + func (m *StreamRate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamRate) XXX_Merge(src proto.Message) + func (m *StreamRate) XXX_Size() int + func (m *StreamRate) XXX_Unmarshal(b []byte) error + func (this *StreamRate) Equal(that interface{}) bool + func (this *StreamRate) GoString() string + func (this *StreamRate) String() string + type StreamRatesRequest struct + func (*StreamRatesRequest) Descriptor() ([]byte, []int) + func (*StreamRatesRequest) ProtoMessage() + func (m *StreamRatesRequest) Marshal() (dAtA []byte, err error) + func (m *StreamRatesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *StreamRatesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StreamRatesRequest) Reset() + func (m *StreamRatesRequest) Size() (n int) + func (m *StreamRatesRequest) Unmarshal(dAtA []byte) error + func (m *StreamRatesRequest) XXX_DiscardUnknown() + func (m *StreamRatesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamRatesRequest) XXX_Merge(src proto.Message) + func (m *StreamRatesRequest) XXX_Size() int + func (m *StreamRatesRequest) XXX_Unmarshal(b []byte) error + func (this *StreamRatesRequest) Equal(that interface{}) bool + func (this *StreamRatesRequest) GoString() string + func (this *StreamRatesRequest) String() string + type StreamRatesResponse struct + StreamRates []*StreamRate + func (*StreamRatesResponse) Descriptor() ([]byte, []int) + func (*StreamRatesResponse) ProtoMessage() + func (m *StreamRatesResponse) GetStreamRates() []*StreamRate + func (m *StreamRatesResponse) Marshal() (dAtA []byte, err error) + func (m *StreamRatesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *StreamRatesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StreamRatesResponse) Reset() + func (m *StreamRatesResponse) Size() (n int) + func (m *StreamRatesResponse) Unmarshal(dAtA []byte) error + func (m *StreamRatesResponse) XXX_DiscardUnknown() + func (m *StreamRatesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamRatesResponse) XXX_Merge(src proto.Message) + func (m *StreamRatesResponse) XXX_Size() int + func (m *StreamRatesResponse) XXX_Unmarshal(b []byte) error + func (this *StreamRatesResponse) Equal(that interface{}) bool + func (this *StreamRatesResponse) GoString() string + func (this *StreamRatesResponse) String() string + type Streams []Stream + func (xs Streams) Len() int + func (xs Streams) Less(i, j int) bool + func (xs Streams) Swap(i, j int) + type TDigest struct + Compression float64 + Max float64 + Min float64 + Processed []*TDigest_Centroid + func (*TDigest) Descriptor() ([]byte, []int) + func (*TDigest) ProtoMessage() + func (m *TDigest) GetCompression() float64 + func (m *TDigest) GetMax() float64 + func (m *TDigest) GetMin() float64 + func (m *TDigest) GetProcessed() []*TDigest_Centroid + func (m *TDigest) Marshal() (dAtA []byte, err error) + func (m *TDigest) MarshalTo(dAtA []byte) (int, error) + func (m *TDigest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TDigest) Reset() + func (m *TDigest) Size() (n int) + func (m *TDigest) Unmarshal(dAtA []byte) error + func (m *TDigest) XXX_DiscardUnknown() + func (m *TDigest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TDigest) XXX_Merge(src proto.Message) + func (m *TDigest) XXX_Size() int + func (m *TDigest) XXX_Unmarshal(b []byte) error + func (this *TDigest) Equal(that interface{}) bool + func (this *TDigest) GoString() string + func (this *TDigest) String() string + type TDigest_Centroid struct + Mean float64 + Weight float64 + func (*TDigest_Centroid) Descriptor() ([]byte, []int) + func (*TDigest_Centroid) ProtoMessage() + func (m *TDigest_Centroid) GetMean() float64 + func (m *TDigest_Centroid) GetWeight() float64 + func (m *TDigest_Centroid) Marshal() (dAtA []byte, err error) + func (m *TDigest_Centroid) MarshalTo(dAtA []byte) (int, error) + func (m *TDigest_Centroid) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TDigest_Centroid) Reset() + func (m *TDigest_Centroid) Size() (n int) + func (m *TDigest_Centroid) Unmarshal(dAtA []byte) error + func (m *TDigest_Centroid) XXX_DiscardUnknown() + func (m *TDigest_Centroid) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TDigest_Centroid) XXX_Merge(src proto.Message) + func (m *TDigest_Centroid) XXX_Size() int + func (m *TDigest_Centroid) XXX_Unmarshal(b []byte) error + func (this *TDigest_Centroid) Equal(that interface{}) bool + func (this *TDigest_Centroid) GoString() string + func (this *TDigest_Centroid) String() string + type TailRequest struct + DelayFor uint32 + Limit uint32 + Plan *github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan + Query string + Start time.Time + func (*TailRequest) Descriptor() ([]byte, []int) + func (*TailRequest) ProtoMessage() + func (m *TailRequest) GetDelayFor() uint32 + func (m *TailRequest) GetLimit() uint32 + func (m *TailRequest) GetQuery() string + func (m *TailRequest) GetStart() time.Time + func (m *TailRequest) Marshal() (dAtA []byte, err error) + func (m *TailRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TailRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TailRequest) Reset() + func (m *TailRequest) Size() (n int) + func (m *TailRequest) Unmarshal(dAtA []byte) error + func (m *TailRequest) XXX_DiscardUnknown() + func (m *TailRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TailRequest) XXX_Merge(src proto.Message) + func (m *TailRequest) XXX_Size() int + func (m *TailRequest) XXX_Unmarshal(b []byte) error + func (this *TailRequest) Equal(that interface{}) bool + func (this *TailRequest) GoString() string + func (this *TailRequest) String() string + type TailResponse struct + DroppedStreams []*DroppedStream + Stream *github_com_grafana_loki_pkg_push.Stream + func (*TailResponse) Descriptor() ([]byte, []int) + func (*TailResponse) ProtoMessage() + func (m *TailResponse) GetDroppedStreams() []*DroppedStream + func (m *TailResponse) Marshal() (dAtA []byte, err error) + func (m *TailResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TailResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TailResponse) Reset() + func (m *TailResponse) Size() (n int) + func (m *TailResponse) Unmarshal(dAtA []byte) error + func (m *TailResponse) XXX_DiscardUnknown() + func (m *TailResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TailResponse) XXX_Merge(src proto.Message) + func (m *TailResponse) XXX_Size() int + func (m *TailResponse) XXX_Unmarshal(b []byte) error + func (this *TailResponse) Equal(that interface{}) bool + func (this *TailResponse) GoString() string + func (this *TailResponse) String() string + type TailersCountRequest struct + func (*TailersCountRequest) Descriptor() ([]byte, []int) + func (*TailersCountRequest) ProtoMessage() + func (m *TailersCountRequest) Marshal() (dAtA []byte, err error) + func (m *TailersCountRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TailersCountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TailersCountRequest) Reset() + func (m *TailersCountRequest) Size() (n int) + func (m *TailersCountRequest) Unmarshal(dAtA []byte) error + func (m *TailersCountRequest) XXX_DiscardUnknown() + func (m *TailersCountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TailersCountRequest) XXX_Merge(src proto.Message) + func (m *TailersCountRequest) XXX_Size() int + func (m *TailersCountRequest) XXX_Unmarshal(b []byte) error + func (this *TailersCountRequest) Equal(that interface{}) bool + func (this *TailersCountRequest) GoString() string + func (this *TailersCountRequest) String() string + type TailersCountResponse struct + Count uint32 + func (*TailersCountResponse) Descriptor() ([]byte, []int) + func (*TailersCountResponse) ProtoMessage() + func (m *TailersCountResponse) GetCount() uint32 + func (m *TailersCountResponse) Marshal() (dAtA []byte, err error) + func (m *TailersCountResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TailersCountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TailersCountResponse) Reset() + func (m *TailersCountResponse) Size() (n int) + func (m *TailersCountResponse) Unmarshal(dAtA []byte) error + func (m *TailersCountResponse) XXX_DiscardUnknown() + func (m *TailersCountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TailersCountResponse) XXX_Merge(src proto.Message) + func (m *TailersCountResponse) XXX_Size() int + func (m *TailersCountResponse) XXX_Unmarshal(b []byte) error + func (this *TailersCountResponse) Equal(that interface{}) bool + func (this *TailersCountResponse) GoString() string + func (this *TailersCountResponse) String() string + type TimeSeries struct + Labels []LabelAdapter + Samples []LegacySample + func TimeseriesFromPool() *TimeSeries + func (*TimeSeries) Descriptor() ([]byte, []int) + func (*TimeSeries) ProtoMessage() + func (m *TimeSeries) GetSamples() []LegacySample + func (m *TimeSeries) Marshal() (dAtA []byte, err error) + func (m *TimeSeries) MarshalTo(dAtA []byte) (int, error) + func (m *TimeSeries) MarshalToSizedBuffer(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 TopK struct + Cms *CountMinSketch + Hyperloglog []byte + List []*TopK_Pair + func (*TopK) Descriptor() ([]byte, []int) + func (*TopK) ProtoMessage() + func (m *TopK) GetCms() *CountMinSketch + func (m *TopK) GetHyperloglog() []byte + func (m *TopK) GetList() []*TopK_Pair + func (m *TopK) Marshal() (dAtA []byte, err error) + func (m *TopK) MarshalTo(dAtA []byte) (int, error) + func (m *TopK) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TopK) Reset() + func (m *TopK) Size() (n int) + func (m *TopK) Unmarshal(dAtA []byte) error + func (m *TopK) XXX_DiscardUnknown() + func (m *TopK) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TopK) XXX_Merge(src proto.Message) + func (m *TopK) XXX_Size() int + func (m *TopK) XXX_Unmarshal(b []byte) error + func (this *TopK) Equal(that interface{}) bool + func (this *TopK) GoString() string + func (this *TopK) String() string + type TopKMatrix struct + Values []*TopKMatrix_Vector + func (*TopKMatrix) Descriptor() ([]byte, []int) + func (*TopKMatrix) ProtoMessage() + func (m *TopKMatrix) GetValues() []*TopKMatrix_Vector + func (m *TopKMatrix) Marshal() (dAtA []byte, err error) + func (m *TopKMatrix) MarshalTo(dAtA []byte) (int, error) + func (m *TopKMatrix) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TopKMatrix) Reset() + func (m *TopKMatrix) Size() (n int) + func (m *TopKMatrix) Unmarshal(dAtA []byte) error + func (m *TopKMatrix) XXX_DiscardUnknown() + func (m *TopKMatrix) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TopKMatrix) XXX_Merge(src proto.Message) + func (m *TopKMatrix) XXX_Size() int + func (m *TopKMatrix) XXX_Unmarshal(b []byte) error + func (this *TopKMatrix) Equal(that interface{}) bool + func (this *TopKMatrix) GoString() string + func (this *TopKMatrix) String() string + type TopKMatrix_Vector struct + TimestampMs int64 + Topk *TopK + func (*TopKMatrix_Vector) Descriptor() ([]byte, []int) + func (*TopKMatrix_Vector) ProtoMessage() + func (m *TopKMatrix_Vector) GetTimestampMs() int64 + func (m *TopKMatrix_Vector) GetTopk() *TopK + func (m *TopKMatrix_Vector) Marshal() (dAtA []byte, err error) + func (m *TopKMatrix_Vector) MarshalTo(dAtA []byte) (int, error) + func (m *TopKMatrix_Vector) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TopKMatrix_Vector) Reset() + func (m *TopKMatrix_Vector) Size() (n int) + func (m *TopKMatrix_Vector) Unmarshal(dAtA []byte) error + func (m *TopKMatrix_Vector) XXX_DiscardUnknown() + func (m *TopKMatrix_Vector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TopKMatrix_Vector) XXX_Merge(src proto.Message) + func (m *TopKMatrix_Vector) XXX_Size() int + func (m *TopKMatrix_Vector) XXX_Unmarshal(b []byte) error + func (this *TopKMatrix_Vector) Equal(that interface{}) bool + func (this *TopKMatrix_Vector) GoString() string + func (this *TopKMatrix_Vector) String() string + type TopK_Pair struct + Count uint32 + Event string + func (*TopK_Pair) Descriptor() ([]byte, []int) + func (*TopK_Pair) ProtoMessage() + func (m *TopK_Pair) GetCount() uint32 + func (m *TopK_Pair) GetEvent() string + func (m *TopK_Pair) Marshal() (dAtA []byte, err error) + func (m *TopK_Pair) MarshalTo(dAtA []byte) (int, error) + func (m *TopK_Pair) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TopK_Pair) Reset() + func (m *TopK_Pair) Size() (n int) + func (m *TopK_Pair) Unmarshal(dAtA []byte) error + func (m *TopK_Pair) XXX_DiscardUnknown() + func (m *TopK_Pair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TopK_Pair) XXX_Merge(src proto.Message) + func (m *TopK_Pair) XXX_Size() int + func (m *TopK_Pair) XXX_Unmarshal(b []byte) error + func (this *TopK_Pair) Equal(that interface{}) bool + func (this *TopK_Pair) GoString() string + func (this *TopK_Pair) String() string + type UnimplementedBloomGatewayServer struct + func (*UnimplementedBloomGatewayServer) FilterChunkRefs(ctx context.Context, req *FilterChunkRefRequest) (*FilterChunkRefResponse, error) + type UnimplementedIndexGatewayServer struct + func (*UnimplementedIndexGatewayServer) GetChunkRef(ctx context.Context, req *GetChunkRefRequest) (*GetChunkRefResponse, error) + func (*UnimplementedIndexGatewayServer) GetSeries(ctx context.Context, req *GetSeriesRequest) (*GetSeriesResponse, error) + func (*UnimplementedIndexGatewayServer) GetShards(req *ShardsRequest, srv IndexGateway_GetShardsServer) error + func (*UnimplementedIndexGatewayServer) GetStats(ctx context.Context, req *IndexStatsRequest) (*IndexStatsResponse, error) + func (*UnimplementedIndexGatewayServer) GetVolume(ctx context.Context, req *VolumeRequest) (*VolumeResponse, error) + func (*UnimplementedIndexGatewayServer) LabelNamesForMetricName(ctx context.Context, req *LabelNamesForMetricNameRequest) (*LabelResponse, error) + func (*UnimplementedIndexGatewayServer) LabelValuesForMetricName(ctx context.Context, req *LabelValuesForMetricNameRequest) (*LabelResponse, error) + func (*UnimplementedIndexGatewayServer) QueryIndex(req *QueryIndexRequest, srv IndexGateway_QueryIndexServer) error + type UnimplementedPatternServer struct + func (*UnimplementedPatternServer) Push(ctx context.Context, req *push.PushRequest) (*push.PushResponse, error) + func (*UnimplementedPatternServer) Query(req *QueryPatternsRequest, srv Pattern_QueryServer) error + type UnimplementedQuerierServer struct + func (*UnimplementedQuerierServer) GetChunkIDs(ctx context.Context, req *GetChunkIDsRequest) (*GetChunkIDsResponse, error) + func (*UnimplementedQuerierServer) GetDetectedFields(ctx context.Context, req *DetectedFieldsRequest) (*DetectedFieldsResponse, error) + func (*UnimplementedQuerierServer) GetDetectedLabels(ctx context.Context, req *DetectedLabelsRequest) (*LabelToValuesResponse, error) + func (*UnimplementedQuerierServer) GetStats(ctx context.Context, req *IndexStatsRequest) (*IndexStatsResponse, error) + func (*UnimplementedQuerierServer) GetVolume(ctx context.Context, req *VolumeRequest) (*VolumeResponse, error) + func (*UnimplementedQuerierServer) Label(ctx context.Context, req *LabelRequest) (*LabelResponse, error) + func (*UnimplementedQuerierServer) Query(req *QueryRequest, srv Querier_QueryServer) error + func (*UnimplementedQuerierServer) QuerySample(req *SampleQueryRequest, srv Querier_QuerySampleServer) error + func (*UnimplementedQuerierServer) Series(ctx context.Context, req *SeriesRequest) (*SeriesResponse, error) + func (*UnimplementedQuerierServer) Tail(req *TailRequest, srv Querier_TailServer) error + func (*UnimplementedQuerierServer) TailersCount(ctx context.Context, req *TailersCountRequest) (*TailersCountResponse, error) + type UnimplementedStreamDataServer struct + func (*UnimplementedStreamDataServer) GetStreamRates(ctx context.Context, req *StreamRatesRequest) (*StreamRatesResponse, error) + type UniqueLabelValues struct + Values []string + func (*UniqueLabelValues) Descriptor() ([]byte, []int) + func (*UniqueLabelValues) ProtoMessage() + func (m *UniqueLabelValues) GetValues() []string + func (m *UniqueLabelValues) Marshal() (dAtA []byte, err error) + func (m *UniqueLabelValues) MarshalTo(dAtA []byte) (int, error) + func (m *UniqueLabelValues) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UniqueLabelValues) Reset() + func (m *UniqueLabelValues) Size() (n int) + func (m *UniqueLabelValues) Unmarshal(dAtA []byte) error + func (m *UniqueLabelValues) XXX_DiscardUnknown() + func (m *UniqueLabelValues) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UniqueLabelValues) XXX_Merge(src proto.Message) + func (m *UniqueLabelValues) XXX_Size() int + func (m *UniqueLabelValues) XXX_Unmarshal(b []byte) error + func (this *UniqueLabelValues) Equal(that interface{}) bool + func (this *UniqueLabelValues) GoString() string + func (this *UniqueLabelValues) String() string + type Volume struct + Name string + Volume uint64 + func (*Volume) Descriptor() ([]byte, []int) + func (*Volume) ProtoMessage() + func (m *Volume) GetName() string + func (m *Volume) GetVolume() uint64 + func (m *Volume) Marshal() (dAtA []byte, err error) + func (m *Volume) MarshalTo(dAtA []byte) (int, error) + func (m *Volume) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Volume) Reset() + func (m *Volume) Size() (n int) + func (m *Volume) Unmarshal(dAtA []byte) error + func (m *Volume) XXX_DiscardUnknown() + func (m *Volume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Volume) XXX_Merge(src proto.Message) + func (m *Volume) XXX_Size() int + func (m *Volume) XXX_Unmarshal(b []byte) error + func (this *Volume) Equal(that interface{}) bool + func (this *Volume) GoString() string + func (this *Volume) String() string + type VolumeRequest struct + AggregateBy string + From github_com_prometheus_common_model.Time + Limit int32 + Matchers string + Step int64 + TargetLabels []string + Through github_com_prometheus_common_model.Time + func (*VolumeRequest) Descriptor() ([]byte, []int) + func (*VolumeRequest) ProtoMessage() + func (m *VolumeRequest) GetAggregateBy() string + func (m *VolumeRequest) GetCachingOptions() (res definitions.CachingOptions) + func (m *VolumeRequest) GetEnd() time.Time + func (m *VolumeRequest) GetLimit() int32 + func (m *VolumeRequest) GetMatchers() string + func (m *VolumeRequest) GetQuery() string + func (m *VolumeRequest) GetStart() time.Time + func (m *VolumeRequest) GetStep() int64 + func (m *VolumeRequest) GetTargetLabels() []string + func (m *VolumeRequest) LogToSpan(sp opentracing.Span) + func (m *VolumeRequest) Marshal() (dAtA []byte, err error) + func (m *VolumeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *VolumeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VolumeRequest) Reset() + func (m *VolumeRequest) Size() (n int) + func (m *VolumeRequest) Unmarshal(dAtA []byte) error + func (m *VolumeRequest) WithQuery(query string) definitions.Request + func (m *VolumeRequest) WithStartEnd(start, end time.Time) definitions.Request + func (m *VolumeRequest) WithStartEndForCache(start, end time.Time) resultscache.Request + func (m *VolumeRequest) XXX_DiscardUnknown() + func (m *VolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VolumeRequest) XXX_Merge(src proto.Message) + func (m *VolumeRequest) XXX_Size() int + func (m *VolumeRequest) XXX_Unmarshal(b []byte) error + func (this *VolumeRequest) Equal(that interface{}) bool + func (this *VolumeRequest) GoString() string + func (this *VolumeRequest) String() string + type VolumeResponse struct + Limit int32 + Volumes []Volume + func (*VolumeResponse) Descriptor() ([]byte, []int) + func (*VolumeResponse) ProtoMessage() + func (m *VolumeResponse) GetLimit() int32 + func (m *VolumeResponse) GetVolumes() []Volume + func (m *VolumeResponse) Marshal() (dAtA []byte, err error) + func (m *VolumeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *VolumeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VolumeResponse) Reset() + func (m *VolumeResponse) Size() (n int) + func (m *VolumeResponse) Unmarshal(dAtA []byte) error + func (m *VolumeResponse) XXX_DiscardUnknown() + func (m *VolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VolumeResponse) XXX_Merge(src proto.Message) + func (m *VolumeResponse) XXX_Size() int + func (m *VolumeResponse) XXX_Unmarshal(b []byte) error + func (this *VolumeResponse) Equal(that interface{}) bool + func (this *VolumeResponse) GoString() string + func (this *VolumeResponse) String() string + type WriteRequest struct + Metadata []*MetricMetadata + SkipLabelNameValidation bool + Source WriteRequest_SourceEnum + Timeseries []PreallocTimeseries + func ToWriteRequest(lbls []labels.Labels, samples []LegacySample, metadata []*MetricMetadata, ...) *WriteRequest + func (*WriteRequest) Descriptor() ([]byte, []int) + func (*WriteRequest) ProtoMessage() + func (m *WriteRequest) GetMetadata() []*MetricMetadata + func (m *WriteRequest) GetSkipLabelNameValidation() bool + 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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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 Other modules containing this package github.com/grafana/loki