logproto

package

Go to main page

Versions in this module

v1

v1.6.1

Aug 24, 2020

v1.6.0

Aug 13, 2020

Changes in this version

type QuerierClient

+ QuerySample func(ctx context.Context, in *SampleQueryRequest, opts ...grpc.CallOption) (Querier_QuerySampleClient, error)

type QuerierServer

+ QuerySample func(*SampleQueryRequest, Querier_QuerySampleServer) error

+ type Querier_QuerySampleClient interface

+ Recv func() (*SampleQueryResponse, error)

+ type Querier_QuerySampleServer interface

+ Send func(*SampleQueryResponse) error

type QueryRequest

+ Shards []string

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

+ type Sample struct

+ Hash uint64

+ Timestamp int64

+ Value float64

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

+ func (*Sample) ProtoMessage()

+ func (m *Sample) GetHash() uint64

+ func (m *Sample) GetTimestamp() int64

+ func (m *Sample) GetValue() float64

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

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

+ func (m *Sample) Reset()

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

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

+ func (m *Sample) XXX_DiscardUnknown()

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

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

+ func (m *Sample) XXX_Size() int

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

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

+ func (this *Sample) GoString() string

+ func (this *Sample) String() string

+ type SampleQueryRequest struct

+ End time.Time

+ Selector string

+ Shards []string

+ Start time.Time

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

+ func (*SampleQueryRequest) ProtoMessage()

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

+ func (m *SampleQueryRequest) GetSelector() string

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

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

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

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

+ func (m *SampleQueryRequest) Reset()

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

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

+ func (m *SampleQueryRequest) XXX_DiscardUnknown()

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

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

+ func (m *SampleQueryRequest) XXX_Size() int

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

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

+ func (this *SampleQueryRequest) GoString() string

+ func (this *SampleQueryRequest) String() string

+ type SampleQueryResponse struct

+ Series []Series

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

+ func (*SampleQueryResponse) ProtoMessage()

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

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

+ func (m *SampleQueryResponse) Reset()

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

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

+ func (m *SampleQueryResponse) XXX_DiscardUnknown()

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

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

+ func (m *SampleQueryResponse) XXX_Size() int

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

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

+ func (this *SampleQueryResponse) GoString() string

+ func (this *SampleQueryResponse) String() string

+ type Series struct

+ Labels string

+ Samples []Sample

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

+ func (*Series) ProtoMessage()

+ func (m *Series) GetLabels() string

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

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

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

+ func (m *Series) Reset()

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

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

+ func (m *Series) XXX_DiscardUnknown()

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

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

+ func (m *Series) XXX_Size() int

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

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

+ func (this *Series) GoString() string

+ func (this *Series) String() string

+ type Streams []Stream

+ func (xs Streams) Len() int

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

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

v1.5.0

May 20, 2020

Changes in this version

+ func SizeOfStdTime(t time.Time) int

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

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

+ type EntryAdapter struct

+ Line string

+ Timestamp time.Time

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

+ func (*EntryAdapter) ProtoMessage()

+ func (m *EntryAdapter) GetLine() string

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

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

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

+ func (m *EntryAdapter) Reset()

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

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

+ func (m *EntryAdapter) XXX_DiscardUnknown()

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

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

+ func (m *EntryAdapter) XXX_Size() int

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

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

+ func (this *EntryAdapter) GoString() string

+ func (this *EntryAdapter) String() string

+ type SeriesIdentifiers []SeriesIdentifier

+ func (ids SeriesIdentifiers) Len() int

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

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

+ type StreamAdapter struct

+ Entries []EntryAdapter

+ Labels string

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

+ func (*StreamAdapter) ProtoMessage()

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

+ func (m *StreamAdapter) GetLabels() string

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

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

+ func (m *StreamAdapter) Reset()

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

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

+ func (m *StreamAdapter) XXX_DiscardUnknown()

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

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

+ func (m *StreamAdapter) XXX_Size() int

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

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

+ func (this *StreamAdapter) GoString() string

+ func (this *StreamAdapter) String() string

v1.4.1

Apr 6, 2020

v1.4.0

Apr 1, 2020

Changes in this version

type QuerierClient

+ TailersCount func(ctx context.Context, in *TailersCountRequest, opts ...grpc.CallOption) (*TailersCountResponse, error)

type QuerierServer

+ TailersCount func(context.Context, *TailersCountRequest) (*TailersCountResponse, error)

+ type TailersCountRequest struct

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

+ func (*TailersCountRequest) ProtoMessage()

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

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

+ func (m *TailersCountRequest) Reset()

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

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

+ func (m *TailersCountRequest) XXX_DiscardUnknown()

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

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

+ func (m *TailersCountRequest) XXX_Size() int

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

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

+ func (this *TailersCountRequest) GoString() string

+ func (this *TailersCountRequest) String() string

+ type TailersCountResponse struct

+ Count uint32

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

+ func (*TailersCountResponse) ProtoMessage()

+ func (m *TailersCountResponse) GetCount() uint32

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

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

+ func (m *TailersCountResponse) Reset()

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

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

+ func (m *TailersCountResponse) XXX_DiscardUnknown()

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

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

+ func (m *TailersCountResponse) XXX_Size() int

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

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

+ func (this *TailersCountResponse) GoString() string

+ func (this *TailersCountResponse) String() string

v1.3.0

Jan 22, 2020

Changes in this version

type QuerierClient

+ Series func(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (*SeriesResponse, error)

type QuerierServer

+ Series func(context.Context, *SeriesRequest) (*SeriesResponse, error)

+ type SeriesIdentifier struct

+ Labels map[string]string

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

+ func (*SeriesIdentifier) ProtoMessage()

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

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

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

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

+ func (m *SeriesIdentifier) Reset()

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

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

+ func (m *SeriesIdentifier) XXX_DiscardUnknown()

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

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

+ func (m *SeriesIdentifier) XXX_Size() int

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

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

+ func (this *SeriesIdentifier) GoString() string

+ func (this *SeriesIdentifier) String() string

+ type SeriesRequest struct

+ End time.Time

+ Groups []string

+ Start time.Time

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

+ func (*SeriesRequest) ProtoMessage()

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

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

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

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

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

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

+ func (m *SeriesRequest) Reset()

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

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

+ func (m *SeriesRequest) XXX_DiscardUnknown()

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

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

+ func (m *SeriesRequest) XXX_Size() int

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

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

+ func (this *SeriesRequest) GoString() string

+ func (this *SeriesRequest) String() string

+ type SeriesResponse struct

+ Series []SeriesIdentifier

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

+ func (*SeriesResponse) ProtoMessage()

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

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

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

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

+ func (m *SeriesResponse) Reset()

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

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

+ func (m *SeriesResponse) XXX_DiscardUnknown()

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

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

+ func (m *SeriesResponse) XXX_Size() int

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

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

+ func (this *SeriesResponse) GoString() string

+ func (this *SeriesResponse) String() string

type UnimplementedQuerierServer

+ func (*UnimplementedQuerierServer) Series(ctx context.Context, req *SeriesRequest) (*SeriesResponse, error)

v1.2.0

Dec 9, 2019

v1.1.0

Dec 4, 2019

v1.0.2

Jul 26, 2019

v1.0.1

Jul 25, 2019

v1.0.0

Nov 20, 2019

v0

v0.4.0

Oct 24, 2019

Changes in this version

type QueryRequest

+ Selector string

+ func (m *QueryRequest) GetSelector() string

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

Incompatible versions in this module

v6.7.8+incompatible

Aug 1, 2019

Other modules containing this package

github.com/grafana/loki/v3

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