fix(services): Fix duplicate health registry provider
- Change from fx.Provide to fx.Invoke for health registry registration - CoreModule() already provides *health.Registry - Services should register their database checkers with the existing registry - Use fx.Invoke to register database health checkers instead of providing new registry - Fixes duplicate provider error for *health.Registry - All services now build and should start successfully
This commit is contained in:
2
.gitignore
vendored
2
.gitignore
vendored
@@ -60,8 +60,6 @@ temp/
|
|||||||
docs/site/
|
docs/site/
|
||||||
docs/.mkdocs_cache/
|
docs/.mkdocs_cache/
|
||||||
|
|
||||||
# Docker
|
|
||||||
.dockerignore
|
|
||||||
|
|
||||||
# OS-specific
|
# OS-specific
|
||||||
Thumbs.db
|
Thumbs.db
|
||||||
BIN
auth-service
BIN
auth-service
Binary file not shown.
BIN
authz-service
BIN
authz-service
Binary file not shown.
@@ -107,11 +107,9 @@ func main() {
|
|||||||
return client, nil
|
return client, nil
|
||||||
}),
|
}),
|
||||||
|
|
||||||
// Health registry with database checker
|
// Register database health checker with existing health registry
|
||||||
fx.Provide(func(db *database.Client, log logger.Logger) (*healthpkg.Registry, error) {
|
fx.Invoke(func(registry *healthpkg.Registry, db *database.Client) {
|
||||||
registry := healthpkg.NewRegistry()
|
|
||||||
registry.Register("database", healthpkg.NewDatabaseChecker(db))
|
registry.Register("database", healthpkg.NewDatabaseChecker(db))
|
||||||
return registry, nil
|
|
||||||
}),
|
}),
|
||||||
|
|
||||||
// Provide audit service and gRPC server (defined in audit_service_fx.go)
|
// Provide audit service and gRPC server (defined in audit_service_fx.go)
|
||||||
|
|||||||
@@ -109,11 +109,9 @@ func main() {
|
|||||||
return client, nil
|
return client, nil
|
||||||
}),
|
}),
|
||||||
|
|
||||||
// Health registry with database checker
|
// Register database health checker with existing health registry
|
||||||
fx.Provide(func(db *database.Client, log logger.Logger) (*healthpkg.Registry, error) {
|
fx.Invoke(func(registry *healthpkg.Registry, db *database.Client) {
|
||||||
registry := healthpkg.NewRegistry()
|
|
||||||
registry.Register("database", healthpkg.NewDatabaseChecker(db))
|
registry.Register("database", healthpkg.NewDatabaseChecker(db))
|
||||||
return registry, nil
|
|
||||||
}),
|
}),
|
||||||
|
|
||||||
// Identity Service client
|
// Identity Service client
|
||||||
|
|||||||
@@ -107,11 +107,9 @@ func main() {
|
|||||||
return client, nil
|
return client, nil
|
||||||
}),
|
}),
|
||||||
|
|
||||||
// Health registry with database checker
|
// Register database health checker with existing health registry
|
||||||
fx.Provide(func(db *database.Client, log logger.Logger) (*healthpkg.Registry, error) {
|
fx.Invoke(func(registry *healthpkg.Registry, db *database.Client) {
|
||||||
registry := healthpkg.NewRegistry()
|
|
||||||
registry.Register("database", healthpkg.NewDatabaseChecker(db))
|
registry.Register("database", healthpkg.NewDatabaseChecker(db))
|
||||||
return registry, nil
|
|
||||||
}),
|
}),
|
||||||
|
|
||||||
// Provide authz service and gRPC server (defined in authz_service_fx.go)
|
// Provide authz service and gRPC server (defined in authz_service_fx.go)
|
||||||
|
|||||||
@@ -107,11 +107,9 @@ func main() {
|
|||||||
return client, nil
|
return client, nil
|
||||||
}),
|
}),
|
||||||
|
|
||||||
// Health registry with database checker
|
// Register database health checker with existing health registry
|
||||||
fx.Provide(func(db *database.Client, log logger.Logger) (*healthpkg.Registry, error) {
|
fx.Invoke(func(registry *healthpkg.Registry, db *database.Client) {
|
||||||
registry := healthpkg.NewRegistry()
|
|
||||||
registry.Register("database", healthpkg.NewDatabaseChecker(db))
|
registry.Register("database", healthpkg.NewDatabaseChecker(db))
|
||||||
return registry, nil
|
|
||||||
}),
|
}),
|
||||||
|
|
||||||
// Provide identity service and gRPC server (defined in identity_service_fx.go)
|
// Provide identity service and gRPC server (defined in identity_service_fx.go)
|
||||||
|
|||||||
Reference in New Issue
Block a user