storage

Sep 23, 2024

Changes in this version

type Metrics

+ InvalidRawMetricNames uint64

+ NaNValueRows uint64

+ RowsReceivedTotal uint64

Mar 1, 2024

Changes in this version

type Metrics

+ SnapshotsCount uint64

type TableMetrics

+ LastPartition partitionMetrics

Jul 27, 2023

Changes in this version

type MetricName

+ func (mn *MetricName) SetTagBytes(key, value []byte)

type Metrics

+ NewTimeseriesCreated uint64

+ TimeseriesPreCreated uint64

+ TimeseriesRepopulated uint64

May 18, 2023

Changes in this version

type Storage

+ func MustOpenStorage(path string, retentionMsecs int64, maxHourlySeries, maxDailySeries int) *Storage

Jan 11, 2023

Changes in this version

type MetricName

+ func (mn *MetricName) MoveFrom(src *MetricName)

Dec 11, 2022

Changes in this version

+ func SetDataFlushInterval(d time.Duration)

+ func SetMergeWorkersCount(n int)

type TableMetrics

+ func (pm *TableMetrics) TotalRowsCount() uint64

Oct 28, 2022

Changes in this version

+ func SetTagFiltersCacheSize(size int)

type IndexDBMetrics

+ TagFiltersToMetricIDsCacheMisses uint64

+ TagFiltersToMetricIDsCacheRequests uint64

+ TagFiltersToMetricIDsCacheSize uint64

+ TagFiltersToMetricIDsCacheSizeBytes uint64

+ TagFiltersToMetricIDsCacheSizeMaxBytes uint64

Aug 30, 2022

Changes in this version

type Metrics

+ DailySeriesLimitCurrentSeries uint64

+ DailySeriesLimitMaxSeries uint64

+ HourlySeriesLimitCurrentSeries uint64

+ HourlySeriesLimitMaxSeries uint64

Jul 14, 2022

Changes in this version

+ func TimestampToHumanReadableFormat(timestamp int64) string

type MetricName

+ func (mn *MetricName) UnmarshalString(s string) error

type Metrics

+ NextRetentionSeconds uint64

type SearchQuery

+ func (sq *SearchQuery) GetTimeRange() TimeRange

type Storage

+ func (s *Storage) DeleteSeries(qt *querytracer.Tracer, tfss []*TagFilters) (int, error)

Jun 20, 2022

Changes in this version

+ func SetRetentionTimezoneOffset(offset time.Duration)

+ func SetTagFilterCacheSize(size int)

type Storage

+ func (s *Storage) GetTSDBStatus(qt *querytracer.Tracer, tfss []*TagFilters, date uint64, focusLabel string, ...) (*TSDBStatus, error)

+ func (s *Storage) SearchLabelNamesWithFiltersOnTimeRange(qt *querytracer.Tracer, tfss []*TagFilters, tr TimeRange, ...) ([]string, error)

+ func (s *Storage) SearchLabelValuesWithFiltersOnTimeRange(qt *querytracer.Tracer, labelName string, tfss []*TagFilters, tr TimeRange, ...) ([]string, error)

type TSDBStatus

+ SeriesCountByFocusLabelValue []TopHeapEntry

+ SeriesCountByLabelName []TopHeapEntry

+ TotalLabelValuePairs uint64

+ TotalSeries uint64

May 5, 2022

Changes in this version

type Storage

+ func (s *Storage) DeleteStaleSnapshots(maxAge time.Duration) error

Apr 7, 2022

Changes in this version

+ func RegexpCacheMaxSizeBytes() int

+ func RegexpCacheSizeBytes() int

+ func RegexpPrefixesCacheMaxSizeBytes() int

+ func RegexpPrefixesCacheMisses() uint64

+ func RegexpPrefixesCacheRequests() uint64

+ func RegexpPrefixesCacheSize() int

+ func RegexpPrefixesCacheSizeBytes() int

type SearchQuery

+ MaxMetrics int

Feb 22, 2022

Changes in this version

+ func SetTSIDCacheSize(size int)

Feb 14, 2022

Changes in this version

type IndexDBMetrics

+ TimeseriesRepopulated uint64

Dec 20, 2021

Changes in this version

+ func GetDedupInterval() int64

