webhook

package

Go to main page

Versions in this module

v1

v1.4.1

Jul 26, 2026

Changes in this version

type SubscriberDelivery

+ EventCreatedAt *time.Time

+ ReplayID *string

type SubscriberStore

+ func (s *SubscriberStore) MarkDeliveredIfPending(ctx context.Context, deliveryID string, statusCode int) (bool, error)

+ func (s *SubscriberStore) MarkSubscriberFailedIfPending(ctx context.Context, deliveryID string, attemptN int, errMsg string, ...) error

+ func (s *SubscriberStore) TransitionSubscriberFailedIfPending(ctx context.Context, deliveryID string, attemptN int, errMsg string, ...) (bool, error)

v1.1.0

Jul 21, 2026

Changes in this version

+ const DeliveryTTL

+ const LeaseDuration

+ func IsDisallowedWebhookIP(ip net.IP) bool

+ type AutoDisableWorker struct

+ func NewAutoDisableWorker(store *identity.Store) *AutoDisableWorker

+ func (w *AutoDisableWorker) Tick(ctx context.Context)

+ type Delivery struct

+ AgentID string

+ Attempts int

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ LastAttemptAt *time.Time

+ LastError string

+ MaxAttempts int

+ MessageID string

+ NextRetryAt time.Time

+ Status string

+ type DeliveryOutcome struct

+ Error string

+ StatusCode int

+ Success bool

+ type DeliveryStore struct

+ func NewDeliveryStore(pool *pgxpool.Pool) *DeliveryStore

+ func (s *DeliveryStore) CreateDelivery(ctx context.Context, messageID string, lastError string) (*Delivery, error)

+ func (s *DeliveryStore) DeleteExpiredDeliveries(ctx context.Context) (int64, error)

+ func (s *DeliveryStore) GetPendingDeliveries(ctx context.Context, limit int) ([]Delivery, error)

+ func (s *DeliveryStore) MarkAttemptFailed(ctx context.Context, messageID, errMsg string, nextRetry time.Time) error

+ func (s *DeliveryStore) MarkDelivered(ctx context.Context, messageID string) error

+ func (s *DeliveryStore) MarkFailed(ctx context.Context, messageID, errMsg string) error

+ type Payload struct

+ AuthHeaders map[string]string

+ CC []string

+ ConversationID string

+ From string

+ MessageID string

+ RawMessage []byte

+ ReceivedAt time.Time

+ Recipient string

+ ReplyTo []string

+ To []string

+ type SubscriberDeliverer struct

+ func NewSubscriberDeliverer(requireHTTPS bool, internalSinkURL string) *SubscriberDeliverer

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

+ type SubscriberDelivery struct

+ Attempts int

+ CreatedAt time.Time

+ EventPayload []byte

+ EventType string

+ ExpiresAt time.Time

+ ID string

+ LastAttemptAt *time.Time

+ LastError string

+ LastStatusCode *int

+ MaxAttempts int

+ MessageID *string

+ NextRetryAt time.Time

+ Status string

+ WebhookID string

+ type SubscriberStore struct

+ func NewSubscriberStore(pool *pgxpool.Pool) *SubscriberStore

+ func (s *SubscriberStore) DeleteExpiredSubscriberDeliveries(ctx context.Context) (int, error)

+ func (s *SubscriberStore) GetSubscriberDeliveryByID(ctx context.Context, deliveryID string) (*SubscriberDelivery, error)

+ func (s *SubscriberStore) InsertPendingForTest(ctx context.Context, webhookID, eventType string, envelope []byte) (string, error)

+ func (s *SubscriberStore) ListDeliveriesByWebhook(ctx context.Context, webhookID, status string, limit int, ...) ([]SubscriberDelivery, error)

+ func (s *SubscriberStore) MarkDelivered(ctx context.Context, deliveryID string, statusCode int) error

+ func (s *SubscriberStore) MarkSubscriberFailed(ctx context.Context, deliveryID string, attemptN int, errMsg string, ...) error

+ func (s *SubscriberStore) RecordSubscriberAttempt(ctx context.Context, deliveryID string, attemptN int, errMsg string, ...) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL