Stateless Sync API
Run sync pipeline (read → write)
Without a request body, reads from the source connector and writes to the destination (backfill mode). With an NDJSON request body, uses the provided messages as input instead of reading from the source (push mode — e.g. piped webhook events).
post/pipeline_sync
Query parameters
state_limitinteger
Stop streaming after N state messages.
Stop streaming after N state messages.
time_limitnumber
Stop streaming after N seconds.
Stop streaming after N seconds.
Headers
JSON-encoded PipelineConfig
JSON-encoded SourceState ({ streams, global }) or legacy flat per-stream state
Response
NDJSON stream of sync messages