Documentation
¶
Overview ¶
Package webhookwire assembles inbound webhooks for the HTTP composition root (#1870): the source store, the receiver mounted at /hooks/, the compactor, and the source service the admin API calls.
Everything a source writes lands in the managed-resources bucket, through a client on the managed-resources S3 connection, because the scratch catalog that reads a source's compacted windows -- which are managed resources -- has to read its raw segments as well. A deployment with no database, no managed resources store or no Trino toolkit has no webhooks.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Webhooks ¶
type Webhooks struct {
// Service manages sources; the admin API mounts it.
Service *whadmin.Service
// contains filtered or unexported fields
}
Webhooks is the assembled feature. A nil *Webhooks is a deployment without webhooks, and every method on it does nothing.
func Build ¶
Build assembles webhooks from the platform. address is the main listener's, which names this replica. It returns nil when the deployment cannot hold a webhook source.
Source Files