logproto

package

Go to main page

Versions in this module

v1

v1.0.1

Nov 19, 2019

Changes in this version

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

+ type Chunk struct

+ Data []byte

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

+ func (*Chunk) ProtoMessage()

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

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

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

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

+ func (m *Chunk) Reset()

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

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

+ func (m *Chunk) XXX_DiscardUnknown()

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

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

+ func (m *Chunk) XXX_Size() int

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

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

+ func (this *Chunk) GoString() string

+ func (this *Chunk) String() string

+ type DroppedStream struct

+ From time.Time

+ Labels string

+ To time.Time

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

+ func (*DroppedStream) ProtoMessage()

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

+ func (m *DroppedStream) GetLabels() string

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

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

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

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

+ func (m *DroppedStream) Reset()

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

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

+ func (m *DroppedStream) XXX_DiscardUnknown()

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

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

+ func (m *DroppedStream) XXX_Size() int

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

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

+ func (this *DroppedStream) GoString() string

+ func (this *DroppedStream) String() string

type Entry

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

+ type IngesterClient interface

+ TransferChunks func(ctx context.Context, opts ...grpc.CallOption) (Ingester_TransferChunksClient, error)

+ func NewIngesterClient(cc *grpc.ClientConn) IngesterClient

+ type IngesterServer interface

+ TransferChunks func(Ingester_TransferChunksServer) error

+ type Ingester_TransferChunksClient interface

+ CloseAndRecv func() (*TransferChunksResponse, error)

+ Send func(*TimeSeriesChunk) error

+ type Ingester_TransferChunksServer interface

+ Recv func() (*TimeSeriesChunk, error)

+ SendAndClose func(*TransferChunksResponse) error

+ type LabelPair struct

+ Name string

+ Value string

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

+ func (*LabelPair) ProtoMessage()

+ func (m *LabelPair) GetName() string

+ func (m *LabelPair) GetValue() string

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

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

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

+ func (m *LabelPair) Reset()

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

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

+ func (m *LabelPair) XXX_DiscardUnknown()

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

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

+ func (m *LabelPair) XXX_Size() int

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

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

+ func (this *LabelPair) GoString() string

+ func (this *LabelPair) String() string

type LabelRequest

+ End *time.Time

+ Start *time.Time

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

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

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

type LabelResponse

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

type PushRequest

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

type PushResponse

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

type QuerierClient

+ Tail func(ctx context.Context, in *TailRequest, opts ...grpc.CallOption) (Querier_TailClient, error)

type QuerierServer

+ Tail func(*TailRequest, Querier_TailServer) error

+ type Querier_TailClient interface

+ Recv func() (*TailResponse, error)

+ type Querier_TailServer interface

+ Send func(*TailResponse) error

type QueryRequest

+ Selector string

+ func (m *QueryRequest) GetSelector() string

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

type QueryResponse

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

type Stream

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

+ type TailRequest struct

+ DelayFor uint32

+ Limit uint32

+ Query string

+ Start time.Time

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

+ func (*TailRequest) ProtoMessage()

+ func (m *TailRequest) GetDelayFor() uint32

+ func (m *TailRequest) GetLimit() uint32

+ func (m *TailRequest) GetQuery() string

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

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

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

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

+ func (m *TailRequest) Reset()

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

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

+ func (m *TailRequest) XXX_DiscardUnknown()

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

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

+ func (m *TailRequest) XXX_Size() int

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

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

+ func (this *TailRequest) GoString() string

+ func (this *TailRequest) String() string

+ type TailResponse struct

+ DroppedStreams []*DroppedStream

+ Stream *Stream

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

+ func (*TailResponse) ProtoMessage()

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

+ func (m *TailResponse) GetStream() *Stream

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

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

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

+ func (m *TailResponse) Reset()

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

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

+ func (m *TailResponse) XXX_DiscardUnknown()

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

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

+ func (m *TailResponse) XXX_Size() int

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

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

