The whole Worker queue() handler for the audit-export consumer,
previously copied verbatim into each host: guard the endpoint config —
a consumer bound without an endpoint logs a config-error and RETRIES the
batch (fail closed: nothing is acked unconfirmed, and the DLQ eventually
surfaces the misconfig) — then delegate to createAuditQueueConsumer.
Type Parameters
TEvent = unknown
Parameters
options: {authHeader?:string;endpoint?:string}
OptionalauthHeader?: string
Sent as the authorization header (the SIEM_AUTH_HEADER secret).
Optionalendpoint?: string
SIEM collector URL (the host's SIEM_ENDPOINT var).
The whole Worker
queue()handler for the audit-export consumer, previously copied verbatim into each host: guard the endpoint config — a consumer bound without an endpoint logs a config-error and RETRIES the batch (fail closed: nothing is acked unconfirmed, and the DLQ eventually surfaces the misconfig) — then delegate to createAuditQueueConsumer.