logproto

package

Go to main page

Versions in this module

v3

v3.3.1

Dec 4, 2024

v3.3.0

Nov 19, 2024

Changes in this version

type CountMinSketch

+ Hyperloglog []byte

+ func (m *CountMinSketch) GetHyperloglog() []byte

+ type CountMinSketchVector struct

+ Metrics []*Labels

+ Sketch *CountMinSketch

+ TimestampMs int64

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

+ func (*CountMinSketchVector) ProtoMessage()

+ func (m *CountMinSketchVector) GetMetrics() []*Labels

+ func (m *CountMinSketchVector) GetSketch() *CountMinSketch

+ func (m *CountMinSketchVector) GetTimestampMs() int64

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

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

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

+ func (m *CountMinSketchVector) Reset()

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

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

+ func (m *CountMinSketchVector) XXX_DiscardUnknown()

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

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

+ func (m *CountMinSketchVector) XXX_Size() int

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

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

+ func (this *CountMinSketchVector) GoString() string

+ func (this *CountMinSketchVector) String() string

type DetectedFieldsRequest

+ Limit uint32

+ Name string

+ Values bool

+ func (m *DetectedFieldsRequest) GetLimit() uint32

+ func (m *DetectedFieldsRequest) GetName() string

+ func (m *DetectedFieldsRequest) GetValues() bool

type DetectedFieldsResponse

+ Limit uint32

+ Values []string

+ func (m *DetectedFieldsResponse) GetLimit() uint32

+ func (m *DetectedFieldsResponse) GetValues() []string

type GetChunkRefResponse

+ Stats stats.Index

+ func (m *GetChunkRefResponse) GetStats() stats.Index

type GroupedChunkRefs

+ Labels *IndexSeries

+ func (m *GroupedChunkRefs) GetLabels() *IndexSeries

+ type Labels struct

+ Metric []*LabelPair

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

+ func (*Labels) ProtoMessage()

+ func (m *Labels) GetMetric() []*LabelPair

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

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

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

+ func (m *Labels) Reset()

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

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

+ func (m *Labels) XXX_DiscardUnknown()

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

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

+ func (m *Labels) XXX_Size() int

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

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

+ func (this *Labels) GoString() string

+ func (this *Labels) String() string

v3.2.2

Dec 4, 2024

v3.2.1

Oct 17, 2024

v3.2.0

Sep 18, 2024

Changes in this version

+ func RegisterPusherRF1Server(s *grpc.Server, srv PusherRF1Server)

+ type PusherRF1Client interface

+ Push func(ctx context.Context, in *push.PushRequest, opts ...grpc.CallOption) (*push.PushResponse, error)

+ func NewPusherRF1Client(cc *grpc.ClientConn) PusherRF1Client

+ type PusherRF1Server interface

+ Push func(context.Context, *push.PushRequest) (*push.PushResponse, error)

+ type UnimplementedPusherRF1Server struct

+ func (*UnimplementedPusherRF1Server) Push(ctx context.Context, req *push.PushRequest) (*push.PushResponse, error)

type VolumeRequest

+ CachingOptions resultscache.CachingOptions

v3.1.2

Oct 17, 2024

v3.1.1

Aug 8, 2024

v3.1.0

Jul 2, 2024

Changes in this version

+ type ChunkRefGroup struct

+ Refs []*ChunkRef

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

+ func (*ChunkRefGroup) ProtoMessage()

+ func (m *ChunkRefGroup) GetRefs() []*ChunkRef

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

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

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

+ func (m *ChunkRefGroup) Reset()

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

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

+ func (m *ChunkRefGroup) XXX_DiscardUnknown()

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

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

+ func (m *ChunkRefGroup) XXX_Size() int

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

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

+ func (this *ChunkRefGroup) GoString() string

+ func (this *ChunkRefGroup) String() string

type DetectedField

+ Parsers []string

+ Sketch []byte

+ func (m *DetectedField) GetParsers() []string

+ func (m *DetectedField) GetSketch() []byte

type DetectedFieldsRequest

+ func (m *DetectedFieldsRequest) GetCachingOptions() (res definitions.CachingOptions)

+ func (m *DetectedFieldsRequest) LogToSpan(sp opentracing.Span)

+ func (m *DetectedFieldsRequest) WithQuery(query string) definitions.Request

+ func (m *DetectedFieldsRequest) WithStartEnd(start, end time.Time) definitions.Request

type DetectedFieldsResponse

+ FieldLimit uint32

+ func (m *DetectedFieldsResponse) GetFieldLimit() uint32

type DetectedLabel

+ Sketch []byte

+ func (m *DetectedLabel) GetSketch() []byte

type DetectedLabelsRequest

+ func (m *DetectedLabelsRequest) GetCachingOptions() (res definitions.CachingOptions)

+ func (m *DetectedLabelsRequest) GetStep() int64

+ func (m *DetectedLabelsRequest) LogToSpan(sp opentracing.Span)

+ func (m *DetectedLabelsRequest) WithQuery(query string) definitions.Request

+ func (m *DetectedLabelsRequest) WithStartEnd(start, end time.Time) definitions.Request

+ func (m *DetectedLabelsRequest) WithStartEndForCache(start, end time.Time) resultscache.Request

type FilterChunkRefRequest

+ Blocks []string

+ func (m *FilterChunkRefRequest) GetBlocks() []string

type GroupedChunkRefs

+ func (a *GroupedChunkRefs) Cmp(b *GroupedChunkRefs) int

+ func (a *GroupedChunkRefs) Less(b *GroupedChunkRefs) bool

type LabelNamesForMetricNameRequest

+ Matchers string

+ func (m *LabelNamesForMetricNameRequest) GetMatchers() string

type QueryPatternsRequest

+ Step int64

type QueryRequest

+ StoreChunks *ChunkRefGroup

+ func (m *QueryRequest) GetStoreChunks() *ChunkRefGroup

type SampleQueryRequest

+ StoreChunks *ChunkRefGroup

+ func (m *SampleQueryRequest) GetStoreChunks() *ChunkRefGroup

type ShardsResponse

+ ChunkGroups []ChunkRefGroup

+ func (m *ShardsResponse) GetChunkGroups() []ChunkRefGroup

+ func (m *ShardsResponse) Merge(other *ShardsResponse)

type ShortRef

+ func (a *ShortRef) Cmp(b *ShortRef) int

+ func (a *ShortRef) Less(b *ShortRef) bool

v3.0.1

Aug 9, 2024

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL