Lines Matching defs:persistence
103 type persistence struct { struct
104 basePath string
106 archivedFingerprintToMetrics *index.FingerprintMetricIndex
107 archivedFingerprintToTimeRange *index.FingerprintTimeRangeIndex
108 labelPairToFingerprints *index.LabelPairFingerprintIndex
109 labelNameToLabelValues *index.LabelNameLabelValuesIndex
111 indexingQueue chan indexingOp
112 indexingStopped chan struct{}
113 indexingFlush chan chan int
115 indexingQueueLength prometheus.Gauge
116 indexingQueueCapacity prometheus.Metric
117 indexingBatchSizes prometheus.Summary
118 indexingBatchDuration prometheus.Summary
119 checkpointDuration prometheus.Summary
120 checkpointLastDuration prometheus.Gauge
121 checkpointLastSize prometheus.Gauge
122 checkpointChunksWritten prometheus.Summary
123 dirtyCounter prometheus.Counter
124 startedDirty prometheus.Gauge
125 checkpointing prometheus.Gauge
126 seriesChunksPersisted prometheus.Histogram
128 dirtyMtx sync.Mutex // Protects dirty and becameDirty.
129 dirty bool // true if persistence was started in dirty state.
130 becameDirty bool // true if an inconsistency came up during runtime.
131 pedanticChecks bool // true if crash recovery should check each series.
132 dirtyFileName string // The file used for locking and to mark dirty state.
133 fLock flock.Releaser // The file lock to protect against concurrent usage.
135 shouldSync syncStrategy
137 minShrinkRatio float64 // How much a series file has to shrink to justify dropping chunks.
139 bufPool sync.Pool
359 func (p *persistence) run() {
364 func (p *persistence) Describe(ch chan<- *prometheus.Desc) {
380 func (p *persistence) Collect(ch chan<- prometheus.Metric) {
398 func (p *persistence) isDirty() bool {
406 func (p *persistence) setDirty(err error) {
422 func (p *persistence) fingerprintsForLabelPair(lp model.LabelPair) model.Fingerprints {
435 func (p *persistence) labelValuesForLabelName(ln model.LabelName) (model.LabelValues, error) {
453 …(p *persistence) persistChunks(fp model.Fingerprint, chunks []chunk.Chunk) (index int, err error) {
482 …sistence) loadChunks(fp model.Fingerprint, indexes []int, indexOffset int) ([]chunk.Chunk, error) {
538 …c (p *persistence) loadChunkDescs(fp model.Fingerprint, offsetFromEnd int) ([]*chunk.Desc, error) {
630 func (p *persistence) checkpointSeriesMapAndHeads(
840 func (p *persistence) loadSeriesMapAndHeads() (sm *seriesMap, chunksToPersist int64, err error) {
890 func (p *persistence) dropAndPersistChunks(
1072 func (p *persistence) deleteSeriesFile(fp model.Fingerprint) (int, error) {
1093 …ce) quarantineSeriesFile(fp model.Fingerprint, quarantineReason error, metric model.Metric) error {
1131 func (p *persistence) seriesFileModTime(fp model.Fingerprint) time.Time {
1143 func (p *persistence) indexMetric(fp model.Fingerprint, m model.Metric) {
1154 func (p *persistence) unindexMetric(fp model.Fingerprint, m model.Metric) {
1162 func (p *persistence) waitForIndexing() {
1175 func (p *persistence) archiveMetric(
1190 func (p *persistence) hasArchivedMetric(fp model.Fingerprint) (
1204 func (p *persistence) updateArchivedTimeRange(
1213 …c (p *persistence) fingerprintsModifiedBefore(beforeTime model.Time) ([]model.Fingerprint, error) {
1234 func (p *persistence) archivedMetric(fp model.Fingerprint) (model.Metric, error) {
1247 func (p *persistence) purgeArchivedMetric(fp model.Fingerprint) (err error) {
1280 func (p *persistence) unarchiveMetric(fp model.Fingerprint) (deletedAnything bool, err error) {
1300 func (p *persistence) close() error {
1336 func (p *persistence) dirNameForFingerprint(fp model.Fingerprint) string {
1341 func (p *persistence) fileNameForFingerprint(fp model.Fingerprint) string {
1346 func (p *persistence) tempFileNameForFingerprint(fp model.Fingerprint) string {
1351 func (p *persistence) openChunkFileForWriting(fp model.Fingerprint) (*os.File, error) {
1365 func (p *persistence) closeChunkFile(f *os.File) {
1376 func (p *persistence) openChunkFileForReading(fp model.Fingerprint) (*os.File, error) {
1380 func (p *persistence) headsFileName() string {
1384 func (p *persistence) headsTempFileName() string {
1388 func (p *persistence) mappingsFileName() string {
1392 func (p *persistence) mappingsTempFileName() string {
1396 func (p *persistence) processIndexingQueue() {
1525 func (p *persistence) checkpointFPMappings(fpm fpMappings) (err error) {
1591 func (p *persistence) loadFPMappings() (fpMappings, model.Fingerprint, error) {
1658 func (p *persistence) writeChunks(w io.Writer, chunks []chunk.Chunk) error {