State model
A partitioned event log feeds time-windowed operational state. Per-entity sequence and watermark prevent late or duplicate events from appearing current.
A customer may be under pressure, coached by a criminal or genuinely making an unusual payment, and the cost of either error is high.
The system sequences behavioural, beneficiary and conversation evidence, selects a risk-appropriate intervention and gives the fraud specialist targeted questions with reasons.
Organisations, systems and operating conditions are intentionally anonymised and recomposed. The design demonstrates engineering and banking-domain reasoning; it does not represent a named client estate, vendor product or measured production result.
Five operating planes separate interaction, identity, decision control, authoritative state and operating evidence.
Permitted workModels may extract, compare and propose hypotheses. Deterministic policy gates and trained investigators own risk classification and disposition.
Consistency rulePin policy, list and evidence versions per case; retain contradiction and non-match evidence as well as supporting evidence.
Hard boundaryThe model is not a system of record, identity provider, policy authority or proof that an external effect occurred.
Events or conversation turns require a decision before the underlying situation changes, with strict latency and back-pressure constraints.
The system may recommend pause, education or specialist review but cannot accuse the customer or override statutory rights.
A deterministic outer workflow contains model-led work inside typed, observable calls. Dashed messages remain proposals until policy or a human grants authority.
A partitioned event log feeds time-windowed operational state. Per-entity sequence and watermark prevent late or duplicate events from appearing current.
Use streaming ingestion for signals, low-latency feature or state reads for the hot path, and asynchronous enrichment outside the decision budget.
Point-in-time correctness takes precedence over the newest unqualified value. Late events trigger correction or review instead of mutating the old decision invisibly.
These roles are deliberately vendor-neutral. Each can be independently owned, versioned and replaced.
Accepts a typed evidence request and returns the minimum permitted facts with source, event time, observation time, validity and exclusions.
Evaluates identity, purpose, capability, amount, risk tier and policy version; returns allow, deny, step-up or human-review with reasons.
Chooses an approved model route by task, risk, evidence quality, latency budget and cost ceiling; enforces structured outputs.
Presents claims beside evidence, alternatives, uncertainty, missing information, permitted actions and current custody.
Appends request, versions, policy result, model proposal, approval, action receipt, readback, correction and custody events under one correlation key.
Durable records carry provenance, authority, effect and custody without turning a transcript into an uncontrolled memory store.
Pin policy, list and evidence versions per case; retain contradiction and non-match evidence as well as supporting evidence.
The selected design is not universally superior. It is the safer fit for this boundary and failure cost.
Prefetch stable, purpose-safe facts; acquire volatile facts on demand against a time-qualified snapshot.
Load a broad customer profile at session start.
Cost acceptedThe selected design adds source calls and latency, but reduces stale data, excess exposure and accidental reuse.
Compile stable decision logic and retain retrieval for explanation and residual ambiguity.
Ask a model to interpret the source document for every request.
Cost acceptedRule compilation needs controlled change, but creates repeatable decisions, regression tests and clear exceptions.
Reserve larger models for residual reasoning after deterministic and smaller-model gates.
Send every request to the most capable available model.
Cost acceptedRouting adds evaluation work and operational complexity, but controls cost, latency and unnecessary data exposure.
Keep people at irreversible, ambiguous and policy-exception points; sample lower-risk automated outcomes independently.
Require the same manual approval at every step.
Cost acceptedRisk-tiering reduces review load but needs calibrated thresholds, sampling and immediate withdrawal of authority when drift appears.
Use append-only events plus a rebuildable current-state projection.
Overwrite the case row with its latest status.
Cost acceptedReplay and storage are more complex, but point-in-time reconstruction and correction lineage remain possible.
Retries are bounded by knowledge of business effect; unknown outcome remains visible, owned and independently reconciled.
Actual thresholds belong to accountable service owners. The design exposes the equations and observables that those owners must baseline.
partition_rate = peak_events_per_second / active_partitionsdecision_budget = ingest + state_read + policy + score + action_commitbacklog_clear_time = queued_events / recovery_throughputTokenise identity before model use, restrict sources by investigation purpose and retain only policy-required evidence.
A design is production-ready only when teams can prove what happened, recover it and change it safely.
false-merge and false-split test
source outage and incomplete-case test
blind sample of deterministic closes
investigator override drift review
Signal set, intervention rationale, script version, customer responses, specialist decision and payment outcome.
A fraud specialist authorises holds or releases within policy.
Start with advisory intervention and measured shadow scoring. Increase automation only when peak-load, late-event and fallback tests preserve the control outcome.
Investigation, policy, data, model-risk and operations owners retain decision and control accountability.