webhooknotify

Sep 5, 2026

Changes in this version

+ func ExpectedOperationID(wh *identity.Webhook, kind string) string

+ type ArgStamper func(ctx context.Context, jobID int64, ref sendingpolicy.OperationRef) error

type Deliverer

+ Compose func(ctx context.Context, wh *identity.Webhook, kind string) (outbound.Envelope, DeliverOutcome)

+ Submit func(ctx context.Context, env outbound.Envelope, ...) DeliverOutcome

type Jobs

+ func (j *Jobs) Compose(ctx context.Context, wh *identity.Webhook, kind string) (outbound.Envelope, DeliverOutcome)

+ func (j *Jobs) Gate() sendingpolicy.Gate

+ func (j *Jobs) NotifyWorker() *NotifyWorker

+ func (j *Jobs) ResolveLegacyOperation(ctx context.Context, webhookID, kind string) (sendingpolicy.OperationRef, error)

+ func (j *Jobs) Submit(ctx context.Context, env outbound.Envelope, ...) DeliverOutcome

+ func (j *Jobs) WithGate(g sendingpolicy.Gate, pool *pgxpool.Pool) *Jobs

type Notifier

+ func (n *Notifier) Compose(ctx context.Context, wh *identity.Webhook, kind string) (outbound.Envelope, DeliverOutcome)

+ func (n *Notifier) Submit(ctx context.Context, env outbound.Envelope, ...) DeliverOutcome

type NotifyWorker

+ func (w *NotifyWorker) Gate() sendingpolicy.Gate

+ func (w *NotifyWorker) WithArgRestamper(s ArgStamper) *NotifyWorker

+ func (w *NotifyWorker) WithArgStamper(s ArgStamper) *NotifyWorker

+ func (w *NotifyWorker) WithGate(g sendingpolicy.Gate) *NotifyWorker

+ func (w *NotifyWorker) WithOperationResolver(r OperationResolver) *NotifyWorker

+ type OperationResolver func(ctx context.Context, webhookID, kind string) (sendingpolicy.OperationRef, error)

type WebhookNotifyArgs

+ OperationRef *sendingpolicy.OperationRef

Aug 8, 2026

Changes in this version

+ const KindDisabled

+ const KindWarning

+ const MaxNotifyAttempts

+ type DeliverOutcome struct

+ Err error

+ Outage bool

+ Permanent bool

+ type Deliverer interface

+ Deliver func(ctx context.Context, wh *identity.Webhook, kind string) DeliverOutcome

+ type Jobs struct

+ func NewJobs(store Store) *Jobs

+ func (j *Jobs) Deliver(ctx context.Context, wh *identity.Webhook, kind string) DeliverOutcome

+ func (j *Jobs) EnqueueDisabledTx(ctx context.Context, tx pgx.Tx, webhookID string) error

+ func (j *Jobs) EnqueueWarningTx(ctx context.Context, tx pgx.Tx, webhookID string) error

+ func (j *Jobs) EnqueueWebhookNotifyTx(ctx context.Context, tx pgx.Tx, webhookID, kind string) (int64, error)

+ func (j *Jobs) RegisterJobs(w *river.Workers) []*river.PeriodicJob

+ func (j *Jobs) SetDeliverer(d Deliverer)

+ func (j *Jobs) SetEnqueuer(e jobs.Enqueuer)

+ func (j *Jobs) WithMetrics(m Metrics) *Jobs

+ type Metrics interface

+ WebhookNotify func(kind, outcome string)

+ type Notifier struct

+ func New(store NotifierStore, r relay, ...) *Notifier

+ func (n *Notifier) Deliver(ctx context.Context, wh *identity.Webhook, kind string) DeliverOutcome

+ func (n *Notifier) FromAddress() string

+ func (n *Notifier) WithDKIM(lookup outbound.DKIMKeyLookup) *Notifier

+ type NotifierStore interface

+ GetUserByID func(ctx context.Context, id string) (*identity.User, error)

+ RecentWebhookFailureStats func(ctx context.Context, webhookID string, window time.Duration) (identity.WebhookFailureStats, error)

+ type NotifyWorker struct

+ func NewNotifyWorker(store Store, deliverer Deliverer) *NotifyWorker

+ func (w *NotifyWorker) NextRetry(job *river.Job[WebhookNotifyArgs]) time.Time

+ func (w *NotifyWorker) WithMetrics(m Metrics) *NotifyWorker

+ func (w *NotifyWorker) Work(ctx context.Context, job *river.Job[WebhookNotifyArgs]) error

+ type Store interface

+ GetWebhookByIDInternal func(ctx context.Context, webhookID string) (*identity.Webhook, error)

+ type WebhookNotifyArgs struct

+ NotifyKind string

+ WebhookID string

+ func (WebhookNotifyArgs) Kind() string