+ func SetDedupInterval(dedupInterval time.Duration)

+ func SetMaxLabelValueLen(n int)

Dec 2, 2021

Changes in this version

type IndexDBMetrics

+ TagFiltersCacheSizeMaxBytes uint64

type Metrics

+ MetricIDCacheSizeMaxBytes uint64

+ MetricNameCacheSizeMaxBytes uint64

+ TSIDCacheSizeMaxBytes uint64

Oct 8, 2021

Changes in this version

+ func SetFreeDiskSpaceLimit(bytes int)

type Storage

+ func (s *Storage) IsReadOnly() bool

Aug 15, 2021

Changes in this version

type BlockRef

+ func (br *BlockRef) RowsCount() int

type IndexDBMetrics

+ GlobalSearchCalls uint64

Jul 15, 2021

Changes in this version

type IndexDBMetrics

+ TagFiltersCacheMisses uint64

+ TagFiltersCacheRequests uint64

+ TagFiltersCacheSize uint64

+ TagFiltersCacheSizeBytes uint64

May 24, 2021

Changes in this version

type MetricName

+ func (mn *MetricName) UnmarshalRaw(src []byte) error

type MetricRow

+ func (mr *MetricRow) UnmarshalX(src []byte) ([]byte, error)

type Metrics

+ DailySeriesLimitRowsDropped uint64

+ HourlySeriesLimitRowsDropped uint64

type Storage

+ func (s *Storage) GetTSDBStatusWithFiltersForDate(tfss []*TagFilters, date uint64, topN int, deadline uint64) (*TSDBStatus, error)

Mar 17, 2021

Changes in this version

+ func SetLogNewSeries(ok bool)

Feb 18, 2021

Changes in this version

type IndexDBMetrics

+ CompositeFilterMissingConversions uint64

+ CompositeFilterSuccessConversions uint64

+ MinTimestampForCompositeIndex uint64

Feb 3, 2021

Changes in this version

type Storage

+ func (s *Storage) SearchGraphitePaths(tr TimeRange, query []byte, maxPaths int, deadline uint64) ([]string, error)

type TagFilters

+ func (tfs *TagFilters) AddGraphiteQuery(query []byte, paths []string, isNegative bool)

Nov 16, 2020

Changes in this version

type SearchQuery

+ func NewSearchQuery(start, end int64, tagFilterss [][]TagFilter) *SearchQuery

type Storage

+ func (s *Storage) DebugFlush()

+ func (s *Storage) RegisterMetricNames(mrs []MetricRow) error

+ func (s *Storage) SearchMetricNames(tfss []*TagFilters, tr TimeRange, maxMetrics int, deadline uint64) ([]MetricName, error)

Nov 7, 2020

Changes in this version

type BlockRef

+ func (br *BlockRef) Init(pr PartRef, data []byte) error

+ func (br *BlockRef) Marshal(dst []byte) []byte

+ func (br *BlockRef) PartRef() PartRef

+ type PartRef struct

type Storage

+ func (s *Storage) SearchTagKeysOnTimeRange(tr TimeRange, maxTagKeys int, deadline uint64) ([]string, error)

+ func (s *Storage) SearchTagValuesOnTimeRange(tagKey []byte, tr TimeRange, maxTagValues int, deadline uint64) ([]string, error)

Oct 13, 2020

Changes in this version

+ func SetFinalMergeDelay(delay time.Duration)

type Metrics

+ RowsAddedTotal uint64

Sep 29, 2020

Changes in this version

type Block

+ func (b *Block) AppendRowsWithTimeRangeFilter(dstTimestamps []int64, dstValues []float64, tr TimeRange) ([]int64, []float64)

+ func (b *Block) MarshalPortable(dst []byte) []byte

+ func (b *Block) UnmarshalPortable(src []byte) ([]byte, error)

Sep 22, 2020

Changes in this version

type Storage

+ func (s *Storage) ForceMergePartitions(partitionNamePrefix string) error

Sep 11, 2020

Changes in this version

type Metrics

+ TimestampsBlocksMerged uint64

+ TimestampsBytesSaved uint64

type Storage

+ func (s *Storage) SearchTagValueSuffixes(tr TimeRange, tagKey, tagValuePrefix []byte, delimiter byte, ...) ([]string, error)

