Searched refs:tombstonesLoader (Results 1 – 6 of 6) sorted by relevance
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/purger/ |
| H A D | tombstones_test.go | 100 tombstonesLoader := NewTombstonesLoader(deleteStore, nil)
109 tombstonesAnalyzer, err := tombstonesLoader.GetPendingTombstones(userID)
158 tombstonesLoader := NewTombstonesLoader(s, nil)
195 …assert.Equal(t, tc.expectedResultsCacheGenNumber, tombstonesLoader.GetResultsCacheGenNumber(tc.ten…
196 …assert.Equal(t, tc.expectedStoreCacheGenNumber, tombstonesLoader.GetStoreCacheGenNumber(tc.tenantI…
203 tombstonesLoader := NewTombstonesLoader(s, nil)
204 tombstonesLoader.getCacheGenNumbers("test")
207 require.NotNil(t, tombstonesLoader.reloadTombstones())
210 require.NotNil(t, tombstonesLoader.getCacheGenNumbers("test2"))
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/purger/ |
| H A D | tombstones_test.go | 100 tombstonesLoader := NewTombstonesLoader(deleteStore, nil)
109 tombstonesAnalyzer, err := tombstonesLoader.GetPendingTombstones(userID)
158 tombstonesLoader := NewTombstonesLoader(s, nil)
195 …assert.Equal(t, tc.expectedResultsCacheGenNumber, tombstonesLoader.GetResultsCacheGenNumber(tc.ten…
196 …assert.Equal(t, tc.expectedStoreCacheGenNumber, tombstonesLoader.GetStoreCacheGenNumber(tc.tenantI…
203 tombstonesLoader := NewTombstonesLoader(s, nil)
204 tombstonesLoader.getCacheGenNumbers("test")
207 require.NotNil(t, tombstonesLoader.reloadTombstones())
210 require.NotNil(t, tombstonesLoader.getCacheGenNumbers("test2"))
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/querier/ |
| H A D | querier.go | 147 …n.Overrides, distributor Distributor, stores []QueryableWithFilter, tombstonesLoader *purger.Tombs…
159 queryable := NewQueryable(distributorQueryable, ns, iteratorFunc, cfg, limits, tombstonesLoader)
219 …IterFn chunkIteratorFunc, cfg Config, limits *validation.Overrides, tombstonesLoader *purger.Tombs…
242 tombstonesLoader: tombstonesLoader,
287 tombstonesLoader *purger.TombstonesLoader member
348 tombstones, err := q.tombstonesLoader.GetPendingTombstonesForInterval(userID, startTime, endTime)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/querier/ |
| H A D | querier.go | 147 …n.Overrides, distributor Distributor, stores []QueryableWithFilter, tombstonesLoader *purger.Tombs…
159 queryable := NewQueryable(distributorQueryable, ns, iteratorFunc, cfg, limits, tombstonesLoader)
219 …IterFn chunkIteratorFunc, cfg Config, limits *validation.Overrides, tombstonesLoader *purger.Tombs…
242 tombstonesLoader: tombstonesLoader,
287 tombstonesLoader *purger.TombstonesLoader member
348 tombstones, err := q.tombstonesLoader.GetPendingTombstonesForInterval(userID, startTime, endTime)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/api/ |
| H A D | handlers.go | 163 tombstonesLoader *purger.TombstonesLoader,
231 cacheGenHeaderMiddleware := getHTTPCacheGenNumberHeaderSetterMiddleware(tombstonesLoader)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/api/ |
| H A D | handlers.go | 163 tombstonesLoader *purger.TombstonesLoader,
231 cacheGenHeaderMiddleware := getHTTPCacheGenNumberHeaderSetterMiddleware(tombstonesLoader)
|