stats

package

Go to main page

Versions in this module

v3

v3.3.1

Dec 4, 2024

v3.3.0

Nov 19, 2024

Changes in this version

type Context

+ func (c *Context) AddIndexPostFilterChunkRefs(i int64)

+ func (c *Context) AddIndexTotalChunkRefs(i int64)

type Index

+ UsedBloomFilters bool

+ func (m *Index) GetUsedBloomFilters() bool

v3.2.2

Dec 4, 2024

v3.2.1

Oct 17, 2024

v3.2.0

Sep 18, 2024

Changes in this version

type Result

+ func (r Result) KVList() []any

v3.1.2

Oct 17, 2024

v3.1.1

Aug 8, 2024

v3.1.0

Jul 2, 2024

Changes in this version

type Index

+ ShardsDuration int64

+ func (m *Index) GetShardsDuration() int64

v3.0.1

Aug 9, 2024

v3.0.0

Apr 8, 2024

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 JoinIndex(ctx context.Context, index Index)

+ func JoinIngesters(ctx context.Context, inc Ingester)

+ func JoinResults(ctx context.Context, res Result)

+ type Cache struct

+ BytesReceived int64

+ BytesSent int64

+ DownloadTime int64

+ EntriesFound int32

+ EntriesRequested int32

+ EntriesStored int32

+ QueryLengthServed int64

+ Requests int32

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

+ func (*Cache) ProtoMessage()

+ func (c *Cache) CacheDownloadTime() time.Duration

+ func (c *Cache) CacheQueryLengthServed() time.Duration

+ func (c *Cache) Merge(m Cache)

+ func (m *Cache) GetBytesReceived() int64

+ func (m *Cache) GetBytesSent() int64

+ func (m *Cache) GetDownloadTime() int64

+ func (m *Cache) GetEntriesFound() int32

+ func (m *Cache) GetEntriesRequested() int32

+ func (m *Cache) GetEntriesStored() int32

+ func (m *Cache) GetQueryLengthServed() int64

+ func (m *Cache) GetRequests() int32

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

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

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

+ func (m *Cache) Reset()

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

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

+ func (m *Cache) XXX_DiscardUnknown()

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

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

+ func (m *Cache) XXX_Size() int

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

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

+ func (this *Cache) GoString() string

+ func (this *Cache) String() string

+ type CacheType string

+ const BloomBlocksCache

+ const BloomFilterCache

+ const BloomMetasCache

+ const ChunkCache

+ const IndexCache

+ const InstantMetricResultsCache

+ const LabelResultCache

+ const ResultCache

+ const SeriesResultCache

+ const StatsResultCache

+ const VolumeResultCache

+ const WriteDedupeCache

+ type Caches struct

+ Chunk Cache

+ Index Cache

+ InstantMetricResult Cache

+ LabelResult Cache

+ Result Cache

+ SeriesResult Cache

+ StatsResult Cache

+ VolumeResult Cache

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

+ func (*Caches) ProtoMessage()

+ func (c *Caches) Merge(m Caches)

+ func (c Caches) Log(log log.Logger)

+ func (m *Caches) GetChunk() Cache

+ func (m *Caches) GetIndex() Cache

+ func (m *Caches) GetInstantMetricResult() Cache

+ func (m *Caches) GetLabelResult() Cache

+ func (m *Caches) GetResult() Cache

+ func (m *Caches) GetSeriesResult() Cache

+ func (m *Caches) GetStatsResult() Cache

+ func (m *Caches) GetVolumeResult() Cache

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

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

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

+ func (m *Caches) Reset()

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

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

+ func (m *Caches) XXX_DiscardUnknown()

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

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

+ func (m *Caches) XXX_Size() int

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

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

+ func (this *Caches) GoString() string

+ func (this *Caches) String() string

+ type Chunk struct

+ CompressedBytes int64

+ DecompressedBytes int64

+ DecompressedLines int64

+ DecompressedStructuredMetadataBytes int64

+ HeadChunkBytes int64

+ HeadChunkLines int64

+ HeadChunkStructuredMetadataBytes int64

+ PostFilterLines 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) GetDecompressedStructuredMetadataBytes() int64

+ func (m *Chunk) GetHeadChunkBytes() int64

+ func (m *Chunk) GetHeadChunkLines() int64

+ func (m *Chunk) GetHeadChunkStructuredMetadataBytes() int64

+ func (m *Chunk) GetPostFilterLines() 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) AddCacheBytesRetrieved(t CacheType, i int)

+ func (c *Context) AddCacheBytesSent(t CacheType, i int)

+ func (c *Context) AddCacheDownloadTime(t CacheType, i time.Duration)

+ func (c *Context) AddCacheEntriesFound(t CacheType, i int)