Aug 15, 2020

Changes in this version

+ var ErrDeadlineExceeded = fmt.Errorf("deadline exceeded")

Aug 9, 2020

Changes in this version

type Metrics

+ SearchTSIDsConcurrencyCapacity uint64

+ SearchTSIDsConcurrencyCurrent uint64

+ SearchTSIDsConcurrencyLimitReached uint64

+ SearchTSIDsConcurrencyLimitTimeout uint64

Jul 8, 2020

Changes in this version

type Metrics

+ SearchDelays uint64

Jun 25, 2020

Changes in this version

type MetricName

+ func (mn *MetricName) SetTags(addTags []string, src *MetricName)

Jun 18, 2020

Changes in this version

+ var MetricsWithDroppedLabels uint64

+ var TooLongLabelNames uint64

+ var TooLongLabelValues uint64

May 16, 2020

Changes in this version

type Metrics

+ SlowMetricNameLoads uint64

+ SlowPerDayIndexInserts uint64

+ SlowRowInserts uint64

May 12, 2020

Changes in this version

type Metrics

+ NextDayMetricIDCacheSize uint64

+ NextDayMetricIDCacheSizeBytes uint64

Apr 27, 2020

Changes in this version

+ type BlockRef struct

+ func (br *BlockRef) MustReadBlock(dst *Block, fetchData bool)

+ type MetricBlockRef struct

+ BlockRef *BlockRef

+ MetricName []byte

type Search

+ MetricBlockRef MetricBlockRef

type Storage

+ func (s *Storage) GetTSDBStatusForDate(date uint64, topN int) (*TSDBStatus, error)

+ type TSDBStatus struct

+ LabelValueCountByLabelName []TopHeapEntry

+ SeriesCountByLabelValuePair []TopHeapEntry

+ SeriesCountByMetricName []TopHeapEntry

+ type TopHeapEntry struct

+ Count uint64

+ Name string

Mar 31, 2020

Changes in this version

type TagFilters

+ func (tfs *TagFilters) Finalize() []*TagFilters

Mar 3, 2020

Changes in this version

type Metrics

+ DedupsDuringMerge uint64

Feb 13, 2020

Changes in this version

+ func SetMinScrapeIntervalForDeduplication(interval time.Duration)

Feb 4, 2020

Changes in this version

+ func DeduplicateSamples(srcTimestamps []int64, srcValues []float64) ([]int64, []float64)

type Metrics

+ PrefetchedMetricIDsSize uint64

+ PrefetchedMetricIDsSizeBytes uint64

Dec 2, 2019

Changes in this version

type IndexDBMetrics

+ MissingMetricNamesForMetricID uint64

Nov 16, 2019

Changes in this version

type Metrics

+ HourMetricIDCacheSizeBytes uint64

Nov 13, 2019

Changes in this version

+ func DisableRecentHourIndex()

type Metrics

+ RecentHourInvertedIndexSizeBytes uint64

Nov 11, 2019

Changes in this version

type IndexDBMetrics

+ DateRangeSearchCalls uint64

+ DateRangeSearchHits uint64

+ IndexBlocksWithMetricIDsIncorrectOrder uint64

+ IndexBlocksWithMetricIDsProcessed uint64

+ NewTimeseriesCreated uint64

+ RecentHourInvertedIndexSearchCalls uint64

+ RecentHourInvertedIndexSearchHits uint64

type Metrics

+ DateMetricIDCacheResetsCount uint64

+ DateMetricIDCacheSyncsCount uint64

+ RecentHourInvertedIndexPendingMetricIDsSize uint64

+ RecentHourInvertedIndexSize uint64

+ RecentHourInvertedIndexUniqueTagPairsSize uint64

Oct 31, 2019

Changes in this version

+ func SetBigMergeWorkersCount(n int)

+ func SetSmallMergeWorkersCount(n int)

Oct 9, 2019

Changes in this version

type Tag

+ func (tag *Tag) Equal(t *Tag) bool

+ func (tag *Tag) Reset()

Aug 28, 2019

Changes in this version

+ func SetMaxLabelsPerTimeseries(maxLabels int)

Aug 6, 2019

Changes in this version

type Metrics

