Add logging for cache reset

timescale · Oct 3, 2022 · c498b09 · c498b09
1 parent fac8f09
commit c498b09
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/pgmodel/ingestor/dispatcher.go b/pkg/pgmodel/ingestor/dispatcher.go
@@ -154,14 +154,17 @@ func (p *pgxDispatcher) runSeriesEpochSync() {
 
 func (p *pgxDispatcher) refreshSeriesEpoch(existingEpoch *model.SeriesEpoch) (*model.SeriesEpoch, error) {
 	dbEpoch, err := p.getServerEpoch()
+	log.Info("msg", "Refreshing series cache epoch")
 	if err != nil {
+		log.Info("msg", "An error occurred refreshing, will reset series and inverted labels caches")
 		// Trash the cache just in case an epoch change occurred, seems safer
 		p.scache.Reset()
 		// Also trash the inverted labels cache, which can also be invalidated when the series cache is
 		p.invertedLabelsCache.Reset()
 		return nil, err
 	}
 	if existingEpoch == nil || *dbEpoch != *existingEpoch {
+		log.Info("msg", "The local epoch is no longer up-to-date, will reset series and inverted labels caches")
 		p.scache.Reset()
 		// If the series cache needs to be invalidated, so does the inverted labels cache
 		p.invertedLabelsCache.Reset()