Skip to content

feat: add scoped metrics and cancellable iterator execution - #11

Merged
yianni merged 1 commit into
mainfrom
hardening/p1-metrics-cancel-ci
Feb 26, 2026
Merged

feat: add scoped metrics and cancellable iterator execution#11
yianni merged 1 commit into
mainfrom
hardening/p1-metrics-cancel-ci

Conversation

@yianni

@yianni yianni commented Feb 26, 2026

Copy link
Copy Markdown
Owner

Summary

  • introduce pipeline-scoped metrics collectors via Metrics.Collector and thread-local collector context
  • propagate scoped collectors through async execution handles, parMap workers, and async boundary producer threads
  • extend ExecutionHandle with metricsSnapshot and add Node.runCancellableIterator(...)
  • add Node-level recoverWith to align API surface with ADR recovery semantics
  • strengthen CI stress gate by running calibrated backpressure validation at 10s

Why

  • addresses P1 hardening goals: metric isolation, iterator cancellation parity, and stronger CI stress assertions

Validation

  • sbt -Dsbt.supershell=false test passes (36 tests)
  • sbt -Dsbt.supershell=false "Test / runMain SimpleStreamProcessor.BackpressureStressValidation 10000" passes

@yianni
yianni merged commit e5cbce7 into main Feb 26, 2026
1 check passed
@yianni
yianni deleted the hardening/p1-metrics-cancel-ci branch February 26, 2026 06:03
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant