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 

type QuerierClient interface {
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Querier_QueryClient, error)
	QuerySample(ctx context.Context, in *SampleQueryRequest, opts ...grpc.CallOption) (Querier_QuerySampleClient, error)
	Label(ctx context.Context, in *LabelRequest, opts ...grpc.CallOption) (*LabelResponse, error)
	Tail(ctx context.Context, in *TailRequest, opts ...grpc.CallOption) (Querier_TailClient, error)
	Series(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (*SeriesResponse, error)
	TailersCount(ctx context.Context, in *TailersCountRequest, opts ...grpc.CallOption) (*TailersCountResponse, error)
}

QuerierClient is the client API for Querier service.

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

func NewQuerierClient 

func NewQuerierClient(cc *grpc.ClientConn) QuerierClient

type QuerierServer 

type QuerierServer interface {
	Query(*QueryRequest, Querier_QueryServer) error
	QuerySample(*SampleQueryRequest, Querier_QuerySampleServer) error
	Label(context.Context, *LabelRequest) (*LabelResponse, error)
	Tail(*TailRequest, Querier_TailServer) error
	Series(context.Context, *SeriesRequest) (*SeriesResponse, error)
	TailersCount(context.Context, *TailersCountRequest) (*TailersCountResponse, error)
}

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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