+ AddRowsConcurrencyCapacity uint64

+ AddRowsConcurrencyCurrent uint64

+ AddRowsConcurrencyDroppedRows uint64

+ AddRowsConcurrencyLimitReached uint64

+ AddRowsConcurrencyLimitTimeout uint64

Jul 31, 2019

Changes in this version

type Metrics

+ TooBigTimestampRows uint64

+ TooSmallTimestampRows uint64

Jul 11, 2019

Changes in this version

type IndexDBMetrics

+ TagCacheSizeBytes uint64

+ UselessTagFiltersCacheSizeBytes uint64

type Metrics

+ DateMetricIDCacheSizeBytes uint64

+ MetricIDCacheSizeBytes uint64

+ MetricNameCacheSizeBytes uint64

+ TSIDCacheSizeBytes uint64

Jun 21, 2019

Changes in this version

type Metrics

+ HourMetricIDCacheSize uint64

Jun 10, 2019

Changes in this version

type IndexDBMetrics

+ DateMetricIDsSearchCalls uint64

+ DateMetricIDsSearchHits uint64

+ RecentHourMetricIDsSearchCalls uint64

+ RecentHourMetricIDsSearchHits uint64

+ UselessTagFiltersCacheBytesSize uint64

+ UselessTagFiltersCacheMisses uint64

+ UselessTagFiltersCacheRequests uint64

+ UselessTagFiltersCacheSize uint64

type Storage

+ func (s *Storage) SearchTagEntries(maxTagKeys, maxTagValues int) ([]TagEntry, error)

+ type TagEntry struct

+ Key string

+ Values []string

May 22, 2019

Changes in this version

+ func MarshalBlock(dst []byte, b *Block) []byte

+ func MarshalMetricNameRaw(dst []byte, labels []prompb.Label) []byte

+ func PutMetricName(mn *MetricName)

+ func RegexpCacheMisses() uint64

+ func RegexpCacheRequests() uint64

+ func RegexpCacheSize() int

+ func UnmarshalBlock(dst *Block, src []byte) ([]byte, error)

+ type Block struct

+ func (b *Block) CopyFrom(src *Block)

+ func (b *Block) Init(tsid *TSID, timestamps, values []int64, scale int16, precisionBits uint8)

+ func (b *Block) MarshalData(timestampsBlockOffset, valuesBlockOffset uint64) ([]byte, []byte, []byte)

+ func (b *Block) Reset()

+ func (b *Block) RowsCount() int

+ func (b *Block) Scale() int16

+ func (b *Block) Timestamps() []int64

+ func (b *Block) UnmarshalData() error

+ func (b *Block) Values() []int64

+ type IndexDBMetrics struct

+ DeletedMetricsCount uint64

+ IndexDBRefCount uint64

+ MissingTSIDsForMetricID uint64

+ TagCacheBytesSize uint64

+ TagCacheMisses uint64

+ TagCacheRequests uint64

+ TagCacheSize uint64

+ type MetricBlock struct

+ Block *Block

+ MetricName []byte

+ func (mb *MetricBlock) Marshal(dst []byte) []byte

+ func (mb *MetricBlock) Unmarshal(src []byte) ([]byte, error)

+ type MetricName struct

+ MetricGroup []byte

+ Tags []Tag

+ func GetMetricName() *MetricName

+ func (mn *MetricName) AddMissingTags(addTags []string, src *MetricName)

+ func (mn *MetricName) AddTag(key, value string)

+ func (mn *MetricName) AddTagBytes(key, value []byte)

+ func (mn *MetricName) CopyFrom(src *MetricName)

+ func (mn *MetricName) GetTagValue(tagKey string) []byte

+ func (mn *MetricName) Marshal(dst []byte) []byte

+ func (mn *MetricName) RemoveTag(tagKey string)

+ func (mn *MetricName) RemoveTagsIgnoring(ignoringTags []string)

+ func (mn *MetricName) RemoveTagsOn(onTags []string)

+ func (mn *MetricName) Reset()

+ func (mn *MetricName) ResetMetricGroup()

+ func (mn *MetricName) String() string

+ func (mn *MetricName) Unmarshal(src []byte) error

+ type MetricRow struct

+ MetricNameRaw []byte