+ func (this *TailResponse) GoString() string

+ func (this *TailResponse) String() string

+ type TimeSeriesChunk struct

+ Chunks []*Chunk

+ FromIngesterId string

+ Labels []*LabelPair

+ UserId string

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

+ func (*TimeSeriesChunk) ProtoMessage()

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

+ func (m *TimeSeriesChunk) GetFromIngesterId() string

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

+ func (m *TimeSeriesChunk) GetUserId() string

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

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

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

+ func (m *TimeSeriesChunk) Reset()

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

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

+ func (m *TimeSeriesChunk) XXX_DiscardUnknown()

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

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

+ func (m *TimeSeriesChunk) XXX_Size() int

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

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

+ func (this *TimeSeriesChunk) GoString() string

+ func (this *TimeSeriesChunk) String() string

+ type TransferChunksResponse struct

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

+ func (*TransferChunksResponse) ProtoMessage()

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

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

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

+ func (m *TransferChunksResponse) Reset()

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

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

+ func (m *TransferChunksResponse) XXX_DiscardUnknown()

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

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

+ func (m *TransferChunksResponse) XXX_Size() int

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

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

+ func (this *TransferChunksResponse) GoString() string

+ func (this *TransferChunksResponse) String() string

+ type UnimplementedIngesterServer struct

+ func (*UnimplementedIngesterServer) TransferChunks(srv Ingester_TransferChunksServer) error

+ type UnimplementedPusherServer struct

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

+ type UnimplementedQuerierServer struct

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

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

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

v0

v0.1.0

Jun 3, 2019

Changes in this version

+ var Direction_name = map[int32]string

+ var Direction_value = map[string]int32

+ var ErrIntOverflowLogproto = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthLogproto = fmt.Errorf("proto: negative length found during unmarshaling")

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

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

+ type Direction int32

+ const BACKWARD

+ const FORWARD

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

+ func (x Direction) String() string

+ type Entry struct

+ Line string

+ Timestamp time.Time

+ func (*Entry) Descriptor() ([]byte, []int)

+ func (*Entry) ProtoMessage()

+ func (m *Entry) GetLine() string

+ func (m *Entry) GetTimestamp() time.Time

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

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

+ func (m *Entry) Reset()

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

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

+ func (m *Entry) XXX_DiscardUnknown()

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

+ func (m *Entry) XXX_Merge(src proto.Message)

+ func (m *Entry) XXX_Size() int

+ func (m *Entry) XXX_Unmarshal(b []byte) error

+ func (this *Entry) Equal(that interface{}) bool

+ func (this *Entry) GoString() string

+ func (this *Entry) String() string

+ type LabelRequest struct

+ Name string

+ Values bool

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

+ func (*LabelRequest) ProtoMessage()

+ func (m *LabelRequest) GetName() string

+ func (m *LabelRequest) GetValues() bool

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

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

+ func (m *LabelRequest) Reset()

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

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

+ func (m *LabelRequest) XXX_DiscardUnknown()

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

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

+ func (m *LabelRequest) XXX_Size() int

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

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

+ func (this *LabelRequest) GoString() string

+ func (this *LabelRequest) String() string

+ type LabelResponse struct

+ Values []string

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

+ func (*LabelResponse) ProtoMessage()

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

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

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

+ func (m *LabelResponse) Reset()

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

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

+ func (m *LabelResponse) XXX_DiscardUnknown()

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

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

+ func (m *LabelResponse) XXX_Size() int

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

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

+ func (this *LabelResponse) GoString() string

+ func (this *LabelResponse) String() string

+ type PushRequest struct

+ Streams []*Stream

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

+ func (*PushRequest) ProtoMessage()

+ func (m *PushRequest) GetStreams() []*Stream

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

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

+ func (m *PushRequest) Reset()

+ func (m *PushRequest) Size() (n int)

+ func (m *PushRequest) Unmarshal(dAtA []byte) error

