logproto

package
v0.0.0-...-e951c9a Latest Latest
Warning

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

Go to latest
Published: Oct 6, 2022 License: AGPL-3.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 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 CopyLabels

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

Efficiently copies labels input slice. To be used in cases where input slice can be reused, but long-term copy is needed.

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 FromLabelAdaptersToLabelsWithCopy

func FromLabelAdaptersToLabelsWithCopy(input []LabelAdapter) labels.Labels

FromLabelAdaptersToLabelsWithCopy converts []LabelAdapter to labels.Labels. Do NOT use unsafe to convert between data types because this function may get in input labels whose data structure is reused.

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 RegisterIndexGatewayServer

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

func RegisterIngesterServer

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

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)

func SizeOfStdTime

func SizeOfStdTime(t time.Time) int

func StdTimeMarshalTo

func StdTimeMarshalTo(t time.Time, data []byte) (int, error)

func StdTimeUnmarshal

func StdTimeUnmarshal(t *time.Time, data []byte) error

Types

type Chunk

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

func (*Chunk) Descriptor

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

func (*Chunk) Equal

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

func (*Chunk) GetData

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

func (*Chunk) GoString

func (this *Chunk) GoString() string

func (*Chunk) Marshal

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

func (*Chunk) MarshalTo

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

func (*Chunk) MarshalToSizedBuffer

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

func (*Chunk) ProtoMessage

func (*Chunk) ProtoMessage()

func (*Chunk) Reset

func (m *Chunk) Reset()

func (*Chunk) Size

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

func (*Chunk) String

func (this *Chunk) String() string

func (*Chunk) Unmarshal

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

func (*Chunk) XXX_DiscardUnknown

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal

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

func (*Chunk) XXX_Merge

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

func (*Chunk) XXX_Size

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal

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

type ChunkRef

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

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

func (*ChunkRef) Descriptor

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

func (*ChunkRef) Equal

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

func (*ChunkRef) FingerprintModel

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

func (*ChunkRef) GetChecksum

func (m *ChunkRef) GetChecksum() uint32

func (*ChunkRef) GetFingerprint

func (m *ChunkRef) GetFingerprint() uint64

func (*ChunkRef) GetUserID

func (m *ChunkRef) GetUserID() string

func (*ChunkRef) GoString

func (this *ChunkRef) GoString() string

func (*ChunkRef) Marshal

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

func (*ChunkRef) MarshalTo

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

func (*ChunkRef) MarshalToSizedBuffer

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

func (*ChunkRef) ProtoMessage

func (*ChunkRef) ProtoMessage()

func (*ChunkRef) Reset

func (m *ChunkRef) Reset()

func (*ChunkRef) Size

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

func (*ChunkRef) String

func (this *ChunkRef) String() string

func (*ChunkRef) Unmarshal

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

func (*ChunkRef) XXX_DiscardUnknown

func (m *ChunkRef) XXX_DiscardUnknown()

func (*ChunkRef) XXX_Marshal

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

func (*ChunkRef) XXX_Merge

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

func (*ChunkRef) XXX_Size

func (m *ChunkRef) XXX_Size() int

func (*ChunkRef) XXX_Unmarshal

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

type 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 Direction

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

func (Direction) EnumDescriptor

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

func (Direction) String

func (x Direction) String() string

type DroppedStream

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

func (*DroppedStream) Descriptor

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

func (*DroppedStream) Equal

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

func (*DroppedStream) GetFrom

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

func (*DroppedStream) GetLabels

func (m *DroppedStream) GetLabels() string

func (*DroppedStream) GetTo

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

func (*DroppedStream) GoString

func (this *DroppedStream) GoString() string

func (*DroppedStream) Marshal

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

func (*DroppedStream) MarshalTo

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

func (*DroppedStream) MarshalToSizedBuffer

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

func (*DroppedStream) ProtoMessage

func (*DroppedStream) ProtoMessage()

func (*DroppedStream) Reset

func (m *DroppedStream) Reset()

func (*DroppedStream) Size

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

func (*DroppedStream) String

func (this *DroppedStream) String() string

func (*DroppedStream) Unmarshal

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

func (*DroppedStream) XXX_DiscardUnknown

func (m *DroppedStream) XXX_DiscardUnknown()

func (*DroppedStream) XXX_Marshal

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

func (*DroppedStream) XXX_Merge

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

func (*DroppedStream) XXX_Size

func (m *DroppedStream) XXX_Size() int

func (*DroppedStream) XXX_Unmarshal

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

type Entry

type Entry struct {
	Timestamp time.Time `protobuf:"bytes,1,opt,name=timestamp,proto3,stdtime" json:"ts"`
	Line      string    `protobuf:"bytes,2,opt,name=line,proto3" json:"line"`
}

Entry is a log entry with a timestamp.

func (*Entry) Equal

func (m *Entry) Equal(that interface{}) bool

func (*Entry) Marshal

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

func (*Entry) MarshalTo

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

func (*Entry) MarshalToSizedBuffer

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

func (*Entry) Size

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

func (*Entry) Unmarshal

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

type EntryAdapter

type EntryAdapter struct {
	Timestamp time.Time `protobuf:"bytes,1,opt,name=timestamp,proto3,stdtime" json:"ts"`
	Line      string    `protobuf:"bytes,2,opt,name=line,proto3" json:"line"`
}

func (*EntryAdapter) Descriptor

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

func (*EntryAdapter) Equal

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

func (*EntryAdapter) GetLine

func (m *EntryAdapter) GetLine() string

func (*EntryAdapter) GetTimestamp

func (m *EntryAdapter) GetTimestamp() time.Time

func (*EntryAdapter) GoString

func (this *EntryAdapter) GoString() string

func (*EntryAdapter) Marshal

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

func (*EntryAdapter) MarshalTo

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

func (*EntryAdapter) MarshalToSizedBuffer

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

func (*EntryAdapter) ProtoMessage

func (*EntryAdapter) ProtoMessage()

