logproto

package
v1.6.0 Latest Latest
Warning

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

Go to latest
Published: Aug 13, 2020 License: Apache-2.0 Imports: 17 Imported by: 375

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

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

func SizeOfStdTime(t time.Time) int

func StdTimeMarshalTo added in v1.5.0

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

func StdTimeUnmarshal added in v1.5.0

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

Types

type Chunk added in v0.2.0

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

func (*Chunk) Descriptor added in v0.2.0

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

func (*Chunk) Equal added in v0.2.0

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

func (*Chunk) GetData added in v0.2.0

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

func (*Chunk) GoString added in v0.2.0

func (this *Chunk) GoString() string

func (*Chunk) Marshal added in v0.2.0

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

func (*Chunk) MarshalTo added in v0.2.0

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

func (*Chunk) ProtoMessage added in v0.2.0

func (*Chunk) ProtoMessage()

func (*Chunk) Reset added in v0.2.0

func (m *Chunk) Reset()

func (*Chunk) Size added in v0.2.0

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

func (*Chunk) String added in v0.2.0

func (this *Chunk) String() string

func (*Chunk) Unmarshal added in v0.2.0

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

func (*Chunk) XXX_DiscardUnknown added in v0.2.0

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal added in v0.2.0

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

func (*Chunk) XXX_Merge added in v0.2.0

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

func (*Chunk) XXX_Size added in v0.2.0

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal added in v0.2.0

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

type Direction

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

func (Direction) EnumDescriptor

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

func (Direction) String

func (x Direction) String() string

type DroppedStream added in v0.2.0

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

func (*DroppedStream) Descriptor added in v0.2.0

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

func (*DroppedStream) Equal added in v0.2.0

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

func (*DroppedStream) GetFrom added in v0.2.0

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

func (*DroppedStream) GetLabels added in v0.2.0

func (m *DroppedStream) GetLabels() string

func (*DroppedStream) GetTo added in v0.2.0

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

func (*DroppedStream) GoString added in v0.2.0

func (this *DroppedStream) GoString() string

func (*DroppedStream) Marshal added in v0.2.0

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

func (*DroppedStream) MarshalTo added in v0.2.0

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

func (*DroppedStream) ProtoMessage added in v0.2.0

func (*DroppedStream) ProtoMessage()

func (*DroppedStream) Reset added in v0.2.0

func (m *DroppedStream) Reset()

func (*DroppedStream) Size added in v0.2.0

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

func (*DroppedStream) String added in v0.2.0

func (this *DroppedStream) String() string

func (*DroppedStream) Unmarshal added in v0.2.0

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

func (*DroppedStream) XXX_DiscardUnknown added in v0.2.0

func (m *DroppedStream) XXX_DiscardUnknown()

func (*DroppedStream) XXX_Marshal added in v0.2.0

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

func (*DroppedStream) XXX_Merge added in v0.2.0

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

func (*DroppedStream) XXX_Size added in v0.2.0

func (m *DroppedStream) XXX_Size() int

func (*DroppedStream) XXX_Unmarshal added in v0.2.0

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

type Entry

type Entry 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 added in v1.5.0

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

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

func (*EntryAdapter) Equal added in v1.5.0

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

func (*EntryAdapter) GetLine added in v1.5.0

func (m *EntryAdapter) GetLine() string

func (*EntryAdapter) GetTimestamp added in v1.5.0

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

func (*EntryAdapter) GoString added in v1.5.0

func (this *EntryAdapter) GoString() string

func (*EntryAdapter) Marshal added in v1.5.0

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

func (*EntryAdapter) MarshalTo added in v1.5.0

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

func (*EntryAdapter) ProtoMessage added in v1.5.0

func (*EntryAdapter) ProtoMessage()

func (*EntryAdapter) Reset added in v1.5.0

func (m *EntryAdapter) Reset()

func (*EntryAdapter) Size added in v1.5.0

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

func (*EntryAdapter) String added in v1.5.0

func (this *EntryAdapter) String() string

func (*EntryAdapter) Unmarshal added in v1.5.0

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

func (*EntryAdapter) XXX_DiscardUnknown added in v1.5.0

func (m *EntryAdapter) XXX_DiscardUnknown()

func (*EntryAdapter) XXX_Marshal added in v1.5.0

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

func (*EntryAdapter) XXX_Merge added in v1.5.0

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

func (*EntryAdapter) XXX_Size added in v1.5.0

func (m *EntryAdapter) XXX_Size() int

func (*EntryAdapter) XXX_Unmarshal added in v1.5.0

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

type IngesterClient added in v0.2.0

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

func NewIngesterClient(cc *grpc.ClientConn) IngesterClient

type IngesterServer added in v0.2.0

type IngesterServer interface {
	TransferChunks(Ingester_TransferChunksServer) error
}

IngesterServer is the server API for Ingester service.

type Ingester_TransferChunksClient added in v0.2.0

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

type Ingester_TransferChunksServer added in v0.2.0

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

type LabelPair added in v0.2.0

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

func (*LabelPair) Descriptor added in v0.2.0

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

func (*LabelPair) Equal added in v0.2.0

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

func (*LabelPair) GetName added in v0.2.0

func (m *LabelPair) GetName() string

func (*LabelPair) GetValue added in v0.2.0

func (m *LabelPair) GetValue() string

func (*LabelPair) GoString added in v0.2.0

func (this *LabelPair) GoString() string

func (*LabelPair) Marshal added in v0.2.0

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

func (*LabelPair) MarshalTo added in v0.2.0

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

func (*LabelPair) ProtoMessage added in v0.2.0

func (*LabelPair) ProtoMessage()

func (*LabelPair) Reset added in v0.2.0

func (m *LabelPair) Reset()

func (*LabelPair) Size added in v0.2.0

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

func (*LabelPair) String added in v0.2.0

func (this *LabelPair) String() string

func (*LabelPair) Unmarshal added in v0.2.0

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

func (*LabelPair) XXX_DiscardUnknown added in v0.2.0

func (m *LabelPair) XXX_DiscardUnknown()

func (*LabelPair) XXX_Marshal added in v0.2.0

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

func (*LabelPair) XXX_Merge added in v0.2.0

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

func (*LabelPair) XXX_Size added in v0.2.0

func (m *LabelPair) XXX_Size() int

func (*LabelPair) XXX_Unmarshal added in v0.2.0

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

type LabelRequest

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

func (*LabelRequest) Descriptor

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

func (*LabelRequest) Equal

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

func (*LabelRequest) GetEnd added in v0.2.0

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

func (*LabelRequest) GetName

func (m *LabelRequest) GetName() string

func (*LabelRequest) GetStart added in v0.2.0

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

func (*LabelRequest) GetValues

func (m *LabelRequest) GetValues() bool

func (*LabelRequest) GoString

func (this *LabelRequest) GoString() string

func (*LabelRequest) Marshal

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

func (*LabelRequest) MarshalTo

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

func (*LabelRequest) 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) 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 QuerierServer

QuerierServer is the server API for Querier service.

type Querier_QueryClient

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

type Querier_QuerySampleClient added in v1.6.0

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

type Querier_QuerySampleServer added in v1.6.0

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

type Querier_QueryServer

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

type Querier_TailClient added in v0.2.0

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

type Querier_TailServer added in v0.2.0

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

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

func (m *QueryRequest) GetSelector() string

func (*QueryRequest) GetShards added in v1.6.0

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

func (*QueryRequest) GetStart

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

func (*QueryRequest) GoString

func (this *QueryRequest) GoString() string

func (*QueryRequest) Marshal

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

func (*QueryRequest) MarshalTo

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

func (*QueryRequest) 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 added in v1.6.0

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

func (*Sample) Descriptor added in v1.6.0

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

func (*Sample) Equal added in v1.6.0

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

func (*Sample) GetHash added in v1.6.0

func (m *Sample) GetHash() uint64

func (*Sample) GetTimestamp added in v1.6.0

func (m *Sample) GetTimestamp() int64

func (*Sample) GetValue added in v1.6.0

func (m *Sample) GetValue() float64

func (*Sample) GoString added in v1.6.0

func (this *Sample) GoString() string

func (*Sample) Marshal added in v1.6.0

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