+ func (m *PushRequest) XXX_DiscardUnknown()

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

+ func (m *PushRequest) XXX_Merge(src proto.Message)

+ func (m *PushRequest) XXX_Size() int

+ func (m *PushRequest) XXX_Unmarshal(b []byte) error

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

+ func (this *PushRequest) GoString() string

+ func (this *PushRequest) String() string

+ type PushResponse struct

+ func (*PushResponse) Descriptor() ([]byte, []int)

+ func (*PushResponse) ProtoMessage()

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

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

+ func (m *PushResponse) Reset()

+ func (m *PushResponse) Size() (n int)

+ func (m *PushResponse) Unmarshal(dAtA []byte) error

+ func (m *PushResponse) XXX_DiscardUnknown()

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

+ func (m *PushResponse) XXX_Merge(src proto.Message)

+ func (m *PushResponse) XXX_Size() int

+ func (m *PushResponse) XXX_Unmarshal(b []byte) error

+ func (this *PushResponse) Equal(that interface{}) bool

+ func (this *PushResponse) GoString() string

+ func (this *PushResponse) String() string

+ type PusherClient interface

+ Push func(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*PushResponse, error)

+ func NewPusherClient(cc *grpc.ClientConn) PusherClient

+ type PusherServer interface

+ Push func(context.Context, *PushRequest) (*PushResponse, error)

+ type QuerierClient interface

+ Label func(ctx context.Context, in *LabelRequest, opts ...grpc.CallOption) (*LabelResponse, error)

+ Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Querier_QueryClient, error)

+ func NewQuerierClient(cc *grpc.ClientConn) QuerierClient

+ type QuerierServer interface

+ Label func(context.Context, *LabelRequest) (*LabelResponse, error)

+ Query func(*QueryRequest, Querier_QueryServer) error

+ type Querier_QueryClient interface

+ Recv func() (*QueryResponse, error)

+ type Querier_QueryServer interface

+ Send func(*QueryResponse) error

+ type QueryRequest struct

+ Direction Direction

+ End time.Time

+ Limit uint32

+ Query string

+ Regex string

+ Start time.Time

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

+ func (*QueryRequest) ProtoMessage()

+ func (m *QueryRequest) GetDirection() Direction

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

+ func (m *QueryRequest) GetLimit() uint32

+ func (m *QueryRequest) GetQuery() string

+ func (m *QueryRequest) GetRegex() string

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

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

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

+ func (m *QueryRequest) Reset()

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

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

+ func (m *QueryRequest) XXX_DiscardUnknown()

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

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

+ func (m *QueryRequest) XXX_Size() int

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

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

+ func (this *QueryRequest) GoString() string

+ func (this *QueryRequest) String() string

+ type QueryResponse struct

+ Streams []*Stream

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

+ func (*QueryResponse) ProtoMessage()

+ func (m *QueryResponse) GetStreams() []*Stream

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

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

+ func (m *QueryResponse) Reset()

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

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

+ func (m *QueryResponse) XXX_DiscardUnknown()

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

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

+ func (m *QueryResponse) XXX_Size() int

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

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

+ func (this *QueryResponse) GoString() string

+ func (this *QueryResponse) String() string

+ type Stream struct

+ Entries []Entry

+ Labels string

+ func (*Stream) Descriptor() ([]byte, []int)

+ func (*Stream) ProtoMessage()

+ func (m *Stream) GetEntries() []Entry

+ func (m *Stream) GetLabels() string

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

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

+ func (m *Stream) Reset()

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

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

+ func (m *Stream) XXX_DiscardUnknown()

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

+ func (m *Stream) XXX_Merge(src proto.Message)

+ func (m *Stream) XXX_Size() int

+ func (m *Stream) XXX_Unmarshal(b []byte) error

+ func (this *Stream) Equal(that interface{}) bool

+ func (this *Stream) GoString() string

+ func (this *Stream) String() string

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