feat: include instance and system attrs with DB stats

goto · Aug 10, 2023 · 6f9bc99 · 6f9bc99
1 parent 9b7f898
commit 6f9bc99
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/internal/store/postgres/postgres.go b/internal/store/postgres/postgres.go
@@ -115,7 +115,11 @@ func NewClient(ctx context.Context, cfg Config) (*Client, error) {
 		return nil, fmt.Errorf("ping DB: %w", err)
 	}
 
-	if err := otelsql.RecordStats(db); err != nil {
+	if err := otelsql.RecordStats(
+		db,
+		otelsql.WithSystem(semconv.DBSystemPostgreSQL),
+		otelsql.WithInstanceName("default"),
+	); err != nil {
 		return nil, err
 	}
 

diff --git a/pkg/worker/pgq/pgq_processor.go b/pkg/worker/pgq/pgq_processor.go
@@ -51,7 +51,11 @@ func NewProcessor(ctx context.Context, cfg Config) (*Processor, error) {
 		return nil, fmt.Errorf("new pgq processor: %w", err)
 	}
 
-	if err := otelsql.RecordStats(db); err != nil {
+	if err := otelsql.RecordStats(
+		db,
+		otelsql.WithSystem(semconv.DBSystemPostgreSQL),
+		otelsql.WithInstanceName("pgq"),
+	); err != nil {
 		return nil, err
 	}