Operator CLI

pipeo replay

Re-deliver a source’s archived events from a time window to one destination.

Reads the archive for one source and time window and creates delivery jobs for one destination. Replaying into a newly added destination is a backfill.

The window needs explicit UTC offsets, so a replay never depends on the operator’s time zone. --max-per-second caps the rate so live traffic keeps flowing.

Usage

pnpm pipeo replay --source <uuid> --destination <uuid> --from <iso> --to <iso> [--run-id <uuid>] [--max-per-second N]

The CLI runs from a checkout of the Pipeo repository (pnpm pipeo ...) and talks to Postgres directly, bypassing workspace isolation by design. It is for operators, not workspace members.

More cli commands

All cli commands →

01
pipeo stats
Print delivery job counts per destination and state, to see the backlog at a glance.
02
pipeo dlq
List a destination’s dead letters and requeue them once the vendor is fixed.
03
pipeo archive run
Run one archiver pass by hand.

More cli commands

pipeo stats

pipeo dlq

pipeo archive run