func (*EntryAdapter) Reset

func (m *EntryAdapter) Reset()

func (*EntryAdapter) Size

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

func (*EntryAdapter) String

func (this *EntryAdapter) String() string

func (*EntryAdapter) Unmarshal

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

func (*EntryAdapter) XXX_DiscardUnknown

func (m *EntryAdapter) XXX_DiscardUnknown()

func (*EntryAdapter) XXX_Marshal

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

func (*EntryAdapter) XXX_Merge

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

func (*EntryAdapter) XXX_Size

func (m *EntryAdapter) XXX_Size() int

func (*EntryAdapter) XXX_Unmarshal

func (m *EntryAdapter) 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"`
}

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

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

IndexGatewayServer is the server API for IndexGateway service.

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() int64

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() int64

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(startTime int64, endTime int64) definitions.Request

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

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

func (m *IndexStatsResponse) AddChunk(_ model.Fingerprint, chk index.ChunkMeta)

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

func (m *IndexStatsResponse) GetStreams() uint64

func (*IndexStatsResponse) GoString

func (this *IndexStatsResponse) GoString() string

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 IngesterClient

type IngesterClient interface {
	TransferChunks(ctx context.Context, opts ...grpc.CallOption) (Ingester_TransferChunksClient, error)
}

IngesterClient is the client API for Ingester service.

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

func NewIngesterClient

func NewIngesterClient(cc *grpc.ClientConn) IngesterClient

type IngesterServer

type IngesterServer interface {
	TransferChunks(Ingester_TransferChunksServer) error
}

IngesterServer is the server API for Ingester service.

type Ingester_TransferChunksClient

type Ingester_TransferChunksClient interface {
	Send(*TimeSeriesChunk) error
	CloseAndRecv() (*TransferChunksResponse, error)
	grpc.ClientStream
}

type Ingester_TransferChunksServer

type Ingester_TransferChunksServer interface {
	SendAndClose(*TransferChunksResponse) error
	Recv() (*TimeSeriesChunk, error)
	grpc.ServerStream
}

type LabelAdapter

type LabelAdapter labels.Label

LabelAdapter is a labels.Label that can be marshalled to/from protos.

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.

func (*LabelAdapter) Compare

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

Compare implements proto.Comparer.

func (*LabelAdapter) Equal

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

Equal implements proto.Equaler.

func (*LabelAdapter) Marshal

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

Marshal implements proto.Marshaller.

func (*LabelAdapter) MarshalTo

func (bs *LabelAdapter) MarshalTo(dAtA []byte) (int, error)

func (*LabelAdapter) MarshalToSizedBuffer

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

MarshalTo implements proto.Marshaller.

func (*LabelAdapter) Size

func (bs *LabelAdapter) Size() (n int)

Size implements proto.Sizer.

func (*LabelAdapter) Unmarshal

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

Unmarshal a LabelAdapter, implements proto.Unmarshaller. NB this is a copy of the autogenerated code to unmarshal a LabelPair, with the byte copying replaced with a yoloString.

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

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

func (*LabelPair) Descriptor

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

func (*LabelPair) Equal

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

func (*LabelPair) GetName

func (m *LabelPair) GetName() string

func (*LabelPair) GetValue

func (m *LabelPair) GetValue() string

func (*LabelPair) GoString

func (this *LabelPair) GoString() string

func (*LabelPair) Marshal

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

func (*LabelPair) MarshalTo

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

func (*LabelPair) MarshalToSizedBuffer

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

func (*LabelPair) ProtoMessage

func (*LabelPair) ProtoMessage()

func (*LabelPair) Reset

func (m *LabelPair) Reset()

func (*LabelPair) Size

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

func (*LabelPair) String

func (this *LabelPair) String() string

func (*LabelPair) Unmarshal

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

func (*LabelPair) XXX_DiscardUnknown

func (m *LabelPair) XXX_DiscardUnknown()

func (*LabelPair) XXX_Marshal

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

func (*LabelPair) XXX_Merge

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

func (*LabelPair) XXX_Size

func (m *LabelPair) XXX_Size() int

func (*LabelPair) XXX_Unmarshal

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

type LabelRequest

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

func (*LabelRequest) Descriptor

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

func (*LabelRequest) Equal

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

func (*LabelRequest) GetEnd

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

func (*LabelRequest) GetName

func (m *LabelRequest) GetName() string

func (*LabelRequest) GetStart

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

func (*LabelRequest) GetValues

func (m *LabelRequest) GetValues() bool

func (*LabelRequest) GoString

func (this *LabelRequest) GoString() string

func (*LabelRequest) Marshal

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

func (*LabelRequest) MarshalTo

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

func (*LabelRequest) MarshalToSizedBuffer

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

func (*LabelRequest) ProtoMessage

func (*LabelRequest) ProtoMessage()

func (*LabelRequest) Reset

func (m *LabelRequest) Reset()

func (*LabelRequest) Size

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

func (*LabelRequest) String

func (this *LabelRequest) String() string

func (*LabelRequest) Unmarshal

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

func (*LabelRequest) XXX_DiscardUnknown

func (m *LabelRequest) XXX_DiscardUnknown()

func (*LabelRequest) XXX_Marshal

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

func (*LabelRequest) XXX_Merge

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

func (*LabelRequest) XXX_Size

func (m *LabelRequest) XXX_Size() int

func (*LabelRequest) XXX_Unmarshal

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

type LabelResponse

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

func MergeLabelResponses

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

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

func (*LabelResponse) Descriptor

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

func (*LabelResponse) Equal

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

func (*LabelResponse) GetValues

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

func (*LabelResponse) GoString

func (this *LabelResponse) GoString() string

func (*LabelResponse) Marshal

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

func (*LabelResponse) MarshalTo

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

func (*LabelResponse) MarshalToSizedBuffer

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

func (*LabelResponse) ProtoMessage

func (*LabelResponse) ProtoMessage()

func (*LabelResponse) Reset

func (m *LabelResponse) Reset()

