Versions in this module Expand all Collapse all v1 v1.0.1 Sep 7, 2022 v1.0.0 Sep 7, 2022 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 RegisterIngesterServer(s *grpc.Server, srv IngesterServer) + func RegisterPusherServer(s *grpc.Server, srv PusherServer) + func RegisterQuerierServer(s *grpc.Server, srv QuerierServer) + func SizeOfStdTime(t time.Time) int + func StdTimeMarshalTo(t time.Time, data []byte) (int, error) + func StdTimeUnmarshal(t *time.Time, data []byte) error + 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) 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 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 (m *Entry) Equal(that interface{}) bool + func (m *Entry) Marshal() (dAtA []byte, err error) + func (m *Entry) MarshalTo(dAtA []byte) (int, error) + func (m *Entry) Size() (n int) + func (m *Entry) Unmarshal(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 GetChunkIDsRequest struct + End time.Time + Matchers string + Start time.Time + func (*GetChunkIDsRequest) Descriptor() ([]byte, []int) + func (*GetChunkIDsRequest) ProtoMessage() + func (m *GetChunkIDsRequest) GetEnd() time.Time + func (m *GetChunkIDsRequest) GetMatchers() string + func (m *GetChunkIDsRequest) GetStart() time.Time + func (m *GetChunkIDsRequest) Marshal() (dAtA []byte, err error) + func (m *GetChunkIDsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetChunkIDsRequest) Reset() + func (m *GetChunkIDsRequest) Size() (n int) + func (m *GetChunkIDsRequest) Unmarshal(dAtA []byte) error + func (m *GetChunkIDsRequest) XXX_DiscardUnknown() + func (m *GetChunkIDsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetChunkIDsRequest) XXX_Merge(src proto.Message) + func (m *GetChunkIDsRequest) XXX_Size() int + func (m *GetChunkIDsRequest) XXX_Unmarshal(b []byte) error + func (this *GetChunkIDsRequest) Equal(that interface{}) bool + func (this *GetChunkIDsRequest) GoString() string + func (this *GetChunkIDsRequest) String() string + type GetChunkIDsResponse struct + ChunkIDs []string + func (*GetChunkIDsResponse) Descriptor() ([]byte, []int) + func (*GetChunkIDsResponse) ProtoMessage() + func (m *GetChunkIDsResponse) GetChunkIDs() []string + func (m *GetChunkIDsResponse) Marshal() (dAtA []byte, err error) + func (m *GetChunkIDsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetChunkIDsResponse) Reset() + func (m *GetChunkIDsResponse) Size() (n int) + func (m *GetChunkIDsResponse) Unmarshal(dAtA []byte) error + func (m *GetChunkIDsResponse) XXX_DiscardUnknown() + func (m *GetChunkIDsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetChunkIDsResponse) XXX_Merge(src proto.Message) + func (m *GetChunkIDsResponse) XXX_Size() int + func (m *GetChunkIDsResponse) XXX_Unmarshal(b []byte) error + func (this *GetChunkIDsResponse) Equal(that interface{}) bool + func (this *GetChunkIDsResponse) GoString() string + func (this *GetChunkIDsResponse) String() string + 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) 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 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) 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 (r *PushRequest) MarshalJSON() ([]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 + GetChunkIDs func(ctx context.Context, in *GetChunkIDsRequest, opts ...grpc.CallOption) (*GetChunkIDsResponse, error) + 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) + QuerySample func(ctx context.Context, in *SampleQueryRequest, opts ...grpc.CallOption) (Querier_QuerySampleClient, error) + Series func(ctx context.Context, in *SeriesRequest, opts ...grpc.CallOption) (*SeriesResponse, error) + Tail func(ctx context.Context, in *TailRequest, opts ...grpc.CallOption) (Querier_TailClient, error) + TailersCount func(ctx context.Context, in *TailersCountRequest, opts ...grpc.CallOption) (*TailersCountResponse, error) + func NewQuerierClient(cc *grpc.ClientConn) QuerierClient + type QuerierServer interface + GetChunkIDs func(context.Context, *GetChunkIDsRequest) (*GetChunkIDsResponse, error) + Label func(context.Context, *LabelRequest) (*LabelResponse, error) + Query func(*QueryRequest, Querier_QueryServer) error + QuerySample func(*SampleQueryRequest, Querier_QuerySampleServer) error + Series func(context.Context, *SeriesRequest) (*SeriesResponse, error) + Tail func(*TailRequest, Querier_TailServer) error + TailersCount func(context.Context, *TailersCountRequest) (*TailersCountResponse, error) + type Querier_QueryClient interface + Recv func() (*QueryResponse, error) + type Querier_QuerySampleClient interface + Recv func() (*SampleQueryResponse, error) + type Querier_QuerySampleServer interface + Send func(*SampleQueryResponse) 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 + Selector string + Shards []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) GetSelector() string + func (m *QueryRequest) GetShards() []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) 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 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 (s Series) Len() int + func (s Series) Less(i, j int) bool + func (s Series) Swap(i, j int) + func (this *Series) Equal(that interface{}) bool + func (this *Series) GoString() string + func (this *Series) String() string + 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) 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 SeriesIdentifiers []SeriesIdentifier + func (ids SeriesIdentifiers) Len() int + func (ids SeriesIdentifiers) Less(i, j int) bool + func (ids SeriesIdentifiers) Swap(i, j int) + 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) 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) 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 Stream struct + Entries []Entry + Labels string + func (m *Stream) Equal(that interface{}) bool + func (m *Stream) Marshal() (dAtA []byte, err error) + func (m *Stream) MarshalTo(dAtA []byte) (int, error) + func (m *Stream) Size() (n int) + func (m *Stream) Unmarshal(dAtA []byte) error + 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 + type Streams []Stream + func (xs Streams) Len() int + func (xs Streams) Less(i, j int) bool + func (xs Streams) Swap(i, j int) + 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) 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) 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 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 + 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) 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) 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
Go to main page