Observability Implementation Results

Observable Port Status

List of Observable wrappers generated by the [GenerateObservablePort] Source Generator.

Repository Observable (InMemory)

Original Class	Observable Wrapper	Port
AIModelRepositoryInMemory	AIModelRepositoryInMemoryObservable	IAIModelRepository
DeploymentRepositoryInMemory	DeploymentRepositoryInMemoryObservable	IDeploymentRepository
AssessmentRepositoryInMemory	AssessmentRepositoryInMemoryObservable	IAssessmentRepository
IncidentRepositoryInMemory	IncidentRepositoryInMemoryObservable	IIncidentRepository
UnitOfWorkInMemory	UnitOfWorkInMemoryObservable	IUnitOfWork

Repository Observable (EfCore)

Original Class	Observable Wrapper	Port
AIModelRepositoryEfCore	AIModelRepositoryEfCoreObservable	IAIModelRepository
DeploymentRepositoryEfCore	DeploymentRepositoryEfCoreObservable	IDeploymentRepository
AssessmentRepositoryEfCore	AssessmentRepositoryEfCoreObservable	IAssessmentRepository
IncidentRepositoryEfCore	IncidentRepositoryEfCoreObservable	IIncidentRepository
UnitOfWorkEfCore	UnitOfWorkEfCoreObservable	IUnitOfWork

Query Observable (InMemory)

Original Class	Observable Wrapper	Port
AIModelQueryInMemory	AIModelQueryInMemoryObservable	IAIModelQuery
AIModelDetailQueryInMemory	AIModelDetailQueryInMemoryObservable	IModelDetailQuery
DeploymentQueryInMemory	DeploymentQueryInMemoryObservable	IDeploymentQuery
DeploymentDetailQueryInMemory	DeploymentDetailQueryInMemoryObservable	IDeploymentDetailQuery
IncidentQueryInMemory	IncidentQueryInMemoryObservable	IIncidentQuery

External Service Observable

Original Class	IO Pattern	Port
ModelHealthCheckService	Timeout + Catch	IModelHealthCheckService
ModelMonitoringService	Retry + Schedule	IModelMonitoringService
ParallelComplianceCheckService	Fork + awaitAll	IParallelComplianceCheckService
ModelRegistryService	Bracket	IModelRegistryService

Observable Port Total: 19 (InMemory Repository 5 + EfCore Repository 5 + Query 5 + External Service 4)

---

CtxEnricher Status

The Functorium Pipeline’s UseCtxEnricher() middleware automatically propagates properties of Command/Query Requests and DomainEvents as ctx.* fields.

Command Request ctx.* Propagation

Command	ctx.* Field	Pillar
RegisterModelCommand	ctx.register_model_command.request.name	Default(L+T)
	ctx.register_model_command.request.version	Default(L+T)
	ctx.register_model_command.request.purpose	Logging
CreateDeploymentCommand	ctx.create_deployment_command.request.model_id	Default(L+T)
	ctx.create_deployment_command.request.environment	All(L+T+M)
	ctx.create_deployment_command.request.drift_threshold	Default+MetricsValue
ReportIncidentCommand	ctx.report_incident_command.request.severity	All(L+T+M)
	ctx.report_incident_command.request.description	Logging

DomainEvent ctx.* Propagation

Event	ctx.* Field	Pillar
AIModel.RiskClassifiedEvent	ctx.risk_classified_event.model_id	Default(L+T)
	ctx.risk_classified_event.new_risk_tier	Default(L+T)
ModelIncident.ReportedEvent	ctx.reported_event.severity	All(L+T+M)
	ctx.reported_event.deployment_id	Default(L+T)

---

Observability Pipeline Configuration Status

services
    .RegisterOpenTelemetry(configuration, AssemblyReference.Assembly)
    .ConfigurePipelines(pipelines => pipelines
        .UseObservability()                          // Batch enable CtxEnricher + Metrics + Tracing + Logging
        .UseValidation()
        .UseException())
    .Build();

UseObservability() Middleware Order

UseObservability() batch enables all 4 observability types. The remaining pipelines are registered via explicit opt-in:

Order	Middleware	Collection Target	Output
1	UseObservability() -> Metrics	Counter(requests, responses), Histogram(duration)	Prometheus / OTLP
2	UseObservability() -> Tracing	Activity Span (entry/exit/tags)	Jaeger / OTLP
3	UseObservability() -> CtxEnricher	Request/Response/Event properties	LogContext + Activity.SetTag + MetricsTagContext
4	UseObservability() -> Logging	Structured logs (Serilog)	Console / OTLP
5	UseValidation()	FluentValidation-based request validation	Validation Error
6	UseException()	Exception -> DomainError/AdapterError conversion	error.type, error.code tags

Event Publishing Observability

services.AddMediator(options =>
{
    options.ServiceLifetime = ServiceLifetime.Scoped;
    options.NotificationPublisherType =
        typeof(ObservableDomainEventNotificationPublisher);
});
services.RegisterDomainEventPublisher();
services.RegisterDomainEventHandlersFromAssembly(
    AiGovernance.Application.AssemblyReference.Assembly);

ObservableDomainEventNotificationPublisher automatically performs metrics, tracing, and logging when publishing DomainEvents. EventHandler observability is provided through Mediator’s NotificationPublisherType.

---

External Service IO Pattern Status

IO patterns and observability integration status for the 4 external services.

ModelHealthCheckService (Timeout + Catch)

IO.liftAsync -> .Timeout(10s) -> .Catch(TimedOut -> fallback) -> .Catch(Exceptional -> error)
                                                              |
                              [GenerateObservablePort] -> Observable wrapper auto-generated
                                                              |
                              adapter.external_service.requests (Counter)
                              adapter.external_service.duration (Histogram)
                              adapter.external_service.responses (Counter + error.type)

ModelMonitoringService (Retry + Schedule)

IO.liftAsync -> .Retry(exponential|jitter|recurs|maxDelay) -> .Catch(Exceptional -> error)
                                                              |
                              Observable wrapper: observes only the final result
                              Retry attempt count tracked via internal logging

ParallelComplianceCheckService (Fork + awaitAll)

CriterionNames.Map(name => CheckSingle(name).Fork()) -> awaitAll(forks) -> .Map(aggregate)
                                                              |
                              Observable wrapper: observes the entire parallel check result as a single call
                              Individual criterion checks execute inside Fork (not individually observed)

ModelRegistryService (Bracket)

acquireSession.Bracket(Use: lookupModel, Fin: releaseSession) -> .Catch(Exceptional -> error)
                                                              |
                              Observable wrapper: observes the entire Bracket as a single call
                              Acquire/Use/Release sub-steps tracked via internal logging

---

Numerical Summary

Item	Count
Observable Port (InMemory Repository)	5
Observable Port (EfCore Repository)	5
Observable Port (Query)	5
Observable Port (External Service)	4
Observable Port Total	19
Pipeline Middleware	5 (Metrics, Tracing, CtxEnricher, Logging, Exception)
DomainEvent Observability	ObservableDomainEventNotificationPublisher
ctx.* MetricsTag Fields	2 (Environment, Severity)
ctx.* MetricsValue Fields	1 (DriftThreshold)
ctx.* Default(L+T) Fields	8+ (ModelId, DeploymentId, Name, Version, etc.)
ctx.* Logging Only Fields	2 (Purpose, Description)