func (*LabelResponse) Size

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

func (*LabelResponse) String

func (this *LabelResponse) String() string

func (*LabelResponse) Unmarshal

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

func (*LabelResponse) XXX_DiscardUnknown

func (m *LabelResponse) XXX_DiscardUnknown()

func (*LabelResponse) XXX_Marshal

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

func (*LabelResponse) XXX_Merge

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

func (*LabelResponse) XXX_Size

func (m *LabelResponse) XXX_Size() int

func (*LabelResponse) XXX_Unmarshal

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

type 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.

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 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 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 struct {
	Streams []Stream `protobuf:"bytes,1,rep,name=streams,proto3,customtype=Stream" json:"streams"`
}

func (*PushRequest) Descriptor

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

func (*PushRequest) Equal

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

func (*PushRequest) GoString

func (this *PushRequest) GoString() string

func (*PushRequest) Marshal

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

func (*PushRequest) MarshalTo

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

func (*PushRequest) MarshalToSizedBuffer

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

func (*PushRequest) ProtoMessage

func (*PushRequest) ProtoMessage()

func (*PushRequest) Reset

func (m *PushRequest) Reset()

func (*PushRequest) Size

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

func (*PushRequest) String

func (this *PushRequest) String() string

func (*PushRequest) Unmarshal

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

func (*PushRequest) XXX_DiscardUnknown

func (m *PushRequest) XXX_DiscardUnknown()

func (*PushRequest) XXX_Marshal

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

func (*PushRequest) XXX_Merge

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

func (*PushRequest) XXX_Size

func (m *PushRequest) XXX_Size() int

func (*PushRequest) XXX_Unmarshal

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

type PushResponse

type PushResponse struct {
}

func (*PushResponse) Descriptor

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

func (*PushResponse) Equal

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

func (*PushResponse) GoString

func (this *PushResponse) GoString() string

func (*PushResponse) Marshal

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

func (*PushResponse) MarshalTo

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

func (*PushResponse) MarshalToSizedBuffer

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

func (*PushResponse) ProtoMessage

func (*PushResponse) ProtoMessage()

func (*PushResponse) Reset

func (m *PushResponse) Reset()

func (*PushResponse) Size

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

func (*PushResponse) String

func (this *PushResponse) String() string

func (*PushResponse) Unmarshal

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

func (*PushResponse) XXX_DiscardUnknown

func (m *PushResponse) XXX_DiscardUnknown()

func (*PushResponse) XXX_Marshal

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

func (*PushResponse) XXX_Merge

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

func (*PushResponse) XXX_Size

func (m *PushResponse) XXX_Size() int

func (*PushResponse) XXX_Unmarshal

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

type PusherClient

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

PusherClient is the client API for Pusher service.

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

func NewPusherClient

func NewPusherClient(cc *grpc.ClientConn) PusherClient

type PusherServer

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

PusherServer is the server API for Pusher service.

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

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

QuerierServer is the server API for Querier service.

type Querier_QueryClient

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

type Querier_QuerySampleClient

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

type Querier_QuerySampleServer

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

type Querier_QueryServer

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

type Querier_TailClient

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

type Querier_TailServer

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

type QueryIndexRequest

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

func (*QueryIndexRequest) Descriptor

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

func (*QueryIndexRequest) Equal

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

func (*QueryIndexRequest) GetQueries

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

func (*QueryIndexRequest) GoString

func (this *QueryIndexRequest) GoString() string

func (*QueryIndexRequest) Marshal

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

func (*QueryIndexRequest) MarshalTo

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

func (*QueryIndexRequest) MarshalToSizedBuffer

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

func (*QueryIndexRequest) ProtoMessage

func (*QueryIndexRequest) ProtoMessage()

func (*QueryIndexRequest) Reset

func (m *QueryIndexRequest) Reset()

func (*QueryIndexRequest) Size

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

func (*QueryIndexRequest) String

func (this *QueryIndexRequest) String() string

func (*QueryIndexRequest) Unmarshal

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

func (*QueryIndexRequest) XXX_DiscardUnknown

func (m *QueryIndexRequest) XXX_DiscardUnknown()

func (*QueryIndexRequest) XXX_Marshal

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

func (*QueryIndexRequest) XXX_Merge

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

func (*QueryIndexRequest) XXX_Size

func (m *QueryIndexRequest) XXX_Size() int

func (*QueryIndexRequest) XXX_Unmarshal

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

type QueryIndexResponse

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

func (*QueryIndexResponse) Descriptor

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

func (*QueryIndexResponse) Equal

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

func (*QueryIndexResponse) GetQueryKey

func (m *QueryIndexResponse) GetQueryKey() string

func (*QueryIndexResponse) GetRows

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

func (*QueryIndexResponse) GoString

func (this *QueryIndexResponse) GoString() string

func (*QueryIndexResponse) Marshal

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

func (*QueryIndexResponse) MarshalTo

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

func (*QueryIndexResponse) MarshalToSizedBuffer

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

func (*QueryIndexResponse) ProtoMessage

func (*QueryIndexResponse) ProtoMessage()

func (*QueryIndexResponse) Reset

func (m *QueryIndexResponse) Reset()

func (*QueryIndexResponse) Size

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

func (*QueryIndexResponse) String

func (this *QueryIndexResponse) String() string

func (*QueryIndexResponse) Unmarshal

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

func (*QueryIndexResponse) XXX_DiscardUnknown

func (m *QueryIndexResponse) XXX_DiscardUnknown()

func (*QueryIndexResponse) XXX_Marshal

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

func (*QueryIndexResponse) XXX_Merge

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

func (*QueryIndexResponse) XXX_Size

func (m *QueryIndexResponse) XXX_Size() int

func (*QueryIndexResponse) XXX_Unmarshal

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

type QueryRequest

type QueryRequest struct {
	Selector  string    `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"`
	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"`
}

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

func (m *QueryRequest) GetSelector() string

