ContextSources

Defined in: packages/pipeline/src/interfaces/context-source.interface.ts:42

Where pipelines take their tenant and correlation id from (createPipeline({ sources })).

Without a source, a pipeline takes the value of the pipeline it is nested in, if any. A missing correlation id comes from the correlation source’s create(), or, with no correlation source, from uuidv7().

Example

import { correlationSource } from '@cqrs-ddd/pipeline-correlation';
import { tenantSource } from '@cqrs-ddd/pipeline-tenant';

const pipeline = createPipeline({
  sources: { tenantId: tenantSource, correlationId: correlationSource },
});

Properties

correlationId?

readonly optional correlationId?: CorrelationSource

Defined in: packages/pipeline/src/interfaces/context-source.interface.ts:44

---

tenantId?

readonly optional tenantId?: ContextSource

Defined in: packages/pipeline/src/interfaces/context-source.interface.ts:43