logproto

package
v1.6.2-0...-b66c343 Latest Latest
Warning

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

Go to latest
Published: Apr 2, 2024 License: AGPL-3.0 Imports: 40 Imported by: 376

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 (
	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 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 added in v0.2.0

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

func (*Chunk) Descriptor added in v0.2.0

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

func (*Chunk) Equal added in v0.2.0

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

func (*Chunk) GetData added in v0.2.0

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

func (*Chunk) GoString added in v0.2.0

func (this *Chunk) GoString() string

func (*Chunk) Marshal added in v0.2.0

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

func (*Chunk) MarshalTo added in v0.2.0

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

func (*Chunk) MarshalToSizedBuffer added in v0.2.0

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

func (*Chunk) ProtoMessage added in v0.2.0

func (*Chunk) ProtoMessage()

func (*Chunk) Reset added in v0.2.0

func (m *Chunk) Reset()

func (*Chunk) Size added in v0.2.0

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

func (*Chunk) String added in v0.2.0

func (this *Chunk) String() string

func (*Chunk) Unmarshal added in v0.2.0

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

func (*Chunk) XXX_DiscardUnknown added in v0.2.0

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal added in v0.2.0

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

func (*Chunk) XXX_Merge added in v0.2.0

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

func (*Chunk) XXX_Size added in v0.2.0

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal added in v0.2.0

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 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"`
}

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) 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,omitempty"`
	End   *time.Time `protobuf:"bytes,2,opt,name=end,proto3,stdtime" json:"end,omitempty"`
	Query string     `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
}

func (*DetectedFieldsRequest) Descriptor

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

func (*DetectedFieldsRequest) Equal

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

func (*DetectedFieldsRequest) GetEnd

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

func (*DetectedFieldsRequest) GetQuery

func (m *DetectedFieldsRequest) GetQuery() string

func (*DetectedFieldsRequest) GetStart

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

func (*DetectedFieldsRequest) GoString

func (this *DetectedFieldsRequest) GoString() string

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) 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"`
}

func (*DetectedFieldsResponse) Descriptor

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

func (*DetectedFieldsResponse) Equal

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

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"`
}

func (*DetectedLabel) Descriptor

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

func (*DetectedLabel) Equal

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

func (*DetectedLabel) GetLabel

func (m *DetectedLabel) GetLabel() string

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,omitempty"`
	End   *time.Time `protobuf:"bytes,2,opt,name=end,proto3,stdtime" json:"end,omitempty"`
	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) 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) GoString

func (this *DetectedLabelsRequest) GoString() string

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) 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 added in v0.2.0

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 added in v0.2.0

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

func (*DroppedStream) Equal added in v0.2.0

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

func (*DroppedStream) GetFrom added in v0.2.0

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

func (*DroppedStream) GetLabels added in v0.2.0

func (m *DroppedStream) GetLabels() string

func (*DroppedStream) GetTo added in v0.2.0

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

func (*DroppedStream) GoString added in v0.2.0

func (this *DroppedStream) GoString() string

func (*DroppedStream) Marshal added in v0.2.0

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

func (*DroppedStream) MarshalTo added in v0.2.0

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

func (*DroppedStream) MarshalToSizedBuffer added in v0.2.0

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

func (*DroppedStream) ProtoMessage added in v0.2.0

func (*DroppedStream) ProtoMessage()

func (*DroppedStream) Reset added in v0.2.0

func (m *DroppedStream) Reset()

func (*DroppedStream) Size added in v0.2.0

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

func (*DroppedStream) String added in v0.2.0

func (this *DroppedStream) String() string

func (*DroppedStream) Unmarshal added in v0.2.0

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

func (*DroppedStream) XXX_DiscardUnknown added in v0.2.0

func (m *DroppedStream) XXX_DiscardUnknown()

func (*DroppedStream) XXX_Marshal added in v0.2.0

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

func (*DroppedStream) XXX_Merge added in v0.2.0

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

func (*DroppedStream) XXX_Size added in v0.2.0

func (m *DroppedStream) XXX_Size() int

func (*DroppedStream) XXX_Unmarshal added in v0.2.0

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 (*FPBounds) GetMin

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"`
	// TODO(salvacorts): Delete this field once the weekly release is done.
	Filters []github_com_grafana_loki_pkg_logql_syntax.LineFilter `protobuf:"bytes,4,rep,name=filters,proto3,customtype=github.com/grafana/loki/pkg/logql/syntax.LineFilter" json:"filters"`
	Plan    github_com_grafana_loki_pkg_querier_plan.QueryPlan    `protobuf:"bytes,5,opt,name=plan,proto3,customtype=github.com/grafana/loki/pkg/querier/plan.QueryPlan" json:"plan"`
}

func (*FilterChunkRefRequest) Descriptor

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

func (*FilterChunkRefRequest) Equal

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

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_pkg_logql_syntax.LineFilter `protobuf:"bytes,4,rep,name=filters,proto3,customtype=github.com/grafana/loki/pkg/logql/syntax.LineFilter" json:"filters"`
	Plan    github_com_grafana_loki_pkg_querier_plan.QueryPlan    `protobuf:"bytes,5,opt,name=plan,proto3,customtype=github.com/grafana/loki/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) 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) 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 (*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 (*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"`
}

func (*LabelNamesForMetricNameRequest) Descriptor

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

func (*LabelNamesForMetricNameRequest) Equal

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

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 added in v0.2.0

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 added in v0.2.0

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

func (*LabelPair) Equal added in v0.2.0

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

func (*LabelPair) GetName added in v0.2.0

func (m *LabelPair) GetName() string

func (*LabelPair) GetValue added in v0.2.0

func (m *LabelPair) GetValue() string

func (*LabelPair) GoString added in v0.2.0

func (this *LabelPair) GoString() string

func (*LabelPair) Marshal added in v0.2.0

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

func (*LabelPair) MarshalTo added in v0.2.0

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

func (*LabelPair) MarshalToSizedBuffer added in v0.2.0

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

func (*LabelPair) ProtoMessage added in v0.2.0

func (*LabelPair) ProtoMessage()

func (*LabelPair) Reset added in v0.2.0

func (m *LabelPair) Reset()

func (*LabelPair) Size added in v0.2.0

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

func (*LabelPair) String added in v0.2.0

func (this *LabelPair) String() string

func (*LabelPair) Unmarshal added in v0.2.0

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

func (*LabelPair) XXX_DiscardUnknown added in v0.2.0

func (m *LabelPair) XXX_DiscardUnknown()

func (*LabelPair) XXX_Marshal added in v0.2.0

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

func (*LabelPair) XXX_Merge added in v0.2.0

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

func (*LabelPair) XXX_Size added in v0.2.0

func (m *LabelPair) XXX_Size() int

func (*LabelPair) XXX_Unmarshal added in v0.2.0

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 added in v0.2.0

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 added in v0.2.0

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 added in v0.2.0

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 added in v0.2.0

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 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 (*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 (*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

func (MetricMetadata_MetricType) EnumDescriptor

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

func (MetricMetadata_MetricType) String

func (x MetricMetadata_MetricType) String() string

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 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 (*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)
}

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)
}

QuerierServer is the server API for Querier service.

type Querier_QueryClient

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

type Querier_QuerySampleClient added in v1.6.0

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

type Querier_QuerySampleServer added in v1.6.0

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

type Querier_QueryServer

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

type Querier_TailClient added in v0.2.0

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

type Querier_TailServer added in v0.2.0

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 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_pkg_querier_plan.QueryPlan `protobuf:"bytes,9,opt,name=plan,proto3,customtype=github.com/grafana/loki/pkg/querier/plan.QueryPlan" json:"plan,omitempty"`
}

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 added in v0.4.0

func (m *QueryRequest) GetSelector() string

Deprecated: Do not use.

func (*QueryRequest) GetShards added in v1.6.0

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

func (*QueryRequest) GetStart

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

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 added in v0.2.0

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"`
}

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) 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 added in v0.2.0

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 added in v1.6.0

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 added in v1.6.0

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

func (*Sample) Equal added in v1.6.0

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

func (*Sample) GetHash added in v1.6.0

func (m *Sample) GetHash() uint64

func (*Sample) GetTimestamp added in v1.6.0

func (m *Sample) GetTimestamp() int64

func (*Sample) GetValue added in v1.6.0

func (m *Sample) GetValue() float64

func (*Sample) GoString added in v1.6.0

func (this *Sample) GoString() string

func (*Sample) Marshal added in v1.6.0

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

func (*Sample) MarshalTo added in v1.6.0

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

func (*Sample) MarshalToSizedBuffer

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

func (*Sample) ProtoMessage added in v1.6.0

func (*Sample) ProtoMessage()

func (*Sample) Reset added in v1.6.0

func (m *Sample) Reset()

func (*Sample) Size added in v1.6.0

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

func (*Sample) String added in v1.6.0

func (this *Sample) String() string

func (*Sample) Unmarshal added in v1.6.0

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

func (*Sample) XXX_DiscardUnknown added in v1.6.0

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal added in v1.6.0

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

func (*Sample) XXX_Merge added in v1.6.0

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

func (*Sample) XXX_Size added in v1.6.0

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal added in v1.6.0

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

type SampleQueryRequest added in v1.6.0

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_pkg_querier_plan.QueryPlan `protobuf:"bytes,6,opt,name=plan,proto3,customtype=github.com/grafana/loki/pkg/querier/plan.QueryPlan" json:"plan,omitempty"`
}

func (*SampleQueryRequest) Descriptor added in v1.6.0

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

func (*SampleQueryRequest) Equal added in v1.6.0

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

func (*SampleQueryRequest) GetDeletes

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

func (*SampleQueryRequest) GetEnd added in v1.6.0

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

func (*SampleQueryRequest) GetSelector deprecated added in v1.6.0

func (m *SampleQueryRequest) GetSelector() string

Deprecated: Do not use.

func (*SampleQueryRequest) GetShards added in v1.6.0

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

func (*SampleQueryRequest) GetStart added in v1.6.0

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

func (*SampleQueryRequest) GoString added in v1.6.0

func (this *SampleQueryRequest) GoString() string

func (*SampleQueryRequest) Marshal added in v1.6.0

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

func (*SampleQueryRequest) MarshalTo added in v1.6.0

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

func (*SampleQueryRequest) MarshalToSizedBuffer

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

func (*SampleQueryRequest) ProtoMessage added in v1.6.0

func (*SampleQueryRequest) ProtoMessage()

func (*SampleQueryRequest) Reset added in v1.6.0

func (m *SampleQueryRequest) Reset()

func (*SampleQueryRequest) Size added in v1.6.0

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

func (*SampleQueryRequest) String added in v1.6.0

func (this *SampleQueryRequest) String() string

func (*SampleQueryRequest) Unmarshal added in v1.6.0

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

func (*SampleQueryRequest) XXX_DiscardUnknown added in v1.6.0

func (m *SampleQueryRequest) XXX_DiscardUnknown()

func (*SampleQueryRequest) XXX_Marshal added in v1.6.0

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

func (*SampleQueryRequest) XXX_Merge added in v1.6.0

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

func (*SampleQueryRequest) XXX_Size added in v1.6.0

func (m *SampleQueryRequest) XXX_Size() int

func (*SampleQueryRequest) XXX_Unmarshal added in v1.6.0

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

type SampleQueryResponse added in v1.6.0

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"`
}

func (*SampleQueryResponse) Descriptor added in v1.6.0

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

func (*SampleQueryResponse) Equal added in v1.6.0

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

func (*SampleQueryResponse) GetStats

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

func (*SampleQueryResponse) GoString added in v1.6.0

func (this *SampleQueryResponse) GoString() string

func (*SampleQueryResponse) Marshal added in v1.6.0

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

func (*SampleQueryResponse) MarshalTo added in v1.6.0

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

func (*SampleQueryResponse) MarshalToSizedBuffer

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

func (*SampleQueryResponse) ProtoMessage added in v1.6.0

func (*SampleQueryResponse) ProtoMessage()

func (*SampleQueryResponse) Reset added in v1.6.0

func (m *SampleQueryResponse) Reset()

func (*SampleQueryResponse) Size added in v1.6.0

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

func (*SampleQueryResponse) String added in v1.6.0

func (this *SampleQueryResponse) String() string

func (*SampleQueryResponse) Unmarshal added in v1.6.0

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

func (*SampleQueryResponse) XXX_DiscardUnknown added in v1.6.0

func (m *SampleQueryResponse) XXX_DiscardUnknown()

func (*SampleQueryResponse) XXX_Marshal added in v1.6.0

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

func (*SampleQueryResponse) XXX_Merge added in v1.6.0

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

func (*SampleQueryResponse) XXX_Size added in v1.6.0

func (m *SampleQueryResponse) XXX_Size() int

func (*SampleQueryResponse) XXX_Unmarshal added in v1.6.0

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

type Series added in v1.6.0

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 added in v1.6.0

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

func (*Series) Equal added in v1.6.0

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

func (*Series) GetLabels added in v1.6.0

func (m *Series) GetLabels() string

func (*Series) GetSamples added in v1.6.0

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

func (*Series) GetStreamHash

func (m *Series) GetStreamHash() uint64

func (*Series) GoString added in v1.6.0

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 added in v1.6.0

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

func (*Series) MarshalTo added in v1.6.0

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

func (*Series) MarshalToSizedBuffer

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

func (*Series) ProtoMessage added in v1.6.0

func (*Series) ProtoMessage()

func (*Series) Reset added in v1.6.0

func (m *Series) Reset()

func (*Series) Size added in v1.6.0

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

func (*Series) String added in v1.6.0

func (this *Series) String() string

func (Series) Swap

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

func (*Series) Unmarshal added in v1.6.0

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

func (*Series) XXX_DiscardUnknown added in v1.6.0

func (m *Series) XXX_DiscardUnknown()

func (*Series) XXX_Marshal added in v1.6.0

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

func (*Series) XXX_Merge added in v1.6.0

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

func (*Series) XXX_Size added in v1.6.0

func (m *Series) XXX_Size() int

func (*Series) XXX_Unmarshal added in v1.6.0

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

type SeriesIdentifier added in v1.3.0

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 added in v1.3.0

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

func (*SeriesIdentifier) Equal added in v1.3.0

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

func (SeriesIdentifier) Get

func (id SeriesIdentifier) Get(key string) string

func (*SeriesIdentifier) GetLabels added in v1.3.0

func (*SeriesIdentifier) GoString added in v1.3.0

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 added in v1.3.0

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

func (*SeriesIdentifier) MarshalTo added in v1.3.0

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

func (*SeriesIdentifier) MarshalToSizedBuffer added in v1.3.0

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

func (*SeriesIdentifier) ProtoMessage added in v1.3.0

func (*SeriesIdentifier) ProtoMessage()

func (*SeriesIdentifier) Reset added in v1.3.0

func (m *SeriesIdentifier) Reset()

func (*SeriesIdentifier) Size added in v1.3.0

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

func (*SeriesIdentifier) String added in v1.3.0

func (this *SeriesIdentifier) String() string

func (SeriesIdentifier) Swap

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

func (*SeriesIdentifier) Unmarshal added in v1.3.0

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

func (*SeriesIdentifier) XXX_DiscardUnknown added in v1.3.0

func (m *SeriesIdentifier) XXX_DiscardUnknown()

func (*SeriesIdentifier) XXX_Marshal added in v1.3.0

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

func (*SeriesIdentifier) XXX_Merge added in v1.3.0

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

func (*SeriesIdentifier) XXX_Size added in v1.3.0

func (m *SeriesIdentifier) XXX_Size() int

