Versions in this module Expand all Collapse all v2 v2.4.3 Feb 9, 2022 Changes in this version + var ErrIntOverflowStats = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthStats = fmt.Errorf("proto: negative length found during unmarshaling") + func ConvertSecondsToNanoseconds(seconds float64) time.Duration + func JoinIngesters(ctx context.Context, inc Ingester) + func JoinResults(ctx context.Context, res Result) + type Chunk struct + CompressedBytes int64 + DecompressedBytes int64 + DecompressedLines int64 + HeadChunkBytes int64 + HeadChunkLines int64 + TotalDuplicates int64 + func (*Chunk) Descriptor() ([]byte, []int) + func (*Chunk) ProtoMessage() + func (m *Chunk) GetCompressedBytes() int64 + func (m *Chunk) GetDecompressedBytes() int64 + func (m *Chunk) GetDecompressedLines() int64 + func (m *Chunk) GetHeadChunkBytes() int64 + func (m *Chunk) GetHeadChunkLines() int64 + func (m *Chunk) GetTotalDuplicates() int64 + 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 Component int64 + type Context struct + func FromContext(ctx context.Context) *Context + func NewContext(ctx context.Context) (*Context, context.Context) + func (c *Context) AddChunksDownloadTime(i time.Duration) + func (c *Context) AddChunksDownloaded(i int64) + func (c *Context) AddChunksRef(i int64) + func (c *Context) AddCompressedBytes(i int64) + func (c *Context) AddDecompressedBytes(i int64) + func (c *Context) AddDecompressedLines(i int64) + func (c *Context) AddDuplicates(i int64) + func (c *Context) AddHeadChunkBytes(i int64) + func (c *Context) AddHeadChunkLines(i int64) + func (c *Context) AddIngesterBatch(size int64) + func (c *Context) AddIngesterReached(i int32) + func (c *Context) AddIngesterTotalChunkMatched(i int64) + func (c *Context) Ingester() Ingester + func (c *Context) Reset() + func (c *Context) Result(execTime time.Duration, queueTime time.Duration) Result + type Ingester struct + Store Store + TotalBatches int64 + TotalChunksMatched int64 + TotalLinesSent int64 + TotalReached int32 + func (*Ingester) Descriptor() ([]byte, []int) + func (*Ingester) ProtoMessage() + func (i *Ingester) Merge(m Ingester) + func (m *Ingester) GetStore() Store + func (m *Ingester) GetTotalBatches() int64 + func (m *Ingester) GetTotalChunksMatched() int64 + func (m *Ingester) GetTotalLinesSent() int64 + func (m *Ingester) GetTotalReached() int32 + func (m *Ingester) Marshal() (dAtA []byte, err error) + func (m *Ingester) MarshalTo(dAtA []byte) (int, error) + func (m *Ingester) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Ingester) Reset() + func (m *Ingester) Size() (n int) + func (m *Ingester) Unmarshal(dAtA []byte) error + func (m *Ingester) XXX_DiscardUnknown() + func (m *Ingester) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Ingester) XXX_Merge(src proto.Message) + func (m *Ingester) XXX_Size() int + func (m *Ingester) XXX_Unmarshal(b []byte) error + func (this *Ingester) Equal(that interface{}) bool + func (this *Ingester) GoString() string + func (this *Ingester) String() string + type Querier struct + Store Store + func (*Querier) Descriptor() ([]byte, []int) + func (*Querier) ProtoMessage() + func (m *Querier) GetStore() Store + func (m *Querier) Marshal() (dAtA []byte, err error) + func (m *Querier) MarshalTo(dAtA []byte) (int, error) + func (m *Querier) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Querier) Reset() + func (m *Querier) Size() (n int) + func (m *Querier) Unmarshal(dAtA []byte) error + func (m *Querier) XXX_DiscardUnknown() + func (m *Querier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Querier) XXX_Merge(src proto.Message) + func (m *Querier) XXX_Size() int + func (m *Querier) XXX_Unmarshal(b []byte) error + func (q *Querier) Merge(m Querier) + func (this *Querier) Equal(that interface{}) bool + func (this *Querier) GoString() string + func (this *Querier) String() string + type Result struct + Ingester Ingester + Querier Querier + Summary Summary + func (*Result) Descriptor() ([]byte, []int) + func (*Result) ProtoMessage() + func (m *Result) GetIngester() Ingester + func (m *Result) GetQuerier() Querier + func (m *Result) GetSummary() Summary + func (m *Result) Marshal() (dAtA []byte, err error) + func (m *Result) MarshalTo(dAtA []byte) (int, error) + func (m *Result) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Result) Reset() + func (m *Result) Size() (n int) + func (m *Result) Unmarshal(dAtA []byte) error + func (m *Result) XXX_DiscardUnknown() + func (m *Result) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Result) XXX_Merge(src proto.Message) + func (m *Result) XXX_Size() int + func (m *Result) XXX_Unmarshal(b []byte) error + func (r *Result) ComputeSummary(execTime time.Duration, queueTime time.Duration) + func (r *Result) Merge(m Result) + func (r Result) ChunksDownloadTime() time.Duration + func (r Result) Log(log log.Logger) + func (r Result) TotalChunksDownloaded() int64 + func (r Result) TotalChunksRef() int64 + func (r Result) TotalDecompressedBytes() int64 + func (r Result) TotalDecompressedLines() int64 + func (r Result) TotalDuplicates() int64 + func (this *Result) Equal(that interface{}) bool + func (this *Result) GoString() string + func (this *Result) String() string + type Store struct + Chunk Chunk + ChunksDownloadTime int64 + TotalChunksDownloaded int64 + TotalChunksRef int64 + func (*Store) Descriptor() ([]byte, []int) + func (*Store) ProtoMessage() + func (m *Store) GetChunk() Chunk + func (m *Store) GetChunksDownloadTime() int64 + func (m *Store) GetTotalChunksDownloaded() int64 + func (m *Store) GetTotalChunksRef() int64 + func (m *Store) Marshal() (dAtA []byte, err error) + func (m *Store) MarshalTo(dAtA []byte) (int, error) + func (m *Store) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Store) Reset() + func (m *Store) Size() (n int) + func (m *Store) Unmarshal(dAtA []byte) error + func (m *Store) XXX_DiscardUnknown() + func (m *Store) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Store) XXX_Merge(src proto.Message) + func (m *Store) XXX_Size() int + func (m *Store) XXX_Unmarshal(b []byte) error + func (s *Store) Merge(m Store) + func (this *Store) Equal(that interface{}) bool + func (this *Store) GoString() string + func (this *Store) String() string + type Summary struct + BytesProcessedPerSecond int64 + ExecTime float64 + LinesProcessedPerSecond int64 + QueueTime float64 + TotalBytesProcessed int64 + TotalLinesProcessed int64 + func (*Summary) Descriptor() ([]byte, []int) + func (*Summary) ProtoMessage() + func (m *Summary) GetBytesProcessedPerSecond() int64 + func (m *Summary) GetExecTime() float64 + func (m *Summary) GetLinesProcessedPerSecond() int64 + func (m *Summary) GetQueueTime() float64 + func (m *Summary) GetTotalBytesProcessed() int64 + func (m *Summary) GetTotalLinesProcessed() int64 + func (m *Summary) Marshal() (dAtA []byte, err error) + func (m *Summary) MarshalTo(dAtA []byte) (int, error) + func (m *Summary) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Summary) Reset() + func (m *Summary) Size() (n int) + func (m *Summary) Unmarshal(dAtA []byte) error + func (m *Summary) XXX_DiscardUnknown() + func (m *Summary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Summary) XXX_Merge(src proto.Message) + func (m *Summary) XXX_Size() int + func (m *Summary) XXX_Unmarshal(b []byte) error + func (s Summary) Log(log log.Logger) + func (this *Summary) Equal(that interface{}) bool + func (this *Summary) GoString() string + func (this *Summary) String() string
Go to main page