Stateless Sync API
Read records from source
Streams NDJSON messages (records, state, catalog). Optional NDJSON body provides live events as input. Alternatively, send Content-Type: application/json with {pipeline, state?, body?} to pass config in the body.
post/pipeline_read
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