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.