logproto

package
v3.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 4, 2024 License: AGPL-3.0 Imports: 41 Imported by: 24

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBloomgateway = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBloomgateway   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthIndexgateway = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIndexgateway   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthLogproto = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogproto   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthMetrics = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetrics   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthPattern = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPattern   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthSketch = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSketch   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Direction_name = map[int32]string{
	0: "FORWARD",
	1: "BACKWARD",
}
View Source 
var Direction_value = map[string]int32{
	"FORWARD":  0,
	"BACKWARD": 1,
}
View Source 
var MetricMetadata_MetricType_name = map[int32]string{
	0: "UNKNOWN",
	1: "COUNTER",
	2: "GAUGE",
	3: "HISTOGRAM",
	4: "GAUGEHISTOGRAM",
	5: "SUMMARY",
	6: "INFO",
	7: "STATESET",
}
View Source 
var MetricMetadata_MetricType_value = map[string]int32{
	"UNKNOWN":        0,
	"COUNTER":        1,
	"GAUGE":          2,
	"HISTOGRAM":      3,
	"GAUGEHISTOGRAM": 4,
	"SUMMARY":        5,
	"INFO":           6,
	"STATESET":       7,
}
View Source 
var WriteRequest_SourceEnum_name = map[int32]string{
	0: "API",
	1: "RULE",
}
View Source 
var WriteRequest_SourceEnum_value = map[string]int32{
	"API":  0,
	"RULE": 1,
}

Functions

func FromLabelAdaptersToLabels 

func FromLabelAdaptersToLabels(ls []LabelAdapter) labels.Labels

FromLabelAdaptersToLabels casts []LabelAdapter to labels.Labels. It uses unsafe, but as LabelAdapter == labels.Label this should be safe. This allows us to use labels.Labels directly in protos.

Note: while resulting labels.Labels is supposedly sorted, this function doesn't enforce that. If input is not sorted, output will be wrong.

func FromLabelAdaptersToMetric 

func FromLabelAdaptersToMetric(ls []LabelAdapter) model.Metric

FromLabelAdaptersToMetric converts []LabelAdapter to a model.Metric. Don't do this on any performance sensitive paths.

func RegisterBloomGatewayServer 

func RegisterBloomGatewayServer(s *grpc.Server, srv BloomGatewayServer)

func RegisterIndexGatewayServer 

func RegisterIndexGatewayServer(s *grpc.Server, srv IndexGatewayServer)

func RegisterPatternServer 

func RegisterPatternServer(s *grpc.Server, srv PatternServer)

func RegisterPusherRF1Server added in v3.2.0 

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

func RegisterPusherServer 

func RegisterPusherServer(s *grpc.Server, srv PusherServer)

func RegisterQuerierServer 

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

func RegisterStreamDataServer 

func RegisterStreamDataServer(s *grpc.Server, srv StreamDataServer)

func ReuseSlice 

func ReuseSlice(ts []PreallocTimeseries)

ReuseSlice puts the slice back into a sync.Pool for reuse.

func ReuseTimeseries 

func ReuseTimeseries(ts *TimeSeries)

ReuseTimeseries puts the timeseries back into a sync.Pool for reuse.

func SampleJsoniterDecode 

func SampleJsoniterDecode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func SampleJsoniterEncode 

func SampleJsoniterEncode(ptr unsafe.Pointer, stream *jsoniter.Stream)

Types

type BloomGatewayClient 

type BloomGatewayClient interface {
	FilterChunkRefs(ctx context.Context, in *FilterChunkRefRequest, opts ...grpc.CallOption) (*FilterChunkRefResponse, error)
}

BloomGatewayClient is the client API for BloomGateway service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBloomGatewayClient 

func NewBloomGatewayClient(cc *grpc.ClientConn) BloomGatewayClient

type BloomGatewayServer 

type BloomGatewayServer interface {
	FilterChunkRefs(context.Context, *FilterChunkRefRequest) (*FilterChunkRefResponse, error)
}

BloomGatewayServer is the server API for BloomGateway service.

type Chunk 

type Chunk struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Chunk) Descriptor 

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

func (*Chunk) Equal 

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

func (*Chunk) GetData 

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

func (*Chunk) GoString 

func (this *Chunk) GoString() string

func (*Chunk) Marshal 

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

func (*Chunk) MarshalTo 

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

func (*Chunk) MarshalToSizedBuffer 

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

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) Reset 

func (m *Chunk) Reset()

func (*Chunk) Size 

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

func (*Chunk) String 

func (this *Chunk) String() string

func (*Chunk) Unmarshal 

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

func (*Chunk) XXX_DiscardUnknown 

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal 

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

func (*Chunk) XXX_Merge 

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

func (*Chunk) XXX_Size 

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal 

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

type ChunkRef 

type ChunkRef struct {
	Fingerprint uint64                                  `protobuf:"varint,1,opt,name=fingerprint,proto3" json:"fingerprint"`
	UserID      string                                  `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"userID"`
	From        github_com_prometheus_common_model.Time `protobuf:"varint,3,opt,name=from,proto3,customtype=github.com/prometheus/common/model.Time" json:"from"`
	Through     github_com_prometheus_common_model.Time `protobuf:"varint,4,opt,name=through,proto3,customtype=github.com/prometheus/common/model.Time" json:"through"`
	// The checksum is not written to the external storage. We use crc32,
	// Castagnoli table. See http://www.evanjones.ca/crc32c.html.
	Checksum uint32 `protobuf:"varint,5,opt,name=checksum,proto3" json:"-"`
}

ChunkRef contains the metadata to reference a Chunk. It is embedded by the Chunk type itself and used to generate the Chunk checksum. So it is imported to take care of the JSON representation of the resulting Go struct.

func (*ChunkRef) Descriptor 

func (*ChunkRef) Descriptor() ([]byte, []int)

func (*ChunkRef) Equal 

func (this *ChunkRef) Equal(that interface{}) bool

func (*ChunkRef) FingerprintModel 

func (c *ChunkRef) FingerprintModel() model.Fingerprint

func (*ChunkRef) GetChecksum 

func (m *ChunkRef) GetChecksum() uint32

func (*ChunkRef) GetFingerprint 

func (m *ChunkRef) GetFingerprint() uint64

func (*ChunkRef) GetUserID 

func (m *ChunkRef) GetUserID() string

func (*ChunkRef) GoString 

func (this *ChunkRef) GoString() string

func (*ChunkRef) Marshal 

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

func (*ChunkRef) MarshalTo 

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

func (*ChunkRef) MarshalToSizedBuffer 

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

func (*ChunkRef) ProtoMessage 

func (*ChunkRef) ProtoMessage()

func (*ChunkRef) Reset 

func (m *ChunkRef) Reset()

func (*ChunkRef) Size 

func (m *ChunkRef) Size() (n int)

func (*ChunkRef) String 

func (this *ChunkRef) String() string

func (*ChunkRef) Unmarshal 

func (m *ChunkRef) Unmarshal(dAtA []byte) error

func (*ChunkRef) XXX_DiscardUnknown 

func (m *ChunkRef) XXX_DiscardUnknown()

func (*ChunkRef) XXX_Marshal 

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

func (*ChunkRef) XXX_Merge 

func (m *ChunkRef) XXX_Merge(src proto.Message)

func (*ChunkRef) XXX_Size 

func (m *ChunkRef) XXX_Size() int

func (*ChunkRef) XXX_Unmarshal 

func (m *ChunkRef) XXX_Unmarshal(b []byte) error

type ChunkRefGroup added in v3.1.0 

type ChunkRefGroup struct {
	Refs []*ChunkRef `protobuf:"bytes,1,rep,name=refs,proto3" json:"refs"`
}

func (*ChunkRefGroup) Descriptor added in v3.1.0 

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

func (*ChunkRefGroup) Equal added in v3.1.0 

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

func (*ChunkRefGroup) GetRefs added in v3.1.0 

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

func (*ChunkRefGroup) GoString added in v3.1.0 

func (this *ChunkRefGroup) GoString() string

func (*ChunkRefGroup) Marshal added in v3.1.0 

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

func (*ChunkRefGroup) MarshalTo added in v3.1.0 

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

func (*ChunkRefGroup) MarshalToSizedBuffer added in v3.1.0 

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

func (*ChunkRefGroup) ProtoMessage added in v3.1.0 

func (*ChunkRefGroup) ProtoMessage()

func (*ChunkRefGroup) Reset added in v3.1.0 

func (m *ChunkRefGroup) Reset()

func (*ChunkRefGroup) Size added in v3.1.0 

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

func (*ChunkRefGroup) String added in v3.1.0 

func (this *ChunkRefGroup) String() string

func (*ChunkRefGroup) Unmarshal added in v3.1.0 

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

func (*ChunkRefGroup) XXX_DiscardUnknown added in v3.1.0 

func (m *ChunkRefGroup) XXX_DiscardUnknown()

func (*ChunkRefGroup) XXX_Marshal added in v3.1.0 

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

func (*ChunkRefGroup) XXX_Merge added in v3.1.0 

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

func (*ChunkRefGroup) XXX_Size added in v3.1.0 

func (m *ChunkRefGroup) XXX_Size() int

func (*ChunkRefGroup) XXX_Unmarshal added in v3.1.0 

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

type CountMinSketch 

type CountMinSketch struct {
	Depth uint32 `protobuf:"varint,1,opt,name=depth,proto3" json:"depth,omitempty"`
	Width uint32 `protobuf:"varint,2,opt,name=width,proto3" json:"width,omitempty"`
	// counters is a matrix of depth * width.
	Counters []uint32 `protobuf:"varint,3,rep,packed,name=counters,proto3" json:"counters,omitempty"`
}

func (*CountMinSketch) Descriptor 

func (*CountMinSketch) Descriptor() ([]byte, []int)

func (*CountMinSketch) Equal 

func (this *CountMinSketch) Equal(that interface{}) bool

func (*CountMinSketch) GetCounters 

func (m *CountMinSketch) GetCounters() []uint32

func (*CountMinSketch) GetDepth 

func (m *CountMinSketch) GetDepth() uint32

func (*CountMinSketch) GetWidth 

func (m *CountMinSketch) GetWidth() uint32

func (*CountMinSketch) GoString 

func (this *CountMinSketch) GoString() string

func (*CountMinSketch) Marshal 

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

func (*CountMinSketch) MarshalTo 

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

func (*CountMinSketch) MarshalToSizedBuffer 

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

func (*CountMinSketch) ProtoMessage 

func (*CountMinSketch) ProtoMessage()

func (*CountMinSketch) Reset 

func (m *CountMinSketch) Reset()

func (*CountMinSketch) Size 

func (m *CountMinSketch) Size() (n int)

func (*CountMinSketch) String 

func (this *CountMinSketch) String() string

func (*CountMinSketch) Unmarshal 

func (m *CountMinSketch) Unmarshal(dAtA []byte) error

func (*CountMinSketch) XXX_DiscardUnknown 

func (m *CountMinSketch) XXX_DiscardUnknown()

func (*CountMinSketch) XXX_Marshal 

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

func (*CountMinSketch) XXX_Merge 

func (m *CountMinSketch) XXX_Merge(src proto.Message)

func (*CountMinSketch) XXX_Size 

func (m *CountMinSketch) XXX_Size() int

func (*CountMinSketch) XXX_Unmarshal 

func (m *CountMinSketch) XXX_Unmarshal(b []byte) error

type Delete 

type Delete struct {
	Selector string `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"`
	Start    int64  `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	End      int64  `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
}

func (*Delete) Descriptor 

func (*Delete) Descriptor() ([]byte, []int)

func (*Delete) Equal 

func (this *Delete) Equal(that interface{}) bool

func (*Delete) GetEnd 

func (m *Delete) GetEnd() int64

func (*Delete) GetSelector 

func (m *Delete) GetSelector() string

func (*Delete) GetStart 

func (m *Delete) GetStart() int64

func (*Delete) GoString 

func (this *Delete) GoString() string

func (*Delete) Marshal 

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

func (*Delete) MarshalTo 

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

func (*Delete) MarshalToSizedBuffer 

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

func (*Delete) ProtoMessage 

func (*Delete) ProtoMessage()

func (*Delete) Reset 

func (m *Delete) Reset()

func (*Delete) Size 

func (m *Delete) Size() (n int)

func (*Delete) String 

func (this *Delete) String() string

func (*Delete) Unmarshal 

func (m *Delete) Unmarshal(dAtA []byte) error

func (*Delete) XXX_DiscardUnknown 

func (m *Delete) XXX_DiscardUnknown()

func (*Delete) XXX_Marshal 

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

func (*Delete) XXX_Merge 

func (m *Delete) XXX_Merge(src proto.Message)

func (*Delete) XXX_Size 

func (m *Delete) XXX_Size() int

func (*Delete) XXX_Unmarshal 

func (m *Delete) XXX_Unmarshal(b []byte) error

type DetectedField 

type DetectedField struct {
	Label       string            `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Type        DetectedFieldType `protobuf:"bytes,2,opt,name=type,proto3,casttype=DetectedFieldType" json:"type,omitempty"`
	Cardinality uint64            `protobuf:"varint,3,opt,name=cardinality,proto3" json:"cardinality,omitempty"`
	Parsers     []string          `protobuf:"bytes,4,rep,name=parsers,proto3" json:"parsers"`
	Sketch      []byte            `protobuf:"bytes,5,opt,name=sketch,proto3" json:"sketch,omitempty"`
}

TODO: make the detected field include the serialized sketch we only want cardinality in the JSON response

func (*DetectedField) Descriptor 

func (*DetectedField) Descriptor() ([]byte, []int)

func (*DetectedField) Equal 

func (this *DetectedField) Equal(that interface{}) bool

func (*DetectedField) GetCardinality 

func (m *DetectedField) GetCardinality() uint64

func (*DetectedField) GetLabel 

func (m *DetectedField) GetLabel() string

func (*DetectedField) GetParsers added in v3.1.0 

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

func (*DetectedField) GetSketch added in v3.1.0 

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

func (*DetectedField) GetType 

func (m *DetectedField) GetType() DetectedFieldType

func (*DetectedField) GoString 

func (this *DetectedField) GoString() string

func (*DetectedField) Marshal 

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

func (*DetectedField) MarshalTo 

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

func (*DetectedField) MarshalToSizedBuffer 

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

func (*DetectedField) ProtoMessage 

func (*DetectedField) ProtoMessage()

func (*DetectedField) Reset 

func (m *DetectedField) Reset()

func (*DetectedField) Size 

func (m *DetectedField) Size() (n int)

func (*DetectedField) String 

func (this *DetectedField) String() string

func (*DetectedField) Unmarshal 

func (m *DetectedField) Unmarshal(dAtA []byte) error

func (*DetectedField) XXX_DiscardUnknown 

func (m *DetectedField) XXX_DiscardUnknown()

func (*DetectedField) XXX_Marshal 

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

func (*DetectedField) XXX_Merge 

func (m *DetectedField) XXX_Merge(src proto.Message)

func (*DetectedField) XXX_Size 

func (m *DetectedField) XXX_Size() int

func (*DetectedField) XXX_Unmarshal 

func (m *DetectedField) XXX_Unmarshal(b []byte) error

type DetectedFieldType 

type DetectedFieldType string
const (
	DetectedFieldString   DetectedFieldType = "string"
	DetectedFieldInt      DetectedFieldType = "int"
	DetectedFieldFloat    DetectedFieldType = "float"
	DetectedFieldBoolean  DetectedFieldType = "boolean"
	DetectedFieldDuration DetectedFieldType = "duration"
	DetectedFieldBytes    DetectedFieldType = "bytes"
)

func (DetectedFieldType) String 

func (d DetectedFieldType) String() string

type DetectedFieldsRequest 

type DetectedFieldsRequest struct {
	Start      time.Time `protobuf:"bytes,1,opt,name=start,proto3,stdtime" json:"start"`
	End        time.Time `protobuf:"bytes,2,opt,name=end,proto3,stdtime" json:"end"`
	Query      string    `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	LineLimit  uint32    `protobuf:"varint,4,opt,name=lineLimit,proto3" json:"lineLimit,omitempty"`
	FieldLimit uint32    `protobuf:"varint,5,opt,name=fieldLimit,proto3" json:"fieldLimit,omitempty"`
	Step       int64     `protobuf:"varint,6,opt,name=step,proto3" json:"step,omitempty"`
}

func (*DetectedFieldsRequest) Descriptor 

func (*DetectedFieldsRequest) Descriptor() ([]byte, []int)

func (*DetectedFieldsRequest) Equal 

func (this *DetectedFieldsRequest) Equal(that interface{}) bool

func (*DetectedFieldsRequest) GetCachingOptions added in v3.1.0 

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

func (*DetectedFieldsRequest) GetEnd 

func (m *DetectedFieldsRequest) GetEnd() time.Time

func (*DetectedFieldsRequest) GetFieldLimit 

func (m *DetectedFieldsRequest) GetFieldLimit() uint32

func (*DetectedFieldsRequest) GetLineLimit 

func (m *DetectedFieldsRequest) GetLineLimit() uint32

func (*DetectedFieldsRequest) GetQuery 

func (m *DetectedFieldsRequest) GetQuery() string

func (*DetectedFieldsRequest) GetStart 

func (m *DetectedFieldsRequest) GetStart() time.Time

func (*DetectedFieldsRequest) GetStep 

func (m *DetectedFieldsRequest) GetStep() int64

func (*DetectedFieldsRequest) GoString 

func (this *DetectedFieldsRequest) GoString() string

func (*DetectedFieldsRequest) LogToSpan added in v3.1.0 

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

func (*DetectedFieldsRequest) Marshal 

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

func (*DetectedFieldsRequest) MarshalTo 

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

func (*DetectedFieldsRequest) MarshalToSizedBuffer 

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

func (*DetectedFieldsRequest) ProtoMessage 

func (*DetectedFieldsRequest) ProtoMessage()

func (*DetectedFieldsRequest) Reset 

func (m *DetectedFieldsRequest) Reset()

func (*DetectedFieldsRequest) Size 

func (m *DetectedFieldsRequest) Size() (n int)

func (*DetectedFieldsRequest) String 

func (this *DetectedFieldsRequest) String() string

func (*DetectedFieldsRequest) Unmarshal 

func (m *DetectedFieldsRequest) Unmarshal(dAtA []byte) error

func (*DetectedFieldsRequest) WithQuery added in v3.1.0 

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

func (*DetectedFieldsRequest) WithStartEnd added in v3.1.0 

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

func (*DetectedFieldsRequest) XXX_DiscardUnknown 

func (m *DetectedFieldsRequest) XXX_DiscardUnknown()

func (*DetectedFieldsRequest) XXX_Marshal 

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

func (*DetectedFieldsRequest) XXX_Merge 

func (m *DetectedFieldsRequest) XXX_Merge(src proto.Message)

func (*DetectedFieldsRequest) XXX_Size 

func (m *DetectedFieldsRequest) XXX_Size() int

func (*DetectedFieldsRequest) XXX_Unmarshal 

func (m *DetectedFieldsRequest) XXX_Unmarshal(b []byte) error

type DetectedFieldsResponse 

type DetectedFieldsResponse struct {
	Fields     []*DetectedField `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	FieldLimit uint32           `protobuf:"varint,2,opt,name=fieldLimit,proto3" json:"fieldLimit,omitempty"`
}

func (*DetectedFieldsResponse) Descriptor 

func (*DetectedFieldsResponse) Descriptor() ([]byte, []int)

func (*DetectedFieldsResponse) Equal 

func (this *DetectedFieldsResponse) Equal(that interface{}) bool

func (*DetectedFieldsResponse) GetFieldLimit added in v3.1.0 

func (m *DetectedFieldsResponse) GetFieldLimit() uint32

func (*DetectedFieldsResponse) GetFields 

func (m *DetectedFieldsResponse) GetFields() []*DetectedField

func (*DetectedFieldsResponse) GoString 

func (this *DetectedFieldsResponse) GoString() string

func (*DetectedFieldsResponse) Marshal 

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

func (*DetectedFieldsResponse) MarshalTo 

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

func (*DetectedFieldsResponse) MarshalToSizedBuffer 

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

func (*DetectedFieldsResponse) ProtoMessage 

func (*DetectedFieldsResponse) ProtoMessage()

func (*DetectedFieldsResponse) Reset 

func (m *DetectedFieldsResponse) Reset()

func (*DetectedFieldsResponse) Size 

func (m *DetectedFieldsResponse) Size() (n int)

func (*DetectedFieldsResponse) String 

func (this *DetectedFieldsResponse) String() string

func (*DetectedFieldsResponse) Unmarshal 

func (m *DetectedFieldsResponse) Unmarshal(dAtA []byte) error

func (*DetectedFieldsResponse) XXX_DiscardUnknown 

func (m *DetectedFieldsResponse) XXX_DiscardUnknown()

func (*DetectedFieldsResponse) XXX_Marshal 

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

func (*DetectedFieldsResponse) XXX_Merge 

func (m *DetectedFieldsResponse) XXX_Merge(src proto.Message)

func (*DetectedFieldsResponse) XXX_Size 

func (m *DetectedFieldsResponse) XXX_Size() int

func (*DetectedFieldsResponse) XXX_Unmarshal 

func (m *DetectedFieldsResponse) XXX_Unmarshal(b []byte) error

type DetectedLabel 

type DetectedLabel struct {
	Label       string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Cardinality uint64 `protobuf:"varint,2,opt,name=cardinality,proto3" json:"cardinality,omitempty"`
	Sketch      []byte `protobuf:"bytes,3,opt,name=sketch,proto3" json:"sketch,omitempty"`
}

func (*DetectedLabel) Descriptor 

func (*DetectedLabel) Descriptor() ([]byte, []int)

func (*DetectedLabel) Equal 

func (this *DetectedLabel) Equal(that interface{}) bool

func (*DetectedLabel) GetCardinality 

func (m *DetectedLabel) GetCardinality() uint64

func (*DetectedLabel) GetLabel 

func (m *DetectedLabel) GetLabel() string

func (*DetectedLabel) GetSketch added in v3.1.0 

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

func (*DetectedLabel) GoString 

func (this *DetectedLabel) GoString() string

func (*DetectedLabel) Marshal 

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

func (*DetectedLabel) MarshalTo 

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

func (*DetectedLabel) MarshalToSizedBuffer 

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

func (*DetectedLabel) ProtoMessage 

func (*DetectedLabel) ProtoMessage()

func (*DetectedLabel) Reset 

func (m *DetectedLabel) Reset()

func (*DetectedLabel) Size 

func (m *DetectedLabel) Size() (n int)

func (*DetectedLabel) String 

func (this *DetectedLabel) String() string

func (*DetectedLabel) Unmarshal 

func (m *DetectedLabel) Unmarshal(dAtA []byte) error

func (*DetectedLabel) XXX_DiscardUnknown 

func (m *DetectedLabel) XXX_DiscardUnknown()

func (*DetectedLabel) XXX_Marshal 

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

func (*DetectedLabel) XXX_Merge 

func (m *DetectedLabel) XXX_Merge(src proto.Message)

func (*DetectedLabel) XXX_Size 

func (m *DetectedLabel) XXX_Size() int

func (*DetectedLabel) XXX_Unmarshal 

func (m *DetectedLabel) XXX_Unmarshal(b []byte) error

type DetectedLabelsRequest 

type DetectedLabelsRequest struct {
	Start time.Time `protobuf:"bytes,1,opt,name=start,proto3,stdtime" json:"start"`
	End   time.Time `protobuf:"bytes,2,opt,name=end,proto3,stdtime" json:"end"`
	Query string    `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
}

func (*DetectedLabelsRequest) Descriptor 

func (*DetectedLabelsRequest) Descriptor() ([]byte, []int)

func (*DetectedLabelsRequest) Equal 

func (this *DetectedLabelsRequest) Equal(that interface{}) bool

func (*DetectedLabelsRequest) GetCachingOptions added in v3.1.0 

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

func (*DetectedLabelsRequest) GetEnd 

func (m *DetectedLabelsRequest) GetEnd() time.Time

func (*DetectedLabelsRequest) GetQuery 

func (m *DetectedLabelsRequest) GetQuery() string

func (*DetectedLabelsRequest) GetStart 

func (m *DetectedLabelsRequest) GetStart() time.Time

func (*DetectedLabelsRequest) GetStep added in v3.1.0 

func (m *DetectedLabelsRequest) GetStep() int64

func (*DetectedLabelsRequest) GoString 

func (this *DetectedLabelsRequest) GoString() string

func (*DetectedLabelsRequest) LogToSpan added in v3.1.0 

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

func (*DetectedLabelsRequest) Marshal 

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

func (*DetectedLabelsRequest) MarshalTo 

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

func (*DetectedLabelsRequest) MarshalToSizedBuffer 

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

func (*DetectedLabelsRequest) ProtoMessage 

func (*DetectedLabelsRequest) ProtoMessage()

func (*DetectedLabelsRequest) Reset 

func (m *DetectedLabelsRequest) Reset()

func (*DetectedLabelsRequest) Size 

func (m *DetectedLabelsRequest) Size() (n int)

func (*DetectedLabelsRequest) String 

func (this *DetectedLabelsRequest) String() string

func (*DetectedLabelsRequest) Unmarshal 

func (m *DetectedLabelsRequest) Unmarshal(dAtA []byte) error

func (*DetectedLabelsRequest) WithQuery added in v3.1.0 

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

func (*DetectedLabelsRequest) WithStartEnd added in v3.1.0 

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

func (*DetectedLabelsRequest) WithStartEndForCache added in v3.1.0 

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

func (*DetectedLabelsRequest) XXX_DiscardUnknown 

func (m *DetectedLabelsRequest) XXX_DiscardUnknown()

func (*DetectedLabelsRequest) XXX_Marshal 

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

func (*DetectedLabelsRequest) XXX_Merge 

func (m *DetectedLabelsRequest) XXX_Merge(src proto.Message)

func (*DetectedLabelsRequest) XXX_Size 

func (m *DetectedLabelsRequest) XXX_Size() int

func (*DetectedLabelsRequest) XXX_Unmarshal 

func (m *DetectedLabelsRequest) XXX_Unmarshal(b []byte) error

type DetectedLabelsResponse 

type DetectedLabelsResponse struct {
	DetectedLabels []*DetectedLabel `protobuf:"bytes,1,rep,name=detectedLabels,proto3" json:"detectedLabels,omitempty"`
}

func (*DetectedLabelsResponse) Descriptor 

func (*DetectedLabelsResponse) Descriptor() ([]byte, []int)

func (*DetectedLabelsResponse) Equal 

func (this *DetectedLabelsResponse) Equal(that interface{}) bool

func (*DetectedLabelsResponse) GetDetectedLabels 

func (m *DetectedLabelsResponse) GetDetectedLabels() []*DetectedLabel

func (*DetectedLabelsResponse) GoString 

func (this *DetectedLabelsResponse) GoString() string

func (*DetectedLabelsResponse) Marshal 

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

func (*DetectedLabelsResponse) MarshalTo 

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

func (*DetectedLabelsResponse) MarshalToSizedBuffer 

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

func (*DetectedLabelsResponse) ProtoMessage 

func (*DetectedLabelsResponse) ProtoMessage()

func (*DetectedLabelsResponse) Reset 

func (m *DetectedLabelsResponse) Reset()

func (*DetectedLabelsResponse) Size 

func (m *DetectedLabelsResponse) Size() (n int)

func (*DetectedLabelsResponse) String 

func (this *DetectedLabelsResponse) String() string

func (*DetectedLabelsResponse) Unmarshal 

func (m *DetectedLabelsResponse) Unmarshal(dAtA []byte) error

func (*DetectedLabelsResponse) XXX_DiscardUnknown 

func (m *DetectedLabelsResponse) XXX_DiscardUnknown()

func (*DetectedLabelsResponse) XXX_Marshal 

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

func (*DetectedLabelsResponse) XXX_Merge 

func (m *DetectedLabelsResponse) XXX_Merge(src proto.Message)

func (*DetectedLabelsResponse) XXX_Size 

func (m *DetectedLabelsResponse) XXX_Size() int

func (*DetectedLabelsResponse) XXX_Unmarshal 

func (m *DetectedLabelsResponse) XXX_Unmarshal(b []byte) error

type Direction 

type Direction int32
const (
	FORWARD  Direction = 0
	BACKWARD Direction = 1
)

func (Direction) EnumDescriptor 

func (Direction) EnumDescriptor() ([]byte, []int)

func (Direction) String 

func (x Direction) String() string

type DroppedStream 

type DroppedStream struct {
	From   time.Time `protobuf:"bytes,1,opt,name=from,proto3,stdtime" json:"from"`
	To     time.Time `protobuf:"bytes,2,opt,name=to,proto3,stdtime" json:"to"`
	Labels string    `protobuf:"bytes,3,opt,name=labels,proto3" json:"labels,omitempty"`
}

func (*DroppedStream) Descriptor 

func (*DroppedStream) Descriptor() ([]byte, []int)

func (*DroppedStream) Equal 

func (this *DroppedStream) Equal(that interface{}) bool

func (*DroppedStream) GetFrom 

func (m *DroppedStream) GetFrom() time.Time

func (*DroppedStream) GetLabels 

func (m *DroppedStream) GetLabels() string

func (*DroppedStream) GetTo 

func (m *DroppedStream) GetTo() time.Time

func (*DroppedStream) GoString 

func (this *DroppedStream) GoString() string

func (*DroppedStream) Marshal 

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

func (*DroppedStream) MarshalTo 

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

func (*DroppedStream) MarshalToSizedBuffer 

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

func (*DroppedStream) ProtoMessage 

func (*DroppedStream) ProtoMessage()

func (*DroppedStream) Reset 

func (m *DroppedStream) Reset()

func (*DroppedStream) Size 

func (m *DroppedStream) Size() (n int)

func (*DroppedStream) String 

func (this *DroppedStream) String() string

func (*DroppedStream) Unmarshal 

func (m *DroppedStream) Unmarshal(dAtA []byte) error

func (*DroppedStream) XXX_DiscardUnknown 

func (m *DroppedStream) XXX_DiscardUnknown()

func (*DroppedStream) XXX_Marshal 

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

func (*DroppedStream) XXX_Merge 

func (m *DroppedStream) XXX_Merge(src proto.Message)

func (*DroppedStream) XXX_Size 

func (m *DroppedStream) XXX_Size() int

func (*DroppedStream) XXX_Unmarshal 

func (m *DroppedStream) XXX_Unmarshal(b []byte) error

type Entry 

type Entry = push.Entry

type FPBounds 

type FPBounds struct {
	Min github_com_prometheus_common_model.Fingerprint `protobuf:"varint,1,opt,name=min,proto3,casttype=github.com/prometheus/common/model.Fingerprint" json:"min"`
	Max github_com_prometheus_common_model.Fingerprint `protobuf:"varint,2,opt,name=max,proto3,casttype=github.com/prometheus/common/model.Fingerprint" json:"max"`
}

FPBounds is identical to the definition in `pkg/storage/bloom/v1/bounds.FingerprintBounds` which ensures we can cast between them without allocations.

func (*FPBounds) Descriptor 

func (*FPBounds) Descriptor() ([]byte, []int)

func (*FPBounds) Equal 

func (this *FPBounds) Equal(that interface{}) bool

func (*FPBounds) GetMax 

func (m *FPBounds) GetMax() github_com_prometheus_common_model.Fingerprint

func (*FPBounds) GetMin 

func (m *FPBounds) GetMin() github_com_prometheus_common_model.Fingerprint

func (*FPBounds) GoString 

func (this *FPBounds) GoString() string

func (*FPBounds) Marshal 

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

func (*FPBounds) MarshalTo 

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

func (*FPBounds) MarshalToSizedBuffer 

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

func (*FPBounds) ProtoMessage 

func (*FPBounds) ProtoMessage()

func (*FPBounds) Reset 

func (m *FPBounds) Reset()

func (*FPBounds) Size 

func (m *FPBounds) Size() (n int)

func (*FPBounds) String 

func (this *FPBounds) String() string

func (*FPBounds) Unmarshal 

func (m *FPBounds) Unmarshal(dAtA []byte) error

func (*FPBounds) XXX_DiscardUnknown 

func (m *FPBounds) XXX_DiscardUnknown()

func (*FPBounds) XXX_Marshal 

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

func (*FPBounds) XXX_Merge 

func (m *FPBounds) XXX_Merge(src proto.Message)

func (*FPBounds) XXX_Size 

func (m *FPBounds) XXX_Size() int

func (*FPBounds) XXX_Unmarshal 

func (m *FPBounds) XXX_Unmarshal(b []byte) error

type FilterChunkRefRequest 

type FilterChunkRefRequest struct {
	From    github_com_prometheus_common_model.Time `protobuf:"varint,1,opt,name=from,proto3,customtype=github.com/prometheus/common/model.Time" json:"from"`
	Through github_com_prometheus_common_model.Time `protobuf:"varint,2,opt,name=through,proto3,customtype=github.com/prometheus/common/model.Time" json:"through"`
	Refs    []*GroupedChunkRefs                     `protobuf:"bytes,3,rep,name=refs,proto3" json:"refs,omitempty"`
	// field id 4 (filters) has been removed in favour of field id 5 (plan)
	Plan   github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan `protobuf:"bytes,5,opt,name=plan,proto3,customtype=github.com/grafana/loki/v3/pkg/querier/plan.QueryPlan" json:"plan"`
	Blocks []string                                              `protobuf:"bytes,6,rep,name=blocks,proto3" json:"blocks,omitempty"`
}

func (*FilterChunkRefRequest) Descriptor 

func (*FilterChunkRefRequest) Descriptor() ([]byte, []int)

func (*FilterChunkRefRequest) Equal 

func (this *FilterChunkRefRequest) Equal(that interface{}) bool

func (*FilterChunkRefRequest) GetBlocks added in v3.1.0 

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

func (*FilterChunkRefRequest) GetCachingOptions 

func (m *FilterChunkRefRequest) GetCachingOptions() (res resultscache.CachingOptions)

GetCachingOptions returns the caching options.

func (*FilterChunkRefRequest) GetEnd 

func (m *FilterChunkRefRequest) GetEnd() time.Time

GetEnd returns the end timestamp of the request in milliseconds.

func (*FilterChunkRefRequest) GetQuery 

func (m *FilterChunkRefRequest) GetQuery() string

TODO(owen-d): why does this return the hash of all the refs instead of the query? The latter should be significantly cheaper, more helpful (readable), and just as correct at being a unique identifier for the request. GetQuery returns the query of the request. The query is the hash for the input chunks refs and the filter expressions.

func (*FilterChunkRefRequest) GetRefs 

func (m *FilterChunkRefRequest) GetRefs() []*GroupedChunkRefs

func (*FilterChunkRefRequest) GetStart 

func (m *FilterChunkRefRequest) GetStart() time.Time

GetStart returns the start timestamp of the request in milliseconds.

func (*FilterChunkRefRequest) GetStep 

func (m *FilterChunkRefRequest) GetStep() int64

GetStep returns the step of the request in milliseconds. Always 0.

func (*FilterChunkRefRequest) GoString 

func (this *FilterChunkRefRequest) GoString() string

func (*FilterChunkRefRequest) Marshal 

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

func (*FilterChunkRefRequest) MarshalTo 

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

func (*FilterChunkRefRequest) MarshalToSizedBuffer 

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

func (*FilterChunkRefRequest) ProtoMessage 

func (*FilterChunkRefRequest) ProtoMessage()

func (*FilterChunkRefRequest) Reset 

func (m *FilterChunkRefRequest) Reset()

func (*FilterChunkRefRequest) Size 

func (m *FilterChunkRefRequest) Size() (n int)

func (*FilterChunkRefRequest) String 

func (this *FilterChunkRefRequest) String() string

func (*FilterChunkRefRequest) Unmarshal 

func (m *FilterChunkRefRequest) Unmarshal(dAtA []byte) error

func (*FilterChunkRefRequest) WithStartEndForCache 

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

WithStartEndForCache implements resultscache.Request.

func (*FilterChunkRefRequest) XXX_DiscardUnknown 

func (m *FilterChunkRefRequest) XXX_DiscardUnknown()

func (*FilterChunkRefRequest) XXX_Marshal 

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

func (*FilterChunkRefRequest) XXX_Merge 

func (m *FilterChunkRefRequest) XXX_Merge(src proto.Message)

func (*FilterChunkRefRequest) XXX_Size 

func (m *FilterChunkRefRequest) XXX_Size() int

func (*FilterChunkRefRequest) XXX_Unmarshal 

func (m *FilterChunkRefRequest) XXX_Unmarshal(b []byte) error

type FilterChunkRefResponse 

type FilterChunkRefResponse struct {
	ChunkRefs []*GroupedChunkRefs `protobuf:"bytes,1,rep,name=chunkRefs,proto3" json:"chunkRefs,omitempty"`
}

func (*FilterChunkRefResponse) Descriptor 

func (*FilterChunkRefResponse) Descriptor() ([]byte, []int)

func (*FilterChunkRefResponse) Equal 

func (this *FilterChunkRefResponse) Equal(that interface{}) bool

func (*FilterChunkRefResponse) GetChunkRefs 

func (m *FilterChunkRefResponse) GetChunkRefs() []*GroupedChunkRefs

func (*FilterChunkRefResponse) GoString 

func (this *FilterChunkRefResponse) GoString() string

func (*FilterChunkRefResponse) Marshal 

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

func (*FilterChunkRefResponse) MarshalTo 

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

func (*FilterChunkRefResponse) MarshalToSizedBuffer 

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

func (*FilterChunkRefResponse) ProtoMessage 

func (*FilterChunkRefResponse) ProtoMessage()

func (*FilterChunkRefResponse) Reset 

func (m *FilterChunkRefResponse) Reset()

func (*FilterChunkRefResponse) Size 

func (m *FilterChunkRefResponse) Size() (n int)

func (*FilterChunkRefResponse) String 

func (this *FilterChunkRefResponse) String() string

func (*FilterChunkRefResponse) Unmarshal 

func (m *FilterChunkRefResponse) Unmarshal(dAtA []byte) error

func (*FilterChunkRefResponse) XXX_DiscardUnknown 

func (m *FilterChunkRefResponse) XXX_DiscardUnknown()

func (*FilterChunkRefResponse) XXX_Marshal 

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

func (*FilterChunkRefResponse) XXX_Merge 

func (m *FilterChunkRefResponse) XXX_Merge(src proto.Message)

func (*FilterChunkRefResponse) XXX_Size 

func (m *FilterChunkRefResponse) XXX_Size() int

func (*FilterChunkRefResponse) XXX_Unmarshal 

func (m *FilterChunkRefResponse) XXX_Unmarshal(b []byte) error

type GetChunkIDsRequest 

type GetChunkIDsRequest struct {
	Matchers string    `protobuf:"bytes,1,opt,name=matchers,proto3" json:"matchers,omitempty"`
	Start    time.Time `protobuf:"bytes,2,opt,name=start,proto3,stdtime" json:"start"`
	End      time.Time `protobuf:"bytes,3,opt,name=end,proto3,stdtime" json:"end"`
}

func (*GetChunkIDsRequest) Descriptor 

func (*GetChunkIDsRequest) Descriptor() ([]byte, []int)

func (*GetChunkIDsRequest) Equal 

func (this *GetChunkIDsRequest) Equal(that interface{}) bool

func (*GetChunkIDsRequest) GetEnd 

func (m *GetChunkIDsRequest) GetEnd() time.Time

func (*GetChunkIDsRequest) GetMatchers 

func (m *GetChunkIDsRequest) GetMatchers() string

func (*GetChunkIDsRequest) GetStart 

func (m *GetChunkIDsRequest) GetStart() time.Time

func (*GetChunkIDsRequest) GoString 

func (this *GetChunkIDsRequest) GoString() string

func (*GetChunkIDsRequest) Marshal 

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

func (*GetChunkIDsRequest) MarshalTo 

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

func (*GetChunkIDsRequest) MarshalToSizedBuffer 

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

func (*GetChunkIDsRequest) ProtoMessage 

func (*GetChunkIDsRequest) ProtoMessage()

func (*GetChunkIDsRequest) Reset 

func (m *GetChunkIDsRequest) Reset()

func (*GetChunkIDsRequest) Size 

func (m *GetChunkIDsRequest) Size() (n int)

func (*GetChunkIDsRequest) String 

func (this *GetChunkIDsRequest) String() string

func (*GetChunkIDsRequest) Unmarshal 

func (m *GetChunkIDsRequest) Unmarshal(dAtA []byte) error

func (*GetChunkIDsRequest) XXX_DiscardUnknown 

func (m *GetChunkIDsRequest) XXX_DiscardUnknown()

func (*GetChunkIDsRequest) XXX_Marshal 

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

func (*GetChunkIDsRequest) XXX_Merge 

func (m *GetChunkIDsRequest) XXX_Merge(src proto.Message)

func (*GetChunkIDsRequest) XXX_Size 

func (m *GetChunkIDsRequest) XXX_Size() int

func (*GetChunkIDsRequest) XXX_Unmarshal 

func (m *GetChunkIDsRequest) XXX_Unmarshal(b []byte) error

type GetChunkIDsResponse 

type GetChunkIDsResponse struct {
	ChunkIDs []string `protobuf:"bytes,1,rep,name=chunkIDs,proto3" json:"chunkIDs,omitempty"`
}

func (*GetChunkIDsResponse) Descriptor 

func (*GetChunkIDsResponse) Descriptor() ([]byte, []int)

func (*GetChunkIDsResponse) Equal 

func (this *GetChunkIDsResponse) Equal(that interface{}) bool

func (*GetChunkIDsResponse) GetChunkIDs 

func (m *GetChunkIDsResponse) GetChunkIDs() []string

func (*GetChunkIDsResponse) GoString 

func (this *GetChunkIDsResponse) GoString() string

func (*GetChunkIDsResponse) Marshal 

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

func (*GetChunkIDsResponse) MarshalTo 

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

func (*GetChunkIDsResponse) MarshalToSizedBuffer 

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

func (*GetChunkIDsResponse) ProtoMessage 

func (*GetChunkIDsResponse) ProtoMessage()

func (*GetChunkIDsResponse) Reset 

func (m *GetChunkIDsResponse) Reset()

func (*GetChunkIDsResponse) Size 

func (m *GetChunkIDsResponse) Size() (n int)

func (*GetChunkIDsResponse) String 

func (this *GetChunkIDsResponse) String() string

func (*GetChunkIDsResponse) Unmarshal 

func (m *GetChunkIDsResponse) Unmarshal(dAtA []byte) error

func (*GetChunkIDsResponse) XXX_DiscardUnknown 

func (m *GetChunkIDsResponse) XXX_DiscardUnknown()

func (*GetChunkIDsResponse) XXX_Marshal 

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

func (*GetChunkIDsResponse) XXX_Merge 

func (m *GetChunkIDsResponse) XXX_Merge(src proto.Message)

func (*GetChunkIDsResponse) XXX_Size 

func (m *GetChunkIDsResponse) XXX_Size() int

func (*GetChunkIDsResponse) XXX_Unmarshal 

func (m *GetChunkIDsResponse) XXX_Unmarshal(b []byte) error

type GetChunkRefRequest 

type GetChunkRefRequest struct {
	From     github_com_prometheus_common_model.Time `protobuf:"varint,1,opt,name=from,proto3,customtype=github.com/prometheus/common/model.Time" json:"from"`
	Through  github_com_prometheus_common_model.Time `protobuf:"varint,2,opt,name=through,proto3,customtype=github.com/prometheus/common/model.Time" json:"through"`
	Matchers string                                  `protobuf:"bytes,3,opt,name=matchers,proto3" json:"matchers,omitempty"`
	// TODO(salvacorts): Delete this field once the weekly release is done.
	Filters []github_com_grafana_loki_v3_pkg_logql_syntax.LineFilter `protobuf:"bytes,4,rep,name=filters,proto3,customtype=github.com/grafana/loki/v3/pkg/logql/syntax.LineFilter" json:"filters"`
	Plan    github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan    `protobuf:"bytes,5,opt,name=plan,proto3,customtype=github.com/grafana/loki/v3/pkg/querier/plan.QueryPlan" json:"plan"`
}

func (*GetChunkRefRequest) Descriptor 

func (*GetChunkRefRequest) Descriptor() ([]byte, []int)

func (*GetChunkRefRequest) Equal 

func (this *GetChunkRefRequest) Equal(that interface{}) bool

func (*GetChunkRefRequest) GetMatchers 

func (m *GetChunkRefRequest) GetMatchers() string

func (*GetChunkRefRequest) GoString 

func (this *GetChunkRefRequest) GoString() string

func (*GetChunkRefRequest) Marshal 

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

func (*GetChunkRefRequest) MarshalTo 

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

func (*GetChunkRefRequest) MarshalToSizedBuffer 

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

func (*GetChunkRefRequest) ProtoMessage 

func (*GetChunkRefRequest) ProtoMessage()

func (*GetChunkRefRequest) Reset 

func (m *GetChunkRefRequest) Reset()

func (*GetChunkRefRequest) Size 

func (m *GetChunkRefRequest) Size() (n int)

func (*GetChunkRefRequest) String 

func (this *GetChunkRefRequest) String() string

func (*GetChunkRefRequest) Unmarshal 

func (m *GetChunkRefRequest) Unmarshal(dAtA []byte) error

func (*GetChunkRefRequest) XXX_DiscardUnknown 

func (m *GetChunkRefRequest) XXX_DiscardUnknown()

func (*GetChunkRefRequest) XXX_Marshal 

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

func (*GetChunkRefRequest) XXX_Merge 

func (m *GetChunkRefRequest) XXX_Merge(src proto.Message)

func (*GetChunkRefRequest) XXX_Size 

func (m *GetChunkRefRequest) XXX_Size() int

func (*GetChunkRefRequest) XXX_Unmarshal 

func (m *GetChunkRefRequest) XXX_Unmarshal(b []byte) error

type GetChunkRefResponse 

type GetChunkRefResponse struct {
	Refs []*ChunkRef `protobuf:"bytes,1,rep,name=refs,proto3" json:"refs,omitempty"`
}

func (*GetChunkRefResponse) Descriptor 

func (*GetChunkRefResponse) Descriptor() ([]byte, []int)

func (*GetChunkRefResponse) Equal 

func (this *GetChunkRefResponse) Equal(that interface{}) bool

func (*GetChunkRefResponse) GetRefs 

func (m *GetChunkRefResponse) GetRefs() []*ChunkRef

func (*GetChunkRefResponse) GoString 

func (this *GetChunkRefResponse) GoString() string

func (*GetChunkRefResponse) Marshal 

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

func (*GetChunkRefResponse) MarshalTo 

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

func (*GetChunkRefResponse) MarshalToSizedBuffer 

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

func (*GetChunkRefResponse) ProtoMessage 

func (*GetChunkRefResponse) ProtoMessage()

func (*GetChunkRefResponse) Reset 

func (m *GetChunkRefResponse) Reset()

func (*GetChunkRefResponse) Size 

func (m *GetChunkRefResponse) Size() (n int)

func (*GetChunkRefResponse) String 

func (this *GetChunkRefResponse) String() string

func (*GetChunkRefResponse) Unmarshal 

func (m *GetChunkRefResponse) Unmarshal(dAtA []byte) error

func (*GetChunkRefResponse) XXX_DiscardUnknown 

func (m *GetChunkRefResponse) XXX_DiscardUnknown()

func (*GetChunkRefResponse) XXX_Marshal 

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

func (*GetChunkRefResponse) XXX_Merge 

func (m *GetChunkRefResponse) XXX_Merge(src proto.Message)

func (*GetChunkRefResponse) XXX_Size 

func (m *GetChunkRefResponse) XXX_Size() int

func (*GetChunkRefResponse) XXX_Unmarshal 

func (m *GetChunkRefResponse) XXX_Unmarshal(b []byte) error

type GetSeriesRequest 

type GetSeriesRequest struct {
	From     github_com_prometheus_common_model.Time `protobuf:"varint,1,opt,name=from,proto3,customtype=github.com/prometheus/common/model.Time" json:"from"`
	Through  github_com_prometheus_common_model.Time `protobuf:"varint,2,opt,name=through,proto3,customtype=github.com/prometheus/common/model.Time" json:"through"`
	Matchers string                                  `protobuf:"bytes,3,opt,name=matchers,proto3" json:"matchers,omitempty"`
}

func (*GetSeriesRequest) Descriptor 

func (*GetSeriesRequest) Descriptor() ([]byte, []int)

func (*GetSeriesRequest) Equal 

func (this *GetSeriesRequest) Equal(that interface{}) bool

func (*GetSeriesRequest) GetMatchers 

func (m *GetSeriesRequest) GetMatchers() string

func (*GetSeriesRequest) GoString 

func (this *GetSeriesRequest) GoString() string

func (*GetSeriesRequest) Marshal 

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

func (*GetSeriesRequest) MarshalTo 

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

func (*GetSeriesRequest) MarshalToSizedBuffer 

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

func (*GetSeriesRequest) ProtoMessage 

func (*GetSeriesRequest) ProtoMessage()

func (*GetSeriesRequest) Reset 

func (m *GetSeriesRequest) Reset()

func (*GetSeriesRequest) Size 

func (m *GetSeriesRequest) Size() (n int)

func (*GetSeriesRequest) String 

func (this *GetSeriesRequest) String() string

func (*GetSeriesRequest) Unmarshal 

func (m *GetSeriesRequest) Unmarshal(dAtA []byte) error

func (*GetSeriesRequest) XXX_DiscardUnknown 

func (m *GetSeriesRequest) XXX_DiscardUnknown()

func (*GetSeriesRequest) XXX_Marshal 

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

func (*GetSeriesRequest) XXX_Merge 

func (m *GetSeriesRequest) XXX_Merge(src proto.Message)

func (*GetSeriesRequest) XXX_Size 

func (m *GetSeriesRequest) XXX_Size() int

func (*GetSeriesRequest) XXX_Unmarshal 

func (m *GetSeriesRequest) XXX_Unmarshal(b []byte) error

type GetSeriesResponse 

type GetSeriesResponse struct {
	Series []IndexSeries `protobuf:"bytes,1,rep,name=series,proto3" json:"series"`
}

func (*GetSeriesResponse) Descriptor 

func (*GetSeriesResponse) Descriptor() ([]byte, []int)

func (*GetSeriesResponse) Equal 

func (this *GetSeriesResponse) Equal(that interface{}) bool

func (*GetSeriesResponse) GetSeries 

func (m *GetSeriesResponse) GetSeries() []IndexSeries

func (*GetSeriesResponse) GoString 

func (this *GetSeriesResponse) GoString() string

func (*GetSeriesResponse) Marshal 

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

func (*GetSeriesResponse) MarshalTo 

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

func (*GetSeriesResponse) MarshalToSizedBuffer 

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

func (*GetSeriesResponse) ProtoMessage 

func (*GetSeriesResponse) ProtoMessage()

func (*GetSeriesResponse) Reset 

func (m *GetSeriesResponse) Reset()

func (*GetSeriesResponse) Size 

func (m *GetSeriesResponse) Size() (n int)

func (*GetSeriesResponse) String 

func (this *GetSeriesResponse) String() string

func (*GetSeriesResponse) Unmarshal 

func (m *GetSeriesResponse) Unmarshal(dAtA []byte) error

func (*GetSeriesResponse) XXX_DiscardUnknown 

func (m *GetSeriesResponse) XXX_DiscardUnknown()

func (*GetSeriesResponse) XXX_Marshal 

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

func (*GetSeriesResponse) XXX_Merge 

func (m *GetSeriesResponse) XXX_Merge(src proto.Message)

func (*GetSeriesResponse) XXX_Size 

func (m *GetSeriesResponse) XXX_Size() int

func (*GetSeriesResponse) XXX_Unmarshal 

func (m *GetSeriesResponse) XXX_Unmarshal(b []byte) error

type GroupedChunkRefs 

type GroupedChunkRefs struct {
	Fingerprint uint64      `protobuf:"varint,1,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	Tenant      string      `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Refs        []*ShortRef `protobuf:"bytes,3,rep,name=refs,proto3" json:"refs,omitempty"`
}

func (*GroupedChunkRefs) Cmp added in v3.1.0 

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

func (*GroupedChunkRefs) Descriptor 

func (*GroupedChunkRefs) Descriptor() ([]byte, []int)

func (*GroupedChunkRefs) Equal 

func (this *GroupedChunkRefs) Equal(that interface{}) bool

func (*GroupedChunkRefs) GetFingerprint 

func (m *GroupedChunkRefs) GetFingerprint() uint64

func (*GroupedChunkRefs) GetRefs 

func (m *GroupedChunkRefs) GetRefs() []*ShortRef

func (*GroupedChunkRefs) GetTenant 

func (m *GroupedChunkRefs) GetTenant() string

func (*GroupedChunkRefs) GoString 

func (this *GroupedChunkRefs) GoString() string

func (*GroupedChunkRefs) Less added in v3.1.0 

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

func (*GroupedChunkRefs) Marshal 

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

func (*GroupedChunkRefs) MarshalTo 

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

func (*GroupedChunkRefs) MarshalToSizedBuffer 

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

func (*GroupedChunkRefs) ProtoMessage 

func (*GroupedChunkRefs) ProtoMessage()

func (*GroupedChunkRefs) Reset 

func (m *GroupedChunkRefs) Reset()

func (*GroupedChunkRefs) Size 

func (m *GroupedChunkRefs) Size() (n int)

func (*GroupedChunkRefs) String 

func (this *GroupedChunkRefs) String() string

func (*GroupedChunkRefs) Unmarshal 

func (m *GroupedChunkRefs) Unmarshal(dAtA []byte) error

func (*GroupedChunkRefs) XXX_DiscardUnknown 

func (m *GroupedChunkRefs) XXX_DiscardUnknown()

func (*GroupedChunkRefs) XXX_Marshal 

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

func (*GroupedChunkRefs) XXX_Merge 

func (m *GroupedChunkRefs) XXX_Merge(src proto.Message)

func (*GroupedChunkRefs) XXX_Size 

func (m *GroupedChunkRefs) XXX_Size() int

func (*GroupedChunkRefs) XXX_Unmarshal 

func (m *GroupedChunkRefs) XXX_Unmarshal(b []byte) error

type IndexGatewayClient 

type IndexGatewayClient interface {
	/// QueryIndex reads the indexes required for given query & sends back the batch of rows
	/// in rpc streams
	QueryIndex(ctx context.Context, in *QueryIndexRequest, opts ...grpc.CallOption) (IndexGateway_QueryIndexClient, error)
	/// GetChunkRef returns chunk reference that match the provided label matchers
	GetChunkRef(ctx context.Context, in *GetChunkRefRequest, opts ...grpc.CallOption) (*GetChunkRefResponse, error)
	GetSeries(ctx context.Context, in *GetSeriesRequest, opts ...grpc.CallOption) (*GetSeriesResponse, error)
	LabelNamesForMetricName(ctx context.Context, in *LabelNamesForMetricNameRequest, opts ...grpc.CallOption) (*LabelResponse, error)
	LabelValuesForMetricName(ctx context.Context, in *LabelValuesForMetricNameRequest, opts ...grpc.CallOption) (*LabelResponse, error)
	// Note: this MUST be the same as the variant defined in
	// logproto.proto on the Querier service.
	GetStats(ctx context.Context, in *IndexStatsRequest, opts ...grpc.CallOption) (*IndexStatsResponse, error)
	// Note: this MUST be the same as the variant defined in
	// logproto.proto on the Querier service.
	GetVolume(ctx context.Context, in *VolumeRequest, opts ...grpc.CallOption) (*VolumeResponse, error)
	// GetShards is an optimized implemented shard-planning implementation
	// on the index gateway and not on the ingester.
	GetShards(ctx context.Context, in *ShardsRequest, opts ...grpc.CallOption) (IndexGateway_GetShardsClient, error)
}

IndexGatewayClient is the client API for IndexGateway service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewIndexGatewayClient 

func NewIndexGatewayClient(cc *grpc.ClientConn) IndexGatewayClient

type IndexGatewayServer 

type IndexGatewayServer interface {
	/// QueryIndex reads the indexes required for given query & sends back the batch of rows
	/// in rpc streams
	QueryIndex(*QueryIndexRequest, IndexGateway_QueryIndexServer) error
	/// GetChunkRef returns chunk reference that match the provided label matchers
	GetChunkRef(context.Context, *GetChunkRefRequest) (*GetChunkRefResponse, error)
	GetSeries(context.Context, *GetSeriesRequest) (*GetSeriesResponse, error)
	LabelNamesForMetricName(context.Context, *LabelNamesForMetricNameRequest) (*LabelResponse, error)
	LabelValuesForMetricName(context.Context, *LabelValuesForMetricNameRequest) (*LabelResponse, error)
	// Note: this MUST be the same as the variant defined in
	// logproto.proto on the Querier service.
	GetStats(context.Context, *IndexStatsRequest) (*IndexStatsResponse, error)
	// Note: this MUST be the same as the variant defined in
	// logproto.proto on the Querier service.
	GetVolume(context.Context, *VolumeRequest) (*VolumeResponse, error)
	// GetShards is an optimized implemented shard-planning implementation
	// on the index gateway and not on the ingester.
	GetShards(*ShardsRequest, IndexGateway_GetShardsServer) error
}

IndexGatewayServer is the server API for IndexGateway service.

type IndexGateway_GetShardsClient 

type IndexGateway_GetShardsClient interface {
	Recv() (*ShardsResponse, error)
	grpc.ClientStream
}

type IndexGateway_GetShardsServer 

type IndexGateway_GetShardsServer interface {
	Send(*ShardsResponse) error
	grpc.ServerStream
}

type IndexGateway_QueryIndexClient 

type IndexGateway_QueryIndexClient interface {
	Recv() (*QueryIndexResponse, error)
	grpc.ClientStream
}

type IndexGateway_QueryIndexServer 

type IndexGateway_QueryIndexServer interface {
	Send(*QueryIndexResponse) error
	grpc.ServerStream
}

type IndexQuery 

type IndexQuery struct {
	TableName        string `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
	HashValue        string `protobuf:"bytes,2,opt,name=hashValue,proto3" json:"hashValue,omitempty"`
	RangeValuePrefix []byte `protobuf:"bytes,3,opt,name=rangeValuePrefix,proto3" json:"rangeValuePrefix,omitempty"`
	RangeValueStart  []byte `protobuf:"bytes,4,opt,name=rangeValueStart,proto3" json:"rangeValueStart,omitempty"`
	ValueEqual       []byte `protobuf:"bytes,5,opt,name=valueEqual,proto3" json:"valueEqual,omitempty"`
}

func (*IndexQuery) Descriptor 

func (*IndexQuery) Descriptor() ([]byte, []int)

func (*IndexQuery) Equal 

func (this *IndexQuery) Equal(that interface{}) bool

func (*IndexQuery) GetHashValue 

func (m *IndexQuery) GetHashValue() string

func (*IndexQuery) GetRangeValuePrefix 

func (m *IndexQuery) GetRangeValuePrefix() []byte

func (*IndexQuery) GetRangeValueStart 

func (m *IndexQuery) GetRangeValueStart() []byte

func (*IndexQuery) GetTableName 

func (m *IndexQuery) GetTableName() string

func (*IndexQuery) GetValueEqual 

func (m *IndexQuery) GetValueEqual() []byte

func (*IndexQuery) GoString 

func (this *IndexQuery) GoString() string

func (*IndexQuery) Marshal 

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

func (*IndexQuery) MarshalTo 

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

func (*IndexQuery) MarshalToSizedBuffer 

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

func (*IndexQuery) ProtoMessage 

func (*IndexQuery) ProtoMessage()

func (*IndexQuery) Reset 

func (m *IndexQuery) Reset()

func (*IndexQuery) Size 

func (m *IndexQuery) Size() (n int)

func (*IndexQuery) String 

func (this *IndexQuery) String() string

func (*IndexQuery) Unmarshal 

func (m *IndexQuery) Unmarshal(dAtA []byte) error

func (*IndexQuery) XXX_DiscardUnknown 

func (m *IndexQuery) XXX_DiscardUnknown()

func (*IndexQuery) XXX_Marshal 

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

func (*IndexQuery) XXX_Merge 

func (m *IndexQuery) XXX_Merge(src proto.Message)

func (*IndexQuery) XXX_Size 

func (m *IndexQuery) XXX_Size() int

func (*IndexQuery) XXX_Unmarshal 

func (m *IndexQuery) XXX_Unmarshal(b []byte) error

type IndexSeries 

type IndexSeries struct {
	Labels []LabelAdapter `protobuf:"bytes,1,rep,name=labels,proto3,customtype=LabelAdapter" json:"labels"`
}

Series calls to the TSDB Index

func (*IndexSeries) Descriptor 

func (*IndexSeries) Descriptor() ([]byte, []int)

func (*IndexSeries) Equal 

func (this *IndexSeries) Equal(that interface{}) bool

func (*IndexSeries) GoString 

func (this *IndexSeries) GoString() string

func (*IndexSeries) Marshal 

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

func (*IndexSeries) MarshalTo 

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

func (*IndexSeries) MarshalToSizedBuffer 

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

func (*IndexSeries) ProtoMessage 

func (*IndexSeries) ProtoMessage()

func (*IndexSeries) Reset 

func (m *IndexSeries) Reset()

func (*IndexSeries) Size 

func (m *IndexSeries) Size() (n int)

func (*IndexSeries) String 

func (this *IndexSeries) String() string

func (*IndexSeries) Unmarshal 

func (m *IndexSeries) Unmarshal(dAtA []byte) error

func (*IndexSeries) XXX_DiscardUnknown 

func (m *IndexSeries) XXX_DiscardUnknown()

func (*IndexSeries) XXX_Marshal 

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

func (*IndexSeries) XXX_Merge 

func (m *IndexSeries) XXX_Merge(src proto.Message)

func (*IndexSeries) XXX_Size 

func (m *IndexSeries) XXX_Size() int

func (*IndexSeries) XXX_Unmarshal 

func (m *IndexSeries) XXX_Unmarshal(b []byte) error

type IndexStatsRequest 

type IndexStatsRequest struct {
	From     github_com_prometheus_common_model.Time `protobuf:"varint,1,opt,name=from,proto3,customtype=github.com/prometheus/common/model.Time" json:"from"`
	Through  github_com_prometheus_common_model.Time `protobuf:"varint,2,opt,name=through,proto3,customtype=github.com/prometheus/common/model.Time" json:"through"`
	Matchers string                                  `protobuf:"bytes,3,opt,name=matchers,proto3" json:"matchers,omitempty"`
}

func (*IndexStatsRequest) Descriptor 

func (*IndexStatsRequest) Descriptor() ([]byte, []int)

func (*IndexStatsRequest) Equal 

func (this *IndexStatsRequest) Equal(that interface{}) bool

func (*IndexStatsRequest) GetCachingOptions 

func (m *IndexStatsRequest) GetCachingOptions() (res definitions.CachingOptions)

GetCachingOptions returns the caching options.

func (*IndexStatsRequest) GetEnd 

func (m *IndexStatsRequest) GetEnd() time.Time

GetEnd returns the end timestamp of the request in milliseconds.

func (*IndexStatsRequest) GetMatchers 

func (m *IndexStatsRequest) GetMatchers() string

func (*IndexStatsRequest) GetQuery 

func (m *IndexStatsRequest) GetQuery() string

GetQuery returns the query of the request.

func (*IndexStatsRequest) GetStart 

func (m *IndexStatsRequest) GetStart() time.Time

GetStart returns the start timestamp of the request in milliseconds.

func (*IndexStatsRequest) GetStep 

func (m *IndexStatsRequest) GetStep() int64

GetStep returns the step of the request in milliseconds.

func (*IndexStatsRequest) GoString 

func (this *IndexStatsRequest) GoString() string

func (*IndexStatsRequest) LogToSpan 

func (m *IndexStatsRequest) LogToSpan(sp opentracing.Span)

LogToSpan writes information about this request to an OpenTracing span

func (*IndexStatsRequest) Marshal 

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

func (*IndexStatsRequest) MarshalTo 

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

func (*IndexStatsRequest) MarshalToSizedBuffer 

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

func (*IndexStatsRequest) ProtoMessage 

func (*IndexStatsRequest) ProtoMessage()

func (*IndexStatsRequest) Reset 

func (m *IndexStatsRequest) Reset()

func (*IndexStatsRequest) Size 

func (m *IndexStatsRequest) Size() (n int)

func (*IndexStatsRequest) String 

func (this *IndexStatsRequest) String() string

func (*IndexStatsRequest) Unmarshal 

func (m *IndexStatsRequest) Unmarshal(dAtA []byte) error

func (*IndexStatsRequest) WithQuery 

func (m *IndexStatsRequest) WithQuery(query string) definitions.Request

WithQuery clone the current request with a different query.

func (*IndexStatsRequest) WithStartEnd 

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

WithStartEnd clone the current request with different start and end timestamp.

func (*IndexStatsRequest) WithStartEndForCache 

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

WithStartEndForCache implements resultscache.Request.

func (*IndexStatsRequest) XXX_DiscardUnknown 

func (m *IndexStatsRequest) XXX_DiscardUnknown()

func (*IndexStatsRequest) XXX_Marshal 

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

func (*IndexStatsRequest) XXX_Merge 

func (m *IndexStatsRequest) XXX_Merge(src proto.Message)

func (*IndexStatsRequest) XXX_Size 

func (m *IndexStatsRequest) XXX_Size() int

func (*IndexStatsRequest) XXX_Unmarshal 

func (m *IndexStatsRequest) XXX_Unmarshal(b []byte) error

type IndexStatsResponse 

type IndexStatsResponse struct {
	Streams uint64 `protobuf:"varint,1,opt,name=streams,proto3" json:"streams"`
	Chunks  uint64 `protobuf:"varint,2,opt,name=chunks,proto3" json:"chunks"`
	Bytes   uint64 `protobuf:"varint,3,opt,name=bytes,proto3" json:"bytes"`
	Entries uint64 `protobuf:"varint,4,opt,name=entries,proto3" json:"entries"`
}

func (*IndexStatsResponse) AddChunkStats 

func (m *IndexStatsResponse) AddChunkStats(s index.ChunkStats)

Safe for concurrent use

func (*IndexStatsResponse) AddStream 

func (m *IndexStatsResponse) AddStream(_ model.Fingerprint)

Safe for concurrent use

func (*IndexStatsResponse) Descriptor 

func (*IndexStatsResponse) Descriptor() ([]byte, []int)

func (*IndexStatsResponse) Equal 

func (this *IndexStatsResponse) Equal(that interface{}) bool

func (*IndexStatsResponse) GetBytes 

func (m *IndexStatsResponse) GetBytes() uint64

func (*IndexStatsResponse) GetChunks 

func (m *IndexStatsResponse) GetChunks() uint64

func (*IndexStatsResponse) GetEntries 

func (m *IndexStatsResponse) GetEntries() uint64

func (*IndexStatsResponse) GetHeaders 

func (i *IndexStatsResponse) GetHeaders() []*definitions.PrometheusResponseHeader

func (*IndexStatsResponse) GetStreams 

func (m *IndexStatsResponse) GetStreams() uint64

func (*IndexStatsResponse) GoString 

func (this *IndexStatsResponse) GoString() string

func (*IndexStatsResponse) LoggingKeyValues 

func (m *IndexStatsResponse) LoggingKeyValues() []interface{}

Helper function for returning the key value pairs to be passed to a logger

func (*IndexStatsResponse) Marshal 

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

func (*IndexStatsResponse) MarshalTo 

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

func (*IndexStatsResponse) MarshalToSizedBuffer 

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

func (*IndexStatsResponse) ProtoMessage 

func (*IndexStatsResponse) ProtoMessage()

func (*IndexStatsResponse) Reset 

func (m *IndexStatsResponse) Reset()

func (*IndexStatsResponse) Size 

func (m *IndexStatsResponse) Size() (n int)

func (*IndexStatsResponse) Stats 

func (m *IndexStatsResponse) Stats() IndexStatsResponse

func (*IndexStatsResponse) String 

func (this *IndexStatsResponse) String() string

func (*IndexStatsResponse) Unmarshal 

func (m *IndexStatsResponse) Unmarshal(dAtA []byte) error

func (*IndexStatsResponse) XXX_DiscardUnknown 

func (m *IndexStatsResponse) XXX_DiscardUnknown()

func (*IndexStatsResponse) XXX_Marshal 

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

func (*IndexStatsResponse) XXX_Merge 

func (m *IndexStatsResponse) XXX_Merge(src proto.Message)

func (*IndexStatsResponse) XXX_Size 

func (m *IndexStatsResponse) XXX_Size() int

func (*IndexStatsResponse) XXX_Unmarshal 

func (m *IndexStatsResponse) XXX_Unmarshal(b []byte) error

type LabelAdapter 

type LabelAdapter = push.LabelAdapter

func FromLabelsToLabelAdapters 

func FromLabelsToLabelAdapters(ls labels.Labels) []LabelAdapter

FromLabelsToLabelAdapters casts labels.Labels to []LabelAdapter. It uses unsafe, but as LabelAdapter == labels.Label this should be safe. This allows us to use labels.Labels directly in protos.

func FromMetricsToLabelAdapters 

func FromMetricsToLabelAdapters(metric model.Metric) []LabelAdapter

FromMetricsToLabelAdapters converts model.Metric to []LabelAdapter. Don't do this on any performance sensitive paths. The result is sorted.

type LabelNamesForMetricNameRequest 

type LabelNamesForMetricNameRequest struct {
	MetricName string                                  `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	From       github_com_prometheus_common_model.Time `protobuf:"varint,2,opt,name=from,proto3,customtype=github.com/prometheus/common/model.Time" json:"from"`
	Through    github_com_prometheus_common_model.Time `protobuf:"varint,3,opt,name=through,proto3,customtype=github.com/prometheus/common/model.Time" json:"through"`
	Matchers   string                                  `protobuf:"bytes,4,opt,name=matchers,proto3" json:"matchers,omitempty"`
}

func (*LabelNamesForMetricNameRequest) Descriptor 

func (*LabelNamesForMetricNameRequest) Descriptor() ([]byte, []int)

func (*LabelNamesForMetricNameRequest) Equal 

func (this *LabelNamesForMetricNameRequest) Equal(that interface{}) bool

func (*LabelNamesForMetricNameRequest) GetMatchers added in v3.1.0 

func (m *LabelNamesForMetricNameRequest) GetMatchers() string

func (*LabelNamesForMetricNameRequest) GetMetricName 

func (m *LabelNamesForMetricNameRequest) GetMetricName() string

func (*LabelNamesForMetricNameRequest) GoString 

func (this *LabelNamesForMetricNameRequest) GoString() string

func (*LabelNamesForMetricNameRequest) Marshal 

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

func (*LabelNamesForMetricNameRequest) MarshalTo 

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

func (*LabelNamesForMetricNameRequest) MarshalToSizedBuffer 

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

func (*LabelNamesForMetricNameRequest) ProtoMessage 

func (*LabelNamesForMetricNameRequest) ProtoMessage()

func (*LabelNamesForMetricNameRequest) Reset 

func (m *LabelNamesForMetricNameRequest) Reset()

func (*LabelNamesForMetricNameRequest) Size 

func (m *LabelNamesForMetricNameRequest) Size() (n int)

func (*LabelNamesForMetricNameRequest) String 

func (this *LabelNamesForMetricNameRequest) String() string

func (*LabelNamesForMetricNameRequest) Unmarshal 

func (m *LabelNamesForMetricNameRequest) Unmarshal(dAtA []byte) error

func (*LabelNamesForMetricNameRequest) XXX_DiscardUnknown 

func (m *LabelNamesForMetricNameRequest) XXX_DiscardUnknown()

func (*LabelNamesForMetricNameRequest) XXX_Marshal 

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

func (*LabelNamesForMetricNameRequest) XXX_Merge 

func (m *LabelNamesForMetricNameRequest) XXX_Merge(src proto.Message)

func (*LabelNamesForMetricNameRequest) XXX_Size 

func (m *LabelNamesForMetricNameRequest) XXX_Size() int

func (*LabelNamesForMetricNameRequest) XXX_Unmarshal 

func (m *LabelNamesForMetricNameRequest) XXX_Unmarshal(b []byte) error

type LabelPair 

type LabelPair struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*LabelPair) Descriptor 

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

func (*LabelPair) Equal 

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

func (*LabelPair) GetName 

func (m *LabelPair) GetName() string

func (*LabelPair) GetValue 

func (m *LabelPair) GetValue() string

func (*LabelPair) GoString 

func (this *LabelPair) GoString() string

func (*LabelPair) Marshal 

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

func (*LabelPair) MarshalTo 

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

func (*LabelPair) MarshalToSizedBuffer 

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

func (*LabelPair) ProtoMessage 

func (*LabelPair) ProtoMessage()

func (*LabelPair) Reset 

func (m *LabelPair) Reset()

func (*LabelPair) Size 

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

func (*LabelPair) String 

func (this *LabelPair) String() string

func (*LabelPair) Unmarshal 

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

func (*LabelPair) XXX_DiscardUnknown 

func (m *LabelPair) XXX_DiscardUnknown()

func (*LabelPair) XXX_Marshal 

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

func (*LabelPair) XXX_Merge 

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

func (*LabelPair) XXX_Size 

func (m *LabelPair) XXX_Size() int

func (*LabelPair) XXX_Unmarshal 

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

type LabelRequest 

type LabelRequest struct {
	Name   string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Values bool       `protobuf:"varint,2,opt,name=values,proto3" json:"values,omitempty"`
	Start  *time.Time `protobuf:"bytes,3,opt,name=start,proto3,stdtime" json:"start,omitempty"`
	End    *time.Time `protobuf:"bytes,4,opt,name=end,proto3,stdtime" json:"end,omitempty"`
	Query  string     `protobuf:"bytes,5,opt,name=query,proto3" json:"query,omitempty"`
}

func (*LabelRequest) Descriptor 

func (*LabelRequest) Descriptor() ([]byte, []int)

func (*LabelRequest) Equal 

func (this *LabelRequest) Equal(that interface{}) bool

func (*LabelRequest) GetEnd 

func (m *LabelRequest) GetEnd() *time.Time

func (*LabelRequest) GetName 

func (m *LabelRequest) GetName() string

func (*LabelRequest) GetQuery 

func (m *LabelRequest) GetQuery() string

func (*LabelRequest) GetStart 

func (m *LabelRequest) GetStart() *time.Time

func (*LabelRequest) GetValues 

func (m *LabelRequest) GetValues() bool

func (*LabelRequest) GoString 

func (this *LabelRequest) GoString() string

func (*LabelRequest) Marshal 

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

func (*LabelRequest) MarshalTo 

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

func (*LabelRequest) MarshalToSizedBuffer 

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

func (*LabelRequest) ProtoMessage 

func (*LabelRequest) ProtoMessage()

func (*LabelRequest) Reset 

func (m *LabelRequest) Reset()

func (*LabelRequest) Size 

func (m *LabelRequest) Size() (n int)

func (*LabelRequest) String 

func (this *LabelRequest) String() string

func (*LabelRequest) Unmarshal 

func (m *LabelRequest) Unmarshal(dAtA []byte) error

func (*LabelRequest) XXX_DiscardUnknown 

func (m *LabelRequest) XXX_DiscardUnknown()

func (*LabelRequest) XXX_Marshal 

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

func (*LabelRequest) XXX_Merge 

func (m *LabelRequest) XXX_Merge(src proto.Message)

func (*LabelRequest) XXX_Size 

func (m *LabelRequest) XXX_Size() int

func (*LabelRequest) XXX_Unmarshal 

func (m *LabelRequest) XXX_Unmarshal(b []byte) error

type LabelResponse 

type LabelResponse struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
}

func MergeLabelResponses 

func MergeLabelResponses(responses []*LabelResponse) (*LabelResponse, error)

Combine unique values from multiple LabelResponses into a single, sorted LabelResponse.

func (*LabelResponse) Descriptor 

func (*LabelResponse) Descriptor() ([]byte, []int)

func (*LabelResponse) Equal 

func (this *LabelResponse) Equal(that interface{}) bool

func (*LabelResponse) GetValues 

func (m *LabelResponse) GetValues() []string

func (*LabelResponse) GoString 

func (this *LabelResponse) GoString() string

func (*LabelResponse) Marshal 

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

func (*LabelResponse) MarshalTo 

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

func (*LabelResponse) MarshalToSizedBuffer 

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

func (*LabelResponse) ProtoMessage 

func (*LabelResponse) ProtoMessage()

func (*LabelResponse) Reset 

func (m *LabelResponse) Reset()

func (*LabelResponse) Size 

func (m *LabelResponse) Size() (n int)

func (*LabelResponse) String 

func (this *LabelResponse) String() string

func (*LabelResponse) Unmarshal 

func (m *LabelResponse) Unmarshal(dAtA []byte) error

func (*LabelResponse) XXX_DiscardUnknown 

func (m *LabelResponse) XXX_DiscardUnknown()

func (*LabelResponse) XXX_Marshal 

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

func (*LabelResponse) XXX_Merge 

func (m *LabelResponse) XXX_Merge(src proto.Message)

func (*LabelResponse) XXX_Size 

func (m *LabelResponse) XXX_Size() int

func (*LabelResponse) XXX_Unmarshal 

func (m *LabelResponse) XXX_Unmarshal(b []byte) error

type LabelToValuesResponse 

type LabelToValuesResponse struct {
	Labels map[string]*UniqueLabelValues `` /* 153-byte string literal not displayed */
}

func (*LabelToValuesResponse) Descriptor 

func (*LabelToValuesResponse) Descriptor() ([]byte, []int)

func (*LabelToValuesResponse) Equal 

func (this *LabelToValuesResponse) Equal(that interface{}) bool

func (*LabelToValuesResponse) GetLabels 

func (m *LabelToValuesResponse) GetLabels() map[string]*UniqueLabelValues

func (*LabelToValuesResponse) GoString 

func (this *LabelToValuesResponse) GoString() string

func (*LabelToValuesResponse) Marshal 

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

func (*LabelToValuesResponse) MarshalTo 

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

func (*LabelToValuesResponse) MarshalToSizedBuffer 

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

func (*LabelToValuesResponse) ProtoMessage 

func (*LabelToValuesResponse) ProtoMessage()

func (*LabelToValuesResponse) Reset 

func (m *LabelToValuesResponse) Reset()

func (*LabelToValuesResponse) Size 

func (m *LabelToValuesResponse) Size() (n int)

func (*LabelToValuesResponse) String 

func (this *LabelToValuesResponse) String() string

func (*LabelToValuesResponse) Unmarshal 

func (m *LabelToValuesResponse) Unmarshal(dAtA []byte) error

func (*LabelToValuesResponse) XXX_DiscardUnknown 

func (m *LabelToValuesResponse) XXX_DiscardUnknown()

func (*LabelToValuesResponse) XXX_Marshal 

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

func (*LabelToValuesResponse) XXX_Merge 

func (m *LabelToValuesResponse) XXX_Merge(src proto.Message)

func (*LabelToValuesResponse) XXX_Size 

func (m *LabelToValuesResponse) XXX_Size() int

func (*LabelToValuesResponse) XXX_Unmarshal 

func (m *LabelToValuesResponse) XXX_Unmarshal(b []byte) error

type LabelValuesForMetricNameRequest 

type LabelValuesForMetricNameRequest struct {
	MetricName string                                  `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	LabelName  string                                  `protobuf:"bytes,2,opt,name=label_name,json=labelName,proto3" json:"label_name,omitempty"`
	From       github_com_prometheus_common_model.Time `protobuf:"varint,3,opt,name=from,proto3,customtype=github.com/prometheus/common/model.Time" json:"from"`
	Through    github_com_prometheus_common_model.Time `protobuf:"varint,4,opt,name=through,proto3,customtype=github.com/prometheus/common/model.Time" json:"through"`
	Matchers   string                                  `protobuf:"bytes,5,opt,name=matchers,proto3" json:"matchers,omitempty"`
}

func (*LabelValuesForMetricNameRequest) Descriptor 

func (*LabelValuesForMetricNameRequest) Descriptor() ([]byte, []int)

func (*LabelValuesForMetricNameRequest) Equal 

func (this *LabelValuesForMetricNameRequest) Equal(that interface{}) bool

func (*LabelValuesForMetricNameRequest) GetLabelName 

func (m *LabelValuesForMetricNameRequest) GetLabelName() string

func (*LabelValuesForMetricNameRequest) GetMatchers 

func (m *LabelValuesForMetricNameRequest) GetMatchers() string

func (*LabelValuesForMetricNameRequest) GetMetricName 

func (m *LabelValuesForMetricNameRequest) GetMetricName() string

func (*LabelValuesForMetricNameRequest) GoString 

func (this *LabelValuesForMetricNameRequest) GoString() string

func (*LabelValuesForMetricNameRequest) Marshal 

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

func (*LabelValuesForMetricNameRequest) MarshalTo 

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

func (*LabelValuesForMetricNameRequest) MarshalToSizedBuffer 

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

func (*LabelValuesForMetricNameRequest) ProtoMessage 

func (*LabelValuesForMetricNameRequest) ProtoMessage()

func (*LabelValuesForMetricNameRequest) Reset 

func (m *LabelValuesForMetricNameRequest) Reset()

func (*LabelValuesForMetricNameRequest) Size 

func (m *LabelValuesForMetricNameRequest) Size() (n int)

func (*LabelValuesForMetricNameRequest) String 

func (this *LabelValuesForMetricNameRequest) String() string

func (*LabelValuesForMetricNameRequest) Unmarshal 

func (m *LabelValuesForMetricNameRequest) Unmarshal(dAtA []byte) error

func (*LabelValuesForMetricNameRequest) XXX_DiscardUnknown 

func (m *LabelValuesForMetricNameRequest) XXX_DiscardUnknown()

func (*LabelValuesForMetricNameRequest) XXX_Marshal 

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

func (*LabelValuesForMetricNameRequest) XXX_Merge 

func (m *LabelValuesForMetricNameRequest) XXX_Merge(src proto.Message)

func (*LabelValuesForMetricNameRequest) XXX_Size 

func (m *LabelValuesForMetricNameRequest) XXX_Size() int

func (*LabelValuesForMetricNameRequest) XXX_Unmarshal 

func (m *LabelValuesForMetricNameRequest) XXX_Unmarshal(b []byte) error

type LegacyLabelPair 

type LegacyLabelPair struct {
	Name  []byte `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

LegacyLabelPair exists for backwards compatibility reasons and is deprecated. Do not use. Use LabelPair instead.

func (*LegacyLabelPair) Descriptor 

func (*LegacyLabelPair) Descriptor() ([]byte, []int)

func (*LegacyLabelPair) Equal 

func (this *LegacyLabelPair) Equal(that interface{}) bool

func (*LegacyLabelPair) GetName 

func (m *LegacyLabelPair) GetName() []byte

func (*LegacyLabelPair) GetValue 

func (m *LegacyLabelPair) GetValue() []byte

func (*LegacyLabelPair) GoString 

func (this *LegacyLabelPair) GoString() string

func (*LegacyLabelPair) Marshal 

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

func (*LegacyLabelPair) MarshalTo 

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

func (*LegacyLabelPair) MarshalToSizedBuffer 

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

func (*LegacyLabelPair) ProtoMessage 

func (*LegacyLabelPair) ProtoMessage()

func (*LegacyLabelPair) Reset 

func (m *LegacyLabelPair) Reset()

func (*LegacyLabelPair) Size 

func (m *LegacyLabelPair) Size() (n int)

func (*LegacyLabelPair) String 

func (this *LegacyLabelPair) String() string

func (*LegacyLabelPair) Unmarshal 

func (m *LegacyLabelPair) Unmarshal(dAtA []byte) error

func (*LegacyLabelPair) XXX_DiscardUnknown 

func (m *LegacyLabelPair) XXX_DiscardUnknown()

func (*LegacyLabelPair) XXX_Marshal 

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

func (*LegacyLabelPair) XXX_Merge 

func (m *LegacyLabelPair) XXX_Merge(src proto.Message)

func (*LegacyLabelPair) XXX_Size 

func (m *LegacyLabelPair) XXX_Size() int

func (*LegacyLabelPair) XXX_Unmarshal 

func (m *LegacyLabelPair) XXX_Unmarshal(b []byte) error

type LegacySample 

type LegacySample struct {
	Value       float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	TimestampMs int64   `protobuf:"varint,2,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
}

LegacySample exists for backwards compatibility reasons and is deprecated. Do not use.

func (*LegacySample) Descriptor 

func (*LegacySample) Descriptor() ([]byte, []int)

func (*LegacySample) Equal 

func (this *LegacySample) Equal(that interface{}) bool

func (*LegacySample) GetTimestampMs 

func (m *LegacySample) GetTimestampMs() int64

func (*LegacySample) GetValue 

func (m *LegacySample) GetValue() float64

func (*LegacySample) GoString 

func (this *LegacySample) GoString() string

func (*LegacySample) Marshal 

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

func (LegacySample) MarshalJSON 

func (s LegacySample) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler.

func (*LegacySample) MarshalTo 

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

func (*LegacySample) MarshalToSizedBuffer 

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

func (*LegacySample) ProtoMessage 

func (*LegacySample) ProtoMessage()

func (*LegacySample) Reset 

func (m *LegacySample) Reset()

func (*LegacySample) Size 

func (m *LegacySample) Size() (n int)

func (*LegacySample) String 

func (this *LegacySample) String() string

func (*LegacySample) Unmarshal 

func (m *LegacySample) Unmarshal(dAtA []byte) error

func (*LegacySample) UnmarshalJSON 

func (s *LegacySample) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler.

func (*LegacySample) XXX_DiscardUnknown 

func (m *LegacySample) XXX_DiscardUnknown()

func (*LegacySample) XXX_Marshal 

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

func (*LegacySample) XXX_Merge 

func (m *LegacySample) XXX_Merge(src proto.Message)

func (*LegacySample) XXX_Size 

func (m *LegacySample) XXX_Size() int

func (*LegacySample) XXX_Unmarshal 

func (m *LegacySample) XXX_Unmarshal(b []byte) error

type LineFilter 

type LineFilter struct {
	Raw []byte `protobuf:"bytes,1,opt,name=raw,proto3" json:"raw,omitempty"`
}

TODO(owen-d): fix. This will break rollouts as soon as the internal repr is changed.

func (*LineFilter) Descriptor 

func (*LineFilter) Descriptor() ([]byte, []int)

func (*LineFilter) Equal 

func (this *LineFilter) Equal(that interface{}) bool

func (*LineFilter) GetRaw 

func (m *LineFilter) GetRaw() []byte

func (*LineFilter) GoString 

func (this *LineFilter) GoString() string

func (*LineFilter) Marshal 

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

func (*LineFilter) MarshalTo 

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

func (*LineFilter) MarshalToSizedBuffer 

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

func (*LineFilter) ProtoMessage 

func (*LineFilter) ProtoMessage()

func (*LineFilter) Reset 

func (m *LineFilter) Reset()

func (*LineFilter) Size 

func (m *LineFilter) Size() (n int)

func (*LineFilter) String 

func (this *LineFilter) String() string

func (*LineFilter) Unmarshal 

func (m *LineFilter) Unmarshal(dAtA []byte) error

func (*LineFilter) XXX_DiscardUnknown 

func (m *LineFilter) XXX_DiscardUnknown()

func (*LineFilter) XXX_Marshal 

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

func (*LineFilter) XXX_Merge 

func (m *LineFilter) XXX_Merge(src proto.Message)

func (*LineFilter) XXX_Size 

func (m *LineFilter) XXX_Size() int

func (*LineFilter) XXX_Unmarshal 

func (m *LineFilter) XXX_Unmarshal(b []byte) error

type Metric 

type Metric struct {
	Labels []LabelAdapter `protobuf:"bytes,1,rep,name=labels,proto3,customtype=LabelAdapter" json:"labels"`
}

func (*Metric) Descriptor 

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

func (*Metric) Equal 

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

func (*Metric) GoString 

func (this *Metric) GoString() string

func (*Metric) Marshal 

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

func (*Metric) MarshalTo 

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

func (*Metric) MarshalToSizedBuffer 

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

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) Reset 

func (m *Metric) Reset()

func (*Metric) Size 

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

func (*Metric) String 

func (this *Metric) String() string

func (*Metric) Unmarshal 

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

func (*Metric) XXX_DiscardUnknown 

func (m *Metric) XXX_DiscardUnknown()

func (*Metric) XXX_Marshal 

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

func (*Metric) XXX_Merge 

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

func (*Metric) XXX_Size 

func (m *Metric) XXX_Size() int

func (*Metric) XXX_Unmarshal 

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

type MetricMetadata 

type MetricMetadata struct {
	Type             MetricMetadata_MetricType `protobuf:"varint,1,opt,name=type,proto3,enum=logproto.MetricMetadata_MetricType" json:"type,omitempty"`
	MetricFamilyName string                    `protobuf:"bytes,2,opt,name=metric_family_name,json=metricFamilyName,proto3" json:"metric_family_name,omitempty"`
	Help             string                    `protobuf:"bytes,4,opt,name=help,proto3" json:"help,omitempty"`
	Unit             string                    `protobuf:"bytes,5,opt,name=unit,proto3" json:"unit,omitempty"`
}

func (*MetricMetadata) Descriptor 

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

func (*MetricMetadata) Equal 

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

func (*MetricMetadata) GetHelp 

func (m *MetricMetadata) GetHelp() string

func (*MetricMetadata) GetMetricFamilyName 

func (m *MetricMetadata) GetMetricFamilyName() string

func (*MetricMetadata) GetType 

func (m *MetricMetadata) GetType() MetricMetadata_MetricType

func (*MetricMetadata) GetUnit 

func (m *MetricMetadata) GetUnit() string

func (*MetricMetadata) GoString 

func (this *MetricMetadata) GoString() string

func (*MetricMetadata) Marshal 

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

func (*MetricMetadata) MarshalTo 

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

func (*MetricMetadata) MarshalToSizedBuffer 

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

func (*MetricMetadata) ProtoMessage 

func (*MetricMetadata) ProtoMessage()

func (*MetricMetadata) Reset 

func (m *MetricMetadata) Reset()

func (*MetricMetadata) Size 

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

func (*MetricMetadata) String 

func (this *MetricMetadata) String() string

func (*MetricMetadata) Unmarshal 

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

func (*MetricMetadata) XXX_DiscardUnknown 

func (m *MetricMetadata) XXX_DiscardUnknown()

func (*MetricMetadata) XXX_Marshal 

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

func (*MetricMetadata) XXX_Merge 

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

func (*MetricMetadata) XXX_Size 

func (m *MetricMetadata) XXX_Size() int

func (*MetricMetadata) XXX_Unmarshal 

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

type MetricMetadata_MetricType 

type MetricMetadata_MetricType int32
const (
	UNKNOWN        MetricMetadata_MetricType = 0
	COUNTER        MetricMetadata_MetricType = 1
	GAUGE          MetricMetadata_MetricType = 2
	HISTOGRAM      MetricMetadata_MetricType = 3
	GAUGEHISTOGRAM MetricMetadata_MetricType = 4
	SUMMARY        MetricMetadata_MetricType = 5
	INFO           MetricMetadata_MetricType = 6
	STATESET       MetricMetadata_MetricType = 7
)

func (MetricMetadata_MetricType) EnumDescriptor 

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

func (MetricMetadata_MetricType) String 

func (x MetricMetadata_MetricType) String() string

type PatternClient 

type PatternClient interface {
	Push(ctx context.Context, in *push.PushRequest, opts ...grpc.CallOption) (*push.PushResponse, error)
	Query(ctx context.Context, in *QueryPatternsRequest, opts ...grpc.CallOption) (Pattern_QueryClient, error)
}

PatternClient is the client API for Pattern service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPatternClient 

func NewPatternClient(cc *grpc.ClientConn) PatternClient

type PatternSample 

type PatternSample struct {
	Timestamp github_com_prometheus_common_model.Time `protobuf:"varint,1,opt,name=timestamp,proto3,customtype=github.com/prometheus/common/model.Time" json:"timestamp"`
	Value     int64                                   `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*PatternSample) Descriptor 

func (*PatternSample) Descriptor() ([]byte, []int)

func (*PatternSample) Equal 

func (this *PatternSample) Equal(that interface{}) bool

func (*PatternSample) GetValue 

func (m *PatternSample) GetValue() int64

func (*PatternSample) GoString 

func (this *PatternSample) GoString() string

func (*PatternSample) Marshal 

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

func (*PatternSample) MarshalTo 

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

func (*PatternSample) MarshalToSizedBuffer 

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

func (*PatternSample) ProtoMessage 

func (*PatternSample) ProtoMessage()

func (*PatternSample) Reset 

func (m *PatternSample) Reset()

func (*PatternSample) Size 

func (m *PatternSample) Size() (n int)

func (*PatternSample) String 

func (this *PatternSample) String() string

func (*PatternSample) Unmarshal 

func (m *PatternSample) Unmarshal(dAtA []byte) error

func (*PatternSample) XXX_DiscardUnknown 

func (m *PatternSample) XXX_DiscardUnknown()

func (*PatternSample) XXX_Marshal 

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

func (*PatternSample) XXX_Merge 

func (m *PatternSample) XXX_Merge(src proto.Message)

func (*PatternSample) XXX_Size 

func (m *PatternSample) XXX_Size() int

func (*PatternSample) XXX_Unmarshal 

func (m *PatternSample) XXX_Unmarshal(b []byte) error

type PatternSeries 

type PatternSeries struct {
	Pattern string           `protobuf:"bytes,1,opt,name=pattern,proto3" json:"pattern,omitempty"`
	Samples []*PatternSample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"`
}

func (*PatternSeries) Descriptor 

func (*PatternSeries) Descriptor() ([]byte, []int)

func (*PatternSeries) Equal 

func (this *PatternSeries) Equal(that interface{}) bool

func (*PatternSeries) GetPattern 

func (m *PatternSeries) GetPattern() string

func (*PatternSeries) GetSamples 

func (m *PatternSeries) GetSamples() []*PatternSample

func (*PatternSeries) GoString 

func (this *PatternSeries) GoString() string

func (*PatternSeries) Marshal 

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

func (*PatternSeries) MarshalTo 

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

func (*PatternSeries) MarshalToSizedBuffer 

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

func (*PatternSeries) ProtoMessage 

func (*PatternSeries) ProtoMessage()

func (*PatternSeries) Reset 

func (m *PatternSeries) Reset()

func (*PatternSeries) Size 

func (m *PatternSeries) Size() (n int)

func (*PatternSeries) String 

func (this *PatternSeries) String() string

func (*PatternSeries) Unmarshal 

func (m *PatternSeries) Unmarshal(dAtA []byte) error

func (*PatternSeries) XXX_DiscardUnknown 

func (m *PatternSeries) XXX_DiscardUnknown()

func (*PatternSeries) XXX_Marshal 

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

func (*PatternSeries) XXX_Merge 

func (m *PatternSeries) XXX_Merge(src proto.Message)

func (*PatternSeries) XXX_Size 

func (m *PatternSeries) XXX_Size() int

func (*PatternSeries) XXX_Unmarshal 

func (m *PatternSeries) XXX_Unmarshal(b []byte) error

type PatternServer 

type PatternServer interface {
	Push(context.Context, *push.PushRequest) (*push.PushResponse, error)
	Query(*QueryPatternsRequest, Pattern_QueryServer) error
}

PatternServer is the server API for Pattern service.

type Pattern_QueryClient 

type Pattern_QueryClient interface {
	Recv() (*QueryPatternsResponse, error)
	grpc.ClientStream
}

type Pattern_QueryServer 

type Pattern_QueryServer interface {
	Send(*QueryPatternsResponse) error
	grpc.ServerStream
}

type Plan 

type Plan struct {
	Raw []byte `protobuf:"bytes,1,opt,name=raw,proto3" json:"raw,omitempty"`
}

TODO(owen-d): fix. This will break rollouts as soon as the internal repr is changed.

func (*Plan) Descriptor 

func (*Plan) Descriptor() ([]byte, []int)

func (*Plan) Equal 

func (this *Plan) Equal(that interface{}) bool

func (*Plan) GetRaw 

func (m *Plan) GetRaw() []byte

func (*Plan) GoString 

func (this *Plan) GoString() string

func (*Plan) Marshal 

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

func (*Plan) MarshalTo 

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

func (*Plan) MarshalToSizedBuffer 

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

func (*Plan) ProtoMessage 

func (*Plan) ProtoMessage()

func (*Plan) Reset 

func (m *Plan) Reset()

func (*Plan) Size 

func (m *Plan) Size() (n int)

func (*Plan) String 

func (this *Plan) String() string

func (*Plan) Unmarshal 

func (m *Plan) Unmarshal(dAtA []byte) error

func (*Plan) XXX_DiscardUnknown 

func (m *Plan) XXX_DiscardUnknown()

func (*Plan) XXX_Marshal 

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

func (*Plan) XXX_Merge 

func (m *Plan) XXX_Merge(src proto.Message)

func (*Plan) XXX_Size 

func (m *Plan) XXX_Size() int

func (*Plan) XXX_Unmarshal 

func (m *Plan) XXX_Unmarshal(b []byte) error

type PreallocConfig 

type PreallocConfig struct{}

PreallocConfig configures how structures will be preallocated to optimise proto unmarshalling.

func (PreallocConfig) RegisterFlags 

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

RegisterFlags registers configuration settings.

type PreallocTimeseries 

type PreallocTimeseries struct {
	*TimeSeries
}

PreallocTimeseries is a TimeSeries which preallocs slices on Unmarshal.

func PreallocTimeseriesSliceFromPool 

func PreallocTimeseriesSliceFromPool() []PreallocTimeseries

PreallocTimeseriesSliceFromPool retrieves a slice of PreallocTimeseries from a sync.Pool. ReuseSlice should be called once done.

func (*PreallocTimeseries) Unmarshal 

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

Unmarshal implements proto.Message.

type PreallocWriteRequest 

type PreallocWriteRequest struct {
	WriteRequest
}

PreallocWriteRequest is a WriteRequest which preallocs slices on Unmarshal.

func (*PreallocWriteRequest) Unmarshal 

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

Unmarshal implements proto.Message.

type PushRequest 

type PushRequest = push.PushRequest

type PushResponse 

type PushResponse = push.PushResponse

type PusherClient 

type PusherClient = push.PusherClient

func NewPusherClient 

func NewPusherClient(cc *grpc.ClientConn) PusherClient

type PusherRF1Client added in v3.2.0 

type PusherRF1Client interface {
	Push(ctx context.Context, in *push.PushRequest, opts ...grpc.CallOption) (*push.PushResponse, error)
}

PusherRF1Client is the client API for PusherRF1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPusherRF1Client added in v3.2.0 

func NewPusherRF1Client(cc *grpc.ClientConn) PusherRF1Client

type PusherRF1Server added in v3.2.0 

type PusherRF1Server interface {
	Push(context.Context, *push.PushRequest) (*push.PushResponse, error)
}

PusherRF1Server is the server API for PusherRF1 service.

type PusherServer 

type PusherServer = push.PusherServer

type QuantileSketch 

type QuantileSketch struct {
	// Types that are valid to be assigned to Sketch:
	//	*QuantileSketch_Tdigest
	//	*QuantileSketch_Ddsketch
	Sketch isQuantileSketch_Sketch `protobuf_oneof:"sketch"`
}

func (*QuantileSketch) Descriptor 

func (*QuantileSketch) Descriptor() ([]byte, []int)

func (*QuantileSketch) Equal 

func (this *QuantileSketch) Equal(that interface{}) bool

func (*QuantileSketch) GetDdsketch 

func (m *QuantileSketch) GetDdsketch() []byte

func (*QuantileSketch) GetSketch 

func (m *QuantileSketch) GetSketch() isQuantileSketch_Sketch

func (*QuantileSketch) GetTdigest 

func (m *QuantileSketch) GetTdigest() *TDigest

func (*QuantileSketch) GoString 

func (this *QuantileSketch) GoString() string

func (*QuantileSketch) Marshal 

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

func (*QuantileSketch) MarshalTo 

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

func (*QuantileSketch) MarshalToSizedBuffer 

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

func (*QuantileSketch) ProtoMessage 

func (*QuantileSketch) ProtoMessage()

func (*QuantileSketch) Reset 

func (m *QuantileSketch) Reset()

func (*QuantileSketch) Size 

func (m *QuantileSketch) Size() (n int)

func (*QuantileSketch) String 

func (this *QuantileSketch) String() string

func (*QuantileSketch) Unmarshal 

func (m *QuantileSketch) Unmarshal(dAtA []byte) error

func (*QuantileSketch) XXX_DiscardUnknown 

func (m *QuantileSketch) XXX_DiscardUnknown()

func (*QuantileSketch) XXX_Marshal 

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

func (*QuantileSketch) XXX_Merge 

func (m *QuantileSketch) XXX_Merge(src proto.Message)

func (*QuantileSketch) XXX_OneofWrappers 

func (*QuantileSketch) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*QuantileSketch) XXX_Size 

func (m *QuantileSketch) XXX_Size() int

func (*QuantileSketch) XXX_Unmarshal 

func (m *QuantileSketch) XXX_Unmarshal(b []byte) error

type QuantileSketchMatrix 

type QuantileSketchMatrix struct {
	Values []*QuantileSketchVector `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
}

func (*QuantileSketchMatrix) Descriptor 

func (*QuantileSketchMatrix) Descriptor() ([]byte, []int)

func (*QuantileSketchMatrix) Equal 

func (this *QuantileSketchMatrix) Equal(that interface{}) bool

func (*QuantileSketchMatrix) GetValues 

func (m *QuantileSketchMatrix) GetValues() []*QuantileSketchVector

func (*QuantileSketchMatrix) GoString 

func (this *QuantileSketchMatrix) GoString() string

func (*QuantileSketchMatrix) Marshal 

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

func (*QuantileSketchMatrix) MarshalTo 

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

func (*QuantileSketchMatrix) MarshalToSizedBuffer 

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

func (*QuantileSketchMatrix) ProtoMessage 

func (*QuantileSketchMatrix) ProtoMessage()

func (*QuantileSketchMatrix) Reset 

func (m *QuantileSketchMatrix) Reset()

func (*QuantileSketchMatrix) Size 

func (m *QuantileSketchMatrix) Size() (n int)

func (*QuantileSketchMatrix) String 

func (this *QuantileSketchMatrix) String() string

func (*QuantileSketchMatrix) Unmarshal 

func (m *QuantileSketchMatrix) Unmarshal(dAtA []byte) error

func (*QuantileSketchMatrix) XXX_DiscardUnknown 

func (m *QuantileSketchMatrix) XXX_DiscardUnknown()

func (*QuantileSketchMatrix) XXX_Marshal 

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

func (*QuantileSketchMatrix) XXX_Merge 

func (m *QuantileSketchMatrix) XXX_Merge(src proto.Message)

func (*QuantileSketchMatrix) XXX_Size 

func (m *QuantileSketchMatrix) XXX_Size() int

func (*QuantileSketchMatrix) XXX_Unmarshal 

func (m *QuantileSketchMatrix) XXX_Unmarshal(b []byte) error

type QuantileSketchSample 

type QuantileSketchSample struct {
	F           *QuantileSketch `protobuf:"bytes,1,opt,name=f,proto3" json:"f,omitempty"`
	TimestampMs int64           `protobuf:"varint,2,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
	Metric      []*LabelPair    `protobuf:"bytes,3,rep,name=metric,proto3" json:"metric,omitempty"`
}

func (*QuantileSketchSample) Descriptor 

func (*QuantileSketchSample) Descriptor() ([]byte, []int)

func (*QuantileSketchSample) Equal 

func (this *QuantileSketchSample) Equal(that interface{}) bool

func (*QuantileSketchSample) GetF 

func (m *QuantileSketchSample) GetF() *QuantileSketch

func (*QuantileSketchSample) GetMetric 

func (m *QuantileSketchSample) GetMetric() []*LabelPair

func (*QuantileSketchSample) GetTimestampMs 

func (m *QuantileSketchSample) GetTimestampMs() int64

func (*QuantileSketchSample) GoString 

func (this *QuantileSketchSample) GoString() string

func (*QuantileSketchSample) Marshal 

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

func (*QuantileSketchSample) MarshalTo 

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

func (*QuantileSketchSample) MarshalToSizedBuffer 

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

func (*QuantileSketchSample) ProtoMessage 

func (*QuantileSketchSample) ProtoMessage()

func (*QuantileSketchSample) Reset 

func (m *QuantileSketchSample) Reset()

func (*QuantileSketchSample) Size 

func (m *QuantileSketchSample) Size() (n int)

func (*QuantileSketchSample) String 

func (this *QuantileSketchSample) String() string

func (*QuantileSketchSample) Unmarshal 

func (m *QuantileSketchSample) Unmarshal(dAtA []byte) error

func (*QuantileSketchSample) XXX_DiscardUnknown 

func (m *QuantileSketchSample) XXX_DiscardUnknown()

func (*QuantileSketchSample) XXX_Marshal 

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

func (*QuantileSketchSample) XXX_Merge 

func (m *QuantileSketchSample) XXX_Merge(src proto.Message)

func (*QuantileSketchSample) XXX_Size 

func (m *QuantileSketchSample) XXX_Size() int

func (*QuantileSketchSample) XXX_Unmarshal 

func (m *QuantileSketchSample) XXX_Unmarshal(b []byte) error

type QuantileSketchVector 

type QuantileSketchVector struct {
	Samples []*QuantileSketchSample `protobuf:"bytes,1,rep,name=samples,proto3" json:"samples,omitempty"`
}

func (*QuantileSketchVector) Descriptor 

func (*QuantileSketchVector) Descriptor() ([]byte, []int)

func (*QuantileSketchVector) Equal 

func (this *QuantileSketchVector) Equal(that interface{}) bool

func (*QuantileSketchVector) GetSamples 

func (m *QuantileSketchVector) GetSamples() []*QuantileSketchSample

func (*QuantileSketchVector) GoString 

func (this *QuantileSketchVector) GoString() string

func (*QuantileSketchVector) Marshal 

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

func (*QuantileSketchVector) MarshalTo 

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

func (*QuantileSketchVector) MarshalToSizedBuffer 

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

func (*QuantileSketchVector) ProtoMessage 

func (*QuantileSketchVector) ProtoMessage()

func (*QuantileSketchVector) Reset 

func (m *QuantileSketchVector) Reset()

func (*QuantileSketchVector) Size 

func (m *QuantileSketchVector) Size() (n int)

func (*QuantileSketchVector) String 

func (this *QuantileSketchVector) String() string

func (*QuantileSketchVector) Unmarshal 

func (m *QuantileSketchVector) Unmarshal(dAtA []byte) error

func (*QuantileSketchVector) XXX_DiscardUnknown 

func (m *QuantileSketchVector) XXX_DiscardUnknown()

func (*QuantileSketchVector) XXX_Marshal 

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

func (*QuantileSketchVector) XXX_Merge 

func (m *QuantileSketchVector) XXX_Merge(src proto.Message)

func (*QuantileSketchVector) XXX_Size 

func (m *QuantileSketchVector) XXX_Size() int

func (*QuantileSketchVector) XXX_Unmarshal 

func (m *QuantileSketchVector) XXX_Unmarshal(b []byte) error

type QuantileSketch_Ddsketch 

type QuantileSketch_Ddsketch struct {
	Ddsketch []byte `protobuf:"bytes,2,opt,name=ddsketch,proto3,oneof"`
}

func (*QuantileSketch_Ddsketch) Equal 

func (this *QuantileSketch_Ddsketch) Equal(that interface{}) bool

func (*QuantileSketch_Ddsketch) GoString 

func (this *QuantileSketch_Ddsketch) GoString() string

func (*QuantileSketch_Ddsketch) MarshalTo 

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

func (*QuantileSketch_Ddsketch) MarshalToSizedBuffer 

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

func (*QuantileSketch_Ddsketch) Size 

func (m *QuantileSketch_Ddsketch) Size() (n int)

func (*QuantileSketch_Ddsketch) String 

func (this *QuantileSketch_Ddsketch) String() string

type QuantileSketch_Tdigest 

type QuantileSketch_Tdigest struct {
	Tdigest *TDigest `protobuf:"bytes,1,opt,name=tdigest,proto3,oneof"`
}

func (*QuantileSketch_Tdigest) Equal 

func (this *QuantileSketch_Tdigest) Equal(that interface{}) bool

func (*QuantileSketch_Tdigest) GoString 

func (this *QuantileSketch_Tdigest) GoString() string

func (*QuantileSketch_Tdigest) MarshalTo 

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

func (*QuantileSketch_Tdigest) MarshalToSizedBuffer 

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

func (*QuantileSketch_Tdigest) Size 

func (m *QuantileSketch_Tdigest) Size() (n int)

func (*QuantileSketch_Tdigest) String 

func (this *QuantileSketch_Tdigest) String() string

type QuerierClient 

type QuerierClient interface {
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Querier_QueryClient, error)
	QuerySample(ctx context.Context, in *SampleQueryRequest, opts ...grpc.CallOption) (Querier_QuerySampleClient, error)
	Label(ctx context.Context, in *LabelRequest, opts ...grpc.CallOption) (*LabelResponse, error)
	Tail(ctx context.Context, in *TailRequest, opts ...grpc.CallOption) (Querier_TailClient, error)
	Series(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (*SeriesResponse, error)
	TailersCount(ctx context.Context, in *TailersCountRequest, opts ...grpc.CallOption) (*TailersCountResponse, error)
	GetChunkIDs(ctx context.Context, in *GetChunkIDsRequest, opts ...grpc.CallOption) (*GetChunkIDsResponse, error)
	// Note: this MUST be the same as the variant defined in
	// indexgateway.proto on the IndexGateway service.
	GetStats(ctx context.Context, in *IndexStatsRequest, opts ...grpc.CallOption) (*IndexStatsResponse, error)
	// Note: this MUST be the same as the variant defined in
	// indexgateway.proto on the IndexGateway service.
	GetVolume(ctx context.Context, in *VolumeRequest, opts ...grpc.CallOption) (*VolumeResponse, error)
	GetDetectedFields(ctx context.Context, in *DetectedFieldsRequest, opts ...grpc.CallOption) (*DetectedFieldsResponse, error)
	GetDetectedLabels(ctx context.Context, in *DetectedLabelsRequest, opts ...grpc.CallOption) (*LabelToValuesResponse, error)
}

QuerierClient is the client API for Querier service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQuerierClient 

func NewQuerierClient(cc *grpc.ClientConn) QuerierClient

type QuerierServer 

type QuerierServer interface {
	Query(*QueryRequest, Querier_QueryServer) error
	QuerySample(*SampleQueryRequest, Querier_QuerySampleServer) error
	Label(context.Context, *LabelRequest) (*LabelResponse, error)
	Tail(*TailRequest, Querier_TailServer) error
	Series(context.Context, *SeriesRequest) (*SeriesResponse, error)
	TailersCount(context.Context, *TailersCountRequest) (*TailersCountResponse, error)
	GetChunkIDs(context.Context, *GetChunkIDsRequest) (*GetChunkIDsResponse, error)
	// Note: this MUST be the same as the variant defined in
	// indexgateway.proto on the IndexGateway service.
	GetStats(context.Context, *IndexStatsRequest) (*IndexStatsResponse, error)
	// Note: this MUST be the same as the variant defined in
	// indexgateway.proto on the IndexGateway service.
	GetVolume(context.Context, *VolumeRequest) (*VolumeResponse, error)
	GetDetectedFields(context.Context, *DetectedFieldsRequest) (*DetectedFieldsResponse, error)
	GetDetectedLabels(context.Context, *DetectedLabelsRequest) (*LabelToValuesResponse, error)
}

QuerierServer is the server API for Querier service.

type Querier_QueryClient 

type Querier_QueryClient interface {
	Recv() (*QueryResponse, error)
	grpc.ClientStream
}

type Querier_QuerySampleClient 

type Querier_QuerySampleClient interface {
	Recv() (*SampleQueryResponse, error)
	grpc.ClientStream
}

type Querier_QuerySampleServer 

type Querier_QuerySampleServer interface {
	Send(*SampleQueryResponse) error
	grpc.ServerStream
}

type Querier_QueryServer 

type Querier_QueryServer interface {
	Send(*QueryResponse) error
	grpc.ServerStream
}

type Querier_TailClient 

type Querier_TailClient interface {
	Recv() (*TailResponse, error)
	grpc.ClientStream
}

type Querier_TailServer 

type Querier_TailServer interface {
	Send(*TailResponse) error
	grpc.ServerStream
}

type QueryIndexRequest 

type QueryIndexRequest struct {
	Queries []*IndexQuery `protobuf:"bytes,1,rep,name=Queries,proto3" json:"Queries,omitempty"`
}

func (*QueryIndexRequest) Descriptor 

func (*QueryIndexRequest) Descriptor() ([]byte, []int)

func (*QueryIndexRequest) Equal 

func (this *QueryIndexRequest) Equal(that interface{}) bool

func (*QueryIndexRequest) GetQueries 

func (m *QueryIndexRequest) GetQueries() []*IndexQuery

func (*QueryIndexRequest) GoString 

func (this *QueryIndexRequest) GoString() string

func (*QueryIndexRequest) Marshal 

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

func (*QueryIndexRequest) MarshalTo 

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

func (*QueryIndexRequest) MarshalToSizedBuffer 

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

func (*QueryIndexRequest) ProtoMessage 

func (*QueryIndexRequest) ProtoMessage()

func (*QueryIndexRequest) Reset 

func (m *QueryIndexRequest) Reset()

func (*QueryIndexRequest) Size 

func (m *QueryIndexRequest) Size() (n int)

func (*QueryIndexRequest) String 

func (this *QueryIndexRequest) String() string

func (*QueryIndexRequest) Unmarshal 

func (m *QueryIndexRequest) Unmarshal(dAtA []byte) error

func (*QueryIndexRequest) XXX_DiscardUnknown 

func (m *QueryIndexRequest) XXX_DiscardUnknown()

func (*QueryIndexRequest) XXX_Marshal 

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

func (*QueryIndexRequest) XXX_Merge 

func (m *QueryIndexRequest) XXX_Merge(src proto.Message)

func (*QueryIndexRequest) XXX_Size 

func (m *QueryIndexRequest) XXX_Size() int

func (*QueryIndexRequest) XXX_Unmarshal 

func (m *QueryIndexRequest) XXX_Unmarshal(b []byte) error

type QueryIndexResponse 

type QueryIndexResponse struct {
	QueryKey string `protobuf:"bytes,1,opt,name=QueryKey,proto3" json:"QueryKey,omitempty"`
	Rows     []*Row `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
}

func (*QueryIndexResponse) Descriptor 

func (*QueryIndexResponse) Descriptor() ([]byte, []int)

func (*QueryIndexResponse) Equal 

func (this *QueryIndexResponse) Equal(that interface{}) bool

func (*QueryIndexResponse) GetQueryKey 

func (m *QueryIndexResponse) GetQueryKey() string

func (*QueryIndexResponse) GetRows 

func (m *QueryIndexResponse) GetRows() []*Row

func (*QueryIndexResponse) GoString 

func (this *QueryIndexResponse) GoString() string

func (*QueryIndexResponse) Marshal 

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

func (*QueryIndexResponse) MarshalTo 

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

func (*QueryIndexResponse) MarshalToSizedBuffer 

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

func (*QueryIndexResponse) ProtoMessage 

func (*QueryIndexResponse) ProtoMessage()

func (*QueryIndexResponse) Reset 

func (m *QueryIndexResponse) Reset()

func (*QueryIndexResponse) Size 

func (m *QueryIndexResponse) Size() (n int)

func (*QueryIndexResponse) String 

func (this *QueryIndexResponse) String() string

func (*QueryIndexResponse) Unmarshal 

func (m *QueryIndexResponse) Unmarshal(dAtA []byte) error

func (*QueryIndexResponse) XXX_DiscardUnknown 

func (m *QueryIndexResponse) XXX_DiscardUnknown()

func (*QueryIndexResponse) XXX_Marshal 

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

func (*QueryIndexResponse) XXX_Merge 

func (m *QueryIndexResponse) XXX_Merge(src proto.Message)

func (*QueryIndexResponse) XXX_Size 

func (m *QueryIndexResponse) XXX_Size() int

func (*QueryIndexResponse) XXX_Unmarshal 

func (m *QueryIndexResponse) XXX_Unmarshal(b []byte) error

type QueryPatternsRequest 

type QueryPatternsRequest struct {
	Query string    `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Start time.Time `protobuf:"bytes,2,opt,name=start,proto3,stdtime" json:"start"`
	End   time.Time `protobuf:"bytes,3,opt,name=end,proto3,stdtime" json:"end"`
	Step  int64     `protobuf:"varint,4,opt,name=step,proto3" json:"step,omitempty"`
}

func (*QueryPatternsRequest) Descriptor 

func (*QueryPatternsRequest) Descriptor() ([]byte, []int)

func (*QueryPatternsRequest) Equal 

func (this *QueryPatternsRequest) Equal(that interface{}) bool

func (*QueryPatternsRequest) GetCachingOptions 

func (m *QueryPatternsRequest) GetCachingOptions() (res definitions.CachingOptions)

func (*QueryPatternsRequest) GetEnd 

func (m *QueryPatternsRequest) GetEnd() time.Time

func (*QueryPatternsRequest) GetQuery 

func (m *QueryPatternsRequest) GetQuery() string

func (*QueryPatternsRequest) GetStart 

func (m *QueryPatternsRequest) GetStart() time.Time

func (*QueryPatternsRequest) GetStep 

func (m *QueryPatternsRequest) GetStep() int64

func (*QueryPatternsRequest) GoString 

func (this *QueryPatternsRequest) GoString() string

func (*QueryPatternsRequest) LogToSpan 

func (m *QueryPatternsRequest) LogToSpan(sp opentracing.Span)

func (*QueryPatternsRequest) Marshal 

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

func (*QueryPatternsRequest) MarshalTo 

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

func (*QueryPatternsRequest) MarshalToSizedBuffer 

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

func (*QueryPatternsRequest) ProtoMessage 

func (*QueryPatternsRequest) ProtoMessage()

func (*QueryPatternsRequest) Reset 

func (m *QueryPatternsRequest) Reset()

func (*QueryPatternsRequest) Size 

func (m *QueryPatternsRequest) Size() (n int)

func (*QueryPatternsRequest) String 

func (this *QueryPatternsRequest) String() string

func (*QueryPatternsRequest) Unmarshal 

func (m *QueryPatternsRequest) Unmarshal(dAtA []byte) error

func (*QueryPatternsRequest) WithQuery 

func (m *QueryPatternsRequest) WithQuery(query string) definitions.Request

func (*QueryPatternsRequest) WithStartEnd 

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

func (*QueryPatternsRequest) WithStartEndForCache 

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

func (*QueryPatternsRequest) XXX_DiscardUnknown 

func (m *QueryPatternsRequest) XXX_DiscardUnknown()

func (*QueryPatternsRequest) XXX_Marshal 

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

func (*QueryPatternsRequest) XXX_Merge 

func (m *QueryPatternsRequest) XXX_Merge(src proto.Message)

func (*QueryPatternsRequest) XXX_Size 

func (m *QueryPatternsRequest) XXX_Size() int

func (*QueryPatternsRequest) XXX_Unmarshal 

func (m *QueryPatternsRequest) XXX_Unmarshal(b []byte) error

type QueryPatternsResponse 

type QueryPatternsResponse struct {
	Series []*PatternSeries `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"`
}

func (*QueryPatternsResponse) Descriptor 

func (*QueryPatternsResponse) Descriptor() ([]byte, []int)

func (*QueryPatternsResponse) Equal 

func (this *QueryPatternsResponse) Equal(that interface{}) bool

func (*QueryPatternsResponse) GetSeries 

func (m *QueryPatternsResponse) GetSeries() []*PatternSeries

func (*QueryPatternsResponse) GoString 

func (this *QueryPatternsResponse) GoString() string

func (*QueryPatternsResponse) Marshal 

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

func (*QueryPatternsResponse) MarshalTo 

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

func (*QueryPatternsResponse) MarshalToSizedBuffer 

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

func (*QueryPatternsResponse) ProtoMessage 

func (*QueryPatternsResponse) ProtoMessage()

func (*QueryPatternsResponse) Reset 

func (m *QueryPatternsResponse) Reset()

func (*QueryPatternsResponse) Size 

func (m *QueryPatternsResponse) Size() (n int)

func (*QueryPatternsResponse) String 

func (this *QueryPatternsResponse) String() string

func (*QueryPatternsResponse) Unmarshal 

func (m *QueryPatternsResponse) Unmarshal(dAtA []byte) error

func (*QueryPatternsResponse) UnmarshalJSON 

