RPC_URL
and RPC_SECRET
. Destinations should make a POST
request
to ${RPC_URL}/<method>
with Authorization: Bearer ${RPC_SECRET}
in the header.
log
reply messagedestination
and enrichment
halt
reply messagedestination
and enrichment
describe
Incoming Messagedestination
and enrichment
spec
is for an enrichment or destination, with only one parameter - {"type": "describe"}
.
Upon request, the destination or enrichment responds with a spec
message.
spec
reply messagedestination
and enrichment
credentialsSchema
maybe a Zod-schema or JSON-schema.
describe-streams
incoming messagedestination
start-stream
incoming messagedestination
start-enrichment
incoming messageenrichment
enrichment-request
incoming messageenrichment
enrichment-reply
reply messageenrichment
row
incoming messagedestination
end-stream
incoming messagedestination
RPC_URL
and RPC_SECRET
.
Destinations should make a POST
request to ${RPC_URL}/<method>
with Authorization: Bearer ${RPC_SECRET}
in the header. Each call must an JSON body, reply is also a JSON object.
["syncId=123", "type=cursor"]
syncId
in the key to avoid conflicts between different syncs. syncId
is a unique identifier of the sync configuration
and is passed along with start-stream
or start-enrichment
messages.state.get
state.set
state.delete
state.deleteAll
["segment1", "segment2"]
and ["segment1", "segment2", "segment3"]
state.list
["segment1", "segment2"]
or
["segment1", "segment2", "segment3"]
). The response is streamed since the response can be large. It’s advised to use a streaming JSON parser to process the response.