func (*QueryRequest) GetShards

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

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 []Stream       `protobuf:"bytes,1,rep,name=streams,proto3,customtype=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

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 RateLimitedStream

type RateLimitedStream struct {
	Labels string `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels,omitempty"`
}

func (*RateLimitedStream) Descriptor

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

func (*RateLimitedStream) Equal

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

func (*RateLimitedStream) GetLabels

func (m *RateLimitedStream) GetLabels() string

func (*RateLimitedStream) GoString

func (this *RateLimitedStream) GoString() string

func (*RateLimitedStream) Marshal

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

func (*RateLimitedStream) MarshalTo

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

func (*RateLimitedStream) MarshalToSizedBuffer

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

func (*RateLimitedStream) ProtoMessage

func (*RateLimitedStream) ProtoMessage()

func (*RateLimitedStream) Reset

func (m *RateLimitedStream) Reset()

func (*RateLimitedStream) Size

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

func (*RateLimitedStream) String

func (this *RateLimitedStream) String() string

func (*RateLimitedStream) Unmarshal

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

func (*RateLimitedStream) XXX_DiscardUnknown

func (m *RateLimitedStream) XXX_DiscardUnknown()

func (*RateLimitedStream) XXX_Marshal

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

func (*RateLimitedStream) XXX_Merge

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

func (*RateLimitedStream) XXX_Size

func (m *RateLimitedStream) XXX_Size() int

func (*RateLimitedStream) XXX_Unmarshal

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

type Row

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

func (*Row) Descriptor

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

func (*Row) Equal

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

func (*Row) GetRangeValue

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

func (*Row) GetValue

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

func (*Row) GoString

func (this *Row) GoString() string

func (*Row) Marshal

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

func (*Row) MarshalTo

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

func (*Row) MarshalToSizedBuffer

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

func (*Row) ProtoMessage

func (*Row) ProtoMessage()

func (*Row) Reset

func (m *Row) Reset()

func (*Row) Size

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

func (*Row) String

func (this *Row) String() string

func (*Row) Unmarshal

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

func (*Row) XXX_DiscardUnknown

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal

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

func (*Row) XXX_Merge

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

func (*Row) XXX_Size

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal

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

type Sample

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

func (*Sample) Descriptor

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

func (*Sample) Equal

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

func (*Sample) GetHash

func (m *Sample) GetHash() uint64

func (*Sample) GetTimestamp

func (m *Sample) GetTimestamp() int64

func (*Sample) GetValue

func (m *Sample) GetValue() float64

func (*Sample) GoString

func (this *Sample) GoString() string

func (*Sample) Marshal

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

func (*Sample) MarshalTo

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

func (*Sample) MarshalToSizedBuffer

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

func (*Sample) ProtoMessage

func (*Sample) ProtoMessage()

func (*Sample) Reset

func (m *Sample) Reset()

func (*Sample) Size

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

func (*Sample) String

func (this *Sample) String() string

func (*Sample) Unmarshal

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

func (*Sample) XXX_DiscardUnknown

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal

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

func (*Sample) XXX_Merge

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

func (*Sample) XXX_Size

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal

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

type SampleQueryRequest

type SampleQueryRequest struct {
	Selector string    `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"`
	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"`
}

func (*SampleQueryRequest) Descriptor

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

func (*SampleQueryRequest) Equal

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

func (*SampleQueryRequest) GetDeletes

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

func (*SampleQueryRequest) GetEnd

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

func (*SampleQueryRequest) GetSelector

func (m *SampleQueryRequest) GetSelector() string

func (*SampleQueryRequest) GetShards

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

func (*SampleQueryRequest) GetStart

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

func (*SampleQueryRequest) GoString

func (this *SampleQueryRequest) GoString() string

func (*SampleQueryRequest) Marshal

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

func (*SampleQueryRequest) MarshalTo

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

func (*SampleQueryRequest) MarshalToSizedBuffer

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

func (*SampleQueryRequest) ProtoMessage

func (*SampleQueryRequest) ProtoMessage()

func (*SampleQueryRequest) Reset

func (m *SampleQueryRequest) Reset()

func (*SampleQueryRequest) Size

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

func (*SampleQueryRequest) String

func (this *SampleQueryRequest) String() string

func (*SampleQueryRequest) Unmarshal

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

func (*SampleQueryRequest) XXX_DiscardUnknown

func (m *SampleQueryRequest) XXX_DiscardUnknown()

func (*SampleQueryRequest) XXX_Marshal

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

func (*SampleQueryRequest) XXX_Merge

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

func (*SampleQueryRequest) XXX_Size

func (m *SampleQueryRequest) XXX_Size() int

func (*SampleQueryRequest) XXX_Unmarshal

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

type SampleQueryResponse

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

func (*SampleQueryResponse) Descriptor

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

func (*SampleQueryResponse) Equal

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

func (*SampleQueryResponse) GetStats

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

func (*SampleQueryResponse) GoString

func (this *SampleQueryResponse) GoString() string

func (*SampleQueryResponse) Marshal

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

func (*SampleQueryResponse) MarshalTo

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

func (*SampleQueryResponse) MarshalToSizedBuffer

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

func (*SampleQueryResponse) ProtoMessage

func (*SampleQueryResponse) ProtoMessage()

func (*SampleQueryResponse) Reset

func (m *SampleQueryResponse) Reset()

func (*SampleQueryResponse) Size

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

func (*SampleQueryResponse) String

func (this *SampleQueryResponse) String() string

func (*SampleQueryResponse) Unmarshal

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

func (*SampleQueryResponse) XXX_DiscardUnknown

func (m *SampleQueryResponse) XXX_DiscardUnknown()

func (*SampleQueryResponse) XXX_Marshal

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

func (*SampleQueryResponse) XXX_Merge

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

func (*SampleQueryResponse) XXX_Size

func (m *SampleQueryResponse) XXX_Size() int

func (*SampleQueryResponse) XXX_Unmarshal

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

type Series

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

func (*Series) Descriptor

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

func (*Series) Equal

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