func (r *QueryPatternsResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface. QueryPatternsResponse json representation is different from the proto 

`{"status":"success","data":[{"pattern":"foo <*> bar","samples":[[1,1],[2,2]]},{"pattern":"foo <*> buzz","samples":[[3,1],[3,2]]}]}`

func (*QueryPatternsResponse) XXX_DiscardUnknown 

func (m *QueryPatternsResponse) XXX_DiscardUnknown()

func (*QueryPatternsResponse) XXX_Marshal 

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

func (*QueryPatternsResponse) XXX_Merge 

func (m *QueryPatternsResponse) XXX_Merge(src proto.Message)

func (*QueryPatternsResponse) XXX_Size 

func (m *QueryPatternsResponse) XXX_Size() int

func (*QueryPatternsResponse) XXX_Unmarshal 

func (m *QueryPatternsResponse) XXX_Unmarshal(b []byte) error

type QueryRequest 

type QueryRequest struct {
	Selector  string                                                 `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"` // Deprecated: Do not use.
	Limit     uint32                                                 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Start     time.Time                                              `protobuf:"bytes,3,opt,name=start,proto3,stdtime" json:"start"`
	End       time.Time                                              `protobuf:"bytes,4,opt,name=end,proto3,stdtime" json:"end"`
	Direction Direction                                              `protobuf:"varint,5,opt,name=direction,proto3,enum=logproto.Direction" json:"direction,omitempty"`
	Shards    []string                                               `protobuf:"bytes,7,rep,name=shards,proto3" json:"shards,omitempty"`
	Deletes   []*Delete                                              `protobuf:"bytes,8,rep,name=deletes,proto3" json:"deletes,omitempty"`
	Plan      *github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan `` /* 126-byte string literal not displayed */
	// If populated, these represent the chunk references that the querier should
	// use to fetch the data, plus any other chunks reported by ingesters.
	StoreChunks *ChunkRefGroup `protobuf:"bytes,10,opt,name=storeChunks,proto3" json:"storeChunks"`
}

func (*QueryRequest) Descriptor 

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

func (*QueryRequest) Equal 

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

func (*QueryRequest) GetDeletes 

func (m *QueryRequest) GetDeletes() []*Delete

func (*QueryRequest) GetDirection 

func (m *QueryRequest) GetDirection() Direction

func (*QueryRequest) GetEnd 

func (m *QueryRequest) GetEnd() time.Time

func (*QueryRequest) GetLimit 

func (m *QueryRequest) GetLimit() uint32

func (*QueryRequest) GetSelector deprecated 

func (m *QueryRequest) GetSelector() string

Deprecated: Do not use.

func (*QueryRequest) GetShards 

func (m *QueryRequest) GetShards() []string

func (*QueryRequest) GetStart 

func (m *QueryRequest) GetStart() time.Time

func (*QueryRequest) GetStoreChunks added in v3.1.0 

func (m *QueryRequest) GetStoreChunks() *ChunkRefGroup

func (*QueryRequest) GoString 

func (this *QueryRequest) GoString() string

func (*QueryRequest) Marshal 

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

func (*QueryRequest) MarshalTo 

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

func (*QueryRequest) MarshalToSizedBuffer 

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

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (m *QueryRequest) Reset()

func (*QueryRequest) Size 

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

func (*QueryRequest) String 

func (this *QueryRequest) String() string

func (*QueryRequest) Unmarshal 

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

func (*QueryRequest) XXX_DiscardUnknown 

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal 

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

func (*QueryRequest) XXX_Merge 

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

func (*QueryRequest) XXX_Size 

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal 

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

type QueryResponse 

type QueryResponse struct {
	Streams  []github_com_grafana_loki_pkg_push.Stream `protobuf:"bytes,1,rep,name=streams,proto3,customtype=github.com/grafana/loki/pkg/push.Stream" json:"streams,omitempty"`
	Stats    stats.Ingester                            `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats"`
	Warnings []string                                  `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
}

func (*QueryResponse) Descriptor 

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

func (*QueryResponse) Equal 

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

func (*QueryResponse) GetStats 

func (m *QueryResponse) GetStats() stats.Ingester

func (*QueryResponse) GetWarnings 

func (m *QueryResponse) GetWarnings() []string

func (*QueryResponse) GoString 

func (this *QueryResponse) GoString() string

func (*QueryResponse) Marshal 

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

func (*QueryResponse) MarshalTo 

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

func (*QueryResponse) MarshalToSizedBuffer 

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

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset 

func (m *QueryResponse) Reset()

func (*QueryResponse) Size 

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

func (*QueryResponse) String 

func (this *QueryResponse) String() string

func (*QueryResponse) Unmarshal 

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

func (*QueryResponse) XXX_DiscardUnknown 

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal 

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

func (*QueryResponse) XXX_Merge 

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

func (*QueryResponse) XXX_Size 

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal 

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

type Row 

type Row struct {
	RangeValue []byte `protobuf:"bytes,1,opt,name=rangeValue,proto3" json:"rangeValue,omitempty"`
	Value      []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Row) Descriptor 

func (*Row) Descriptor() ([]byte, []int)

func (*Row) Equal 

func (this *Row) Equal(that interface{}) bool

func (*Row) GetRangeValue 

func (m *Row) GetRangeValue() []byte

func (*Row) GetValue 

func (m *Row) GetValue() []byte

func (*Row) GoString 

func (this *Row) GoString() string

func (*Row) Marshal 

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

func (*Row) MarshalTo 

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

func (*Row) MarshalToSizedBuffer 

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

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) Reset 

func (m *Row) Reset()

func (*Row) Size 

func (m *Row) Size() (n int)

func (*Row) String 

func (this *Row) String() string

func (*Row) Unmarshal 

func (m *Row) Unmarshal(dAtA []byte) error

func (*Row) XXX_DiscardUnknown 

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal 

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

func (*Row) XXX_Merge 

func (m *Row) XXX_Merge(src proto.Message)

func (*Row) XXX_Size 

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal 

func (m *Row) XXX_Unmarshal(b []byte) error

type Sample 

type Sample struct {
	Timestamp int64   `protobuf:"varint,1,opt,name=timestamp,proto3" json:"ts"`
	Value     float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value"`
	Hash      uint64  `protobuf:"varint,3,opt,name=hash,proto3" json:"hash"`
}

func (*Sample) Descriptor 

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

func (*Sample) Equal 

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

func (*Sample) GetHash 

func (m *Sample) GetHash() uint64

func (*Sample) GetTimestamp 

func (m *Sample) GetTimestamp() int64

func (*Sample) GetValue 

func (m *Sample) GetValue() float64

func (*Sample) GoString 

func (this *Sample) GoString() string

func (*Sample) Marshal 

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

func (*Sample) MarshalTo 

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

func (*Sample) MarshalToSizedBuffer 

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

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) Reset 

func (m *Sample) Reset()

func (*Sample) Size 

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

func (*Sample) String 

func (this *Sample) String() string

func (*Sample) Unmarshal 

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

func (*Sample) XXX_DiscardUnknown 

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal 

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

func (*Sample) XXX_Merge 

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

func (*Sample) XXX_Size 

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal 

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

type SampleQueryRequest 

type SampleQueryRequest struct {
	Selector string                                                 `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"` // Deprecated: Do not use.
	Start    time.Time                                              `protobuf:"bytes,2,opt,name=start,proto3,stdtime" json:"start"`
	End      time.Time                                              `protobuf:"bytes,3,opt,name=end,proto3,stdtime" json:"end"`
	Shards   []string                                               `protobuf:"bytes,4,rep,name=shards,proto3" json:"shards,omitempty"`
	Deletes  []*Delete                                              `protobuf:"bytes,5,rep,name=deletes,proto3" json:"deletes,omitempty"`
	Plan     *github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan `` /* 126-byte string literal not displayed */
	// If populated, these represent the chunk references that the querier should
	// use to fetch the data, plus any other chunks reported by ingesters.
	StoreChunks *ChunkRefGroup `protobuf:"bytes,10,opt,name=storeChunks,proto3" json:"storeChunks"`
}

func (*SampleQueryRequest) Descriptor 

func (*SampleQueryRequest) Descriptor() ([]byte, []int)

func (*SampleQueryRequest) Equal 

func (this *SampleQueryRequest) Equal(that interface{}) bool

func (*SampleQueryRequest) GetDeletes 

func (m *SampleQueryRequest) GetDeletes() []*Delete

func (*SampleQueryRequest) GetEnd 

func (m *SampleQueryRequest) GetEnd() time.Time

func (*SampleQueryRequest) GetSelector deprecated 

func (m *SampleQueryRequest) GetSelector() string

Deprecated: Do not use.

func (*SampleQueryRequest) GetShards 

func (m *SampleQueryRequest) GetShards() []string

func (*SampleQueryRequest) GetStart 

func (m *SampleQueryRequest) GetStart() time.Time

func (*SampleQueryRequest) GetStoreChunks added in v3.1.0 

func (m *SampleQueryRequest) GetStoreChunks() *ChunkRefGroup

func (*SampleQueryRequest) GoString 

func (this *SampleQueryRequest) GoString() string

func (*SampleQueryRequest) Marshal 

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

func (*SampleQueryRequest) MarshalTo 

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

func (*SampleQueryRequest) MarshalToSizedBuffer 

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

func (*SampleQueryRequest) ProtoMessage 

func (*SampleQueryRequest) ProtoMessage()

func (*SampleQueryRequest) Reset 

func (m *SampleQueryRequest) Reset()

func (*SampleQueryRequest) Size 

func (m *SampleQueryRequest) Size() (n int)

func (*SampleQueryRequest) String 

func (this *SampleQueryRequest) String() string

func (*SampleQueryRequest) Unmarshal 

func (m *SampleQueryRequest) Unmarshal(dAtA []byte) error

func (*SampleQueryRequest) XXX_DiscardUnknown 

func (m *SampleQueryRequest) XXX_DiscardUnknown()

func (*SampleQueryRequest) XXX_Marshal 

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

func (*SampleQueryRequest) XXX_Merge 

func (m *SampleQueryRequest) XXX_Merge(src proto.Message)

func (*SampleQueryRequest) XXX_Size 

func (m *SampleQueryRequest) XXX_Size() int

func (*SampleQueryRequest) XXX_Unmarshal 

func (m *SampleQueryRequest) XXX_Unmarshal(b []byte) error

type SampleQueryResponse 

type SampleQueryResponse struct {
	Series   []Series       `protobuf:"bytes,1,rep,name=series,proto3,customtype=Series" json:"series,omitempty"`
	Stats    stats.Ingester `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats"`
	Warnings []string       `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
}

func (*SampleQueryResponse) Descriptor 

func (*SampleQueryResponse) Descriptor() ([]byte, []int)

func (*SampleQueryResponse) Equal 

func (this *SampleQueryResponse) Equal(that interface{}) bool

func (*SampleQueryResponse) GetStats 

func (m *SampleQueryResponse) GetStats() stats.Ingester

func (*SampleQueryResponse) GetWarnings 

func (m *SampleQueryResponse) GetWarnings() []string

func (*SampleQueryResponse) GoString 

func (this *SampleQueryResponse) GoString() string

func (*SampleQueryResponse) Marshal 

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

func (*SampleQueryResponse) MarshalTo 

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

func (*SampleQueryResponse) MarshalToSizedBuffer 

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

func (*SampleQueryResponse) ProtoMessage 

func (*SampleQueryResponse) ProtoMessage()

func (*SampleQueryResponse) Reset 

func (m *SampleQueryResponse) Reset()

func (*SampleQueryResponse) Size 

func (m *SampleQueryResponse) Size() (n int)

func (*SampleQueryResponse) String 

func (this *SampleQueryResponse) String() string

func (*SampleQueryResponse) Unmarshal 

func (m *SampleQueryResponse) Unmarshal(dAtA []byte) error

func (*SampleQueryResponse) XXX_DiscardUnknown 

func (m *SampleQueryResponse) XXX_DiscardUnknown()

func (*SampleQueryResponse) XXX_Marshal 

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

func (*SampleQueryResponse) XXX_Merge 

func (m *SampleQueryResponse) XXX_Merge(src proto.Message)

func (*SampleQueryResponse) XXX_Size 

func (m *SampleQueryResponse) XXX_Size() int

func (*SampleQueryResponse) XXX_Unmarshal 

func (m *SampleQueryResponse) XXX_Unmarshal(b []byte) error

type Series 

type Series struct {
	Labels     string   `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels"`
	Samples    []Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples"`
	StreamHash uint64   `protobuf:"varint,3,opt,name=streamHash,proto3" json:"streamHash"`
}

func (*Series) Descriptor 

func (*Series) Descriptor() ([]byte, []int)

func (*Series) Equal 

func (this *Series) Equal(that interface{}) bool

func (*Series) GetLabels 

func (m *Series) GetLabels() string

func (*Series) GetSamples 

func (m *Series) GetSamples() []Sample

func (*Series) GetStreamHash 

func (m *Series) GetStreamHash() uint64

func (*Series) GoString 

func (this *Series) GoString() string

func (Series) Len 

func (s Series) Len() int

func (Series) Less 

func (s Series) Less(i, j int) bool

func (*Series) Marshal 

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

func (*Series) MarshalTo 

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

func (*Series) MarshalToSizedBuffer 

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

func (*Series) ProtoMessage 

func (*Series) ProtoMessage()

func (*Series) Reset 

func (m *Series) Reset()

func (*Series) Size 

func (m *Series) Size() (n int)

func (*Series) String 

func (this *Series) String() string

func (Series) Swap 

func (s Series) Swap(i, j int)

func (*Series) Unmarshal 

func (m *Series) Unmarshal(dAtA []byte) error

func (*Series) XXX_DiscardUnknown 

func (m *Series) XXX_DiscardUnknown()

func (*Series) XXX_Marshal 

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

func (*Series) XXX_Merge 

func (m *Series) XXX_Merge(src proto.Message)

func (*Series) XXX_Size 

func (m *Series) XXX_Size() int

func (*Series) XXX_Unmarshal 

func (m *Series) XXX_Unmarshal(b []byte) error

type SeriesIdentifier 

type SeriesIdentifier struct {
	Labels []SeriesIdentifier_LabelsEntry `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"`
}

func SeriesIdentifierFromLabels 

func SeriesIdentifierFromLabels(in labels.Labels) SeriesIdentifier

func SeriesIdentifierFromMap 

func SeriesIdentifierFromMap(in map[string]string) SeriesIdentifier

func (*SeriesIdentifier) Descriptor 

func (*SeriesIdentifier) Descriptor() ([]byte, []int)

func (*SeriesIdentifier) Equal 

func (this *SeriesIdentifier) Equal(that interface{}) bool

func (SeriesIdentifier) Get 

func (id SeriesIdentifier) Get(key string) string

func (*SeriesIdentifier) GetLabels 

func (m *SeriesIdentifier) GetLabels() []SeriesIdentifier_LabelsEntry

func (*SeriesIdentifier) GoString 

func (this *SeriesIdentifier) GoString() string

func (SeriesIdentifier) Hash 

func (id SeriesIdentifier) Hash(b []byte) uint64

Hash returns hash of the labels according to Prometheus' Labels.Hash function. `b` is a buffer that should be reused to avoid allocations.

func (SeriesIdentifier) Len 

func (id SeriesIdentifier) Len() int

func (SeriesIdentifier) Less 

func (id SeriesIdentifier) Less(i, j int) bool

func (*SeriesIdentifier) Marshal 

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

func (*SeriesIdentifier) MarshalTo 

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

func (*SeriesIdentifier) MarshalToSizedBuffer 

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

func (*SeriesIdentifier) ProtoMessage 

func (*SeriesIdentifier) ProtoMessage()

func (*SeriesIdentifier) Reset 

func (m *SeriesIdentifier) Reset()

func (*SeriesIdentifier) Size 

func (m *SeriesIdentifier) Size() (n int)

func (*SeriesIdentifier) String 

func (this *SeriesIdentifier) String() string

func (SeriesIdentifier) Swap 

func (id SeriesIdentifier) Swap(i, j int)

func (*SeriesIdentifier) Unmarshal 

func (m *SeriesIdentifier) Unmarshal(dAtA []byte) error

func (*SeriesIdentifier) XXX_DiscardUnknown 

func (m *SeriesIdentifier) XXX_DiscardUnknown()

func (*SeriesIdentifier) XXX_Marshal 

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

func (*SeriesIdentifier) XXX_Merge 

func (m *SeriesIdentifier) XXX_Merge(src proto.Message)

func (*SeriesIdentifier) XXX_Size 

func (m *SeriesIdentifier) XXX_Size() int

func (*SeriesIdentifier) XXX_Unmarshal 

func (m *SeriesIdentifier) XXX_Unmarshal(b []byte) error

type SeriesIdentifier_LabelsEntry 

type SeriesIdentifier_LabelsEntry struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func MustNewSeriesEntries 

func MustNewSeriesEntries(labels ...string) []SeriesIdentifier_LabelsEntry

func (*SeriesIdentifier_LabelsEntry) Descriptor 

func (*SeriesIdentifier_LabelsEntry) Descriptor() ([]byte, []int)

func (*SeriesIdentifier_LabelsEntry) Equal 

func (this *SeriesIdentifier_LabelsEntry) Equal(that interface{}) bool

func (*SeriesIdentifier_LabelsEntry) GetKey 

func (m *SeriesIdentifier_LabelsEntry) GetKey() string

func (*SeriesIdentifier_LabelsEntry) GetValue 

func (m *SeriesIdentifier_LabelsEntry) GetValue() string

func (*SeriesIdentifier_LabelsEntry) GoString 

func (this *SeriesIdentifier_LabelsEntry) GoString() string

func (*SeriesIdentifier_LabelsEntry) Marshal 

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

func (*SeriesIdentifier_LabelsEntry) MarshalTo 

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

func (*SeriesIdentifier_LabelsEntry) MarshalToSizedBuffer 

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

func (*SeriesIdentifier_LabelsEntry) ProtoMessage 

func (*SeriesIdentifier_LabelsEntry) ProtoMessage()

func (*SeriesIdentifier_LabelsEntry) Reset 

func (m *SeriesIdentifier_LabelsEntry) Reset()

func (*SeriesIdentifier_LabelsEntry) Size 

func (m *SeriesIdentifier_LabelsEntry) Size() (n int)

func (*SeriesIdentifier_LabelsEntry) String 

func (this *SeriesIdentifier_LabelsEntry) String() string

func (*SeriesIdentifier_LabelsEntry) Unmarshal 

func (m *SeriesIdentifier_LabelsEntry) Unmarshal(dAtA []byte) error

func (*SeriesIdentifier_LabelsEntry) XXX_DiscardUnknown 

func (m *SeriesIdentifier_LabelsEntry) XXX_DiscardUnknown()

func (*SeriesIdentifier_LabelsEntry) XXX_Marshal 

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

func (*SeriesIdentifier_LabelsEntry) XXX_Merge 

func (m *SeriesIdentifier_LabelsEntry) XXX_Merge(src proto.Message)

func (*SeriesIdentifier_LabelsEntry) XXX_Size 

func (m *SeriesIdentifier_LabelsEntry) XXX_Size() int

func (*SeriesIdentifier_LabelsEntry) XXX_Unmarshal 

func (m *SeriesIdentifier_LabelsEntry) XXX_Unmarshal(b []byte) error

type SeriesRequest 

type SeriesRequest struct {
	Start  time.Time `protobuf:"bytes,1,opt,name=start,proto3,stdtime" json:"start"`
	End    time.Time `protobuf:"bytes,2,opt,name=end,proto3,stdtime" json:"end"`
	Groups []string  `protobuf:"bytes,3,rep,name=groups,proto3" json:"groups,omitempty"`
	Shards []string  `protobuf:"bytes,4,rep,name=shards,proto3" json:"shards,omitempty"`
}

func (*SeriesRequest) Descriptor 

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

func (*SeriesRequest) Equal 

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

func (*SeriesRequest) GetEnd 

func (m *SeriesRequest) GetEnd() time.Time

func (*SeriesRequest) GetGroups 

func (m *SeriesRequest) GetGroups() []string

func (*SeriesRequest) GetShards 

func (m *SeriesRequest) GetShards() []string

func (*SeriesRequest) GetStart 

func (m *SeriesRequest) GetStart() time.Time

func (*SeriesRequest) GoString 

func (this *SeriesRequest) GoString() string

func (*SeriesRequest) Marshal 

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

func (*SeriesRequest) MarshalTo 

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

func (*SeriesRequest) MarshalToSizedBuffer 

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

func (*SeriesRequest) ProtoMessage 

func (*SeriesRequest) ProtoMessage()

func (*SeriesRequest) Reset 

func (m *SeriesRequest) Reset()

func (*SeriesRequest) Size 

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

func (*SeriesRequest) String 

func (this *SeriesRequest) String() string

func (*SeriesRequest) Unmarshal 

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

func (*SeriesRequest) XXX_DiscardUnknown 

func (m *SeriesRequest) XXX_DiscardUnknown()

func (*SeriesRequest) XXX_Marshal 

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

func (*SeriesRequest) XXX_Merge 

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

func (*SeriesRequest) XXX_Size 

func (m *SeriesRequest) XXX_Size() int

func (*SeriesRequest) XXX_Unmarshal 

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

type SeriesResponse 

type SeriesResponse struct {
	Series []SeriesIdentifier `protobuf:"bytes,1,rep,name=series,proto3" json:"series"`
}

func MergeSeriesResponses 

func MergeSeriesResponses(responses []*SeriesResponse) (*SeriesResponse, error)

Combine unique label sets from multiple SeriesResponse and return a single SeriesResponse.

func (*SeriesResponse) Descriptor 

func (*SeriesResponse) Descriptor() ([]byte, []int)

func (*SeriesResponse) Equal 

func (this *SeriesResponse) Equal(that interface{}) bool

func (*SeriesResponse) GetSeries 

func (m *SeriesResponse) GetSeries() []SeriesIdentifier

func (*SeriesResponse) GoString 

func (this *SeriesResponse) GoString() string

func (*SeriesResponse) Marshal 

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

func (*SeriesResponse) MarshalTo 

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

func (*SeriesResponse) MarshalToSizedBuffer 

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

func (*SeriesResponse) ProtoMessage 

func (*SeriesResponse) ProtoMessage()

func (*SeriesResponse) Reset 

func (m *SeriesResponse) Reset()

func (*SeriesResponse) Size 

func (m *SeriesResponse) Size() (n int)

func (*SeriesResponse) String 

func (this *SeriesResponse) String() string

func (*SeriesResponse) Unmarshal 

func (m *SeriesResponse) Unmarshal(dAtA []byte) error

func (*SeriesResponse) XXX_DiscardUnknown 

func (m *SeriesResponse) XXX_DiscardUnknown()

func (*SeriesResponse) XXX_Marshal 

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

func (*SeriesResponse) XXX_Merge 

func (m *SeriesResponse) XXX_Merge(src proto.Message)

func (*SeriesResponse) XXX_Size 

func (m *SeriesResponse) XXX_Size() int

func (*SeriesResponse) XXX_Unmarshal 

func (m *SeriesResponse) XXX_Unmarshal(b []byte) error

type Shard 

type Shard struct {
	Bounds FPBounds            `protobuf:"bytes,1,opt,name=bounds,proto3" json:"bounds"`
	Stats  *IndexStatsResponse `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats"`
}

func (*Shard) Descriptor 

func (*Shard) Descriptor() ([]byte, []int)

func (*Shard) Equal 

func (this *Shard) Equal(that interface{}) bool

func (*Shard) GetBounds 

func (m *Shard) GetBounds() FPBounds

func (*Shard) GetStats 

func (m *Shard) GetStats() *IndexStatsResponse

func (*Shard) GoString 

func (this *Shard) GoString() string

func (*Shard) Marshal 

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

func (*Shard) MarshalTo 

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

func (*Shard) MarshalToSizedBuffer 

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

func (*Shard) ProtoMessage 

func (*Shard) ProtoMessage()

func (*Shard) Reset 

func (m *Shard) Reset()

func (*Shard) Size 

func (m *Shard) Size() (n int)

func (*Shard) SpaceFor 

func (m *Shard) SpaceFor(stats *IndexStatsResponse, targetShardBytes uint64) bool

func (*Shard) String 

func (this *Shard) String() string

func (*Shard) Unmarshal 

func (m *Shard) Unmarshal(dAtA []byte) error

func (*Shard) XXX_DiscardUnknown 

func (m *Shard) XXX_DiscardUnknown()

func (*Shard) XXX_Marshal 

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

func (*Shard) XXX_Merge 

func (m *Shard) XXX_Merge(src proto.Message)

func (*Shard) XXX_Size 

func (m *Shard) XXX_Size() int

func (*Shard) XXX_Unmarshal 

func (m *Shard) XXX_Unmarshal(b []byte) error

type ShardsRequest 

type ShardsRequest struct {
	From                github_com_prometheus_common_model.Time `protobuf:"varint,1,opt,name=from,proto3,customtype=github.com/prometheus/common/model.Time" json:"from"`
	Through             github_com_prometheus_common_model.Time `protobuf:"varint,2,opt,name=through,proto3,customtype=github.com/prometheus/common/model.Time" json:"through"`
	Query               string                                  `protobuf:"bytes,3,opt,name=query,proto3" json:"query"`
	TargetBytesPerShard uint64                                  `protobuf:"varint,4,opt,name=targetBytesPerShard,proto3" json:"targetBytesPerShard"`
}

func (*ShardsRequest) Descriptor 

func (*ShardsRequest) Descriptor() ([]byte, []int)

func (*ShardsRequest) Equal 

func (this *ShardsRequest) Equal(that interface{}) bool

func (*ShardsRequest) GetCachingOptions 

func (m *ShardsRequest) GetCachingOptions() (res definitions.CachingOptions)

func (*ShardsRequest) GetEnd 

func (m *ShardsRequest) GetEnd() time.Time

func (*ShardsRequest) GetQuery 

func (m *ShardsRequest) GetQuery() string

func (*ShardsRequest) GetStart 

func (m *ShardsRequest) GetStart() time.Time

func (*ShardsRequest) GetStep 

func (m *ShardsRequest) GetStep() int64

func (*ShardsRequest) GetTargetBytesPerShard 

func (m *ShardsRequest) GetTargetBytesPerShard() uint64

func (*ShardsRequest) GoString 

func (this *ShardsRequest) GoString() string

func (*ShardsRequest) LogToSpan 

func (m *ShardsRequest) LogToSpan(sp opentracing.Span)

func (*ShardsRequest) Marshal 

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

func (*ShardsRequest) MarshalTo 

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

func (*ShardsRequest) MarshalToSizedBuffer 

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

func (*ShardsRequest) ProtoMessage 

func (*ShardsRequest) ProtoMessage()

func (*ShardsRequest) Reset 

func (m *ShardsRequest) Reset()

func (*ShardsRequest) Size 

func (m *ShardsRequest) Size() (n int)

func (*ShardsRequest) String 

func (this *ShardsRequest) String() string

func (*ShardsRequest) Unmarshal 

