logproto

package
v0.0.0-...-0f21197 Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2024 License: Apache-2.0 Imports: 17 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	TimestampLabel = "timestamp: "
)

Variables

View Source 
var (
	ErrInvalidLengthLogproto = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogproto   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Direction_name = map[int32]string{
	0: "FORWARD",
	1: "BACKWARD",
}
View Source 
var Direction_value = map[string]int32{
	"FORWARD":  0,
	"BACKWARD": 1,
}

Functions

func RegisterIngesterServer 

func RegisterIngesterServer(s *grpc.Server, srv IngesterServer)

func RegisterPusherServer 

func RegisterPusherServer(s *grpc.Server, srv PusherServer)

func RegisterQuerierServer 

func RegisterQuerierServer(s *grpc.Server, srv QuerierServer)

func SizeOfStdTime 

func SizeOfStdTime(t time.Time) int

func StdTimeMarshalTo 

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

func StdTimeUnmarshal 

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

Types

type Chunk 

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

func (*Chunk) Descriptor 

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

func (*Chunk) Equal 

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

func (*Chunk) GetData 

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

func (*Chunk) GoString 

func (this *Chunk) GoString() string

func (*Chunk) Marshal 

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

func (*Chunk) MarshalTo 

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

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) Reset 

func (m *Chunk) Reset()

func (*Chunk) Size 

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

func (*Chunk) String 

func (this *Chunk) String() string

func (*Chunk) Unmarshal 

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

func (*Chunk) XXX_DiscardUnknown 

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal 

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

func (*Chunk) XXX_Merge 

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

func (*Chunk) XXX_Size 

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal 

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

type Direction 

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

func (Direction) EnumDescriptor 

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

func (Direction) String 

func (x Direction) String() string

type DroppedStream 

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

func (*DroppedStream) Descriptor 

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

func (*DroppedStream) Equal 

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

func (*DroppedStream) GetFrom 

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

func (*DroppedStream) GetLabels 

func (m *DroppedStream) GetLabels() string

func (*DroppedStream) GetTo 

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

func (*DroppedStream) GoString 

func (this *DroppedStream) GoString() string

func (*DroppedStream) Marshal 

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

func (*DroppedStream) MarshalTo 

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

func (*DroppedStream) ProtoMessage 

func (*DroppedStream) ProtoMessage()

func (*DroppedStream) Reset 

func (m *DroppedStream) Reset()

func (*DroppedStream) Size 

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

func (*DroppedStream) String 

func (this *DroppedStream) String() string

func (*DroppedStream) Unmarshal 

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

func (*DroppedStream) XXX_DiscardUnknown 

func (m *DroppedStream) XXX_DiscardUnknown()

func (*DroppedStream) XXX_Marshal 

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

func (*DroppedStream) XXX_Merge 

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

func (*DroppedStream) XXX_Size 

func (m *DroppedStream) XXX_Size() int

func (*DroppedStream) XXX_Unmarshal 

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

type Entry 

type Entry struct {
	Timestamp time.Time `protobuf:"bytes,1,opt,name=timestamp,proto3,stdtime" json:"ts"`
	Line      string    `protobuf:"bytes,2,opt,name=line,proto3" json:"line"`
}

Entry is a log entry with a timestamp.

func (*Entry) Equal 

func (m *Entry) Equal(that interface{}) bool

func (*Entry) Marshal 

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

func (*Entry) MarshalTo 

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

func (*Entry) Size 

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

func (*Entry) Unmarshal 

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

type EntryAdapter 

type EntryAdapter struct {
	Timestamp time.Time `protobuf:"bytes,1,opt,name=timestamp,proto3,stdtime" json:"ts"`
	Line      string    `protobuf:"bytes,2,opt,name=line,proto3" json:"line"`
}

func (*EntryAdapter) Descriptor 

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

func (*EntryAdapter) Equal 

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

func (*EntryAdapter) GetLine 

func (m *EntryAdapter) GetLine() string

func (*EntryAdapter) GetTimestamp 

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

func (*EntryAdapter) GoString 

func (this *EntryAdapter) GoString() string

func (*EntryAdapter) Marshal 

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

func (*EntryAdapter) MarshalTo 

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

func (*EntryAdapter) ProtoMessage 

func (*EntryAdapter) ProtoMessage()

func (*EntryAdapter) Reset 

func (m *EntryAdapter) Reset()

func (*EntryAdapter) Size 

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

func (*EntryAdapter) String 

