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). Alternatively, send Content-Type: application/json with {pipeline, state?, body?} to pass config in the body.
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 SyncState ({ source, destination, sync_run }). Falls back to empty state if invalid.
Request body
Response
NDJSON stream of sync messages