func (m *ShardsRequest) Unmarshal(dAtA []byte) error

func (*ShardsRequest) WithQuery 

func (m *ShardsRequest) WithQuery(query string) definitions.Request

func (*ShardsRequest) WithStartEnd 

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

func (*ShardsRequest) WithStartEndForCache 

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

func (*ShardsRequest) XXX_DiscardUnknown 

func (m *ShardsRequest) XXX_DiscardUnknown()

func (*ShardsRequest) XXX_Marshal 

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

func (*ShardsRequest) XXX_Merge 

func (m *ShardsRequest) XXX_Merge(src proto.Message)

func (*ShardsRequest) XXX_Size 

func (m *ShardsRequest) XXX_Size() int

func (*ShardsRequest) XXX_Unmarshal 

func (m *ShardsRequest) XXX_Unmarshal(b []byte) error

type ShardsResponse 

type ShardsResponse struct {
	Shards     []Shard      `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards"`
	Statistics stats.Result `protobuf:"bytes,2,opt,name=statistics,proto3" json:"statistics"`
	// If present, includes the chunk refs for each shard,
	// therefore the length will be equal to the length of the `shards` field.
	ChunkGroups []ChunkRefGroup `protobuf:"bytes,3,rep,name=chunkGroups,proto3" json:"chunkGroups"`
}

func (*ShardsResponse) Descriptor 

func (*ShardsResponse) Descriptor() ([]byte, []int)

func (*ShardsResponse) Equal 

func (this *ShardsResponse) Equal(that interface{}) bool

func (*ShardsResponse) GetChunkGroups added in v3.1.0 

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

func (*ShardsResponse) GetShards 

func (m *ShardsResponse) GetShards() []Shard

func (*ShardsResponse) GetStatistics 

func (m *ShardsResponse) GetStatistics() stats.Result

func (*ShardsResponse) GoString 

func (this *ShardsResponse) GoString() string

func (*ShardsResponse) Marshal 

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

func (*ShardsResponse) MarshalTo 

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

func (*ShardsResponse) MarshalToSizedBuffer 

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

func (*ShardsResponse) Merge added in v3.1.0 

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

func (*ShardsResponse) ProtoMessage 

func (*ShardsResponse) ProtoMessage()

func (*ShardsResponse) Reset 

func (m *ShardsResponse) Reset()

func (*ShardsResponse) Size 

func (m *ShardsResponse) Size() (n int)

func (*ShardsResponse) String 

func (this *ShardsResponse) String() string

func (*ShardsResponse) Unmarshal 

func (m *ShardsResponse) Unmarshal(dAtA []byte) error

func (*ShardsResponse) XXX_DiscardUnknown 

func (m *ShardsResponse) XXX_DiscardUnknown()

func (*ShardsResponse) XXX_Marshal 

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

func (*ShardsResponse) XXX_Merge 

func (m *ShardsResponse) XXX_Merge(src proto.Message)

func (*ShardsResponse) XXX_Size 

func (m *ShardsResponse) XXX_Size() int

func (*ShardsResponse) XXX_Unmarshal 

func (m *ShardsResponse) XXX_Unmarshal(b []byte) error

type ShortRef 

type ShortRef struct {
	From     github_com_prometheus_common_model.Time `protobuf:"varint,1,opt,name=from,proto3,customtype=github.com/prometheus/common/model.Time" json:"from"`
	Through  github_com_prometheus_common_model.Time `protobuf:"varint,2,opt,name=through,proto3,customtype=github.com/prometheus/common/model.Time" json:"through"`
	Checksum uint32                                  `protobuf:"varint,3,opt,name=checksum,proto3" json:"checksum,omitempty"`
}

func (*ShortRef) Cmp added in v3.1.0 

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

Cmp returns a positive number when a > b, a negative number when a < b, and 0 when a == b

func (*ShortRef) Descriptor 

func (*ShortRef) Descriptor() ([]byte, []int)

func (*ShortRef) Equal 

func (this *ShortRef) Equal(that interface{}) bool

func (*ShortRef) GetChecksum 

func (m *ShortRef) GetChecksum() uint32

func (*ShortRef) GoString 

func (this *ShortRef) GoString() string

func (*ShortRef) Less added in v3.1.0 

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

func (*ShortRef) Marshal 

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

func (*ShortRef) MarshalTo 

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

func (*ShortRef) MarshalToSizedBuffer 

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

func (*ShortRef) ProtoMessage 

func (*ShortRef) ProtoMessage()

func (*ShortRef) Reset 

func (m *ShortRef) Reset()

func (*ShortRef) Size 

func (m *ShortRef) Size() (n int)

func (*ShortRef) String 

func (this *ShortRef) String() string

func (*ShortRef) Unmarshal 

func (m *ShortRef) Unmarshal(dAtA []byte) error

func (*ShortRef) XXX_DiscardUnknown 

func (m *ShortRef) XXX_DiscardUnknown()

func (*ShortRef) XXX_Marshal 

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

func (*ShortRef) XXX_Merge 

func (m *ShortRef) XXX_Merge(src proto.Message)

func (*ShortRef) XXX_Size 

func (m *ShortRef) XXX_Size() int

func (*ShortRef) XXX_Unmarshal 

func (m *ShortRef) XXX_Unmarshal(b []byte) error

type Stream 

type Stream = push.Stream

type StreamDataClient 

type StreamDataClient interface {
	GetStreamRates(ctx context.Context, in *StreamRatesRequest, opts ...grpc.CallOption) (*StreamRatesResponse, error)
}

StreamDataClient is the client API for StreamData service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStreamDataClient 

func NewStreamDataClient(cc *grpc.ClientConn) StreamDataClient

type StreamDataServer 

type StreamDataServer interface {
	GetStreamRates(context.Context, *StreamRatesRequest) (*StreamRatesResponse, error)
}

StreamDataServer is the server API for StreamData service.

type StreamRate 

type StreamRate struct {
	StreamHash        uint64 `protobuf:"varint,1,opt,name=streamHash,proto3" json:"streamHash,omitempty"`
	StreamHashNoShard uint64 `protobuf:"varint,2,opt,name=streamHashNoShard,proto3" json:"streamHashNoShard,omitempty"`
	Rate              int64  `protobuf:"varint,3,opt,name=rate,proto3" json:"rate,omitempty"`
	Tenant            string `protobuf:"bytes,4,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Pushes            uint32 `protobuf:"varint,5,opt,name=pushes,proto3" json:"pushes,omitempty"`
}

func (*StreamRate) Descriptor 

func (*StreamRate) Descriptor() ([]byte, []int)

func (*StreamRate) Equal 

func (this *StreamRate) Equal(that interface{}) bool

func (*StreamRate) GetPushes 

func (m *StreamRate) GetPushes() uint32

func (*StreamRate) GetRate 

func (m *StreamRate) GetRate() int64

func (*StreamRate) GetStreamHash 

func (m *StreamRate) GetStreamHash() uint64

func (*StreamRate) GetStreamHashNoShard 

func (m *StreamRate) GetStreamHashNoShard() uint64

func (*StreamRate) GetTenant 

func (m *StreamRate) GetTenant() string

func (*StreamRate) GoString 

func (this *StreamRate) GoString() string

func (*StreamRate) Marshal 

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

func (*StreamRate) MarshalTo 

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

func (*StreamRate) MarshalToSizedBuffer 

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

func (*StreamRate) ProtoMessage 

func (*StreamRate) ProtoMessage()

func (*StreamRate) Reset 

func (m *StreamRate) Reset()

func (*StreamRate) Size 

func (m *StreamRate) Size() (n int)

func (*StreamRate) String 

func (this *StreamRate) String() string

func (*StreamRate) Unmarshal 

func (m *StreamRate) Unmarshal(dAtA []byte) error

func (*StreamRate) XXX_DiscardUnknown 

func (m *StreamRate) XXX_DiscardUnknown()

func (*StreamRate) XXX_Marshal 

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

func (*StreamRate) XXX_Merge 

func (m *StreamRate) XXX_Merge(src proto.Message)

func (*StreamRate) XXX_Size 

func (m *StreamRate) XXX_Size() int

func (*StreamRate) XXX_Unmarshal 

func (m *StreamRate) XXX_Unmarshal(b []byte) error

type StreamRatesRequest 

type StreamRatesRequest struct {
}

func (*StreamRatesRequest) Descriptor 

func (*StreamRatesRequest) Descriptor() ([]byte, []int)

func (*StreamRatesRequest) Equal 

func (this *StreamRatesRequest) Equal(that interface{}) bool

func (*StreamRatesRequest) GoString 

func (this *StreamRatesRequest) GoString() string

func (*StreamRatesRequest) Marshal 

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

func (*StreamRatesRequest) MarshalTo 

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

func (*StreamRatesRequest) MarshalToSizedBuffer 

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

func (*StreamRatesRequest) ProtoMessage 

func (*StreamRatesRequest) ProtoMessage()

func (*StreamRatesRequest) Reset 

func (m *StreamRatesRequest) Reset()

func (*StreamRatesRequest) Size 

func (m *StreamRatesRequest) Size() (n int)

func (*StreamRatesRequest) String 

func (this *StreamRatesRequest) String() string

func (*StreamRatesRequest) Unmarshal 

func (m *StreamRatesRequest) Unmarshal(dAtA []byte) error

func (*StreamRatesRequest) XXX_DiscardUnknown 

func (m *StreamRatesRequest) XXX_DiscardUnknown()

func (*StreamRatesRequest) XXX_Marshal 

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

func (*StreamRatesRequest) XXX_Merge 

func (m *StreamRatesRequest) XXX_Merge(src proto.Message)

func (*StreamRatesRequest) XXX_Size 

func (m *StreamRatesRequest) XXX_Size() int

func (*StreamRatesRequest) XXX_Unmarshal 

func (m *StreamRatesRequest) XXX_Unmarshal(b []byte) error

type StreamRatesResponse 

type StreamRatesResponse struct {
	StreamRates []*StreamRate `protobuf:"bytes,1,rep,name=streamRates,proto3" json:"streamRates,omitempty"`
}

func (*StreamRatesResponse) Descriptor 

func (*StreamRatesResponse) Descriptor() ([]byte, []int)

func (*StreamRatesResponse) Equal 

func (this *StreamRatesResponse) Equal(that interface{}) bool

func (*StreamRatesResponse) GetStreamRates 

func (m *StreamRatesResponse) GetStreamRates() []*StreamRate

func (*StreamRatesResponse) GoString 

func (this *StreamRatesResponse) GoString() string

func (*StreamRatesResponse) Marshal 

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

func (*StreamRatesResponse) MarshalTo 

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

func (*StreamRatesResponse) MarshalToSizedBuffer 

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

func (*StreamRatesResponse) ProtoMessage 

func (*StreamRatesResponse) ProtoMessage()

func (*StreamRatesResponse) Reset 

func (m *StreamRatesResponse) Reset()

func (*StreamRatesResponse) Size 

func (m *StreamRatesResponse) Size() (n int)

func (*StreamRatesResponse) String 

func (this *StreamRatesResponse) String() string

func (*StreamRatesResponse) Unmarshal 

func (m *StreamRatesResponse) Unmarshal(dAtA []byte) error

func (*StreamRatesResponse) XXX_DiscardUnknown 

func (m *StreamRatesResponse) XXX_DiscardUnknown()

func (*StreamRatesResponse) XXX_Marshal 

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

func (*StreamRatesResponse) XXX_Merge 

func (m *StreamRatesResponse) XXX_Merge(src proto.Message)

func (*StreamRatesResponse) XXX_Size 

func (m *StreamRatesResponse) XXX_Size() int

func (*StreamRatesResponse) XXX_Unmarshal 

func (m *StreamRatesResponse) XXX_Unmarshal(b []byte) error

type Streams 

type Streams []Stream

func (Streams) Len 

func (xs Streams) Len() int

func (Streams) Less 

func (xs Streams) Less(i, j int) bool

func (Streams) Swap 

func (xs Streams) Swap(i, j int)

type TDigest 

type TDigest struct {
	Min         float64             `protobuf:"fixed64,1,opt,name=min,proto3" json:"min,omitempty"`
	Max         float64             `protobuf:"fixed64,2,opt,name=max,proto3" json:"max,omitempty"`
	Compression float64             `protobuf:"fixed64,3,opt,name=compression,proto3" json:"compression,omitempty"`
	Processed   []*TDigest_Centroid `protobuf:"bytes,4,rep,name=processed,proto3" json:"processed,omitempty"`
}

"Large" bytes format from https://github.com/tdunning/t-digest

func (*TDigest) Descriptor 

func (*TDigest) Descriptor() ([]byte, []int)

func (*TDigest) Equal 

func (this *TDigest) Equal(that interface{}) bool

func (*TDigest) GetCompression 

func (m *TDigest) GetCompression() float64

func (*TDigest) GetMax 

func (m *TDigest) GetMax() float64

func (*TDigest) GetMin 

func (m *TDigest) GetMin() float64

func (*TDigest) GetProcessed 

func (m *TDigest) GetProcessed() []*TDigest_Centroid

func (*TDigest) GoString 

func (this *TDigest) GoString() string

func (*TDigest) Marshal 

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

func (*TDigest) MarshalTo 

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

func (*TDigest) MarshalToSizedBuffer 

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

func (*TDigest) ProtoMessage 

func (*TDigest) ProtoMessage()

func (*TDigest) Reset 

func (m *TDigest) Reset()

func (*TDigest) Size 

func (m *TDigest) Size() (n int)

func (*TDigest) String 

func (this *TDigest) String() string

func (*TDigest) Unmarshal 

func (m *TDigest) Unmarshal(dAtA []byte) error

func (*TDigest) XXX_DiscardUnknown 

func (m *TDigest) XXX_DiscardUnknown()

func (*TDigest) XXX_Marshal 

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

func (*TDigest) XXX_Merge 

func (m *TDigest) XXX_Merge(src proto.Message)

func (*TDigest) XXX_Size 

func (m *TDigest) XXX_Size() int

func (*TDigest) XXX_Unmarshal 

func (m *TDigest) XXX_Unmarshal(b []byte) error

type TDigest_Centroid 

type TDigest_Centroid struct {
	Mean   float64 `protobuf:"fixed64,1,opt,name=mean,proto3" json:"mean,omitempty"`
	Weight float64 `protobuf:"fixed64,2,opt,name=weight,proto3" json:"weight,omitempty"`
}

func (*TDigest_Centroid) Descriptor 

func (*TDigest_Centroid) Descriptor() ([]byte, []int)

func (*TDigest_Centroid) Equal 

func (this *TDigest_Centroid) Equal(that interface{}) bool

func (*TDigest_Centroid) GetMean 

func (m *TDigest_Centroid) GetMean() float64

func (*TDigest_Centroid) GetWeight 

func (m *TDigest_Centroid) GetWeight() float64

func (*TDigest_Centroid) GoString 

func (this *TDigest_Centroid) GoString() string

func (*TDigest_Centroid) Marshal 

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

func (*TDigest_Centroid) MarshalTo 

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

func (*TDigest_Centroid) MarshalToSizedBuffer 

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

func (*TDigest_Centroid) ProtoMessage 

func (*TDigest_Centroid) ProtoMessage()

func (*TDigest_Centroid) Reset 

func (m *TDigest_Centroid) Reset()

func (*TDigest_Centroid) Size 

func (m *TDigest_Centroid) Size() (n int)

func (*TDigest_Centroid) String 

func (this *TDigest_Centroid) String() string

func (*TDigest_Centroid) Unmarshal 

func (m *TDigest_Centroid) Unmarshal(dAtA []byte) error

func (*TDigest_Centroid) XXX_DiscardUnknown 

func (m *TDigest_Centroid) XXX_DiscardUnknown()

func (*TDigest_Centroid) XXX_Marshal 

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

func (*TDigest_Centroid) XXX_Merge 

func (m *TDigest_Centroid) XXX_Merge(src proto.Message)

func (*TDigest_Centroid) XXX_Size 

func (m *TDigest_Centroid) XXX_Size() int

func (*TDigest_Centroid) XXX_Unmarshal 

func (m *TDigest_Centroid) XXX_Unmarshal(b []byte) error

type TailRequest 

type TailRequest struct {
	Query    string                                                 `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // Deprecated: Do not use.
	DelayFor uint32                                                 `protobuf:"varint,3,opt,name=delayFor,proto3" json:"delayFor,omitempty"`
	Limit    uint32                                                 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	Start    time.Time                                              `protobuf:"bytes,5,opt,name=start,proto3,stdtime" json:"start"`
	Plan     *github_com_grafana_loki_v3_pkg_querier_plan.QueryPlan `` /* 126-byte string literal not displayed */
}

func (*TailRequest) Descriptor 

func (*TailRequest) Descriptor() ([]byte, []int)

func (*TailRequest) Equal 

func (this *TailRequest) Equal(that interface{}) bool

func (*TailRequest) GetDelayFor 

func (m *TailRequest) GetDelayFor() uint32

func (*TailRequest) GetLimit 

func (m *TailRequest) GetLimit() uint32

func (*TailRequest) GetQuery deprecated 

func (m *TailRequest) GetQuery() string

Deprecated: Do not use.

func (*TailRequest) GetStart 

func (m *TailRequest) GetStart() time.Time

func (*TailRequest) GoString 

func (this *TailRequest) GoString() string

func (*TailRequest) Marshal 

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

func (*TailRequest) MarshalTo 

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

func (*TailRequest) MarshalToSizedBuffer 

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

func (*TailRequest) ProtoMessage 

func (*TailRequest) ProtoMessage()

func (*TailRequest) Reset 

func (m *TailRequest) Reset()

func (*TailRequest) Size 

func (m *TailRequest) Size() (n int)

func (*TailRequest) String 

func (this *TailRequest) String() string

func (*TailRequest) Unmarshal 

func (m *TailRequest) Unmarshal(dAtA []byte) error

func (*TailRequest) XXX_DiscardUnknown 

func (m *TailRequest) XXX_DiscardUnknown()

func (*TailRequest) XXX_Marshal 

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

func (*TailRequest) XXX_Merge 

func (m *TailRequest) XXX_Merge(src proto.Message)

func (*TailRequest) XXX_Size 

func (m *TailRequest) XXX_Size() int

func (*TailRequest) XXX_Unmarshal 

func (m *TailRequest) XXX_Unmarshal(b []byte) error

type TailResponse 

type TailResponse struct {
	Stream         *github_com_grafana_loki_pkg_push.Stream `protobuf:"bytes,1,opt,name=stream,proto3,customtype=github.com/grafana/loki/pkg/push.Stream" json:"stream,omitempty"`
	DroppedStreams []*DroppedStream                         `protobuf:"bytes,2,rep,name=droppedStreams,proto3" json:"droppedStreams,omitempty"`
}

func (*TailResponse) Descriptor 

func (*TailResponse) Descriptor() ([]byte, []int)

func (*TailResponse) Equal 

func (this *TailResponse) Equal(that interface{}) bool

func (*TailResponse) GetDroppedStreams 

func (m *TailResponse) GetDroppedStreams() []*DroppedStream

func (*TailResponse) GoString 

func (this *TailResponse) GoString() string

func (*TailResponse) Marshal 

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

func (*TailResponse) MarshalTo 

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

func (*TailResponse) MarshalToSizedBuffer 

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

func (*TailResponse) ProtoMessage 

func (*TailResponse) ProtoMessage()

func (*TailResponse) Reset 

func (m *TailResponse) Reset()

func (*TailResponse) Size 

func (m *TailResponse) Size() (n int)

func (*TailResponse) String 

func (this *TailResponse) String() string

func (*TailResponse) Unmarshal 

func (m *TailResponse) Unmarshal(dAtA []byte) error

func (*TailResponse) XXX_DiscardUnknown 

func (m *TailResponse) XXX_DiscardUnknown()

func (*TailResponse) XXX_Marshal 

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

func (*TailResponse) XXX_Merge 

func (m *TailResponse) XXX_Merge(src proto.Message)

func (*TailResponse) XXX_Size 

func (m *TailResponse) XXX_Size() int

func (*TailResponse) XXX_Unmarshal 

func (m *TailResponse) XXX_Unmarshal(b []byte) error

type TailersCountRequest 

type TailersCountRequest struct {
}

func (*TailersCountRequest) Descriptor 

func (*TailersCountRequest) Descriptor() ([]byte, []int)

func (*TailersCountRequest) Equal 

func (this *TailersCountRequest) Equal(that interface{}) bool

func (*TailersCountRequest) GoString 

func (this *TailersCountRequest) GoString() string

func (*TailersCountRequest) Marshal 

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

func (*TailersCountRequest) MarshalTo 

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

func (*TailersCountRequest) MarshalToSizedBuffer 

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

func (*TailersCountRequest) ProtoMessage 

func (*TailersCountRequest) ProtoMessage()

func (*TailersCountRequest) Reset 

func (m *TailersCountRequest) Reset()

func (*TailersCountRequest) Size 

func (m *TailersCountRequest) Size() (n int)

func (*TailersCountRequest) String 

func (this *TailersCountRequest) String() string

func (*TailersCountRequest) Unmarshal 

func (m *TailersCountRequest) Unmarshal(dAtA []byte) error

func (*TailersCountRequest) XXX_DiscardUnknown 

func (m *TailersCountRequest) XXX_DiscardUnknown()

func (*TailersCountRequest) XXX_Marshal 

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

func (*TailersCountRequest) XXX_Merge 

func (m *TailersCountRequest) XXX_Merge(src proto.Message)

func (*TailersCountRequest) XXX_Size 

func (m *TailersCountRequest) XXX_Size() int

func (*TailersCountRequest) XXX_Unmarshal 

func (m *TailersCountRequest) XXX_Unmarshal(b []byte) error

type TailersCountResponse 

type TailersCountResponse struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
}

func (*TailersCountResponse) Descriptor 

func (*TailersCountResponse) Descriptor() ([]byte, []int)

func (*TailersCountResponse) Equal 

func (this *TailersCountResponse) Equal(that interface{}) bool

func (*TailersCountResponse) GetCount 

func (m *TailersCountResponse) GetCount() uint32

func (*TailersCountResponse) GoString 

func (this *TailersCountResponse) GoString() string

func (*TailersCountResponse) Marshal 

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

func (*TailersCountResponse) MarshalTo 

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

func (*TailersCountResponse) MarshalToSizedBuffer 

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

func (*TailersCountResponse) ProtoMessage 

func (*TailersCountResponse) ProtoMessage()

func (*TailersCountResponse) Reset 

func (m *TailersCountResponse) Reset()

func (*TailersCountResponse) Size 

func (m *TailersCountResponse) Size() (n int)

func (*TailersCountResponse) String 

func (this *TailersCountResponse) String() string

func (*TailersCountResponse) Unmarshal 

func (m *TailersCountResponse) Unmarshal(dAtA []byte) error

func (*TailersCountResponse) XXX_DiscardUnknown 

func (m *TailersCountResponse) XXX_DiscardUnknown()

func (*TailersCountResponse) XXX_Marshal 

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

func (*TailersCountResponse) XXX_Merge 

func (m *TailersCountResponse) XXX_Merge(src proto.Message)

func (*TailersCountResponse) XXX_Size 

func (m *TailersCountResponse) XXX_Size() int

func (*TailersCountResponse) XXX_Unmarshal 

func (m *TailersCountResponse) XXX_Unmarshal(b []byte) error

type TimeSeries 

type TimeSeries struct {
	Labels []LabelAdapter `protobuf:"bytes,1,rep,name=labels,proto3,customtype=LabelAdapter" json:"labels"`
	// Sorted by time, oldest sample first.
	Samples []LegacySample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples"`
}

func TimeseriesFromPool 

func TimeseriesFromPool() *TimeSeries

TimeseriesFromPool retrieves a pointer to a TimeSeries from a sync.Pool. ReuseTimeseries should be called once done, unless ReuseSlice was called on the slice that contains this TimeSeries.

func (*TimeSeries) Descriptor 

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

func (*TimeSeries) Equal 

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

func (*TimeSeries) GetSamples 

func (m *TimeSeries) GetSamples() []LegacySample

func (*TimeSeries) GoString 

func (this *TimeSeries) GoString() string

func (*TimeSeries) Marshal 

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

func (*TimeSeries) MarshalTo 

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

func (*TimeSeries) MarshalToSizedBuffer 

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

func (*TimeSeries) ProtoMessage 

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) Reset 

func (m *TimeSeries) Reset()

func (*TimeSeries) Size 

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

func (*TimeSeries) String 

func (this *TimeSeries) String() string

func (*TimeSeries) Unmarshal 

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

func (*TimeSeries) XXX_DiscardUnknown 

func (m *TimeSeries) XXX_DiscardUnknown()

func (*TimeSeries) XXX_Marshal 

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

func (*TimeSeries) XXX_Merge 

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