func (*Sample) MarshalTo added in v1.6.0

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

func (*Sample) ProtoMessage added in v1.6.0

func (*Sample) ProtoMessage()

func (*Sample) Reset added in v1.6.0

func (m *Sample) Reset()

func (*Sample) Size added in v1.6.0

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

func (*Sample) String added in v1.6.0

func (this *Sample) String() string

func (*Sample) Unmarshal added in v1.6.0

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

func (*Sample) XXX_DiscardUnknown added in v1.6.0

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal added in v1.6.0

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

func (*Sample) XXX_Merge added in v1.6.0

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

func (*Sample) XXX_Size added in v1.6.0

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal added in v1.6.0

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

type SampleQueryRequest added in v1.6.0

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

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

func (*SampleQueryRequest) Equal added in v1.6.0

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

func (*SampleQueryRequest) GetEnd added in v1.6.0

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

func (*SampleQueryRequest) GetSelector added in v1.6.0

func (m *SampleQueryRequest) GetSelector() string

func (*SampleQueryRequest) GetShards added in v1.6.0

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

func (*SampleQueryRequest) GetStart added in v1.6.0

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

func (*SampleQueryRequest) GoString added in v1.6.0

func (this *SampleQueryRequest) GoString() string

func (*SampleQueryRequest) Marshal added in v1.6.0

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

func (*SampleQueryRequest) MarshalTo added in v1.6.0

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

func (*SampleQueryRequest) ProtoMessage added in v1.6.0

func (*SampleQueryRequest) ProtoMessage()

func (*SampleQueryRequest) Reset added in v1.6.0

func (m *SampleQueryRequest) Reset()

func (*SampleQueryRequest) Size added in v1.6.0

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

func (*SampleQueryRequest) String added in v1.6.0

func (this *SampleQueryRequest) String() string

func (*SampleQueryRequest) Unmarshal added in v1.6.0

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

func (*SampleQueryRequest) XXX_DiscardUnknown added in v1.6.0

func (m *SampleQueryRequest) XXX_DiscardUnknown()

func (*SampleQueryRequest) XXX_Marshal added in v1.6.0

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

func (*SampleQueryRequest) XXX_Merge added in v1.6.0

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

func (*SampleQueryRequest) XXX_Size added in v1.6.0

func (m *SampleQueryRequest) XXX_Size() int

func (*SampleQueryRequest) XXX_Unmarshal added in v1.6.0

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

type SampleQueryResponse added in v1.6.0

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

func (*SampleQueryResponse) Descriptor added in v1.6.0

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

func (*SampleQueryResponse) Equal added in v1.6.0

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

func (*SampleQueryResponse) GoString added in v1.6.0

func (this *SampleQueryResponse) GoString() string

func (*SampleQueryResponse) Marshal added in v1.6.0

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

func (*SampleQueryResponse) MarshalTo added in v1.6.0

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

func (*SampleQueryResponse) ProtoMessage added in v1.6.0

func (*SampleQueryResponse) ProtoMessage()

func (*SampleQueryResponse) Reset added in v1.6.0

func (m *SampleQueryResponse) Reset()

func (*SampleQueryResponse) Size added in v1.6.0

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

func (*SampleQueryResponse) String added in v1.6.0

func (this *SampleQueryResponse) String() string

func (*SampleQueryResponse) Unmarshal added in v1.6.0

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

func (*SampleQueryResponse) XXX_DiscardUnknown added in v1.6.0

func (m *SampleQueryResponse) XXX_DiscardUnknown()

func (*SampleQueryResponse) XXX_Marshal added in v1.6.0

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

func (*SampleQueryResponse) XXX_Merge added in v1.6.0

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

func (*SampleQueryResponse) XXX_Size added in v1.6.0

func (m *SampleQueryResponse) XXX_Size() int

func (*SampleQueryResponse) XXX_Unmarshal added in v1.6.0

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

type Series added in v1.6.0

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

func (*Series) Descriptor added in v1.6.0

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

func (*Series) Equal added in v1.6.0

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

func (*Series) GetLabels added in v1.6.0

func (m *Series) GetLabels() string

func (*Series) GetSamples added in v1.6.0

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

