logproto

package

Go to main page

Versions in this module

v1

v1.0.2

Jul 26, 2019

v1.0.1

Jul 25, 2019

v0

v0.3.0

Aug 18, 2019

v0.2.0

Aug 2, 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

+ 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

+ Regex 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) GetRegex() 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.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