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

messagelifecycle

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

+ var ErrDedupeConflict = errors.New("message lifecycle dedupe conflict")

+ var ErrDirectionMismatch = errors.New("message lifecycle direction does not match message")

+ var ErrMessageNotFound = errors.New("message lifecycle message not found")

+ func Catalog() map[ReasonCode]Definition

+ func IsTerminalSubmissionFailure(code ReasonCode) bool

+ func SafeAuthenticationEvidence(authentication any) (map[string]any, error)

+ func SafeCorrelationIDs(correlationIDs map[string]string) map[string]string

+ func SafeDiagnostic(value string) string

+ func SendSuppressionDedupeKey(jobID int64, attempt int, recipient string) string

+ type AppendInput struct

+ CorrelationIDs map[string]string

+ DedupeKey string

+ Direction string

+ Evidence map[string]any

+ MessageID string

+ OccurredAt time.Time

+ ReasonCode ReasonCode

+ Recipient string

+ type Definition struct

+ Outcome Outcome

+ Retryable bool

+ Stage Stage

+ func Lookup(reason ReasonCode) (Definition, bool)

+ type EventSnapshot struct

+ CreatedAt time.Time

+ Envelope json.RawMessage

+ ID string

+ Type string

+ type MessageLifecycleTransition struct

+ CorrelationIDs map[string]string

+ DedupeKey string

+ Direction string

+ Evidence map[string]any

+ ID string

+ MessageID string

+ OccurredAt time.Time

+ Outcome Outcome

+ ReasonCode ReasonCode

+ Recipient string

+ Reconstructed bool

+ Retryable bool

+ SourceTransitionID string

+ Stage Stage

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

+ func MergeTransitions(persisted, reconstructed []MessageLifecycleTransition) []MessageLifecycleTransition

+ func NewTransition(input AppendInput) (MessageLifecycleTransition, error)

+ func Reconstruct(snapshot Snapshot) []MessageLifecycleTransition

+ type Outcome string

+ const OutcomeAccepted

+ const OutcomeApplied

+ const OutcomeApproved

+ const OutcomeBlocked

+ const OutcomeBounced

+ const OutcomeDeferred

+ const OutcomeDelivered

+ const OutcomeEnqueued

+ const OutcomeFailed

+ const OutcomeIndeterminate

+ const OutcomePassed

+ const OutcomePending

+ const OutcomeRejected

+ const OutcomeReported

+ type ReasonCode string

+ const ReasonAcceptanceInboundSMTP

+ const ReasonAcceptanceLocalLoopback

+ const ReasonAcceptanceOutboundAPI

+ const ReasonAuthenticationDMARCFail

+ const ReasonAuthenticationDMARCNone

+ const ReasonAuthenticationDMARCPass

+ const ReasonAuthenticationDMARCPermanentError

+ const ReasonAuthenticationDMARCTemporaryError

+ const ReasonComplaintRecipientReported

+ const ReasonDeliveryPermanentBounce

+ const ReasonDeliveryRecipientServerAccepted

+ const ReasonDeliveryTemporaryDelay

+ const ReasonDeliveryTransientBounce

+ const ReasonDeliveryUndeterminedBounce

+ const ReasonQueueInboundProcessing

+ const ReasonQueueOutboundSubmission

+ const ReasonReviewApproved

+ const ReasonReviewExpiredApproved

+ const ReasonReviewExpiredRejected

+ const ReasonReviewHoldCreated

+ const ReasonReviewRejected

+ const ReasonSubmissionCancelled

+ const ReasonSubmissionLocalLoopbackAccepted

+ const ReasonSubmissionLocalRetriesExhausted

+ const ReasonSubmissionProviderRejected

+ const ReasonSubmissionTemporaryFailure

+ const ReasonSubmissionUpstreamAccepted

+ const ReasonSuppressionComplaintApplied

+ const ReasonSuppressionHardBounceApplied

+ const ReasonSuppressionRecipientBlocked

+ func AuthenticationReason(status string) (ReasonCode, error)

+ func BounceReason(bounceType string) ReasonCode

+ type RecipientSnapshot struct

+ Address string

+ Detail string

+ ID string

+ Status string

+ UpdatedAt time.Time

+ type Snapshot struct

+ AgentID string

+ ApprovalExpiresAt *time.Time

+ Authentication json.RawMessage

+ CreatedAt time.Time

+ DeliveryFailureSource string

+ DeliveryStatus string

+ Direction string

+ EmailMessageID string

+ Events []EventSnapshot

+ JobCreatedAt *time.Time

+ MessageID string

+ Method string

+ ProviderAcceptedAt *time.Time

+ ProviderMessageID string

+ Recipients []RecipientSnapshot

+ ReviewedAt *time.Time

+ SendJobID *int64

+ Status string

+ Suppressions []SuppressionSnapshot

+ UserID string

+ type Stage string

+ const StageAccepted

+ const StageAuthentication

+ const StageComplaint

+ const StageDelivery

+ const StageQueued

+ const StageReview

+ const StageSubmission

+ const StageSuppression

+ type Store struct

+ func NewStore(pool *pgxpool.Pool) *Store

+ func (s *Store) ListForMessage(ctx context.Context, messageID, agentID string) ([]MessageLifecycleTransition, error)

+ type SuppressionSnapshot struct

+ Address string

+ CreatedAt time.Time

+ ID string

+ Source string

+ SourceMessageID string