+ Timestamp int64

+ Value float64

+ func (mr *MetricRow) CopyFrom(src *MetricRow)

+ func (mr *MetricRow) Marshal(dst []byte) []byte

+ func (mr *MetricRow) String() string

+ func (mr *MetricRow) Unmarshal(src []byte) ([]byte, error)

+ type Metrics struct

+ DateMetricIDCacheBytesSize uint64

+ DateMetricIDCacheCollisions uint64

+ DateMetricIDCacheMisses uint64

+ DateMetricIDCacheRequests uint64

+ DateMetricIDCacheSize uint64

+ IndexDBMetrics IndexDBMetrics

+ MetricIDCacheBytesSize uint64

+ MetricIDCacheCollisions uint64

+ MetricIDCacheMisses uint64

+ MetricIDCacheRequests uint64

+ MetricIDCacheSize uint64

+ MetricNameCacheBytesSize uint64

+ MetricNameCacheCollisions uint64

+ MetricNameCacheMisses uint64

+ MetricNameCacheRequests uint64

+ MetricNameCacheSize uint64

+ TSIDCacheBytesSize uint64

+ TSIDCacheCollisions uint64

+ TSIDCacheMisses uint64

+ TSIDCacheRequests uint64

+ TSIDCacheSize uint64

+ TableMetrics TableMetrics

+ func (m *Metrics) Reset()

+ type Search struct

+ MetricBlock MetricBlock

+ MissingMetricNamesForMetricID uint64

+ func (s *Search) Error() error

+ func (s *Search) Init(storage *Storage, tfss []*TagFilters, tr TimeRange, maxMetrics int)

+ func (s *Search) MustClose()

+ func (s *Search) NextMetricBlock() bool

+ type SearchQuery struct

+ MaxTimestamp int64

+ MinTimestamp int64

+ TagFilterss [][]TagFilter

+ func (sq *SearchQuery) Marshal(dst []byte) []byte

+ func (sq *SearchQuery) String() string

+ func (sq *SearchQuery) Unmarshal(src []byte) ([]byte, error)

+ type Storage struct

+ func OpenStorage(path string, retentionMonths int) (*Storage, error)

+ func (s *Storage) AddRows(mrs []MetricRow, precisionBits uint8) error

+ func (s *Storage) CreateSnapshot() (string, error)

+ func (s *Storage) DeleteMetrics(tfss []*TagFilters) (int, error)

+ func (s *Storage) DeleteSnapshot(snapshotName string) error

+ func (s *Storage) GetSeriesCount() (uint64, error)

+ func (s *Storage) ListSnapshots() ([]string, error)

+ func (s *Storage) MustClose()

+ func (s *Storage) SearchTagKeys(maxTagKeys int) ([]string, error)

+ func (s *Storage) SearchTagValues(tagKey []byte, maxTagValues int) ([]string, error)

+ func (s *Storage) UpdateMetrics(m *Metrics)

+ type TSID struct

+ InstanceID uint32

+ JobID uint32

+ MetricGroupID uint64

+ MetricID uint64

+ func (t *TSID) Less(b *TSID) bool

+ func (t *TSID) Marshal(dst []byte) []byte

+ func (t *TSID) Unmarshal(src []byte) ([]byte, error)

+ type TableMetrics struct

+ PartitionsRefCount uint64

+ type Tag struct

+ Key []byte

+ Value []byte

+ func (tag *Tag) Marshal(dst []byte) []byte

+ func (tag *Tag) Unmarshal(src []byte) ([]byte, error)

+ type TagFilter struct

+ IsNegative bool

+ IsRegexp bool

+ Key []byte

+ Value []byte

+ func (tf *TagFilter) Marshal(dst []byte) []byte

+ func (tf *TagFilter) String() string

+ func (tf *TagFilter) Unmarshal(src []byte) ([]byte, error)

+ type TagFilters struct

+ func NewTagFilters() *TagFilters

+ func (tfs *TagFilters) Add(key, value []byte, isNegative, isRegexp bool) error

+ func (tfs *TagFilters) Reset()

+ func (tfs *TagFilters) String() string

+ type TimeRange struct

+ MaxTimestamp int64

+ MinTimestamp int64

+ func (tr *TimeRange) String() string