Versions in this module Expand all Collapse all v1 v1.0.2 Jul 26, 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 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) 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 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 + End *time.Time + Name string + Start *time.Time + Values bool + func (*LabelRequest) Descriptor() ([]byte, []int) + func (*LabelRequest) ProtoMessage() + func (m *LabelRequest) GetEnd() *time.Time + func (m *LabelRequest) GetName() string + func (m *LabelRequest) GetStart() *time.Time + 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) + Tail func(ctx context.Context, in *TailRequest, opts ...grpc.CallOption) (Querier_TailClient, error) + func NewQuerierClient(cc *grpc.ClientConn) QuerierClient + type QuerierServer interface + Label func(context.Context, *LabelRequest) (*LabelResponse, error) + Query func(*QueryRequest, Querier_QueryServer) error + Tail func(*TailRequest, Querier_TailServer) error + type Querier_QueryClient interface + Recv func() (*QueryResponse, error) + type Querier_QueryServer interface + Send func(*QueryResponse) error + type Querier_TailClient interface + Recv func() (*TailResponse, error) + type Querier_TailServer interface + Send func(*TailResponse) 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 + 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) 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) 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 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
Go to main page