func (this *EntryAdapter) String() string

func (*EntryAdapter) Unmarshal 

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

func (*EntryAdapter) XXX_DiscardUnknown 

func (m *EntryAdapter) XXX_DiscardUnknown()

func (*EntryAdapter) XXX_Marshal 

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

func (*EntryAdapter) XXX_Merge 

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

func (*EntryAdapter) XXX_Size 

func (m *EntryAdapter) XXX_Size() int

func (*EntryAdapter) XXX_Unmarshal 

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

type GetChunkIDsRequest 

type GetChunkIDsRequest struct {
	Matchers string    `protobuf:"bytes,1,opt,name=matchers,proto3" json:"matchers,omitempty"`
	Start    time.Time `protobuf:"bytes,2,opt,name=start,proto3,stdtime" json:"start"`
	End      time.Time `protobuf:"bytes,3,opt,name=end,proto3,stdtime" json:"end"`
}

func (*GetChunkIDsRequest) Descriptor 

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

func (*GetChunkIDsRequest) Equal 

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

func (*GetChunkIDsRequest) GetEnd 

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

func (*GetChunkIDsRequest) GetMatchers 

func (m *GetChunkIDsRequest) GetMatchers() string

func (*GetChunkIDsRequest) GetStart 

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

func (*GetChunkIDsRequest) GoString 

func (this *GetChunkIDsRequest) GoString() string

func (*GetChunkIDsRequest) Marshal 

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

func (*GetChunkIDsRequest) MarshalTo 

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

func (*GetChunkIDsRequest) ProtoMessage 

func (*GetChunkIDsRequest) ProtoMessage()

func (*GetChunkIDsRequest) Reset 

func (m *GetChunkIDsRequest) Reset()

func (*GetChunkIDsRequest) Size 

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

func (*GetChunkIDsRequest) String 

func (this *GetChunkIDsRequest) String() string

func (*GetChunkIDsRequest) Unmarshal 

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

func (*GetChunkIDsRequest) XXX_DiscardUnknown 

func (m *GetChunkIDsRequest) XXX_DiscardUnknown()

func (*GetChunkIDsRequest) XXX_Marshal 

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

func (*GetChunkIDsRequest) XXX_Merge 

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

func (*GetChunkIDsRequest) XXX_Size 

func (m *GetChunkIDsRequest) XXX_Size() int

func (*GetChunkIDsRequest) XXX_Unmarshal 

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

type GetChunkIDsResponse 

type GetChunkIDsResponse struct {
	ChunkIDs []string `protobuf:"bytes,1,rep,name=chunkIDs,proto3" json:"chunkIDs,omitempty"`
}

func (*GetChunkIDsResponse) Descriptor 

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

func (*GetChunkIDsResponse) Equal 

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

func (*GetChunkIDsResponse) GetChunkIDs 

func (m *GetChunkIDsResponse) GetChunkIDs() []string

func (*GetChunkIDsResponse) GoString 

func (this *GetChunkIDsResponse) GoString() string

func (*GetChunkIDsResponse) Marshal 

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

func (*GetChunkIDsResponse) MarshalTo 

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

func (*GetChunkIDsResponse) ProtoMessage 

func (*GetChunkIDsResponse) ProtoMessage()

func (*GetChunkIDsResponse) Reset 

func (m *GetChunkIDsResponse) Reset()

func (*GetChunkIDsResponse) Size 

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

func (*GetChunkIDsResponse) String 

func (this *GetChunkIDsResponse) String() string

func (*GetChunkIDsResponse) Unmarshal 

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

func (*GetChunkIDsResponse) XXX_DiscardUnknown 

func (m *GetChunkIDsResponse) XXX_DiscardUnknown()

func (*GetChunkIDsResponse) XXX_Marshal 

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

func (*GetChunkIDsResponse) XXX_Merge 

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

func (*GetChunkIDsResponse) XXX_Size 

func (m *GetChunkIDsResponse) XXX_Size() int

func (*GetChunkIDsResponse) XXX_Unmarshal 

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

type IngesterClient 

type IngesterClient interface {
	TransferChunks(ctx context.Context, opts ...grpc.CallOption) (Ingester_TransferChunksClient, error)
}

IngesterClient is the client API for Ingester service.

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

func NewIngesterClient 

func NewIngesterClient(cc *grpc.ClientConn) IngesterClient

type IngesterServer 

type IngesterServer interface {
	TransferChunks(Ingester_TransferChunksServer) error
}

IngesterServer is the server API for Ingester service.

type Ingester_TransferChunksClient 

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

type Ingester_TransferChunksServer 

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

type LabelPair 

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

func (*LabelPair) Descriptor 

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

func (*LabelPair) Equal 

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

func (*LabelPair) GetName 

func (m *LabelPair) GetName() string

func (*LabelPair) GetValue 

func (m *LabelPair) GetValue() string

func (*LabelPair) GoString 

func (this *LabelPair) GoString() string

func (*LabelPair) Marshal 

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

func (*LabelPair) MarshalTo 

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

func (*LabelPair) ProtoMessage 

func (*LabelPair) ProtoMessage()

func (*LabelPair) Reset 

func (m *LabelPair) Reset()

func (*LabelPair) Size 

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

func (*LabelPair) String 

func (this *LabelPair) String() string

func (*LabelPair) Unmarshal 

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

func (*LabelPair) XXX_DiscardUnknown 

func (m *LabelPair) XXX_DiscardUnknown()

func (*LabelPair) XXX_Marshal 

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

func (*LabelPair) XXX_Merge 

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

func (*LabelPair) XXX_Size 

func (m *LabelPair) XXX_Size() int

func (*LabelPair) XXX_Unmarshal 

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

type LabelRequest 

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

func (*LabelRequest) Descriptor 

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

func (*LabelRequest) Equal 

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

func (*LabelRequest) GetEnd 

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

func (*LabelRequest) GetName 

func (m *LabelRequest) GetName() string

func (*LabelRequest) GetStart 

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

func (*LabelRequest) GetValues 

func (m *LabelRequest) GetValues() bool

func (*LabelRequest) GoString 

func (this *LabelRequest) GoString() string

func (*LabelRequest) Marshal 

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

func (*LabelRequest) MarshalTo 

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

func (*LabelRequest) ProtoMessage 

func (*LabelRequest) ProtoMessage()

func (*LabelRequest) Reset 

func (m *LabelRequest) Reset()

func (*LabelRequest) Size 

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

func (*LabelRequest) String 

func (this *LabelRequest) String() string

func (*LabelRequest) Unmarshal 

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

func (*LabelRequest) XXX_DiscardUnknown 

func (m *LabelRequest) XXX_DiscardUnknown()

func (*LabelRequest) XXX_Marshal 

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

func (*LabelRequest) XXX_Merge 

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

func (*LabelRequest) XXX_Size 

func (m *LabelRequest) XXX_Size() int

func (*LabelRequest) XXX_Unmarshal 

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

type LabelResponse 

type LabelResponse struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
}

func (*LabelResponse) Descriptor 

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

func (*LabelResponse) Equal 

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

func (*LabelResponse) GetValues 

func (m *LabelResponse) GetValues() []string

func (*LabelResponse) GoString 

func (this *LabelResponse) GoString() string

func (*LabelResponse) Marshal 

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

func (*LabelResponse) MarshalTo 

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

func (*LabelResponse) ProtoMessage 

func (*LabelResponse) ProtoMessage()

func (*LabelResponse) Reset 

func (m *LabelResponse) Reset()

func (*LabelResponse) Size 

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

func (*LabelResponse) String 

func (this *LabelResponse) String() string

func (*LabelResponse) Unmarshal 

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

func (*LabelResponse) XXX_DiscardUnknown 

func (m *LabelResponse) XXX_DiscardUnknown()

func (*LabelResponse) XXX_Marshal 

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

func (*LabelResponse) XXX_Merge 

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

func (*LabelResponse) XXX_Size 

func (m *LabelResponse) XXX_Size() int

func (*LabelResponse) XXX_Unmarshal 

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

type PushRequest 

type PushRequest struct {
	Streams []Stream `protobuf:"bytes,1,rep,name=streams,proto3,customtype=Stream" json:"streams"`
}

func (*PushRequest) Descriptor 

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

func (*PushRequest) Equal 

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

func (*PushRequest) GoString 

func (this *PushRequest) GoString() string

func (*PushRequest) Marshal 

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

func (*PushRequest) 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)
	GetChunkIDs(ctx context.Context, in *GetChunkIDsRequest, opts ...grpc.CallOption) (*GetChunkIDsResponse, error)
}

QuerierClient is the client API for Querier service.

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

func NewQuerierClient 

func NewQuerierClient(cc *grpc.ClientConn) QuerierClient

type QuerierServer 

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

QuerierServer is the server API for Querier service.