func (*TimeSeries) XXX_Size 

func (m *TimeSeries) XXX_Size() int

func (*TimeSeries) XXX_Unmarshal 

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

type TopK 

type TopK struct {
	Cms         *CountMinSketch `protobuf:"bytes,1,opt,name=cms,proto3" json:"cms,omitempty"`
	List        []*TopK_Pair    `protobuf:"bytes,2,rep,name=list,proto3" json:"list,omitempty"`
	Hyperloglog []byte          `protobuf:"bytes,3,opt,name=hyperloglog,proto3" json:"hyperloglog,omitempty"`
}

func (*TopK) Descriptor 

func (*TopK) Descriptor() ([]byte, []int)

func (*TopK) Equal 

func (this *TopK) Equal(that interface{}) bool

func (*TopK) GetCms 

func (m *TopK) GetCms() *CountMinSketch

func (*TopK) GetHyperloglog 

func (m *TopK) GetHyperloglog() []byte

func (*TopK) GetList 

func (m *TopK) GetList() []*TopK_Pair

func (*TopK) GoString 

func (this *TopK) GoString() string

func (*TopK) Marshal 

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

func (*TopK) MarshalTo 

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

func (*TopK) MarshalToSizedBuffer 

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

func (*TopK) ProtoMessage 

func (*TopK) ProtoMessage()

func (*TopK) Reset 

func (m *TopK) Reset()

func (*TopK) Size 

func (m *TopK) Size() (n int)

func (*TopK) String 

func (this *TopK) String() string

func (*TopK) Unmarshal 

func (m *TopK) Unmarshal(dAtA []byte) error

func (*TopK) XXX_DiscardUnknown 

func (m *TopK) XXX_DiscardUnknown()

func (*TopK) XXX_Marshal 

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

func (*TopK) XXX_Merge 

func (m *TopK) XXX_Merge(src proto.Message)

func (*TopK) XXX_Size 

func (m *TopK) XXX_Size() int

func (*TopK) XXX_Unmarshal 

func (m *TopK) XXX_Unmarshal(b []byte) error

type TopKMatrix 

type TopKMatrix struct {
	Values []*TopKMatrix_Vector `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
}

func (*TopKMatrix) Descriptor 

func (*TopKMatrix) Descriptor() ([]byte, []int)

func (*TopKMatrix) Equal 

func (this *TopKMatrix) Equal(that interface{}) bool

func (*TopKMatrix) GetValues 

func (m *TopKMatrix) GetValues() []*TopKMatrix_Vector

func (*TopKMatrix) GoString 

func (this *TopKMatrix) GoString() string

func (*TopKMatrix) Marshal 

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

func (*TopKMatrix) MarshalTo 

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

func (*TopKMatrix) MarshalToSizedBuffer 

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

func (*TopKMatrix) ProtoMessage 

func (*TopKMatrix) ProtoMessage()

func (*TopKMatrix) Reset 

func (m *TopKMatrix) Reset()

func (*TopKMatrix) Size 

func (m *TopKMatrix) Size() (n int)

func (*TopKMatrix) String 

func (this *TopKMatrix) String() string

func (*TopKMatrix) Unmarshal 

func (m *TopKMatrix) Unmarshal(dAtA []byte) error

func (*TopKMatrix) XXX_DiscardUnknown 

func (m *TopKMatrix) XXX_DiscardUnknown()

func (*TopKMatrix) XXX_Marshal 

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

func (*TopKMatrix) XXX_Merge 

func (m *TopKMatrix) XXX_Merge(src proto.Message)

func (*TopKMatrix) XXX_Size 

func (m *TopKMatrix) XXX_Size() int

func (*TopKMatrix) XXX_Unmarshal 

func (m *TopKMatrix) XXX_Unmarshal(b []byte) error

type TopKMatrix_Vector 

type TopKMatrix_Vector struct {
	Topk        *TopK `protobuf:"bytes,1,opt,name=topk,proto3" json:"topk,omitempty"`
	TimestampMs int64 `protobuf:"varint,2,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
}

func (*TopKMatrix_Vector) Descriptor 

func (*TopKMatrix_Vector) Descriptor() ([]byte, []int)

func (*TopKMatrix_Vector) Equal 

func (this *TopKMatrix_Vector) Equal(that interface{}) bool

func (*TopKMatrix_Vector) GetTimestampMs 

func (m *TopKMatrix_Vector) GetTimestampMs() int64

func (*TopKMatrix_Vector) GetTopk 

func (m *TopKMatrix_Vector) GetTopk() *TopK

func (*TopKMatrix_Vector) GoString 

func (this *TopKMatrix_Vector) GoString() string

func (*TopKMatrix_Vector) Marshal 

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

func (*TopKMatrix_Vector) MarshalTo 

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

func (*TopKMatrix_Vector) MarshalToSizedBuffer 

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

func (*TopKMatrix_Vector) ProtoMessage 

func (*TopKMatrix_Vector) ProtoMessage()

func (*TopKMatrix_Vector) Reset 

func (m *TopKMatrix_Vector) Reset()

func (*TopKMatrix_Vector) Size 

func (m *TopKMatrix_Vector) Size() (n int)

func (*TopKMatrix_Vector) String 

func (this *TopKMatrix_Vector) String() string

func (*TopKMatrix_Vector) Unmarshal 

func (m *TopKMatrix_Vector) Unmarshal(dAtA []byte) error

func (*TopKMatrix_Vector) XXX_DiscardUnknown 

func (m *TopKMatrix_Vector) XXX_DiscardUnknown()

func (*TopKMatrix_Vector) XXX_Marshal 

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

func (*TopKMatrix_Vector) XXX_Merge 

func (m *TopKMatrix_Vector) XXX_Merge(src proto.Message)

func (*TopKMatrix_Vector) XXX_Size 

func (m *TopKMatrix_Vector) XXX_Size() int

func (*TopKMatrix_Vector) XXX_Unmarshal 

func (m *TopKMatrix_Vector) XXX_Unmarshal(b []byte) error

type TopK_Pair 

type TopK_Pair struct {
	Event string `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
}

func (*TopK_Pair) Descriptor 

func (*TopK_Pair) Descriptor() ([]byte, []int)

func (*TopK_Pair) Equal 

func (this *TopK_Pair) Equal(that interface{}) bool

func (*TopK_Pair) GetCount 

func (m *TopK_Pair) GetCount() uint32

func (*TopK_Pair) GetEvent 

func (m *TopK_Pair) GetEvent() string

func (*TopK_Pair) GoString 

func (this *TopK_Pair) GoString() string

func (*TopK_Pair) Marshal 

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

func (*TopK_Pair) MarshalTo 

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

func (*TopK_Pair) MarshalToSizedBuffer 

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

func (*TopK_Pair) ProtoMessage 

func (*TopK_Pair) ProtoMessage()

func (*TopK_Pair) Reset 

func (m *TopK_Pair) Reset()

func (*TopK_Pair) Size 

func (m *TopK_Pair) Size() (n int)

func (*TopK_Pair) String 

func (this *TopK_Pair) String() string

func (*TopK_Pair) Unmarshal 

func (m *TopK_Pair) Unmarshal(dAtA []byte) error

func (*TopK_Pair) XXX_DiscardUnknown 

func (m *TopK_Pair) XXX_DiscardUnknown()

func (*TopK_Pair) XXX_Marshal 

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

func (*TopK_Pair) XXX_Merge 

func (m *TopK_Pair) XXX_Merge(src proto.Message)

func (*TopK_Pair) XXX_Size 

func (m *TopK_Pair) XXX_Size() int

func (*TopK_Pair) XXX_Unmarshal 

func (m *TopK_Pair) XXX_Unmarshal(b []byte) error

type UnimplementedBloomGatewayServer 

type UnimplementedBloomGatewayServer struct {
}

UnimplementedBloomGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedBloomGatewayServer) FilterChunkRefs 

func (*UnimplementedBloomGatewayServer) FilterChunkRefs(ctx context.Context, req *FilterChunkRefRequest) (*FilterChunkRefResponse, error)

type UnimplementedIndexGatewayServer 

type UnimplementedIndexGatewayServer struct {
}

UnimplementedIndexGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexGatewayServer) GetChunkRef 

func (*UnimplementedIndexGatewayServer) GetChunkRef(ctx context.Context, req *GetChunkRefRequest) (*GetChunkRefResponse, error)

func (*UnimplementedIndexGatewayServer) GetSeries 

func (*UnimplementedIndexGatewayServer) GetSeries(ctx context.Context, req *GetSeriesRequest) (*GetSeriesResponse, error)

func (*UnimplementedIndexGatewayServer) GetShards 

func (*UnimplementedIndexGatewayServer) GetShards(req *ShardsRequest, srv IndexGateway_GetShardsServer) error

func (*UnimplementedIndexGatewayServer) GetStats 

func (*UnimplementedIndexGatewayServer) GetStats(ctx context.Context, req *IndexStatsRequest) (*IndexStatsResponse, error)

func (*UnimplementedIndexGatewayServer) GetVolume 

func (*UnimplementedIndexGatewayServer) GetVolume(ctx context.Context, req *VolumeRequest) (*VolumeResponse, error)

func (*UnimplementedIndexGatewayServer) LabelNamesForMetricName 

func (*UnimplementedIndexGatewayServer) LabelNamesForMetricName(ctx context.Context, req *LabelNamesForMetricNameRequest) (*LabelResponse, error)

func (*UnimplementedIndexGatewayServer) LabelValuesForMetricName 

func (*UnimplementedIndexGatewayServer) LabelValuesForMetricName(ctx context.Context, req *LabelValuesForMetricNameRequest) (*LabelResponse, error)

func (*UnimplementedIndexGatewayServer) QueryIndex 

func (*UnimplementedIndexGatewayServer) QueryIndex(req *QueryIndexRequest, srv IndexGateway_QueryIndexServer) error

type UnimplementedPatternServer 

type UnimplementedPatternServer struct {
}

UnimplementedPatternServer can be embedded to have forward compatible implementations.

func (*UnimplementedPatternServer) Push 

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

func (*UnimplementedPatternServer) Query 

func (*UnimplementedPatternServer) Query(req *QueryPatternsRequest, srv Pattern_QueryServer) error

type UnimplementedPusherRF1Server added in v3.2.0 

type UnimplementedPusherRF1Server struct {
}

UnimplementedPusherRF1Server can be embedded to have forward compatible implementations.

func (*UnimplementedPusherRF1Server) Push added in v3.2.0 

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

type UnimplementedQuerierServer 

type UnimplementedQuerierServer struct {
}

UnimplementedQuerierServer can be embedded to have forward compatible implementations.

func (*UnimplementedQuerierServer) GetChunkIDs 

func (*UnimplementedQuerierServer) GetChunkIDs(ctx context.Context, req *GetChunkIDsRequest) (*GetChunkIDsResponse, error)

func (*UnimplementedQuerierServer) GetDetectedFields 

func (*UnimplementedQuerierServer) GetDetectedFields(ctx context.Context, req *DetectedFieldsRequest) (*DetectedFieldsResponse, error)

func (*UnimplementedQuerierServer) GetDetectedLabels 

func (*UnimplementedQuerierServer) GetDetectedLabels(ctx context.Context, req *DetectedLabelsRequest) (*LabelToValuesResponse, error)

func (*UnimplementedQuerierServer) GetStats 

func (*UnimplementedQuerierServer) GetStats(ctx context.Context, req *IndexStatsRequest) (*IndexStatsResponse, error)

func (*UnimplementedQuerierServer) GetVolume 

func (*UnimplementedQuerierServer) GetVolume(ctx context.Context, req *VolumeRequest) (*VolumeResponse, error)

func (*UnimplementedQuerierServer) Label 

func (*UnimplementedQuerierServer) Label(ctx context.Context, req *LabelRequest) (*LabelResponse, error)

func (*UnimplementedQuerierServer) Query 

func (*UnimplementedQuerierServer) Query(req *QueryRequest, srv Querier_QueryServer) error

func (*UnimplementedQuerierServer) QuerySample 

func (*UnimplementedQuerierServer) QuerySample(req *SampleQueryRequest, srv Querier_QuerySampleServer) error

func (*UnimplementedQuerierServer) Series 

func (*UnimplementedQuerierServer) Series(ctx context.Context, req *SeriesRequest) (*SeriesResponse, error)

func (*UnimplementedQuerierServer) Tail 

func (*UnimplementedQuerierServer) Tail(req *TailRequest, srv Querier_TailServer) error

func (*UnimplementedQuerierServer) TailersCount 

func (*UnimplementedQuerierServer) TailersCount(ctx context.Context, req *TailersCountRequest) (*TailersCountResponse, error)

type UnimplementedStreamDataServer 

type UnimplementedStreamDataServer struct {
}

UnimplementedStreamDataServer can be embedded to have forward compatible implementations.

func (*UnimplementedStreamDataServer) GetStreamRates 

func (*UnimplementedStreamDataServer) GetStreamRates(ctx context.Context, req *StreamRatesRequest) (*StreamRatesResponse, error)

type UniqueLabelValues 

type UniqueLabelValues struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
}

func (*UniqueLabelValues) Descriptor 

func (*UniqueLabelValues) Descriptor() ([]byte, []int)

func (*UniqueLabelValues) Equal 

func (this *UniqueLabelValues) Equal(that interface{}) bool

func (*UniqueLabelValues) GetValues 

func (m *UniqueLabelValues) GetValues() []string

func (*UniqueLabelValues) GoString 

func (this *UniqueLabelValues) GoString() string

func (*UniqueLabelValues) Marshal 

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

func (*UniqueLabelValues) MarshalTo 

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

func (*UniqueLabelValues) MarshalToSizedBuffer 

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

func (*UniqueLabelValues) ProtoMessage 

func (*UniqueLabelValues) ProtoMessage()

func (*UniqueLabelValues) Reset 

func (m *UniqueLabelValues) Reset()

func (*UniqueLabelValues) Size 

func (m *UniqueLabelValues) Size() (n int)

func (*UniqueLabelValues) String 

func (this *UniqueLabelValues) String() string

func (*UniqueLabelValues) Unmarshal 

func (m *UniqueLabelValues) Unmarshal(dAtA []byte) error

func (*UniqueLabelValues) XXX_DiscardUnknown 

func (m *UniqueLabelValues) XXX_DiscardUnknown()

func (*UniqueLabelValues) XXX_Marshal 

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

func (*UniqueLabelValues) XXX_Merge 

func (m *UniqueLabelValues) XXX_Merge(src proto.Message)

func (*UniqueLabelValues) XXX_Size 

func (m *UniqueLabelValues) XXX_Size() int

func (*UniqueLabelValues) XXX_Unmarshal 

func (m *UniqueLabelValues) XXX_Unmarshal(b []byte) error

type Volume 

type Volume struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name"`
	Volume uint64 `protobuf:"varint,3,opt,name=volume,proto3" json:"volume"`
}

func (*Volume) Descriptor 

func (*Volume) Descriptor() ([]byte, []int)

func (*Volume) Equal 

func (this *Volume) Equal(that interface{}) bool

func (*Volume) GetName 

func (m *Volume) GetName() string

func (*Volume) GetVolume 

func (m *Volume) GetVolume() uint64

func (*Volume) GoString 

func (this *Volume) GoString() string

func (*Volume) Marshal 

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

func (*Volume) MarshalTo 

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

func (*Volume) MarshalToSizedBuffer 

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

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) Reset 

func (m *Volume) Reset()

func (*Volume) Size 

func (m *Volume) Size() (n int)

func (*Volume) String 

func (this *Volume) String() string

func (*Volume) Unmarshal 

func (m *Volume) Unmarshal(dAtA []byte) error

func (*Volume) XXX_DiscardUnknown 

func (m *Volume) XXX_DiscardUnknown()

func (*Volume) XXX_Marshal 

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

func (*Volume) XXX_Merge 

func (m *Volume) XXX_Merge(src proto.Message)

func (*Volume) XXX_Size 

func (m *Volume) XXX_Size() int

func (*Volume) XXX_Unmarshal 

func (m *Volume) XXX_Unmarshal(b []byte) error

type VolumeRequest 

type VolumeRequest struct {
	From           github_com_prometheus_common_model.Time `protobuf:"varint,1,opt,name=from,proto3,customtype=github.com/prometheus/common/model.Time" json:"from"`
	Through        github_com_prometheus_common_model.Time `protobuf:"varint,2,opt,name=through,proto3,customtype=github.com/prometheus/common/model.Time" json:"through"`
	Matchers       string                                  `protobuf:"bytes,3,opt,name=matchers,proto3" json:"matchers,omitempty"`
	Limit          int32                                   `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	Step           int64                                   `protobuf:"varint,5,opt,name=step,proto3" json:"step,omitempty"`
	TargetLabels   []string                                `protobuf:"bytes,6,rep,name=targetLabels,proto3" json:"targetLabels,omitempty"`
	AggregateBy    string                                  `protobuf:"bytes,7,opt,name=aggregateBy,proto3" json:"aggregateBy,omitempty"`
	CachingOptions resultscache.CachingOptions             `protobuf:"bytes,8,opt,name=cachingOptions,proto3" json:"cachingOptions"`
}

func (*VolumeRequest) Descriptor 

func (*VolumeRequest) Descriptor() ([]byte, []int)

func (*VolumeRequest) Equal 

func (this *VolumeRequest) Equal(that interface{}) bool

func (*VolumeRequest) GetAggregateBy 

func (m *VolumeRequest) GetAggregateBy() string

func (*VolumeRequest) GetCachingOptions 

func (m *VolumeRequest) GetCachingOptions() resultscache.CachingOptions

func (*VolumeRequest) GetEnd 

func (m *VolumeRequest) GetEnd() time.Time

GetEnd returns the end timestamp of the request in milliseconds.

func (*VolumeRequest) GetLimit 

func (m *VolumeRequest) GetLimit() int32

func (*VolumeRequest) GetMatchers 

func (m *VolumeRequest) GetMatchers() string

func (*VolumeRequest) GetQuery 

func (m *VolumeRequest) GetQuery() string

GetQuery returns the query of the request.

func (*VolumeRequest) GetStart 

func (m *VolumeRequest) GetStart() time.Time

GetStart returns the start timestamp of the request in milliseconds.

func (*VolumeRequest) GetStep 

func (m *VolumeRequest) GetStep() int64

func (*VolumeRequest) GetTargetLabels 

func (m *VolumeRequest) GetTargetLabels() []string

func (*VolumeRequest) GoString 

func (this *VolumeRequest) GoString() string

func (*VolumeRequest) LogToSpan 

func (m *VolumeRequest) LogToSpan(sp opentracing.Span)

LogToSpan writes information about this request to an OpenTracing span

func (*VolumeRequest) Marshal 

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

func (*VolumeRequest) MarshalTo 

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

func (*VolumeRequest) MarshalToSizedBuffer 

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

func (*VolumeRequest) ProtoMessage 

func (*VolumeRequest) ProtoMessage()

func (*VolumeRequest) Reset 

func (m *VolumeRequest) Reset()

func (*VolumeRequest) Size 

func (m *VolumeRequest) Size() (n int)

func (*VolumeRequest) String 

func (this *VolumeRequest) String() string

func (*VolumeRequest) Unmarshal 

func (m *VolumeRequest) Unmarshal(dAtA []byte) error

func (*VolumeRequest) WithQuery 

func (m *VolumeRequest) WithQuery(query string) definitions.Request

WithQuery clone the current request with a different query.

func (*VolumeRequest) WithStartEnd 

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

WithStartEnd clone the current request with different start and end timestamp.

func (*VolumeRequest) WithStartEndForCache 

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

WithStartEndForCache implements resultscache.Request.

func (*VolumeRequest) XXX_DiscardUnknown 

func (m *VolumeRequest) XXX_DiscardUnknown()

func (*VolumeRequest) XXX_Marshal 

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

func (*VolumeRequest) XXX_Merge 

func (m *VolumeRequest) XXX_Merge(src proto.Message)

func (*VolumeRequest) XXX_Size 

func (m *VolumeRequest) XXX_Size() int

func (*VolumeRequest) XXX_Unmarshal 

func (m *VolumeRequest) XXX_Unmarshal(b []byte) error

type VolumeResponse 

type VolumeResponse struct {
	Volumes []Volume `protobuf:"bytes,1,rep,name=volumes,proto3" json:"volumes"`
	Limit   int32    `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
}

func (*VolumeResponse) Descriptor 

func (*VolumeResponse) Descriptor() ([]byte, []int)

func (*VolumeResponse) Equal 

func (this *VolumeResponse) Equal(that interface{}) bool

func (*VolumeResponse) GetLimit 

func (m *VolumeResponse) GetLimit() int32

func (*VolumeResponse) GetVolumes 

func (m *VolumeResponse) GetVolumes() []Volume

func (*VolumeResponse) GoString 

func (this *VolumeResponse) GoString() string

func (*VolumeResponse) Marshal 

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

func (*VolumeResponse) MarshalTo 

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

func (*VolumeResponse) MarshalToSizedBuffer 

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

func (*VolumeResponse) ProtoMessage 

func (*VolumeResponse) ProtoMessage()

func (*VolumeResponse) Reset 

func (m *VolumeResponse) Reset()

func (*VolumeResponse) Size 

func (m *VolumeResponse) Size() (n int)

func (*VolumeResponse) String 

func (this *VolumeResponse) String() string

func (*VolumeResponse) Unmarshal 

func (m *VolumeResponse) Unmarshal(dAtA []byte) error

func (*VolumeResponse) XXX_DiscardUnknown 

func (m *VolumeResponse) XXX_DiscardUnknown()

func (*VolumeResponse) XXX_Marshal 

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

func (*VolumeResponse) XXX_Merge 

func (m *VolumeResponse) XXX_Merge(src proto.Message)

func (*VolumeResponse) XXX_Size 

func (m *VolumeResponse) XXX_Size() int

func (*VolumeResponse) XXX_Unmarshal 

func (m *VolumeResponse) XXX_Unmarshal(b []byte) error

type WriteRequest 

type WriteRequest struct {
	Timeseries              []PreallocTimeseries    `protobuf:"bytes,1,rep,name=timeseries,proto3,customtype=PreallocTimeseries" json:"timeseries"`
	Source                  WriteRequest_SourceEnum `protobuf:"varint,2,opt,name=Source,proto3,enum=logproto.WriteRequest_SourceEnum" json:"Source,omitempty"`
	Metadata                []*MetricMetadata       `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty"`
	SkipLabelNameValidation bool                    `` /* 138-byte string literal not displayed */
}

func ToWriteRequest 

func ToWriteRequest(lbls []labels.Labels, samples []LegacySample, metadata []*MetricMetadata, source WriteRequest_SourceEnum) *WriteRequest

ToWriteRequest converts matched slices of Labels, Samples and Metadata into a WriteRequest proto. It gets timeseries from the pool, so ReuseSlice() should be called when done.

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) Equal 

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

func (*WriteRequest) GetMetadata 

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

func (*WriteRequest) GetSkipLabelNameValidation 

func (m *WriteRequest) GetSkipLabelNameValidation() bool

func (*WriteRequest) GetSource 

func (m *WriteRequest) GetSource() WriteRequest_SourceEnum

func (*WriteRequest) GoString 

func (this *WriteRequest) GoString() string

func (*WriteRequest) Marshal 

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

func (*WriteRequest) MarshalTo 

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

func (*WriteRequest) MarshalToSizedBuffer 

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

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) Size 

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

func (*WriteRequest) String 

func (this *WriteRequest) String() string

func (*WriteRequest) Unmarshal 

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

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

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

func (*WriteRequest) XXX_Merge 

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

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

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

type WriteRequest_SourceEnum 

type WriteRequest_SourceEnum int32
const (
	API  WriteRequest_SourceEnum = 0
	RULE WriteRequest_SourceEnum = 1
)

func (WriteRequest_SourceEnum) EnumDescriptor 

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

func (WriteRequest_SourceEnum) String 

func (x WriteRequest_SourceEnum) String() string

type WriteResponse 

type WriteResponse struct {
}

func (*WriteResponse) Descriptor 

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

func (*WriteResponse) Equal 

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

func (*WriteResponse) GoString 

func (this *WriteResponse) GoString() string

func (*WriteResponse) Marshal 

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

func (*WriteResponse) MarshalTo 

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

func (*WriteResponse) MarshalToSizedBuffer 

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

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) Size 

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

func (*WriteResponse) String 

func (this *WriteResponse) String() string

func (*WriteResponse) Unmarshal 

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

func (*WriteResponse) XXX_DiscardUnknown 

func (m *WriteResponse) XXX_DiscardUnknown()

func (*WriteResponse) XXX_Marshal 

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

func (*WriteResponse) XXX_Merge 

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

func (*WriteResponse) XXX_Size 

func (m *WriteResponse) XXX_Size() int

func (*WriteResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.