func (*Series) GoString added in v1.6.0

func (this *Series) GoString() string

func (*Series) Marshal added in v1.6.0

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

func (*Series) MarshalTo added in v1.6.0

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

func (*Series) ProtoMessage added in v1.6.0

func (*Series) ProtoMessage()

func (*Series) Reset added in v1.6.0

func (m *Series) Reset()

func (*Series) Size added in v1.6.0

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

func (*Series) String added in v1.6.0

func (this *Series) String() string

func (*Series) Unmarshal added in v1.6.0

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

func (*Series) XXX_DiscardUnknown added in v1.6.0

func (m *Series) XXX_DiscardUnknown()

func (*Series) XXX_Marshal added in v1.6.0

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

func (*Series) XXX_Merge added in v1.6.0

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

func (*Series) XXX_Size added in v1.6.0

func (m *Series) XXX_Size() int

func (*Series) XXX_Unmarshal added in v1.6.0

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

type SeriesIdentifier added in v1.3.0

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

func (*SeriesIdentifier) Descriptor added in v1.3.0

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

func (*SeriesIdentifier) Equal added in v1.3.0

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

func (*SeriesIdentifier) GetLabels added in v1.3.0

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

func (*SeriesIdentifier) GoString added in v1.3.0

func (this *SeriesIdentifier) GoString() string

func (*SeriesIdentifier) Marshal added in v1.3.0

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

func (*SeriesIdentifier) MarshalTo added in v1.3.0

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

func (*SeriesIdentifier) ProtoMessage added in v1.3.0

func (*SeriesIdentifier) ProtoMessage()

func (*SeriesIdentifier) Reset added in v1.3.0

func (m *SeriesIdentifier) Reset()

func (*SeriesIdentifier) Size added in v1.3.0

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

func (*SeriesIdentifier) String added in v1.3.0

func (this *SeriesIdentifier) String() string

func (*SeriesIdentifier) Unmarshal added in v1.3.0

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

func (*SeriesIdentifier) XXX_DiscardUnknown added in v1.3.0

func (m *SeriesIdentifier) XXX_DiscardUnknown()

func (*SeriesIdentifier) XXX_Marshal added in v1.3.0

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

func (*SeriesIdentifier) XXX_Merge added in v1.3.0

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

func (*SeriesIdentifier) XXX_Size added in v1.3.0

func (m *SeriesIdentifier) XXX_Size() int

func (*SeriesIdentifier) XXX_Unmarshal added in v1.3.0

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

type SeriesIdentifiers added in v1.5.0

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

func (ids SeriesIdentifiers) Len() int

func (SeriesIdentifiers) Less added in v1.5.0

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

func (SeriesIdentifiers) Swap added in v1.5.0

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

type SeriesRequest added in v1.3.0

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

func (*SeriesRequest) Descriptor added in v1.3.0

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

func (*SeriesRequest) Equal added in v1.3.0

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

func (*SeriesRequest) GetEnd added in v1.3.0

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

func (*SeriesRequest) GetGroups added in v1.3.0

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

func (*SeriesRequest) GetStart added in v1.3.0

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

func (*SeriesRequest) GoString added in v1.3.0

func (this *SeriesRequest) GoString() string

func (*SeriesRequest) Marshal added in v1.3.0

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

func (*SeriesRequest) MarshalTo added in v1.3.0

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

func (*SeriesRequest) ProtoMessage added in v1.3.0

func (*SeriesRequest) ProtoMessage()

func (*SeriesRequest) Reset added in v1.3.0

func (m *SeriesRequest) Reset()

func (*SeriesRequest) Size added in v1.3.0

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

func (*SeriesRequest) String added in v1.3.0

func (this *SeriesRequest) String() string

func (*SeriesRequest) Unmarshal added in v1.3.0

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

func (*SeriesRequest) XXX_DiscardUnknown added in v1.3.0

func (m *SeriesRequest) XXX_DiscardUnknown()

func (*SeriesRequest) XXX_Marshal added in v1.3.0

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

func (*SeriesRequest) XXX_Merge added in v1.3.0

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

func (*SeriesRequest) XXX_Size added in v1.3.0