type Querier_QueryClient 

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

type Querier_QuerySampleClient 

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

type Querier_QuerySampleServer 

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

type Querier_QueryServer 

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

type Querier_TailClient 

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

type Querier_TailServer 

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

type QueryRequest 

type QueryRequest struct {
	Selector  string    `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"`
	Limit     uint32    `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Start     time.Time `protobuf:"bytes,3,opt,name=start,proto3,stdtime" json:"start"`
	End       time.Time `protobuf:"bytes,4,opt,name=end,proto3,stdtime" json:"end"`
	Direction Direction `protobuf:"varint,5,opt,name=direction,proto3,enum=logproto.Direction" json:"direction,omitempty"`
	Shards    []string  `protobuf:"bytes,7,rep,name=shards,proto3" json:"shards,omitempty"`
}

func (*QueryRequest) Descriptor 

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

func (*QueryRequest) Equal 

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

func (*QueryRequest) GetDirection 

func (m *QueryRequest) GetDirection() Direction

func (*QueryRequest) GetEnd 

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

func (*QueryRequest) GetLimit 

func (m *QueryRequest) GetLimit() uint32

func (*QueryRequest) GetSelector 

func (m *QueryRequest) GetSelector() string

func (*QueryRequest) GetShards 

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

func (*QueryRequest) GetStart 

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

func (*QueryRequest) GoString 

func (this *QueryRequest) GoString() string

func (*QueryRequest) Marshal 

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

func (*QueryRequest) MarshalTo 

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

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (m *QueryRequest) Reset()

func (*QueryRequest) Size 

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

func (*QueryRequest) String 

func (this *QueryRequest) String() string

func (*QueryRequest) Unmarshal 

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

func (*QueryRequest) XXX_DiscardUnknown 

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal 

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

func (*QueryRequest) XXX_Merge 

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

func (*QueryRequest) XXX_Size 

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal 

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

type QueryResponse 

type QueryResponse struct {
	Streams []Stream `protobuf:"bytes,1,rep,name=streams,proto3,customtype=Stream" json:"streams,omitempty"`
}

func (*QueryResponse) Descriptor 

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

func (*QueryResponse) Equal 

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

func (*QueryResponse) GoString 

func (this *QueryResponse) GoString() string

func (*QueryResponse) Marshal 

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

func (*QueryResponse) MarshalTo 

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

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset 

func (m *QueryResponse) Reset()

func (*QueryResponse) Size 

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

func (*QueryResponse) String 

func (this *QueryResponse) String() string

func (*QueryResponse) Unmarshal 

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

func (*QueryResponse) XXX_DiscardUnknown 

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal 

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

func (*QueryResponse) XXX_Merge 

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

func (*QueryResponse) XXX_Size 

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal 

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

type Sample 

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

func (*Sample) Descriptor 

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

func (*Sample) Equal 

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

func (*Sample) GetHash 

func (m *Sample) GetHash() uint64

func (*Sample) GetTimestamp 

func (m *Sample) GetTimestamp() int64

func (*Sample) GetValue 

func (m *Sample) GetValue() float64

func (*Sample) GoString 

func (this *Sample) GoString() string

func (*Sample) Marshal 

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

func (*Sample) MarshalTo 

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

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) Reset 

func (m *Sample) Reset()

func (*Sample) Size 

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

func (*Sample) String 

func (this *Sample) String() string

func (*Sample) Unmarshal 

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

func (*Sample) XXX_DiscardUnknown 

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal 

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

func (*Sample) XXX_Merge 

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

func (*Sample) XXX_Size 

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal 

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

type SampleQueryRequest 

type SampleQueryRequest struct {
	Selector string    `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"`
	Start    time.Time `protobuf:"bytes,2,opt,name=start,proto3,stdtime" json:"start"`
	End      time.Time `protobuf:"bytes,3,opt,name=end,proto3,stdtime" json:"end"`
	Shards   []string  `protobuf:"bytes,4,rep,name=shards,proto3" json:"shards,omitempty"`
}

func (*SampleQueryRequest) Descriptor 

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

func (*SampleQueryRequest) Equal 

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

func (*SampleQueryRequest) GetEnd 

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

func (*SampleQueryRequest) GetSelector 

func (m *SampleQueryRequest) GetSelector() string

func (*SampleQueryRequest) GetShards 

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

func (*SampleQueryRequest) GetStart 

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

func (*SampleQueryRequest) GoString 

