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 (m *MetricMetadata) GetType() MetricMetadata_MetricType

func (*MetricMetadata) GetUnit 

func (m *MetricMetadata) GetUnit() string

func (*MetricMetadata) GoString 

func (this *MetricMetadata) GoString() string

func (*MetricMetadata) Marshal 

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

func (*MetricMetadata) MarshalTo 

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

func (*MetricMetadata) MarshalToSizedBuffer 

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

func (*MetricMetadata) ProtoMessage 

func (*MetricMetadata) ProtoMessage()

func (*MetricMetadata) Reset 

func (m *MetricMetadata) Reset()

func (*MetricMetadata) Size 

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

func (*MetricMetadata) String 

func (this *MetricMetadata) String() string

func (*MetricMetadata) Unmarshal 

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

func (*MetricMetadata) XXX_DiscardUnknown 

func (m *MetricMetadata) XXX_DiscardUnknown()

func (*MetricMetadata) XXX_Marshal 

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

func (*MetricMetadata) XXX_Merge 

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

func (*MetricMetadata) XXX_Size 

func (m *MetricMetadata) XXX_Size() int

func (*MetricMetadata) XXX_Unmarshal 

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

type MetricMetadata_MetricType 

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

func (MetricMetadata_MetricType) EnumDescriptor 

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

func (MetricMetadata_MetricType) String 

func (x MetricMetadata_MetricType) String() string

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

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

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

func (*UnimplementedIngesterServer) TransferChunks(srv Ingester_TransferChunksServer) error

type UnimplementedPusherServer 

type UnimplementedPusherServer struct {
}

UnimplementedPusherServer can be embedded to have forward compatible implementations.

func (*UnimplementedPusherServer) Push 

func (*UnimplementedPusherServer) Push(ctx context.Context, req *PushRequest) (*PushResponse, error)

type UnimplementedQuerierServer 

type UnimplementedQuerierServer struct {
}

UnimplementedQuerierServer can be embedded to have forward compatible implementations.

func (*UnimplementedQuerierServer) GetChunkIDs 

func (*UnimplementedQuerierServer) GetChunkIDs(ctx context.Context, req *GetChunkIDsRequest) (*GetChunkIDsResponse, error)

func (*UnimplementedQuerierServer) Label 

func (*UnimplementedQuerierServer) Label(ctx context.Context, req *LabelRequest) (*LabelResponse, error)

func (*UnimplementedQuerierServer) Query 

func (*UnimplementedQuerierServer) Query(req *QueryRequest, srv Querier_QueryServer) error

func (*UnimplementedQuerierServer) QuerySample 

func (*UnimplementedQuerierServer) QuerySample(req *SampleQueryRequest, srv Querier_QuerySampleServer) error

func (*UnimplementedQuerierServer) Series 

func (*UnimplementedQuerierServer) Series(ctx context.Context, req *SeriesRequest) (*SeriesResponse, error)

func (*UnimplementedQuerierServer) Tail 

func (*UnimplementedQuerierServer) Tail(req *TailRequest, srv Querier_TailServer) error

func (*UnimplementedQuerierServer) TailersCount 

func (*UnimplementedQuerierServer) TailersCount(ctx context.Context, req *TailersCountRequest) (*TailersCountResponse, error)

type WriteRequest 

type WriteRequest struct {
	Timeseries              []PreallocTimeseries    `protobuf:"bytes,1,rep,name=timeseries,proto3,customtype=PreallocTimeseries" json:"timeseries"`
	Source                  WriteRequest_SourceEnum `protobuf:"varint,2,opt,name=Source,proto3,enum=logproto.WriteRequest_SourceEnum" json:"Source,omitempty"`
	Metadata                []*MetricMetadata       `protobuf:"bytes,3,rep,name=metadata,proto3" json:"metadata,omitempty"`
	SkipLabelNameValidation bool                    `` /* 138-byte string literal not displayed */
}

func ToWriteRequest 

func ToWriteRequest(lbls []labels.Labels, samples []LegacySample, metadata []*MetricMetadata, source WriteRequest_SourceEnum) *WriteRequest

ToWriteRequest converts matched slices of Labels, Samples and Metadata into a WriteRequest proto. It gets timeseries from the pool, so ReuseSlice() should be called when done.

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) Equal 

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

func (*WriteRequest) GetMetadata 

func (m *WriteRequest) GetMetadata() []*MetricMetadata

func (*WriteRequest) GetSkipLabelNameValidation 

func (m *WriteRequest) GetSkipLabelNameValidation() bool

func (*WriteRequest) GetSource 

func (m *WriteRequest) GetSource() WriteRequest_SourceEnum

func (*WriteRequest) GoString 

func (this *WriteRequest) GoString() string

func (*WriteRequest) Marshal 

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

func (*WriteRequest) MarshalTo 

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

func (*WriteRequest) MarshalToSizedBuffer 

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

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) Size 

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

func (*WriteRequest) String 

func (this *WriteRequest) String() string

func (*WriteRequest) Unmarshal 

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

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

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

func (*WriteRequest) XXX_Merge 

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

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

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

type WriteRequest_SourceEnum 

type WriteRequest_SourceEnum int32
const (
	API  WriteRequest_SourceEnum = 0
	RULE WriteRequest_SourceEnum = 1
)

func (WriteRequest_SourceEnum) EnumDescriptor 

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

func (WriteRequest_SourceEnum) String 

func (x WriteRequest_SourceEnum) String() string

type WriteResponse 

type WriteResponse struct {
}

func (*WriteResponse) Descriptor 

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

func (*WriteResponse) Equal 

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

func (*WriteResponse) GoString 

func (this *WriteResponse) GoString() string

func (*WriteResponse) Marshal 

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

func (*WriteResponse) MarshalTo 

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

func (*WriteResponse) MarshalToSizedBuffer 

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

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) Size 

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

func (*WriteResponse) String 

func (this *WriteResponse) String() string

func (*WriteResponse) Unmarshal 

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

func (*WriteResponse) XXX_DiscardUnknown 

func (m *WriteResponse) XXX_DiscardUnknown()

func (*WriteResponse) XXX_Marshal 

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

func (*WriteResponse) XXX_Merge 

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

func (*WriteResponse) XXX_Size 

func (m *WriteResponse) XXX_Size() int

func (*WriteResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.