Reference
Collector SDK
Review the Node collector surface.
createSeamwardCollector
Create a process-level collector.
createSeamwardCollector accepts a Source key, secret ingest token, and optional endpoint, deployment context, redaction policy, queue limits, batching, and timing dependencies.
observeWebhook
Wrap an inbound webhook operation.
observeWebhook accepts an Integration key and stable route metadata, then returns a function that invokes the existing JSON handler while recording its outcome.
stats
Read queue and delivery counters.
stats() exposes queue and delivery counters for local health checks. It is observational and does not flush or stop the collector.
stop
Flush and stop the collector.
stop() performs the collector shutdown path and gives queued observations a final flush opportunity. Call it from the application’s process termination hook.
