Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

logproto

package

Go to main page

Versions in this module

v1

v1.10.0

Apr 21, 2026

v1.8.2

Apr 21, 2026

v1.8.1

Nov 17, 2025

v1.8.0

Nov 5, 2025

v1.7.0

Aug 25, 2025

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")

+ var ErrUnexpectedEndOfGroupLogproto = fmt.Errorf("proto: unexpected end of group")

+ 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) 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 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) 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 struct

+ Line string

+ Timestamp time.Time

+ func (m *Entry) Equal(that any) bool

+ 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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) 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 struct

+ End *time.Time

+ Name string

+ Query 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) GetQuery() 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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) 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 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) 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 Stream struct

+ Entries []Entry

+ Labels string

+ func (m *Stream) Equal(that any) bool

+ 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) MarshalToSizedBuffer(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) 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) 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 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) MarshalToSizedBuffer(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) MarshalToSizedBuffer(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) 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) GetChunkIDs(ctx context.Context, req *GetChunkIDsRequest) (*GetChunkIDsResponse, error)

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

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

+ func (*UnimplementedQuerierServer) QuerySample(req *SampleQueryRequest, srv Querier_QuerySampleServer) error

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

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

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