Licence
exellix-license
Version
3.0.2
Deps
1
Size
106 kB
Vulns
0
Weekly
0
@x12i/memorix-pipeline-runtime
Org-scoped operational persistence helpers used by the pipeline stack: artifacts (DataRef), receipts, DLQ, execution claims, checkpoints, schedule claims, retention sweeps, and identity merge helpers.
This is a ledger/storage package, not the DAG engine. The engine lives in @x12i/memorix-pipeline.
Install
npm install @x12i/memorix-pipeline-runtime@3.0.2| Audience | Use this package? |
|---|---|
| Remote app | No — /api/pipelines + /api/operations |
| Platform / pipeline package | Yes (Mongo or in-memory stores) |
What it stores
| Kind | Role |
|---|---|
| Artifacts | Large step outputs behind DataRef / artifactId |
| Receipts | Write acknowledgements |
| DLQ | Failed items for replay policy |
| Claims / checkpoints | Lease + cursor state for durable execution |
| Schedule claims | Scheduler ownership |
Core API
import {
createMongoOperationalStores,
createMemoryOperationalStores,
ensureOperationalIndexes,
COLLECTION_NAMES,
redactSensitive,
deriveCanonicalRecordId,
mergeRecords,
sweepRetentionClasses,
} from "@x12i/memorix-pipeline-runtime";| Export | Role |
|---|---|
createMongoOperationalStores / createMemoryOperationalStores |
Store bundle (OperationalStores) |
ensureOperationalIndexes / COLLECTION_NAMES |
Mongo layout |
redactSensitive |
Scrub sensitive values in logs/exports |
deriveCanonicalRecordId / mergeRecords / batchMerge |
Identity policy helpers |
sweepRetentionClass(es) |
Retention class cleanup |
How it fits
memorix-pipeline (engine)
→ run / attempt ledger (pipeline package)
→ artifacts / DataRef (this package + pipeline ledger)
memorix-service /api/pipelines · /api/operationsDocs
- Ebook: Building Pipelines
- Mutation capture note (journey):
../memorix-pipeline/docs/mutation-refs-capture.md - Hub: https://ebooks.memorix.x12i.com
npm test