Compare commits

...

3 Commits

Author SHA1 Message Date
Peter Štibraný
e672e7a732 Update pkg/storage/unified/sql/backend.go
Co-authored-by: Rafael Bortolon Paulovic <rafael.paulovic@grafana.com>
2025-12-05 12:14:41 +01:00
Peter Štibraný
a70260c227 Fix typos, my keyboar is acting up tody :( 2025-12-05 11:52:09 +01:00
Peter Štibraný
6d657b0a55 Log lastImportTimeMaxAge when initializing backend, and when deleting old import entries. 2025-12-05 11:48:11 +01:00

View File

@@ -85,11 +85,13 @@ func NewBackend(opts BackendOptions) (Backend, error) {
if opts.WatchBufferSize == 0 {
opts.WatchBufferSize = defaultWatchBufferSize
}
l := logging.DefaultLogger.With("logger", "sql-resource-server")
l.Debug("initializing unified storage sql backend", "lastImportTimeMaxAge", opts.LastImportTimeMaxAge)
return &backend{
isHA: opts.IsHA,
done: ctx.Done(),
cancel: cancel,
log: logging.DefaultLogger.With("logger", "sql-resource-server"),
log: l,
tracer: opts.Tracer,
reg: opts.Reg,
dbProvider: opts.DBProvider,
@@ -979,10 +981,13 @@ func (b *backend) GetResourceLastImportTimes(ctx context.Context) iter.Seq2[reso
// Delete old entries, if configured, and if enough time has passed since last deletion.
if b.lastImportTimeMaxAge > 0 && time.Since(b.lastImportTimeDeletionTime.Load()) > limitLastImportTimesDeletion {
now := time.Now()
threshold := now.Add(-b.lastImportTimeMaxAge)
b.log.Debug("Deleting last import times older or equal than threshold", "threshold", threshold, "maxAge", b.lastImportTimeMaxAge)
res, err := dbutil.Exec(ctx, b.db, sqlResourceLastImportTimeDelete, &sqlResourceLastImportTimeDeleteRequest{
SQLTemplate: sqltemplate.New(b.dialect),
Threshold: now.Add(-b.lastImportTimeMaxAge),
Threshold: threshold,
})
if err != nil {