Enable/disable form actions, and a quick reference for how each part of this POC works.
Form actions
Toggle any action off to hide/disable its button on the main data entry page — useful to keep a demo focused, or to take an action temporarily out of service (e.g. while HCL is mid-migration on VoltMX).
How this POC works
Order-to-Cash pipeline: PostgreSQL (simulated SAP source) → Kafka (CDC via Debezium) → MinIO/S3 (data lake), observed end-to-end by Actian Data Observability, with two optional gates/exports layered on top.
1
Submit All to Pipeline — direct path. Rows go straight into customer_master (PostgreSQL), replicated in real time by Debezium into Kafka → MinIO → S3 → dashboards. No quality gate.
2
Push to Pipeline — Circuit Breaker — quality-gated path. Rows are staged first (customer_master_staging, invisible to Debezium), Actian DO scans the whole batch in one pass, and only rows that pass DQ - credit overexposure get promoted into the real table. Violating rows stay quarantined, visible on the Quarantine Monitor. Full detail: see DOC/Circuit_Breaker_Flow.md in the repo.
3
DQ Violations Monitor — live view of every record flagged by Actian DO's Record Validation Rules on the main INPUT_PostgreSQL asset (the direct-path data), read from S3 binning output.
4
Quarantine Monitor — the rows blocked by the Circuit Breaker above. Separate from DQ Violations: a row here never reached the real pipeline, so it can't show up there too.
5
Push to VoltMX — on demand only (no timer). Triggers a fresh Actian DO scan on all 3 observed assets (PostgreSQL, Kafka, MinIO/S3) in parallel, waits ~4-5 min for them to finish, then pushes DQ events + metrics to HCL's VoltMX Observability service, feeding their FSO dashboard.
6
Refresh ADO Metrics — lighter, separate action. Just re-reads whatever Actian DO's last completed scan produced and refreshes the local cache used by our own Grafana dashboard. Does not trigger a new scan — run a scan first (via this page's Push to VoltMX button, or the ADO console) if you want fresh numbers.