Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

webhookdelivery

package

Go to main page

Versions in this module

v1

v1.4.1

Jul 26, 2026

Changes in this version

type DeliverWorker

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

type Jobs

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

+ type Metrics interface

+ WebhookAttempt func(outcome, statusClass string, seconds float64)

+ WebhookDeliveryRescued func(count int)

+ WebhookFirstAttemptLatency func(seconds float64)

+ WebhookTerminal func(outcome, scope string, count int)

v1.1.0

Jul 21, 2026

Changes in this version

+ const MaxDeliveryAttempts

+ type DeliverWorker struct

+ func NewDeliverWorker(subStore *webhook.SubscriberStore, deliverer Deliverer, webhooks WebhookReader) *DeliverWorker

+ func (w *DeliverWorker) NextRetry(job *river.Job[WebhookDeliverArgs]) time.Time

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

+ type Deliverer interface

+ Deliver func(ctx context.Context, url string, body []byte, ...) webhook.DeliveryOutcome

+ type Jobs struct

+ func NewJobs(subStore *webhook.SubscriberStore, deliverer Deliverer, webhooks WebhookReader, ...) *Jobs

+ func (j *Jobs) EnqueueDelivery(ctx context.Context, pool *pgxpool.Pool, deliveryID string) error

+ func (j *Jobs) EnqueueDeliveryTx(ctx context.Context, tx pgx.Tx, deliveryID string) (int64, error)

+ func (j *Jobs) ReconcilePending(ctx context.Context, pool *pgxpool.Pool) (int, error)

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

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

+ type MaintenanceJobs struct

+ func NewMaintenanceJobs(sweeper Sweeper) *MaintenanceJobs

+ func (m *MaintenanceJobs) RegisterJobs(w *river.Workers) []*river.PeriodicJob

+ type MaintenanceWorker struct

+ func NewMaintenanceWorker(sweeper Sweeper) *MaintenanceWorker

+ func (w *MaintenanceWorker) Work(ctx context.Context, _ *river.Job[WebhookMaintenanceArgs]) error

+ type ReconcileWorker struct

+ func (w *ReconcileWorker) Work(ctx context.Context, _ *river.Job[WebhookReconcileArgs]) error

+ type Sweeper interface

+ Tick func(ctx context.Context)

+ type WebhookDeliverArgs struct

+ DeliveryID string

+ func (WebhookDeliverArgs) Kind() string

+ type WebhookMaintenanceArgs struct

+ func (WebhookMaintenanceArgs) Kind() string

+ type WebhookReader interface

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

+ type WebhookReconcileArgs struct

+ func (WebhookReconcileArgs) Kind() string