func (this *SampleQueryRequest) GoString() string

func (*SampleQueryRequest) Marshal 

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

func (*SampleQueryRequest) MarshalTo 

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

func (*SampleQueryRequest) ProtoMessage 

func (*SampleQueryRequest) ProtoMessage()

func (*SampleQueryRequest) Reset 

func (m *SampleQueryRequest) Reset()

func (*SampleQueryRequest) Size 

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

func (*SampleQueryRequest) String 

func (this *SampleQueryRequest) String() string

func (*SampleQueryRequest) Unmarshal 

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

func (*SampleQueryRequest) XXX_DiscardUnknown 

func (m *SampleQueryRequest) XXX_DiscardUnknown()

func (*SampleQueryRequest) XXX_Marshal 

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

func (*SampleQueryRequest) XXX_Merge 

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

func (*SampleQueryRequest) XXX_Size 

func (m *SampleQueryRequest) XXX_Size() int

func (*SampleQueryRequest) XXX_Unmarshal 

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

type SampleQueryResponse 

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

func (*SampleQueryResponse) Descriptor 

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

func (*SampleQueryResponse) Equal 

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

func (*SampleQueryResponse) GoString 

func (this *SampleQueryResponse) GoString() string

func (*SampleQueryResponse) Marshal 

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

func (*SampleQueryResponse) MarshalTo 

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

func (*SampleQueryResponse) ProtoMessage 

func (*SampleQueryResponse) ProtoMessage()

func (*SampleQueryResponse) Reset 

func (m *SampleQueryResponse) Reset()

func (*SampleQueryResponse) Size 

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

func (*SampleQueryResponse) String 

func (this *SampleQueryResponse) String() string

func (*SampleQueryResponse) Unmarshal 

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

func (*SampleQueryResponse) XXX_DiscardUnknown 

func (m *SampleQueryResponse) XXX_DiscardUnknown()

func (*SampleQueryResponse) XXX_Marshal 

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

func (*SampleQueryResponse) XXX_Merge 

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

func (*SampleQueryResponse) XXX_Size 

func (m *SampleQueryResponse) XXX_Size() int

func (*SampleQueryResponse) XXX_Unmarshal 

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

type Series 

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

func (*Series) Descriptor 

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

func (*Series) Equal 

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

func (*Series) GetLabels 

func (m *Series) GetLabels() string

func (*Series) GetSamples 

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

func (*Series) GoString 

func (this *Series) GoString() string

func (Series) Len 

func (s Series) Len() int

func (Series) Less 

func (s Series) Less(i, j int) bool

func (*Series) Marshal 

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

func (*Series) MarshalTo 

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

func (*Series) ProtoMessage 

func (*Series) ProtoMessage()

func (*Series) Reset 

func (m *Series) Reset()

func (*Series) Size 

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

func (*Series) String 

func (this *Series) String() string

func (Series) Swap 

func (s Series) Swap(i, j int)

func (*Series) Unmarshal 

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

func (*Series) XXX_DiscardUnknown 

func (m *Series) XXX_DiscardUnknown()

func (*Series) XXX_Marshal 

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

func (*Series) XXX_Merge 

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

func (*Series) XXX_Size 

func (m *Series) XXX_Size() int

func (*Series) XXX_Unmarshal 

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

type SeriesIdentifier 

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

func (*SeriesIdentifier) Descriptor 

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

func (*SeriesIdentifier) Equal 

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

func (*SeriesIdentifier) GetLabels 

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

func (*SeriesIdentifier) GoString 

func (this *SeriesIdentifier) GoString() string

func (*SeriesIdentifier) Marshal 

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

func (*SeriesIdentifier) MarshalTo 

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

func (*SeriesIdentifier) ProtoMessage 

func (*SeriesIdentifier) ProtoMessage()

func (*SeriesIdentifier) Reset 

func (m *SeriesIdentifier) Reset()

func (*SeriesIdentifier) Size 

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

func (*SeriesIdentifier) String 

func (this *SeriesIdentifier) String() string

func (*SeriesIdentifier) Unmarshal 

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

func (*SeriesIdentifier) XXX_DiscardUnknown 

func (m *SeriesIdentifier) XXX_DiscardUnknown()

func (*SeriesIdentifier) XXX_Marshal 

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

func (*SeriesIdentifier) XXX_Merge 

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

func (*SeriesIdentifier) XXX_Size 

func (m *SeriesIdentifier) XXX_Size() int