func (*SeriesIdentifier) XXX_Unmarshal added in v1.3.0

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 (*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 added in v1.3.0

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 added in v1.3.0

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

func (*SeriesRequest) Equal added in v1.3.0

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

func (*SeriesRequest) GetEnd added in v1.3.0

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

func (*SeriesRequest) GetGroups added in v1.3.0

func (m *SeriesRequest) GetGroups() []string

func (*SeriesRequest) GetShards

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

func (*SeriesRequest) GetStart added in v1.3.0

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

func (*SeriesRequest) GoString added in v1.3.0

func (this *SeriesRequest) GoString() string

func (*SeriesRequest) Marshal added in v1.3.0

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

func (*SeriesRequest) MarshalTo added in v1.3.0

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

func (*SeriesRequest) MarshalToSizedBuffer added in v1.3.0

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

func (*SeriesRequest) ProtoMessage added in v1.3.0

func (*SeriesRequest) ProtoMessage()

func (*SeriesRequest) Reset added in v1.3.0

func (m *SeriesRequest) Reset()

func (*SeriesRequest) Size added in v1.3.0

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

func (*SeriesRequest) String added in v1.3.0

func (this *SeriesRequest) String() string

func (*SeriesRequest) Unmarshal added in v1.3.0

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

func (*SeriesRequest) XXX_DiscardUnknown added in v1.3.0

func (m *SeriesRequest) XXX_DiscardUnknown()

func (*SeriesRequest) XXX_Marshal added in v1.3.0

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

func (*SeriesRequest) XXX_Merge added in v1.3.0

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

func (*SeriesRequest) XXX_Size added in v1.3.0

func (m *SeriesRequest) XXX_Size() int

func (*SeriesRequest) XXX_Unmarshal added in v1.3.0

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

type SeriesResponse added in v1.3.0

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 added in v1.3.0

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

func (*SeriesResponse) Equal added in v1.3.0

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

func (*SeriesResponse) GetSeries added in v1.3.0

func (m *SeriesResponse) GetSeries() []SeriesIdentifier

func (*SeriesResponse) GoString added in v1.3.0

func (this *SeriesResponse) GoString() string

func (*SeriesResponse) Marshal added in v1.3.0

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

func (*SeriesResponse) MarshalTo added in v1.3.0

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

func (*SeriesResponse) MarshalToSizedBuffer added in v1.3.0

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

func (*SeriesResponse) ProtoMessage added in v1.3.0

func (*SeriesResponse) ProtoMessage()

func (*SeriesResponse) Reset added in v1.3.0

func (m *SeriesResponse) Reset()

func (*SeriesResponse) Size added in v1.3.0

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

func (*SeriesResponse) String added in v1.3.0

func (this *SeriesResponse) String() string

func (*SeriesResponse) Unmarshal added in v1.3.0

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

func (*SeriesResponse) XXX_DiscardUnknown added in v1.3.0

func (m *SeriesResponse) XXX_DiscardUnknown()

func (*SeriesResponse) XXX_Marshal added in v1.3.0

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

func (*SeriesResponse) XXX_Merge added in v1.3.0

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

func (*SeriesResponse) XXX_Size added in v1.3.0

func (m *SeriesResponse) XXX_Size() int

func (*SeriesResponse) XXX_Unmarshal added in v1.3.0

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=target_bytes_per_shard,json=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"`
}

func (*ShardsResponse) Descriptor

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

func (*ShardsResponse) Equal

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

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) 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) 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) 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 added in v1.6.0

type Streams []Stream

func (Streams) Len added in v1.6.0

func (xs Streams) Len() int

func (Streams) Less added in v1.6.0

func (xs Streams) Less(i, j int) bool

func (Streams) Swap added in v1.6.0

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 added in v0.2.0

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_pkg_querier_plan.QueryPlan `protobuf:"bytes,6,opt,name=plan,proto3,customtype=github.com/grafana/loki/pkg/querier/plan.QueryPlan" json:"plan,omitempty"`
}

func (*TailRequest) Descriptor added in v0.2.0

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

