logproto

package
v2.5.2 Latest Latest
Warning

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

Go to latest
Published: Apr 27, 2022 License: AGPL-3.0 Imports: 29 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 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 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 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 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 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

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

func (*UnimplementedQuerierServer) Query

func (*UnimplementedQuerierServer) QuerySample

func (*UnimplementedQuerierServer) Series

func (*UnimplementedQuerierServer) Tail

func (*UnimplementedQuerierServer) TailersCount

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