feat: add traces

formancehq · Sep 8, 2024 · d2c5f07 · d2c5f07
1 parent 767f647
commit d2c5f07
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 1 deletion.
diff --git a/components/ledger/internal/controller/ledger/resolver.go b/components/ledger/internal/controller/ledger/resolver.go
@@ -63,7 +63,8 @@ func (r *Resolver) GetLedger(ctx context.Context, name string) (*Controller, err
 		return nil, err
 	}
 
-	r.metricsRegistry.ActiveLedgers().Add(ctx, +1)
+	// todo: add only once
+	//r.metricsRegistry.ActiveLedgers().Add(ctx, +1)
 
 	return New(
 		name,

diff --git a/components/ledger/internal/storage/bucket/migrations.go b/components/ledger/internal/storage/bucket/migrations.go
@@ -5,6 +5,7 @@ import (
 	"context"
 	"embed"
 	_ "embed"
+	"github.com/formancehq/ledger/internal/opentelemetry/tracer"
 	"github.com/formancehq/stack/libs/go-libs/migrations"
 	"github.com/uptrace/bun"
 	"text/template"
@@ -32,5 +33,8 @@ func getMigrator(name string) *migrations.Migrator {
 }
 
 func Migrate(ctx context.Context, db bun.IDB, name string) error {
+	ctx, span := tracer.Start(ctx, "Migrate bucket")
+	defer span.End()
+
 	return getMigrator(name).Up(ctx, db)
 }
diff --git a/components/ledger/internal/storage/ledger/migrations.go b/components/ledger/internal/storage/ledger/migrations.go
@@ -6,6 +6,7 @@ import (
 	"embed"
 	_ "embed"
 	"fmt"
+	"github.com/formancehq/ledger/internal/opentelemetry/tracer"
 	"github.com/formancehq/stack/libs/go-libs/migrations"
 	"github.com/uptrace/bun"
 	"text/template"
@@ -37,5 +38,8 @@ func getMigrator(bucketName, ledgerName string) *migrations.Migrator {
 }
 
 func Migrate(ctx context.Context, db bun.IDB, bucketName, ledgerName string) error {
+	ctx, span := tracer.Start(ctx, "Migrate ledger")
+	defer span.End()
+
 	return getMigrator(bucketName, ledgerName).Up(ctx, db)
 }