func (*TailRequest) Equal added in v0.2.0

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

func (*TailRequest) GetDelayFor added in v0.2.0

func (m *TailRequest) GetDelayFor() uint32

func (*TailRequest) GetLimit added in v0.2.0

func (m *TailRequest) GetLimit() uint32

func (*TailRequest) GetQuery deprecated added in v0.2.0

func (m *TailRequest) GetQuery() string

Deprecated: Do not use.

func (*TailRequest) GetStart added in v0.2.0

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

func (*TailRequest) GoString added in v0.2.0

func (this *TailRequest) GoString() string

func (*TailRequest) Marshal added in v0.2.0

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

func (*TailRequest) MarshalTo added in v0.2.0

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

func (*TailRequest) MarshalToSizedBuffer added in v0.2.0

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

func (*TailRequest) ProtoMessage added in v0.2.0

func (*TailRequest) ProtoMessage()

func (*TailRequest) Reset added in v0.2.0

func (m *TailRequest) Reset()

func (*TailRequest) Size added in v0.2.0

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

func (*TailRequest) String added in v0.2.0

func (this *TailRequest) String() string

func (*TailRequest) Unmarshal added in v0.2.0

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

func (*TailRequest) XXX_DiscardUnknown added in v0.2.0

func (m *TailRequest) XXX_DiscardUnknown()

func (*TailRequest) XXX_Marshal added in v0.2.0

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

func (*TailRequest) XXX_Merge added in v0.2.0

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

func (*TailRequest) XXX_Size added in v0.2.0

func (m *TailRequest) XXX_Size() int

func (*TailRequest) XXX_Unmarshal added in v0.2.0

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

type TailResponse added in v0.2.0

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 added in v0.2.0

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

func (*TailResponse) Equal added in v0.2.0

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

func (*TailResponse) GetDroppedStreams added in v0.2.0

func (m *TailResponse) GetDroppedStreams() []*DroppedStream

func (*TailResponse) GoString added in v0.2.0

func (this *TailResponse) GoString() string

func (*TailResponse) Marshal added in v0.2.0

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

func (*TailResponse) MarshalTo added in v0.2.0

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

func (*TailResponse) MarshalToSizedBuffer added in v0.2.0

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

func (*TailResponse) ProtoMessage added in v0.2.0

func (*TailResponse) ProtoMessage()

func (*TailResponse) Reset added in v0.2.0

func (m *TailResponse) Reset()

func (*TailResponse) Size added in v0.2.0

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

func (*TailResponse) String added in v0.2.0

func (this *TailResponse) String() string

func (*TailResponse) Unmarshal added in v0.2.0

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

func (*TailResponse) XXX_DiscardUnknown added in v0.2.0

func (m *TailResponse) XXX_DiscardUnknown()

func (*TailResponse) XXX_Marshal added in v0.2.0

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

func (*TailResponse) XXX_Merge added in v0.2.0

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

func (*TailResponse) XXX_Size added in v0.2.0

func (m *TailResponse) XXX_Size() int

func (*TailResponse) XXX_Unmarshal added in v0.2.0

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

type TailersCountRequest added in v1.4.0

type TailersCountRequest struct {
}

func (*TailersCountRequest) Descriptor added in v1.4.0

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

func (*TailersCountRequest) Equal added in v1.4.0

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

func (*TailersCountRequest) GoString added in v1.4.0

func (this *TailersCountRequest) GoString() string

func (*TailersCountRequest) Marshal added in v1.4.0

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

func (*TailersCountRequest) MarshalTo added in v1.4.0

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

func (*TailersCountRequest) MarshalToSizedBuffer

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

func (*TailersCountRequest) ProtoMessage added in v1.4.0

func (*TailersCountRequest) ProtoMessage()

func (*TailersCountRequest) Reset added in v1.4.0

func (m *TailersCountRequest) Reset()

func (*TailersCountRequest) Size added in v1.4.0

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

func (*TailersCountRequest) String added in v1.4.0

func (this *TailersCountRequest) String() string

