dag-projection / Exports / ProjectionReadModelService
Class: ProjectionReadModelService
Service that builds read-model projections from DAG run storage.
See
IStoragePort
Table of contents
Constructors
Methods
Constructors
constructor
• new ProjectionReadModelService(storage): ProjectionReadModelService
Parameters
| Name | Type |
|---|---|
storage | IStoragePort |
Returns
Defined in
services/projection-read-model-service.ts:68
Methods
buildRunProjection
▸ buildRunProjection(dagRunId): Promise<TResult<IRunProjection, IDagError>>
Builds a run projection with task runs and status summary.
Parameters
| Name | Type | Description |
|---|---|---|
dagRunId | string | The DAG run identifier to project. |
Returns
Promise<TResult<IRunProjection, IDagError>>
Run projection or a validation error if the run is not found.
Defined in
services/projection-read-model-service.ts:75
buildLineageProjection
▸ buildLineageProjection(dagRunId): Promise<TResult<ILineageProjection, IDagError>>
Builds a lineage projection showing node graph and task statuses.
Parameters
| Name | Type | Description |
|---|---|---|
dagRunId | string | The DAG run identifier to project. |
Returns
Promise<TResult<ILineageProjection, IDagError>>
Lineage projection or a validation error.
Defined in
services/projection-read-model-service.ts:109
buildDashboardProjection
▸ buildDashboardProjection(dagRunId): Promise<TResult<IDashboardProjection, IDagError>>
Builds a combined dashboard projection with both run and lineage views.
Parameters
| Name | Type | Description |
|---|---|---|
dagRunId | string | The DAG run identifier to project. |
Returns
Promise<TResult<IDashboardProjection, IDagError>>
Dashboard projection or a validation error.