func (m *SeriesRequest) XXX_Size() int

func (*SeriesRequest) XXX_Unmarshal added in v1.3.0

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

type SeriesResponse added in v1.3.0

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

func (*SeriesResponse) Descriptor added in v1.3.0

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

func (*SeriesResponse) Equal added in v1.3.0

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

func (*SeriesResponse) GetSeries added in v1.3.0

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

func (*SeriesResponse) GoString added in v1.3.0

func (this *SeriesResponse) GoString() string

func (*SeriesResponse) Marshal added in v1.3.0

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

func (*SeriesResponse) MarshalTo added in v1.3.0

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

func (*SeriesResponse) ProtoMessage added in v1.3.0

func (*SeriesResponse) ProtoMessage()

func (*SeriesResponse) Reset added in v1.3.0

func (m *SeriesResponse) Reset()

func (*SeriesResponse) Size added in v1.3.0

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

func (*SeriesResponse) String added in v1.3.0

func (this *SeriesResponse) String() string

func (*SeriesResponse) Unmarshal added in v1.3.0

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

func (*SeriesResponse) XXX_DiscardUnknown added in v1.3.0

func (m *SeriesResponse) XXX_DiscardUnknown()

func (*SeriesResponse) XXX_Marshal added in v1.3.0

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

func (*SeriesResponse) XXX_Merge added in v1.3.0

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

func (*SeriesResponse) XXX_Size added in v1.3.0

func (m *SeriesResponse) XXX_Size() int

func (*SeriesResponse) XXX_Unmarshal added in v1.3.0

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

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

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

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

func (*StreamAdapter) Equal added in v1.5.0

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

func (*StreamAdapter) GetEntries added in v1.5.0

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

func (*StreamAdapter) GetLabels added in v1.5.0

func (m *StreamAdapter) GetLabels() string

func (*StreamAdapter) GoString added in v1.5.0

func (this *StreamAdapter) GoString() string

func (*StreamAdapter) Marshal added in v1.5.0

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

func (*StreamAdapter) MarshalTo added in v1.5.0

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

func (*StreamAdapter) ProtoMessage added in v1.5.0

func (*StreamAdapter) ProtoMessage()

func (*StreamAdapter) Reset added in v1.5.0

func (m *StreamAdapter) Reset()

func (*StreamAdapter) Size added in v1.5.0

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

func (*StreamAdapter) String added in v1.5.0

func (this *StreamAdapter) String() string

func (*StreamAdapter) Unmarshal added in v1.5.0

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

func (*StreamAdapter) XXX_DiscardUnknown added in v1.5.0

func (m *StreamAdapter) XXX_DiscardUnknown()

func (*StreamAdapter) XXX_Marshal added in v1.5.0

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

func (*StreamAdapter) XXX_Merge added in v1.5.0

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

func (*StreamAdapter) XXX_Size added in v1.5.0

func (m *StreamAdapter) XXX_Size() int

func (*StreamAdapter) XXX_Unmarshal added in v1.5.0

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

type Streams added in v1.6.0

type Streams []Stream

func (Streams) Len added in v1.6.0

func (xs Streams) Len() int

func (Streams) Less added in v1.6.0

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

func (Streams) Swap added in v1.6.0

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

type TailRequest added in v0.2.0

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

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

func (*TailRequest) Equal added in v0.2.0

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

func (*TailRequest) GetDelayFor added in v0.2.0

func (m *TailRequest) GetDelayFor() uint32

func (*TailRequest) GetLimit added in v0.2.0

func (m *TailRequest) GetLimit() uint32

func (*TailRequest) GetQuery added in v0.2.0

func (m *TailRequest) GetQuery() string

func (*TailRequest) GetStart added in v0.2.0

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

func (*TailRequest) GoString added in v0.2.0

func (this *TailRequest) GoString() string

func (*TailRequest) Marshal added in v0.2.0

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

func (*TailRequest) MarshalTo added in v0.2.0

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

func (*TailRequest) ProtoMessage added in v0.2.0

func (*TailRequest) ProtoMessage()

func (*TailRequest) Reset added in v0.2.0

func (m *TailRequest) Reset()

func (*TailRequest) Size added in v0.2.0

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