func (*TailersCountRequest) Unmarshal added in v1.4.0

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

func (*TailersCountRequest) XXX_DiscardUnknown added in v1.4.0

func (m *TailersCountRequest) XXX_DiscardUnknown()

func (*TailersCountRequest) XXX_Marshal added in v1.4.0

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

func (*TailersCountRequest) XXX_Merge added in v1.4.0

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

func (*TailersCountRequest) XXX_Size added in v1.4.0

func (m *TailersCountRequest) XXX_Size() int

func (*TailersCountRequest) XXX_Unmarshal added in v1.4.0

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

type TailersCountResponse added in v1.4.0

type TailersCountResponse struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
}

func (*TailersCountResponse) Descriptor added in v1.4.0

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

func (*TailersCountResponse) Equal added in v1.4.0

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

func (*TailersCountResponse) GetCount added in v1.4.0

func (m *TailersCountResponse) GetCount() uint32

func (*TailersCountResponse) GoString added in v1.4.0

func (this *TailersCountResponse) GoString() string

func (*TailersCountResponse) Marshal added in v1.4.0

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

func (*TailersCountResponse) MarshalTo added in v1.4.0

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

func (*TailersCountResponse) MarshalToSizedBuffer

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

func (*TailersCountResponse) ProtoMessage added in v1.4.0

func (*TailersCountResponse) ProtoMessage()

func (*TailersCountResponse) Reset added in v1.4.0

func (m *TailersCountResponse) Reset()

func (*TailersCountResponse) Size added in v1.4.0

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

func (*TailersCountResponse) String added in v1.4.0

func (this *TailersCountResponse) String() string

func (*TailersCountResponse) Unmarshal added in v1.4.0

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

func (*TailersCountResponse) XXX_DiscardUnknown added in v1.4.0

func (m *TailersCountResponse) XXX_DiscardUnknown()

func (*TailersCountResponse) XXX_Marshal added in v1.4.0

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

func (*TailersCountResponse) XXX_Merge added in v1.4.0

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

func (*TailersCountResponse) XXX_Size added in v1.4.0

func (m *TailersCountResponse) XXX_Size() int

func (*TailersCountResponse) XXX_Unmarshal added in v1.4.0

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

type UnimplementedIndexGatewayServer

type UnimplementedIndexGatewayServer struct {
}

UnimplementedIndexGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexGatewayServer) GetChunkRef

func (*UnimplementedIndexGatewayServer) GetSeries

func (*UnimplementedIndexGatewayServer) GetShards

func (*UnimplementedIndexGatewayServer) GetStats

func (*UnimplementedIndexGatewayServer) GetVolume

func (*UnimplementedIndexGatewayServer) LabelNamesForMetricName

func (*UnimplementedIndexGatewayServer) LabelValuesForMetricName

func (*UnimplementedIndexGatewayServer) QueryIndex

type UnimplementedQuerierServer added in v0.2.0

type UnimplementedQuerierServer struct {
}

UnimplementedQuerierServer can be embedded to have forward compatible implementations.

func (*UnimplementedQuerierServer) GetChunkIDs

func (*UnimplementedQuerierServer) GetDetectedFields

func (*UnimplementedQuerierServer) GetStats

func (*UnimplementedQuerierServer) GetVolume

func (*UnimplementedQuerierServer) Label added in v0.2.0

func (*UnimplementedQuerierServer) Query added in v0.2.0

func (*UnimplementedQuerierServer) QuerySample

func (*UnimplementedQuerierServer) Series added in v1.3.0

func (*UnimplementedQuerierServer) Tail added in v0.2.0

func (*UnimplementedQuerierServer) TailersCount

type UnimplementedStreamDataServer

type UnimplementedStreamDataServer struct {
}

UnimplementedStreamDataServer can be embedded to have forward compatible implementations.

func (*UnimplementedStreamDataServer) GetStreamRates

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"`
}

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() (res definitions.CachingOptions)

GetCachingOptions returns the caching options.

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

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

Jump to

Keyboard shortcuts

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