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

delivery

package

Go to main page

Versions in this module

v1

v1.5.0

Aug 1, 2026

v1.4.1

Jul 26, 2026

v1.4.0

Jul 26, 2026

v1.3.0

Jul 25, 2026

v1.2.2

Jul 24, 2026

v1.2.1

Jul 23, 2026

Changes in this version

type Event

+ OccurredAt time.Time

+ ProviderEventID string

type FiredEvent

+ OccurredAt time.Time

+ type ProviderAcceptanceFinalizer func(ctx context.Context, tx pgx.Tx, messageID string) error

type Store

+ AddSuppressionTx func(ctx context.Context, tx pgx.Tx, ...) (suppressionID string, added bool, err error)

+ AppendLifecycleTx func(ctx context.Context, tx pgx.Tx, input messagelifecycle.AppendInput) (messagelifecycle.MessageLifecycleTransition, error)

+ HasApplicableRecipientTx func(ctx context.Context, tx pgx.Tx, messageID string, addresses []string) (bool, error)

+ ProviderAcceptancePendingTx func(ctx context.Context, tx pgx.Tx, messageID string) (bool, error)

+ RecordDeliveryOutcomeTx func(ctx context.Context, tx pgx.Tx, messageID, address string, status Status, ...) (applied bool, err error)

+ RecordProviderAcceptEvidenceTx func(ctx context.Context, tx pgx.Tx, messageID, sesMessageID string, ...) error

+ RecordProviderRejectTx func(ctx context.Context, tx pgx.Tx, messageID, detail string, occurredAt time.Time) error

+ WithTx func(ctx context.Context, fn func(tx pgx.Tx) error) error

v1.2.0

Jul 22, 2026

v1.1.0

Jul 21, 2026

Changes in this version

+ const EventEmailBounced

+ const EventEmailComplained

+ const EventEmailDelivered

+ const EventEmailFailed

+ const EventSuppressionAdded

+ const MessageIDHeader

+ func ConfirmSubscriptionURL(m *SNSMessage) (string, bool)

+ func HTTPCertFetcher(ctx context.Context, certURL string) ([]byte, error)

+ func Handler(v *Verifier, c *Consumer) http.HandlerFunc

+ type CertFetcher func(ctx context.Context, url string) ([]byte, error)

+ type Consumer struct

+ func NewConsumer(store Store, fire Firer) *Consumer

+ func (c *Consumer) Process(ctx context.Context, ev *Event) error

+ type CorrelatedMessage struct

+ AgentID string

+ BCC []string

+ CC []string

+ ConversationID string

+ From string

+ MessageID string

+ MessageType string

+ Method string

+ Subject string

+ To []string

+ UserID string

+ type Event struct

+ BounceSubType string

+ BounceType string

+ E2AMessageID string

+ Kind EventKind

+ Recipients []RecipientOutcome

+ SESMessageID string

+ func ParseSESNotification(messageBody []byte) (*Event, error)

+ type EventKind string

+ const KindBounce

+ const KindComplaint

+ const KindDelivery

+ const KindDeliveryDelay

+ const KindOther

+ const KindReject

+ const KindSend

+ type FailureSource string

+ const FailureSourceLocal

+ const FailureSourceProvider

+ func (fs FailureSource) Correctable() bool

+ type FiredEvent struct

+ AgentID string

+ ConversationID string

+ Data any

+ DedupKey string

+ MessageID string

+ Type string

+ UserID string

+ type Firer func(ctx context.Context, e FiredEvent)

+ type RecipientOutcome struct

+ Address string

+ Detail string

+ Status Status

+ Suppress bool

+ type SNSMessage struct

+ Message string

+ MessageId string

+ Signature string

+ SignatureVersion string

+ SigningCertURL string

+ Subject string

+ SubscribeURL string

+ Timestamp string

+ Token string

+ TopicArn string

+ Type string

+ type Status string

+ const StatusAccepted

+ const StatusBounced

+ const StatusComplained

+ const StatusDeferred

+ const StatusDelivered

+ const StatusFailed

+ const StatusQueued

+ const StatusSending

+ const StatusSent

+ func Merge(current, incoming Status) Status

+ func ResolveMessageRollup(current Status, source FailureSource, rollup Status) Status

+ func (s Status) ProvesProviderAcceptance() bool

+ func (s Status) Terminal() bool

+ func (s Status) Valid() bool

+ type Store interface

+ AddSuppression func(ctx context.Context, userID, address, reason, source, sourceMessageID string) (added bool, err error)

+ CorrelateByE2AMessageID func(ctx context.Context, e2aMessageID string) (m *CorrelatedMessage, found bool, err error)

+ CorrelateBySESMessageID func(ctx context.Context, sesMessageID string) (m *CorrelatedMessage, found bool, err error)

+ RecordDeliveryOutcome func(ctx context.Context, messageID, address string, status Status, detail string) error

+ RecordProviderAcceptEvidence func(ctx context.Context, messageID, sesMessageID string) error

+ type Verifier struct

+ func NewVerifier(allowedTopicARNs []string, fetch CertFetcher) *Verifier

+ func (v *Verifier) IsSubscriptionConfirmation(m *SNSMessage) bool

+ func (v *Verifier) Verify(ctx context.Context, m *SNSMessage) error