func (*SeriesIdentifier) XXX_Unmarshal 

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

type SeriesIdentifiers 

type SeriesIdentifiers []SeriesIdentifier

Note, this is not very efficient and use should be minimized as it requires label construction on each comparison

func (SeriesIdentifiers) Len 

func (ids SeriesIdentifiers) Len() int

func (SeriesIdentifiers) Less 

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

func (SeriesIdentifiers) Swap 

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

type SeriesRequest 

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

func (*SeriesRequest) Descriptor 

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

func (*SeriesRequest) Equal 

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

func (*SeriesRequest) GetEnd 

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

func (*SeriesRequest) GetGroups 

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

func (*SeriesRequest) GetStart 

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

func (*SeriesRequest) GoString 

func (this *SeriesRequest) GoString() string

func (*SeriesRequest) Marshal 

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

func (*SeriesRequest) MarshalTo 

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

func (*SeriesRequest) ProtoMessage 

func (*SeriesRequest) ProtoMessage()

func (*SeriesRequest) Reset 

func (m *SeriesRequest) Reset()

func (*SeriesRequest) Size 

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

func (*SeriesRequest) String 

func (this *SeriesRequest) String() string

func (*SeriesRequest) Unmarshal 

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

func (*SeriesRequest) XXX_DiscardUnknown 

func (m *SeriesRequest) XXX_DiscardUnknown()

func (*SeriesRequest) XXX_Marshal 

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

func (*SeriesRequest) XXX_Merge 

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

func (*SeriesRequest) XXX_Size 

func (m *SeriesRequest) XXX_Size() int

func (*SeriesRequest) XXX_Unmarshal 

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

type SeriesResponse 

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

func (*SeriesResponse) Descriptor 

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

func (*SeriesResponse) Equal 

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

func (*SeriesResponse) GetSeries 

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

func (*SeriesResponse) GoString 

func (this *SeriesResponse) GoString() string

func (*SeriesResponse) Marshal 

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

func (*SeriesResponse) MarshalTo 

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

func (*SeriesResponse) ProtoMessage 

func (*SeriesResponse) ProtoMessage()

func (*SeriesResponse) Reset 

func (m *SeriesResponse) Reset()

func (*SeriesResponse) Size 

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

func (*SeriesResponse) String 

func (this *SeriesResponse) String() string

func (*SeriesResponse) Unmarshal 

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

func (*SeriesResponse) XXX_DiscardUnknown 

func (m *SeriesResponse) XXX_DiscardUnknown()

func (*SeriesResponse) XXX_Marshal 

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

func (*SeriesResponse) XXX_Merge 

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

func (*SeriesResponse) XXX_Size 

func (m *SeriesResponse) XXX_Size() int

func (*SeriesResponse) XXX_Unmarshal 

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

type Stream 

type Stream struct {
	Labels  string  `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels"`
	Entries []Entry `protobuf:"bytes,2,rep,name=entries,proto3,customtype=EntryAdapter" json:"entries"`
}

Stream contains a unique labels set as a string and a set of entries for it. We are not using the proto generated version but this custom one so that we can improve serialization see benchmark.

func (*Stream) Equal 

func (m *Stream) Equal(that interface{}) bool

func (*Stream) Marshal 

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

func (*Stream) MarshalTo 

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

func (*Stream) Size 

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

func (*Stream) Unmarshal 

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

type StreamAdapter 

type StreamAdapter struct {
	Labels  string         `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels"`
	Entries []EntryAdapter `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries"`
}

func (*StreamAdapter) Descriptor 

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

func (*StreamAdapter) Equal 

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

func (*StreamAdapter) GetEntries 

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

func (*StreamAdapter) GetLabels 

func (m *StreamAdapter) GetLabels() string

func (*StreamAdapter) GoString 

func (this *StreamAdapter) GoString() string

func (*StreamAdapter) Marshal 

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

func (*StreamAdapter) MarshalTo 

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

func (*StreamAdapter) ProtoMessage 

func (*StreamAdapter) ProtoMessage()

func (*StreamAdapter) Reset 

func (m *StreamAdapter) Reset()

func (*StreamAdapter) Size 

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

func (*StreamAdapter) String 

func (this *StreamAdapter) String() string

func (*StreamAdapter) Unmarshal 

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

func (*StreamAdapter) XXX_DiscardUnknown 

func (m *StreamAdapter) XXX_DiscardUnknown()

func (*StreamAdapter) XXX_Marshal 

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

func (*StreamAdapter) XXX_Merge 

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

func (*StreamAdapter) XXX_Size 

func (m *StreamAdapter) XXX_Size() int

func (*StreamAdapter) XXX_Unmarshal 

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

type Streams 

type Streams []Stream

func (Streams) Len 

func (xs Streams) Len() int

func (Streams) Less 

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

func (Streams) Swap 

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

type TailRequest 

type TailRequest struct {
	Query    string    `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	DelayFor uint32    `protobuf:"varint,3,opt,name=delayFor,proto3" json:"delayFor,omitempty"`
	Limit    uint32    `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	Start    time.Time `protobuf:"bytes,5,opt,name=start,proto3,stdtime" json:"start"`
}

func (*TailRequest) Descriptor 

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

func (*TailRequest) Equal 

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

func (*TailRequest) GetDelayFor 

func (m *TailRequest) GetDelayFor() uint32

func (*TailRequest) GetLimit 

func (m *TailRequest) GetLimit() uint32

func (*TailRequest) GetQuery 

func (m *TailRequest) GetQuery() string

func (*TailRequest) GetStart 

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

func (*TailRequest) GoString 

func (this *TailRequest) GoString() string

func (*TailRequest) Marshal 

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

func (*TailRequest) MarshalTo 

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

func (*TailRequest) ProtoMessage 

func (*TailRequest) ProtoMessage()

func (*TailRequest) Reset 

func (m *TailRequest) Reset()

func (*TailRequest) Size 

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

func (*TailRequest) String 

func (this *TailRequest) String() string

func (*TailRequest) Unmarshal 

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

func (*TailRequest) XXX_DiscardUnknown 

func (m *TailRequest) XXX_DiscardUnknown()

func (*TailRequest) XXX_Marshal 

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

func (*TailRequest) XXX_Merge 

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

func (*TailRequest) XXX_Size 

func (m *TailRequest) XXX_Size() int

func (*TailRequest) XXX_Unmarshal 

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

type TailResponse 

type TailResponse struct {
	Stream         *Stream          `protobuf:"bytes,1,opt,name=stream,proto3,customtype=Stream" json:"stream,omitempty"`
	DroppedStreams []*DroppedStream `protobuf:"bytes,2,rep,name=droppedStreams,proto3" json:"droppedStreams,omitempty"`
}

func (*TailResponse) Descriptor 

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

func (*TailResponse) Equal 

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

func (*TailResponse) GetDroppedStreams 

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

func (*TailResponse) GoString 

func (this *TailResponse) GoString() string

func (*TailResponse) Marshal 

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

func (*TailResponse) MarshalTo 

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

func (*TailResponse) ProtoMessage 

func (*TailResponse) ProtoMessage()

func (*TailResponse) Reset 

func (m *TailResponse) Reset()

func (*TailResponse) Size 

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

func (*TailResponse) String 

func (this *TailResponse) String() string

func (*TailResponse) Unmarshal 

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

func (*TailResponse) XXX_DiscardUnknown 

func (m *TailResponse) XXX_DiscardUnknown()

func (*TailResponse) XXX_Marshal 

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

func (*TailResponse) XXX_Merge 

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

func (*TailResponse) XXX_Size 

func (m *TailResponse) XXX_Size() int

func (*TailResponse) XXX_Unmarshal 

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

type TailersCountRequest 

type TailersCountRequest struct {
}

func (*TailersCountRequest) Descriptor 

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

func (*TailersCountRequest) Equal 

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

func (*TailersCountRequest) GoString 

func (this *TailersCountRequest) GoString() string

func (*TailersCountRequest) Marshal 

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

func (*TailersCountRequest) MarshalTo 

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

func (*TailersCountRequest) ProtoMessage 

func (*TailersCountRequest) ProtoMessage()

func (*TailersCountRequest) Reset 

func (m *TailersCountRequest) Reset()

func (*TailersCountRequest) Size 

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

func (*TailersCountRequest) String 

func (this *TailersCountRequest) String() string

func (*TailersCountRequest) Unmarshal 

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

func (*TailersCountRequest) XXX_DiscardUnknown 

func (m *TailersCountRequest) XXX_DiscardUnknown()

func (*TailersCountRequest) XXX_Marshal 

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

func (*TailersCountRequest) XXX_Merge 

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

func (*TailersCountRequest) XXX_Size 

func (m *TailersCountRequest) XXX_Size() int

func (*TailersCountRequest) XXX_Unmarshal 

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

type TailersCountResponse 

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

func (*TailersCountResponse) Descriptor 

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

func (*TailersCountResponse) Equal 

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

func (*TailersCountResponse) GetCount 

func (m *TailersCountResponse) GetCount() uint32

func (*TailersCountResponse) GoString 

func (this *TailersCountResponse) GoString() string

func (*TailersCountResponse) Marshal 

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

func (*TailersCountResponse) MarshalTo 

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

func (*TailersCountResponse) ProtoMessage 

func (*TailersCountResponse) ProtoMessage()

func (*TailersCountResponse) Reset 

func (m *TailersCountResponse) Reset()

func (*TailersCountResponse) Size 

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

func (*TailersCountResponse) String 

func (this *TailersCountResponse) String() string

func (*TailersCountResponse) Unmarshal 

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

func (*TailersCountResponse) XXX_DiscardUnknown 

func (m *TailersCountResponse) XXX_DiscardUnknown()

func (*TailersCountResponse) XXX_Marshal 

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

func (*TailersCountResponse) XXX_Merge 

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

func (*TailersCountResponse) XXX_Size 

func (m *TailersCountResponse) XXX_Size() int

func (*TailersCountResponse) XXX_Unmarshal 

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

type TimeSeriesChunk 

type TimeSeriesChunk struct {
	FromIngesterId string       `protobuf:"bytes,1,opt,name=from_ingester_id,json=fromIngesterId,proto3" json:"from_ingester_id,omitempty"`
	UserId         string       `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Labels         []*LabelPair `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"`
	Chunks         []*Chunk     `protobuf:"bytes,4,rep,name=chunks,proto3" json:"chunks,omitempty"`
}

func (*TimeSeriesChunk) Descriptor 

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

func (*TimeSeriesChunk) Equal 

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

func (*TimeSeriesChunk) GetChunks 

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

func (*TimeSeriesChunk) GetFromIngesterId 

func (m *TimeSeriesChunk) GetFromIngesterId() string

func (*TimeSeriesChunk) GetLabels 

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

func (*TimeSeriesChunk) GetUserId 

func (m *TimeSeriesChunk) GetUserId() string

func (*TimeSeriesChunk) GoString 

func (this *TimeSeriesChunk) GoString() string

func (*TimeSeriesChunk) Marshal 

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

func (*TimeSeriesChunk) MarshalTo 

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

func (*TimeSeriesChunk) ProtoMessage 

func (*TimeSeriesChunk) ProtoMessage()

func (*TimeSeriesChunk) Reset 

func (m *TimeSeriesChunk) Reset()

func (*TimeSeriesChunk) Size 

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

func (*TimeSeriesChunk) String 

func (this *TimeSeriesChunk) String() string

func (*TimeSeriesChunk) Unmarshal 

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

func (*TimeSeriesChunk) XXX_DiscardUnknown 

func (m *TimeSeriesChunk) XXX_DiscardUnknown()

func (*TimeSeriesChunk) XXX_Marshal 

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

func (*TimeSeriesChunk) XXX_Merge 

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

func (*TimeSeriesChunk) XXX_Size 

func (m *TimeSeriesChunk) XXX_Size() int

func (*TimeSeriesChunk) XXX_Unmarshal 

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

type TransferChunksResponse 

type TransferChunksResponse struct {
}

func (*TransferChunksResponse) Descriptor 

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

func (*TransferChunksResponse) Equal 

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

func (*TransferChunksResponse) GoString 

func (this *TransferChunksResponse) GoString() string

func (*TransferChunksResponse) Marshal 

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

func (*TransferChunksResponse) MarshalTo 

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

func (*TransferChunksResponse) ProtoMessage 

func (*TransferChunksResponse) ProtoMessage()

func (*TransferChunksResponse) Reset 

func (m *TransferChunksResponse) Reset()

func (*TransferChunksResponse) Size 

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

func (*TransferChunksResponse) String 

func (this *TransferChunksResponse) String() string

func (*TransferChunksResponse) Unmarshal 

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

func (*TransferChunksResponse) XXX_DiscardUnknown 

func (m *TransferChunksResponse) XXX_DiscardUnknown()

func (*TransferChunksResponse) XXX_Marshal 

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

func (*TransferChunksResponse) XXX_Merge 

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

func (*TransferChunksResponse) XXX_Size 

func (m *TransferChunksResponse) XXX_Size() int

func (*TransferChunksResponse) XXX_Unmarshal 

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

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.