func (*Series) GetLabels

func (m *Series) GetLabels() string

func (*Series) GetSamples

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

func (*Series) GetStreamHash

func (m *Series) GetStreamHash() uint64

func (*Series) GoString

func (this *Series) GoString() string

func (Series) Len

func (s Series) Len() int

func (Series) Less

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

func (*Series) Marshal

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

func (*Series) MarshalTo

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

func (*Series) MarshalToSizedBuffer

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

func (*Series) ProtoMessage

func (*Series) ProtoMessage()

func (*Series) Reset

func (m *Series) Reset()

func (*Series) Size

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

func (*Series) String

func (this *Series) String() string

func (Series) Swap

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

func (*Series) Unmarshal

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

func (*Series) XXX_DiscardUnknown

func (m *Series) XXX_DiscardUnknown()

func (*Series) XXX_Marshal

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

func (*Series) XXX_Merge

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

func (*Series) XXX_Size

func (m *Series) XXX_Size() int

func (*Series) XXX_Unmarshal

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

type SeriesIdentifier

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

func (*SeriesIdentifier) Descriptor

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

func (*SeriesIdentifier) Equal

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

func (*SeriesIdentifier) GetLabels

func (m *SeriesIdentifier) GetLabels() map[string]string

func (*SeriesIdentifier) GoString

func (this *SeriesIdentifier) GoString() string

func (*SeriesIdentifier) Marshal

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

func (*SeriesIdentifier) MarshalTo

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

func (*SeriesIdentifier) MarshalToSizedBuffer

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

func (*SeriesIdentifier) ProtoMessage

func (*SeriesIdentifier) ProtoMessage()

func (*SeriesIdentifier) Reset

func (m *SeriesIdentifier) Reset()

func (*SeriesIdentifier) Size

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

func (*SeriesIdentifier) String

func (this *SeriesIdentifier) String() string

func (*SeriesIdentifier) Unmarshal

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

func (*SeriesIdentifier) XXX_DiscardUnknown

func (m *SeriesIdentifier) XXX_DiscardUnknown()

func (*SeriesIdentifier) XXX_Marshal

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

func (*SeriesIdentifier) XXX_Merge

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

func (*SeriesIdentifier) XXX_Size

func (m *SeriesIdentifier) XXX_Size() int

func (*SeriesIdentifier) XXX_Unmarshal

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

type SeriesIdentifiers

type SeriesIdentifiers []SeriesIdentifier

Note, this is not very efficient and use should be minimized as it requires label construction on each comparison

func (SeriesIdentifiers) Len

func (ids SeriesIdentifiers) Len() int

func (SeriesIdentifiers) Less

func (ids SeriesIdentifiers) Less(i, j int) bool

func (SeriesIdentifiers) Swap

func (ids SeriesIdentifiers) Swap(i, j int)

type SeriesRequest

type SeriesRequest struct {
	Start  time.Time `protobuf:"bytes,1,opt,name=start,proto3,stdtime" json:"start"`
	End    time.Time `protobuf:"bytes,2,opt,name=end,proto3,stdtime" json:"end"`
	Groups []string  `protobuf:"bytes,3,rep,name=groups,proto3" json:"groups,omitempty"`
	Shards []string  `protobuf:"bytes,4,rep,name=shards,proto3" json:"shards,omitempty"`
}

func (*SeriesRequest) Descriptor

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

func (*SeriesRequest) Equal

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

func (*SeriesRequest) GetEnd

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

func (*SeriesRequest) GetGroups

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

func (*SeriesRequest) GetShards

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

func (*SeriesRequest) GetStart

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

func (*SeriesRequest) GoString

func (this *SeriesRequest) GoString() string

func (*SeriesRequest) Marshal

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

func (*SeriesRequest) MarshalTo

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

func (*SeriesRequest) MarshalToSizedBuffer

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

func (*SeriesRequest) ProtoMessage

func (*SeriesRequest) ProtoMessage()

func (*SeriesRequest) Reset

func (m *SeriesRequest) Reset()

func (*SeriesRequest) Size

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

func (*SeriesRequest) String

func (this *SeriesRequest) String() string

func (*SeriesRequest) Unmarshal

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

func (*SeriesRequest) XXX_DiscardUnknown

func (m *SeriesRequest) XXX_DiscardUnknown()

func (*SeriesRequest) XXX_Marshal

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

func (*SeriesRequest) XXX_Merge

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

func (*SeriesRequest) XXX_Size

func (m *SeriesRequest) XXX_Size() int

func (*SeriesRequest) XXX_Unmarshal

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

type SeriesResponse

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

func MergeSeriesResponses

func MergeSeriesResponses(responses []*SeriesResponse) (*SeriesResponse, error)

Combine unique label sets from multiple SeriesResponse and return a single SeriesResponse.

func (*SeriesResponse) Descriptor

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

func (*SeriesResponse) Equal

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

func (*SeriesResponse) GetSeries

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

func (*SeriesResponse) GoString

func (this *SeriesResponse) GoString() string

func (*SeriesResponse) Marshal

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

func (*SeriesResponse) MarshalTo

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

func (*SeriesResponse) MarshalToSizedBuffer

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

func (*SeriesResponse) ProtoMessage

func (*SeriesResponse) ProtoMessage()

func (*SeriesResponse) Reset

func (m *SeriesResponse) Reset()

func (*SeriesResponse) Size

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

func (*SeriesResponse) String

func (this *SeriesResponse) String() string

func (*SeriesResponse) Unmarshal

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

func (*SeriesResponse) XXX_DiscardUnknown

func (m *SeriesResponse) XXX_DiscardUnknown()

func (*SeriesResponse) XXX_Marshal

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

func (*SeriesResponse) XXX_Merge

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

func (*SeriesResponse) XXX_Size

func (m *SeriesResponse) XXX_Size() int

func (*SeriesResponse) XXX_Unmarshal

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

type Stream

