Skip to content

feat: add replay stage observability - #87

Merged
jbiskur merged 1 commit into
mainfrom
allora/replay-observability
Aug 5, 2026
Merged

feat: add replay stage observability#87
jbiskur merged 1 commit into
mainfrom
allora/replay-observability

Conversation

@allora2026

Copy link
Copy Markdown
Contributor

Summary

Adds Phase 1 replay-stage observability to @flowcore/data-pump without changing replay algorithms or concurrency.

Measurement added

  • fetch duration/result and returned event counts
  • handler duration/result with bounded batch-size buckets
  • acknowledgement duration/result
  • checkpoint duration/result
  • idle duration with finite reasons
  • duration buckets covering slow replays through 120 seconds

Existing metric names, exports, and private/default registry behavior are preserved. New result/reason/batch labels use finite enumerations.

This PR intentionally does not change buffer algorithms, acknowledgement membership checks, bucket traversal, prefetch, or in-flight concurrency. It establishes the baseline for the next optimization PR.

Verification

  • bun test61 passed, 0 failed
  • bun run lint — pass
  • bun run typecheck — pass
  • bun run format:check — pass
  • bun run build — pass
  • git diff --check — pass
  • class-based state-manager receiver regression covered
  • independent spec review — pass
  • independent code-quality/security review — approved

Research

@jbiskur
jbiskur merged commit dd8c2b3 into main Aug 5, 2026
3 checks passed
@jbiskur
jbiskur deleted the allora/replay-observability branch August 5, 2026 09:39
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.

2 participants