logproto

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Dec 16, 2023 License: Apache-2.0 Imports: 19 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 Direction_name = map[int32]string{
	0: "FORWARD",
	1: "BACKWARD",
}
View Source
var Direction_value = map[string]int32{
	"FORWARD":  0,
	"BACKWARD": 1,
}

Functions

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

func (r *PushRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*PushRequest) MarshalTo

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

func (*QueryRequest) Descriptor

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

func (*QueryRequest) Equal

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

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

func (*QueryResponse) Descriptor

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

func (*QueryResponse) Equal

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

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

func (*SampleQueryRequest) Descriptor

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

func (*SampleQueryRequest) Equal

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

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

func (*SampleQueryResponse) Descriptor

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

func (*SampleQueryResponse) Equal

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

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

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

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

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

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

Jump to

Keyboard shortcuts

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