type Stream struct {
	Labels  string  `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels"`
	Entries []Entry `protobuf:"bytes,2,rep,name=entries,proto3,customtype=EntryAdapter" json:"entries"`
	Hash    uint64  `protobuf:"varint,3,opt,name=hash,proto3" json:"-"`
}

Stream contains a unique labels set as a string and a set of entries for it. We are not using the proto generated version but this custom one so that we can improve serialization see benchmark.

func (*Stream) Equal

func (m *Stream) Equal(that interface{}) bool

func (*Stream) Marshal

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

func (*Stream) MarshalTo

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

func (*Stream) MarshalToSizedBuffer

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

func (*Stream) Size

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

func (*Stream) Unmarshal

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

type StreamAdapter

type StreamAdapter struct {
	Labels  string         `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels"`
	Entries []EntryAdapter `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries"`
	// hash contains the original hash of the stream.
	Hash uint64 `protobuf:"varint,3,opt,name=hash,proto3" json:"-"`
}

func (*StreamAdapter) Descriptor

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

func (*StreamAdapter) Equal

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

func (*StreamAdapter) GetEntries

func (m *StreamAdapter) GetEntries() []EntryAdapter

func (*StreamAdapter) GetHash

func (m *StreamAdapter) GetHash() uint64

func (*StreamAdapter) GetLabels

func (m *StreamAdapter) GetLabels() string

func (*StreamAdapter) GoString

func (this *StreamAdapter) GoString() string

func (*StreamAdapter) Marshal

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

func (*StreamAdapter) MarshalTo

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

func (*StreamAdapter) MarshalToSizedBuffer

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

func (*StreamAdapter) ProtoMessage

func (*StreamAdapter) ProtoMessage()

func (*StreamAdapter) Reset

func (m *StreamAdapter) Reset()

func (*StreamAdapter) Size

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

func (*StreamAdapter) String

func (this *StreamAdapter) String() string

func (*StreamAdapter) Unmarshal

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

func (*StreamAdapter) XXX_DiscardUnknown

func (m *StreamAdapter) XXX_DiscardUnknown()

func (*StreamAdapter) XXX_Marshal

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

func (*StreamAdapter) XXX_Merge

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

func (*StreamAdapter) XXX_Size

func (m *StreamAdapter) XXX_Size() int

func (*StreamAdapter) XXX_Unmarshal

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

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

func (*StreamRate) Descriptor

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

func (*StreamRate) Equal

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

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

func (this *StreamRate) GoString() string

func (*StreamRate) Marshal

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

func (*StreamRate) MarshalTo

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

func (*StreamRate) MarshalToSizedBuffer

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

func (*StreamRate) ProtoMessage

func (*StreamRate) ProtoMessage()

func (*StreamRate) Reset

func (m *StreamRate) Reset()

func (*StreamRate) Size

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

func (*StreamRate) String

func (this *StreamRate) String() string

func (*StreamRate) Unmarshal

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

func (*StreamRate) XXX_DiscardUnknown

func (m *StreamRate) XXX_DiscardUnknown()

func (*StreamRate) XXX_Marshal

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

func (*StreamRate) XXX_Merge

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

func (*StreamRate) XXX_Size

func (m *StreamRate) XXX_Size() int

func (*StreamRate) XXX_Unmarshal

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

type StreamRatesRequest

type StreamRatesRequest struct {
}

func (*StreamRatesRequest) Descriptor

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

func (*StreamRatesRequest) Equal

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

func (*StreamRatesRequest) GoString

func (this *StreamRatesRequest) GoString() string

func (*StreamRatesRequest) Marshal

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

func (*StreamRatesRequest) MarshalTo

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

func (*StreamRatesRequest) MarshalToSizedBuffer

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

func (*StreamRatesRequest) ProtoMessage

func (*StreamRatesRequest) ProtoMessage()

func (*StreamRatesRequest) Reset

func (m *StreamRatesRequest) Reset()

func (*StreamRatesRequest) Size

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

func (*StreamRatesRequest) String

func (this *StreamRatesRequest) String() string

func (*StreamRatesRequest) Unmarshal

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

func (*StreamRatesRequest) XXX_DiscardUnknown

func (m *StreamRatesRequest) XXX_DiscardUnknown()

func (*StreamRatesRequest) XXX_Marshal

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

func (*StreamRatesRequest) XXX_Merge

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

func (*StreamRatesRequest) XXX_Size

func (m *StreamRatesRequest) XXX_Size() int

func (*StreamRatesRequest) XXX_Unmarshal

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

type StreamRatesResponse

type StreamRatesResponse struct {
	StreamRates []*StreamRate `protobuf:"bytes,1,rep,name=streamRates,proto3" json:"streamRates,omitempty"`
}

func (*StreamRatesResponse) Descriptor

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

func (*StreamRatesResponse) Equal

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

func (*StreamRatesResponse) GetStreamRates

func (m *StreamRatesResponse) GetStreamRates() []*StreamRate

func (*StreamRatesResponse) GoString

func (this *StreamRatesResponse) GoString() string

func (*StreamRatesResponse) Marshal

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

func (*StreamRatesResponse) MarshalTo

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

func (*StreamRatesResponse) MarshalToSizedBuffer

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

func (*StreamRatesResponse) ProtoMessage

func (*StreamRatesResponse) ProtoMessage()

func (*StreamRatesResponse) Reset

func (m *StreamRatesResponse) Reset()

func (*StreamRatesResponse) Size

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

func (*StreamRatesResponse) String

func (this *StreamRatesResponse) String() string

func (*StreamRatesResponse) Unmarshal

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

func (*StreamRatesResponse) XXX_DiscardUnknown

func (m *StreamRatesResponse) XXX_DiscardUnknown()

func (*StreamRatesResponse) XXX_Marshal

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

func (*StreamRatesResponse) XXX_Merge

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

func (*StreamRatesResponse) XXX_Size

func (m *StreamRatesResponse) XXX_Size() int

func (*StreamRatesResponse) XXX_Unmarshal

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