+ func (c *Context) AddCacheEntriesRequested(t CacheType, i int)

+ func (c *Context) AddCacheEntriesStored(t CacheType, i int)

+ func (c *Context) AddCacheQueryLengthServed(t CacheType, i time.Duration)

+ func (c *Context) AddCacheRequest(t CacheType, i int)

+ func (c *Context) AddChunkRefsFetchTime(i time.Duration)

+ 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) AddCongestionControlLatency(i time.Duration)

+ func (c *Context) AddDecompressedBytes(i int64)

+ func (c *Context) AddDecompressedLines(i int64)

+ func (c *Context) AddDecompressedStructuredMetadataBytes(i int64)

+ func (c *Context) AddDuplicates(i int64)

+ func (c *Context) AddHeadChunkBytes(i int64)

+ func (c *Context) AddHeadChunkLines(i int64)

+ func (c *Context) AddHeadChunkStructuredMetadataBytes(i int64)

+ func (c *Context) AddIngesterBatch(size int64)

+ func (c *Context) AddIngesterReached(i int32)

+ func (c *Context) AddIngesterTotalChunkMatched(i int64)

+ func (c *Context) AddPipelineWrapperFilterdLines(i int64)

+ func (c *Context) AddPostFilterLines(i int64)

+ func (c *Context) AddSplitQueries(num int64)

+ func (c *Context) Caches() Caches

+ func (c *Context) Index() Index

+ func (c *Context) Ingester() Ingester

+ func (c *Context) Reset()

+ func (c *Context) Result(execTime time.Duration, queueTime time.Duration, totalEntriesReturned int) Result

+ func (c *Context) SetQueryReferencedStructuredMetadata()

+ func (c *Context) Store() Store

+ type Index struct

+ PostFilterChunks int64

+ TotalChunks int64

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

+ func (*Index) ProtoMessage()

+ func (i *Index) Merge(m Index)

+ func (m *Index) GetPostFilterChunks() int64

+ func (m *Index) GetTotalChunks() int64

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

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

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

+ func (m *Index) Reset()

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

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

+ func (m *Index) XXX_DiscardUnknown()

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

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

+ func (m *Index) XXX_Size() int

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

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

+ func (this *Index) GoString() string

+ func (this *Index) String() string

+ 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

+ Caches Caches

+ Index Index

+ Ingester Ingester

+ Querier Querier

+ Summary Summary

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

+ func (*Result) ProtoMessage()

+ func (m *Result) GetCaches() Caches

+ func (m *Result) GetIndex() Index

+ 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, totalEntriesReturned int)

+ func (r *Result) Merge(m Result)

+ func (r *Result) MergeSplit(m Result)

+ func (r Result) ChunkRefsFetchTime() time.Duration

+ func (r Result) ChunksDownloadTime() time.Duration

+ func (r Result) CongestionControlLatency() time.Duration

+ func (r Result) Log(log log.Logger)

+ func (r Result) PipelineWrapperFilteredLines() int64

+ func (r Result) QueryReferencedStructuredMetadata() bool

+ 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

+ ChunkRefsFetchTime int64

+ ChunksDownloadTime int64

+ CongestionControlLatency int64

+ PipelineWrapperFilteredLines int64

+ QueryReferencedStructured bool

+ TotalChunksDownloaded int64

+ TotalChunksRef int64

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

+ func (*Store) ProtoMessage()

+ func (m *Store) GetChunk() Chunk

+ func (m *Store) GetChunkRefsFetchTime() int64

+ func (m *Store) GetChunksDownloadTime() int64

+ func (m *Store) GetCongestionControlLatency() int64

+ func (m *Store) GetPipelineWrapperFilteredLines() int64

+ func (m *Store) GetQueryReferencedStructured() bool

+ 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) ChunksDownloadDuration() time.Duration

+ 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

+ Shards int64

+ Splits int64

+ Subqueries int64

+ TotalBytesProcessed int64

+ TotalEntriesReturned int64

+ TotalLinesProcessed int64

+ TotalPostFilterLines int64

+ TotalStructuredMetadataBytesProcessed 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) GetShards() int64

+ func (m *Summary) GetSplits() int64

+ func (m *Summary) GetSubqueries() int64

+ func (m *Summary) GetTotalBytesProcessed() int64

+ func (m *Summary) GetTotalEntriesReturned() int64

+ func (m *Summary) GetTotalLinesProcessed() int64

+ func (m *Summary) GetTotalPostFilterLines() int64

+ func (m *Summary) GetTotalStructuredMetadataBytesProcessed() 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) Merge(m Summary)

+ func (s Summary) Log(log log.Logger)

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

+ func (this *Summary) GoString() string

+ func (this *Summary) String() string

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