func (*TailRequest) String added in v0.2.0

func (this *TailRequest) String() string

func (*TailRequest) Unmarshal added in v0.2.0

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

func (*TailRequest) XXX_DiscardUnknown added in v0.2.0

func (m *TailRequest) XXX_DiscardUnknown()

func (*TailRequest) XXX_Marshal added in v0.2.0

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

func (*TailRequest) XXX_Merge added in v0.2.0

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

func (*TailRequest) XXX_Size added in v0.2.0

func (m *TailRequest) XXX_Size() int

func (*TailRequest) XXX_Unmarshal added in v0.2.0

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

type TailResponse added in v0.2.0

type TailResponse struct {
	Stream         *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 added in v0.2.0

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

func (*TailResponse) Equal added in v0.2.0

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

func (*TailResponse) GetDroppedStreams added in v0.2.0

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

func (*TailResponse) GoString added in v0.2.0

func (this *TailResponse) GoString() string

func (*TailResponse) Marshal added in v0.2.0

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

func (*TailResponse) MarshalTo added in v0.2.0

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

func (*TailResponse) ProtoMessage added in v0.2.0

func (*TailResponse) ProtoMessage()

func (*TailResponse) Reset added in v0.2.0

func (m *TailResponse) Reset()

func (*TailResponse) Size added in v0.2.0

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

func (*TailResponse) String added in v0.2.0

func (this *TailResponse) String() string

func (*TailResponse) Unmarshal added in v0.2.0

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

func (*TailResponse) XXX_DiscardUnknown added in v0.2.0

func (m *TailResponse) XXX_DiscardUnknown()

func (*TailResponse) XXX_Marshal added in v0.2.0

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

func (*TailResponse) XXX_Merge added in v0.2.0

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

func (*TailResponse) XXX_Size added in v0.2.0

func (m *TailResponse) XXX_Size() int

func (*TailResponse) XXX_Unmarshal added in v0.2.0

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

type TailersCountRequest added in v1.4.0

type TailersCountRequest struct {
}

func (*TailersCountRequest) Descriptor added in v1.4.0

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

func (*TailersCountRequest) Equal added in v1.4.0

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

func (*TailersCountRequest) GoString added in v1.4.0

func (this *TailersCountRequest) GoString() string

func (*TailersCountRequest) Marshal added in v1.4.0

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

func (*TailersCountRequest) MarshalTo added in v1.4.0

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

func (*TailersCountRequest) ProtoMessage added in v1.4.0

func (*TailersCountRequest) ProtoMessage()

func (*TailersCountRequest) Reset added in v1.4.0

func (m *TailersCountRequest) Reset()

func (*TailersCountRequest) Size added in v1.4.0

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

func (*TailersCountRequest) String added in v1.4.0

func (this *TailersCountRequest) String() string

func (*TailersCountRequest) Unmarshal added in v1.4.0

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

func (*TailersCountRequest) XXX_DiscardUnknown added in v1.4.0

func (m *TailersCountRequest) XXX_DiscardUnknown()

func (*TailersCountRequest) XXX_Marshal added in v1.4.0

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

func (*TailersCountRequest) XXX_Merge added in v1.4.0

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

func (*TailersCountRequest) XXX_Size added in v1.4.0

func (m *TailersCountRequest) XXX_Size() int

func (*TailersCountRequest) XXX_Unmarshal added in v1.4.0

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

type TailersCountResponse added in v1.4.0

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

func (*TailersCountResponse) Descriptor added in v1.4.0

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

func (*TailersCountResponse) Equal added in v1.4.0

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

func (*TailersCountResponse) GetCount added in v1.4.0

func (m *TailersCountResponse) GetCount() uint32

func (*TailersCountResponse) GoString added in v1.4.0

func (this *TailersCountResponse) GoString() string

func (*TailersCountResponse) Marshal added in v1.4.0

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

func (*TailersCountResponse) MarshalTo added in v1.4.0

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

func (*TailersCountResponse) ProtoMessage added in v1.4.0

func (*TailersCountResponse) ProtoMessage()

func (*TailersCountResponse) Reset added in v1.4.0

func (m *TailersCountResponse) Reset()

func (*TailersCountResponse) Size added in v1.4.0

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

func (*TailersCountResponse) String added in v1.4.0

func (this *TailersCountResponse) String() string

func (*TailersCountResponse) Unmarshal added in v1.4.0

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

func (*TailersCountResponse) XXX_DiscardUnknown added in v1.4.0

func (m *TailersCountResponse) XXX_DiscardUnknown()

func (*TailersCountResponse) XXX_Marshal added in v1.4.0

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

func (*TailersCountResponse) XXX_Merge added in v1.4.0

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

func (*TailersCountResponse) XXX_Size added in v1.4.0

func (m *TailersCountResponse) XXX_Size() int

func (*TailersCountResponse) XXX_Unmarshal added in v1.4.0

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

type TimeSeriesChunk added in v0.2.0

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

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

func (*TimeSeriesChunk) Equal added in v0.2.0

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

func (*TimeSeriesChunk) GetChunks added in v0.2.0

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

func (*TimeSeriesChunk) GetFromIngesterId added in v0.2.0

func (m *TimeSeriesChunk) GetFromIngesterId() string

func (*TimeSeriesChunk) GetLabels added in v0.2.0

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

func (*TimeSeriesChunk) GetUserId added in v0.2.0

func (m *TimeSeriesChunk) GetUserId() string

func (*TimeSeriesChunk) GoString added in v0.2.0

func (this *TimeSeriesChunk) GoString() string

func (*TimeSeriesChunk) Marshal added in v0.2.0

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

func (*TimeSeriesChunk) MarshalTo added in v0.2.0

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

func (*TimeSeriesChunk) ProtoMessage added in v0.2.0

func (*TimeSeriesChunk) ProtoMessage()

func (*TimeSeriesChunk) Reset added in v0.2.0

func (m *TimeSeriesChunk) Reset()

func (*TimeSeriesChunk) Size added in v0.2.0

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

func (*TimeSeriesChunk) String added in v0.2.0

func (this *TimeSeriesChunk) String() string

func (*TimeSeriesChunk) Unmarshal added in v0.2.0

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

func (*TimeSeriesChunk) XXX_DiscardUnknown added in v0.2.0

func (m *TimeSeriesChunk) XXX_DiscardUnknown()

func (*TimeSeriesChunk) XXX_Marshal added in v0.2.0

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

func (*TimeSeriesChunk) XXX_Merge added in v0.2.0

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

func (*TimeSeriesChunk) XXX_Size added in v0.2.0

func (m *TimeSeriesChunk) XXX_Size() int

func (*TimeSeriesChunk) XXX_Unmarshal added in v0.2.0

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

type TransferChunksResponse added in v0.2.0

type TransferChunksResponse struct {
}

func (*TransferChunksResponse) Descriptor added in v0.2.0

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

func (*TransferChunksResponse) Equal added in v0.2.0

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

func (*TransferChunksResponse) GoString added in v0.2.0

func (this *TransferChunksResponse) GoString() string

func (*TransferChunksResponse) Marshal added in v0.2.0

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

func (*TransferChunksResponse) MarshalTo added in v0.2.0

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

func (*TransferChunksResponse) ProtoMessage added in v0.2.0

func (*TransferChunksResponse) ProtoMessage()

func (*TransferChunksResponse) Reset added in v0.2.0

func (m *TransferChunksResponse) Reset()

func (*TransferChunksResponse) Size added in v0.2.0

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

func (*TransferChunksResponse) String added in v0.2.0

func (this *TransferChunksResponse) String() string

func (*TransferChunksResponse) Unmarshal added in v0.2.0

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

func (*TransferChunksResponse) XXX_DiscardUnknown added in v0.2.0

func (m *TransferChunksResponse) XXX_DiscardUnknown()

func (*TransferChunksResponse) XXX_Marshal added in v0.2.0

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

func (*TransferChunksResponse) XXX_Merge added in v0.2.0

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

func (*TransferChunksResponse) XXX_Size added in v0.2.0

func (m *TransferChunksResponse) XXX_Size() int

func (*TransferChunksResponse) XXX_Unmarshal added in v0.2.0

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