type Streams

type Streams []Stream

func (Streams) Len

func (xs Streams) Len() int

func (Streams) Less

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

func (Streams) Swap

func (xs Streams) Swap(i, j int)

type TailRequest

type TailRequest struct {
	Query    string    `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	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"`
}

func (*TailRequest) Descriptor

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

func (*TailRequest) Equal

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

func (*TailRequest) GetDelayFor

func (m *TailRequest) GetDelayFor() uint32

func (*TailRequest) GetLimit

func (m *TailRequest) GetLimit() uint32

func (*TailRequest) GetQuery

func (m *TailRequest) GetQuery() string

func (*TailRequest) GetStart

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

func (*TailRequest) GoString

func (this *TailRequest) GoString() string

func (*TailRequest) Marshal

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

func (*TailRequest) MarshalTo

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

func (*TailRequest) MarshalToSizedBuffer

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

func (*TailRequest) ProtoMessage

func (*TailRequest) ProtoMessage()

func (*TailRequest) Reset

func (m *TailRequest) Reset()

func (*TailRequest) Size

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

func (*TailRequest) String

func (this *TailRequest) String() string

func (*TailRequest) Unmarshal

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

func (*TailRequest) XXX_DiscardUnknown

func (m *TailRequest) XXX_DiscardUnknown()

func (*TailRequest) XXX_Marshal

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

func (*TailRequest) XXX_Merge

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

func (*TailRequest) XXX_Size

func (m *TailRequest) XXX_Size() int

func (*TailRequest) XXX_Unmarshal

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

type TailResponse

type TailResponse struct {
	Stream         *Stream          `protobuf:"bytes,1,opt,name=stream,proto3,customtype=Stream" json:"stream,omitempty"`
	DroppedStreams []*DroppedStream `protobuf:"bytes,2,rep,name=droppedStreams,proto3" json:"droppedStreams,omitempty"`
}

func (*TailResponse) Descriptor

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

func (*TailResponse) Equal

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

func (*TailResponse) GetDroppedStreams

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

func (*TailResponse) GoString

func (this *TailResponse) GoString() string

func (*TailResponse) Marshal

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

func (*TailResponse) MarshalTo

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

func (*TailResponse) MarshalToSizedBuffer

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

func (*TailResponse) ProtoMessage

func (*TailResponse) ProtoMessage()

func (*TailResponse) Reset

func (m *TailResponse) Reset()

func (*TailResponse) Size

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

func (*TailResponse) String

func (this *TailResponse) String() string

func (*TailResponse) Unmarshal

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

func (*TailResponse) XXX_DiscardUnknown

func (m *TailResponse) XXX_DiscardUnknown()

func (*TailResponse) XXX_Marshal

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

func (*TailResponse) XXX_Merge

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

func (*TailResponse) XXX_Size

func (m *TailResponse) XXX_Size() int

func (*TailResponse) XXX_Unmarshal

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

type TailersCountRequest

type TailersCountRequest struct {
}

func (*TailersCountRequest) Descriptor

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

func (*TailersCountRequest) Equal

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

func (*TailersCountRequest) GoString

func (this *TailersCountRequest) GoString() string

func (*TailersCountRequest) Marshal

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

func (*TailersCountRequest) MarshalTo

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

func (*TailersCountRequest) MarshalToSizedBuffer

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

func (*TailersCountRequest) ProtoMessage

func (*TailersCountRequest) ProtoMessage()

func (*TailersCountRequest) Reset

func (m *TailersCountRequest) Reset()

func (*TailersCountRequest) Size

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

func (*TailersCountRequest) String

func (this *TailersCountRequest) String() string

func (*TailersCountRequest) Unmarshal

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

func (*TailersCountRequest) XXX_DiscardUnknown

func (m *TailersCountRequest) XXX_DiscardUnknown()

func (*TailersCountRequest) XXX_Marshal

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

func (*TailersCountRequest) XXX_Merge

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

func (*TailersCountRequest) XXX_Size

func (m *TailersCountRequest) XXX_Size() int

func (*TailersCountRequest) XXX_Unmarshal

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

type TailersCountResponse

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

func (*TailersCountResponse) Descriptor

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

func (*TailersCountResponse) Equal

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

func (*TailersCountResponse) GetCount

func (m *TailersCountResponse) GetCount() uint32

func (*TailersCountResponse) GoString

func (this *TailersCountResponse) GoString() string

func (*TailersCountResponse) Marshal

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

func (*TailersCountResponse) MarshalTo

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

func (*TailersCountResponse) MarshalToSizedBuffer

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

func (*TailersCountResponse) ProtoMessage

func (*TailersCountResponse) ProtoMessage()

func (*TailersCountResponse) Reset

func (m *TailersCountResponse) Reset()

func (*TailersCountResponse) Size

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

func (*TailersCountResponse) String

func (this *TailersCountResponse) String() string

func (*TailersCountResponse) Unmarshal

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

func (*TailersCountResponse) XXX_DiscardUnknown

func (m *TailersCountResponse) XXX_DiscardUnknown()

func (*TailersCountResponse) XXX_Marshal

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

func (*TailersCountResponse) XXX_Merge

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

func (*TailersCountResponse) XXX_Size

func (m *TailersCountResponse) XXX_Size() int

func (*TailersCountResponse) XXX_Unmarshal

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

type TimeSeries

type TimeSeries struct {
	Labels []LabelAdapter `protobuf:"bytes,1,rep,name=labels,proto3,customtype=LabelAdapter" json:"labels"`
	// Sorted by time, oldest sample first.
	Samples []LegacySample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples"`
}

func TimeseriesFromPool

func TimeseriesFromPool() *TimeSeries

TimeseriesFromPool retrieves a pointer to a TimeSeries from a sync.Pool. ReuseTimeseries should be called once done, unless ReuseSlice was called on the slice that contains this TimeSeries.

func (*TimeSeries) Descriptor

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

func (*TimeSeries) Equal

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

func (*TimeSeries) GetSamples

