IntenseWebs/grafana
3
0
Fork 0
mirror of https://github.com/grafana/grafana.git synced 2025-02-25 18:55:37 -06:00
Code Issues Packages Projects Releases Wiki Activity

Unified Storage: Add traces to poller (#95369)

Browse Source 
add traces to poller
This commit is contained in:
owensmallwood 2024-10-24 13:49:38 -06:00 committed by GitHub
parent 2deced7d40
commit ecebaf1bdf
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/storage/unified/sql/backend.go
View File

@ -531,6 +531,7 @@ func (b *backend) poller(ctx context.Context, since groupResourceRV, stream chan
case <-b.done: case <-b.done:
return return
case <-t.C: case <-t.C:
ctx, span := b.tracer.Start(ctx, tracePrefix+"poller")
// List the latest RVs // List the latest RVs
grv, err := b.listLatestRVs(ctx) grv, err := b.listLatestRVs(ctx)
if err != nil { if err != nil {
@ -562,12 +563,15 @@ func (b *backend) poller(ctx context.Context, since groupResourceRV, stream chan
} }
t.Reset(b.pollingInterval) t.Reset(b.pollingInterval)
span.End()
} }
} }
} }
// listLatestRVs returns the latest resource version for each (Group, Resource) pair. // listLatestRVs returns the latest resource version for each (Group, Resource) pair.
func (b *backend) listLatestRVs(ctx context.Context) (groupResourceRV, error) { func (b *backend) listLatestRVs(ctx context.Context) (groupResourceRV, error) {
ctx, span := b.tracer.Start(ctx, tracePrefix+"listLatestRVs")
defer span.End()
var grvs []*groupResourceVersion var grvs []*groupResourceVersion
err := b.db.WithTx(ctx, ReadCommittedRO, func(ctx context.Context, tx db.Tx) error { err := b.db.WithTx(ctx, ReadCommittedRO, func(ctx context.Context, tx db.Tx) error {
var err error var err error