func (m *TimeSeries) GetSamples() []LegacySample

func (*TimeSeries) GoString

func (this *TimeSeries) GoString() string

func (*TimeSeries) Marshal

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

func (*TimeSeries) MarshalTo

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

func (*TimeSeries) MarshalToSizedBuffer

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

func (*TimeSeries) ProtoMessage

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) Reset

func (m *TimeSeries) Reset()

func (*TimeSeries) Size

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

func (*TimeSeries) String

func (this *TimeSeries) String() string

func (*TimeSeries) Unmarshal

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

func (*TimeSeries) XXX_DiscardUnknown

func (m *TimeSeries) XXX_DiscardUnknown()

func (*TimeSeries) XXX_Marshal

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

func (*TimeSeries) XXX_Merge

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

func (*TimeSeries) XXX_Size

func (m *TimeSeries) XXX_Size() int

func (*TimeSeries) XXX_Unmarshal

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

type TimeSeriesChunk

type TimeSeriesChunk struct {
	FromIngesterId string       `protobuf:"bytes,1,opt,name=from_ingester_id,json=fromIngesterId,proto3" json:"from_ingester_id,omitempty"`
	UserId         string       `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Labels         []*LabelPair `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"`
	Chunks         []*Chunk     `protobuf:"bytes,4,rep,name=chunks,proto3" json:"chunks,omitempty"`
}

func (*TimeSeriesChunk) Descriptor

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

func (*TimeSeriesChunk) Equal

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

func (*TimeSeriesChunk) GetChunks

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

func (*TimeSeriesChunk) GetFromIngesterId

func (m *TimeSeriesChunk) GetFromIngesterId() string

func (*TimeSeriesChunk) GetLabels

func (m *TimeSeriesChunk) GetLabels() []*LabelPair

func (*TimeSeriesChunk) GetUserId

func (m *TimeSeriesChunk) GetUserId() string

func (*TimeSeriesChunk) GoString

func (this *TimeSeriesChunk) GoString() string

func (*TimeSeriesChunk) Marshal

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

func (*TimeSeriesChunk) MarshalTo

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

func (*TimeSeriesChunk) MarshalToSizedBuffer

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

func (*TimeSeriesChunk) ProtoMessage

func (*TimeSeriesChunk) ProtoMessage()

func (*TimeSeriesChunk) Reset

func (m *TimeSeriesChunk) Reset()

func (*TimeSeriesChunk) Size

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

func (*TimeSeriesChunk) String

func (this *TimeSeriesChunk) String() string

func (*TimeSeriesChunk) Unmarshal

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

func (*TimeSeriesChunk) XXX_DiscardUnknown

func (m *TimeSeriesChunk) XXX_DiscardUnknown()

func (*TimeSeriesChunk) XXX_Marshal

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

func (*TimeSeriesChunk) XXX_Merge

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

func (*TimeSeriesChunk) XXX_Size

func (m *TimeSeriesChunk) XXX_Size() int

func (*TimeSeriesChunk) XXX_Unmarshal

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

type TransferChunksResponse

type TransferChunksResponse struct {
}

func (*TransferChunksResponse) Descriptor

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

func (*TransferChunksResponse) Equal

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

func (*TransferChunksResponse) GoString

func (this *TransferChunksResponse) GoString() string

func (*TransferChunksResponse) Marshal

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

func (*TransferChunksResponse) MarshalTo

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

func (*TransferChunksResponse) MarshalToSizedBuffer

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

func (*TransferChunksResponse) ProtoMessage

func (*TransferChunksResponse) ProtoMessage()

func (*TransferChunksResponse) Reset

func (m *TransferChunksResponse) Reset()

func (*TransferChunksResponse) Size

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

func (*TransferChunksResponse) String

func (this *TransferChunksResponse) String() string

func (*TransferChunksResponse) Unmarshal

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

func (*TransferChunksResponse) XXX_DiscardUnknown

func (m *TransferChunksResponse) XXX_DiscardUnknown()

func (*TransferChunksResponse) XXX_Marshal

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

func (*TransferChunksResponse) XXX_Merge

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

func (*TransferChunksResponse) XXX_Size

func (m *TransferChunksResponse) XXX_Size() int

func (*TransferChunksResponse) XXX_Unmarshal

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

type UnimplementedIndexGatewayServer

type UnimplementedIndexGatewayServer struct {
}

UnimplementedIndexGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexGatewayServer) GetChunkRef

func (*UnimplementedIndexGatewayServer) GetSeries

func (*UnimplementedIndexGatewayServer) GetStats

func (*UnimplementedIndexGatewayServer) LabelNamesForMetricName

func (*UnimplementedIndexGatewayServer) LabelValuesForMetricName

func (*UnimplementedIndexGatewayServer) QueryIndex

type UnimplementedIngesterServer

type UnimplementedIngesterServer struct {
}

UnimplementedIngesterServer can be embedded to have forward compatible implementations.

func (*UnimplementedIngesterServer) TransferChunks

type UnimplementedPusherServer

type UnimplementedPusherServer struct {
}

UnimplementedPusherServer can be embedded to have forward compatible implementations.

func (*UnimplementedPusherServer) Push

type UnimplementedQuerierServer

type UnimplementedQuerierServer struct {
}

UnimplementedQuerierServer can be embedded to have forward compatible implementations.

func (*UnimplementedQuerierServer) GetChunkIDs

func (*UnimplementedQuerierServer) GetStats

func (*UnimplementedQuerierServer) Label

func (*UnimplementedQuerierServer) Query

func (*UnimplementedQuerierServer) QuerySample

func (*UnimplementedQuerierServer) Series

func (*UnimplementedQuerierServer) Tail

func (*UnimplementedQuerierServer) TailersCount

type UnimplementedStreamDataServer

type UnimplementedStreamDataServer struct {
}

UnimplementedStreamDataServer can be embedded to have forward compatible implementations.

func (*UnimplementedStreamDataServer) GetStreamRates

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