identity

package

Go to main page

Versions in this module

v1

v1.5.0

Aug 1, 2026

Changes in this version

+ const ContactSourceImport

+ const ContactSourceInbound

+ const ContactSourceManual

+ const DefaultMaxContacts

+ const ImportStatusCreated

+ const ImportStatusFailed

+ const ImportStatusSkipped

+ const ImportStatusUpdated

+ const MaxThreadAnchorMatches

+ const ThreadIdentityAuditBatchSize

+ const ThreadIdentityAuditMaxDepth

+ var ErrContactExists = errors.New("contact already exists")

+ var ErrContactLimitReached = errors.New("contact limit reached")

+ var ErrContactNotFound = errors.New("contact not found")

+ var ErrContactPreconditionFailed = errors.New("contact precondition failed")

+ var ErrEngagementNotFound = errors.New("engagement not found")

+ var ErrEngagementPreconditionFailed = errors.New("engagement precondition failed")

+ var ErrImportBatchNotFound = errors.New("import batch not found")

+ func IsValidThreadID(id string) bool

+ func NewContactID() string

+ func NewEngagementID() string

+ func NewImportBatchID() string

+ func NewThreadID() string

+ type Contact struct

+ Address string

+ CreatedAt time.Time

+ DisplayName string

+ ID string

+ ImportBatchID string

+ Metadata map[string]any

+ Source string

+ UpdatedAt time.Time

+ type ContactEngagement struct

+ Address string

+ AgentEmail string

+ ContactID string

+ ContactMetadata map[string]any

+ CreatedAt time.Time

+ DisplayName string

+ FirstOutboundAt *time.Time

+ ID string

+ InboundCount int

+ LastConversationID string

+ LastInboundAt *time.Time

+ LastOutboundAt *time.Time

+ Metadata map[string]any

+ NextActionAt *time.Time

+ OutboundCount int

+ Stage string

+ Suppressed bool

+ SuppressionReason string

+ SuppressionSource string

+ UpdatedAt time.Time

+ func (e ContactEngagement) Replied() bool

+ type ContactFilter struct

+ CreatedAfter time.Time

+ CreatedBefore time.Time

+ ImportBatchID string

+ Source string

+ type ContactImportOptions struct

+ AgentID string

+ Merge bool

+ Stage string

+ type ContactImportOutcome struct

+ Address string

+ Code string

+ Enrolled bool

+ Index int

+ Message string

+ Status string

+ type ContactImportRow struct

+ Address string

+ DisplayName *string

+ Metadata map[string]any

+ type DueEngagement struct

+ Address string

+ AgentEmail string

+ ContactMetadata map[string]any

+ DisplayName string

+ EngagementID string

+ LastConversationID string

+ LastOutboundAt *time.Time

+ NextActionAt time.Time

+ OutboundCount int

+ Replied bool

+ Stage string

+ UserID string

+ type EngagementFilter struct

+ LastOutboundBefore time.Time

+ NextActionBefore time.Time

+ Replied *bool

+ Stage string

+ Suppressed *bool

+ type InboundThreadEvidence struct

+ DeliveryTwinSourceID string

+ InReplyTo []RFCMessageIDCandidate

+ References []RFCMessageIDCandidate

type Message

+ RFCMessageIDKey string

+ ScheduledAt *time.Time

+ ThreadID string

+ ThreadParentID string

+ type OutboundJobCanceller interface

+ CancelTx func(ctx context.Context, tx pgx.Tx, jobID int64) error

type OutboundSendPayload

+ ScheduledAt *time.Time

+ type RFCMessageIDCandidate struct

+ Canonical string

+ Original string

+ type ScheduledSendFinalizer interface

+ FinalizeScheduledCancellationTx func(ctx context.Context, tx pgx.Tx, messageID string, jobID int64, ...) error

type Store

+ func (s *Store) AuditThreadIdentity(ctx context.Context, afterID string) (ThreadIdentityAuditResult, error)

+ func (s *Store) AuditThreadIdentityBatch(ctx context.Context, afterID string, limit, maxDepth int) (ThreadIdentityAuditResult, error)

+ func (s *Store) ClaimDueEngagements(ctx context.Context, now time.Time, limit int) ([]DueEngagement, error)

+ func (s *Store) ClaimDueEngagementsTx(ctx context.Context, tx pgx.Tx, now time.Time, limit int) ([]DueEngagement, error)

+ func (s *Store) CreateContact(ctx context.Context, userID, address, displayName string, ...) (Contact, error)

+ func (s *Store) CreateInboundMessageAuthenticatedThreadedInTx(ctx context.Context, tx pgx.Tx, id, agentID string, auth InboundAuth, ...) (*Message, error)

+ func (s *Store) CreateInboundMessageAuthenticatedTwinInTx(ctx context.Context, tx pgx.Tx, sourceMessageID, id, agentID string, ...) (*Message, error)

+ func (s *Store) CreateOutboundMessageThreadedTx(ctx context.Context, tx pgx.Tx, parentMessageID string, agentID string, ...) (*Message, error)

+ func (s *Store) CreatePendingOutboundMessageManagedThreadedTx(ctx context.Context, tx pgx.Tx, parentMessageID, agentID string, ...) (*Message, error)

+ func (s *Store) DeleteContact(ctx context.Context, userID, address string) (bool, error)

+ func (s *Store) DeleteEngagement(ctx context.Context, userID, agentID, address string) (bool, error)

+ func (s *Store) DeleteImportBatch(ctx context.Context, userID, batchID string) (deleted int, retained int, engagementsDeleted int, err error)

+ func (s *Store) EnsureThreadTx(ctx context.Context, tx pgx.Tx, agentID, messageID string) (string, error)

+ func (s *Store) GetContactByAddress(ctx context.Context, userID, address string) (Contact, error)

+ func (s *Store) GetEngagement(ctx context.Context, userID, agentID, address string) (ContactEngagement, error)

+ func (s *Store) ImportContacts(ctx context.Context, userID, batchID string, rows []ContactImportRow, ...) ([]ContactImportOutcome, error)

+ func (s *Store) ImportContactsWithOptions(ctx context.Context, userID, batchID string, rows []ContactImportRow, ...) ([]ContactImportOutcome, error)

+ func (s *Store) ListContacts(ctx context.Context, userID string, f ContactFilter, limit int, ...) ([]Contact, error)

+ func (s *Store) ListEngagements(ctx context.Context, userID, agentID string, f EngagementFilter, limit int, ...) ([]ContactEngagement, error)

+ func (s *Store) MaxContactsForUser(ctx context.Context, userID string) (int, error)

+ func (s *Store) RecordInboundActivity(ctx context.Context, userID, agentID, address, conversationID string, ...) (bool, error)

+ func (s *Store) RecordInboundActivityTx(ctx context.Context, tx pgx.Tx, ...) (bool, error)

+ func (s *Store) RecordOutboundActivity(ctx context.Context, userID, agentID, address, conversationID string, ...) (bool, error)

+ func (s *Store) RecordOutboundActivityTx(ctx context.Context, tx pgx.Tx, ...) (bool, error)

+ func (s *Store) SetOutboundJobCanceller(c OutboundJobCanceller)

+ func (s *Store) SetScheduledSendFinalizer(f ScheduledSendFinalizer)

+ func (s *Store) SetThreadMetrics(metrics ThreadIdentityMetrics)

+ func (s *Store) StampScheduledAtTx(ctx context.Context, tx pgx.Tx, messageID string, at time.Time) error

+ func (s *Store) UpdateContact(ctx context.Context, userID, address string, displayName *string, ...) (Contact, error)

+ func (s *Store) UpdateContactIfUnchanged(ctx context.Context, userID, address string, displayName *string, ...) (Contact, error)

+ func (s *Store) UpdateEngagementIfUnchanged(ctx context.Context, userID, agentID, address string, stage *string, ...) (ContactEngagement, error)

+ func (s *Store) UpsertEngagement(ctx context.Context, userID, agentID, address string, stage *string, ...) (ContactEngagement, bool, error)

+ type ThreadIdentityAuditResult struct

+ ConversationsSampled int

+ MultiConversationThreads int

+ MultiThreadConversations int

+ NextCursor string

+ NullThreadsByAge ThreadNullAgeBuckets

+ RepairedParentPointers int

+ Scanned int

+ ThreadsSampled int

+ Violations ThreadInvariantViolations

+ type ThreadIdentityMetrics interface

+ ThreadResolution func(source string, count int)

+ type ThreadInvariantViolations struct

+ CrossAgentParent int

+ Cycle int

+ CycleDepthLimit int

+ DanglingParent int

+ ThreadMismatch int

+ type ThreadNullAgeBuckets struct

+ LessThanOneHour int

+ OneToSixHours int

+ SixToTwentyFourHours int

v1.4.1

Jul 26, 2026

v1.4.0

Jul 26, 2026

Changes in this version

+ var ErrEmailConflict = errors.New("identity: email already held by another user")

type Store

+ func (s *Store) CountAgentsOnDomain(ctx context.Context, domain, userID string) (live, trashed int, err error)

+ func (s *Store) ProvisionUser(ctx context.Context, externalRef, email, name string) (*User, bool, error)

v1.3.0

Jul 25, 2026

Changes in this version

+ type LocalInboundScreen struct

+ FlagReason string

+ Flagged bool

+ MessageID string

+ Screening InboundScreening

v1.2.2

Jul 24, 2026

v1.2.1

Jul 23, 2026

Changes in this version

+ var ErrInvalidApprovalTarget = fmt.Errorf("invalid approval target")

type InboundIntake

+ ProcessJobID int64

type Message

+ LifecycleTransitions []messagelifecycle.MessageLifecycleTransition

type OutboundSendPayload

+ ProviderAcceptedAt *time.Time

type OutboundSentInfo

+ ProviderAcceptedAt time.Time

type Store

+ func (s *Store) AddSuppressionTx(ctx context.Context, tx pgx.Tx, ...) (string, bool, error)

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

+ func (s *Store) ApproveInboundReviewWithTransition(ctx context.Context, messageID, agentID, reviewerID string) (messagelifecycle.MessageLifecycleTransition, error)

+ func (s *Store) ExpireApproveReviewWithTransition(ctx context.Context, messageID string) (messagelifecycle.MessageLifecycleTransition, error)

+ func (s *Store) ExpireRejectReviewWithTransition(ctx context.Context, messageID, rejectionReason string) (messagelifecycle.MessageLifecycleTransition, error)

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

+ func (s *Store) OutboundSendJobIDTx(ctx context.Context, tx pgx.Tx, messageID string) (int64, error)

+ func (s *Store) PreserveOutboundTerminalFailure(ctx context.Context, messageID string, jobID int64, attempt int, ...) error

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

+ func (s *Store) RecordDeliveryOutcomeTx(ctx context.Context, tx pgx.Tx, messageID, address string, ...) (bool, error)

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

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

+ func (s *Store) RejectInboundReviewWithTransition(ctx context.Context, messageID, agentID, reviewerID, rejectionReason string) (messagelifecycle.MessageLifecycleTransition, error)

v1.2.0

Jul 22, 2026

v1.1.0

Jul 21, 2026

Changes in this version

+ const AutoDisableThreshold

+ const AutoDisableWindow

+ const ConversationListHardCap

+ const DashboardDefaultWindowDays

+ const DashboardMaxWindowDays

+ const DefaultMaxTemplates

+ const DefaultMaxWebhooks

+ const HITLDefaultExpirationAct

+ const HITLDefaultTTLSeconds

+ const HITLExpirationApprove

+ const HITLExpirationReject

+ const HITLMaxTTLSeconds

+ const IntakeStatusAccepted

+ const IntakeStatusFailed

+ const IntakeStatusProcessed

+ const MaxAPIKeyNameLen

+ const MaxAgentNameLen

+ const MaxLabelsPerMessage

+ const MaxRejectReasonLen

+ const MessageStatusPendingReview

+ const MessageStatusReviewApproved

+ const MessageStatusReviewExpiredApproved

+ const MessageStatusReviewExpiredRejected

+ const MessageStatusReviewRejected

+ const MessageStatusSent

+ const OutboundPolicyAllowlist

+ const OutboundPolicyDomain

+ const OutboundPolicyOpen

+ const OutboundSendClaimStaleWindow

+ const ReviewReasonInboundScan

+ const ReviewReasonOutboundScan

+ const ReviewReasonOutboundSend

+ const ReviewReasonRecipientGate

+ const ReviewReasonSenderGate

+ const ScanActionBlock

+ const ScanActionFlag

+ const ScanActionReview

+ const ScanOff

+ const ScanOn

+ const ScopeAccount

+ const ScopeAgent

+ const ScreeningSourceGate

+ const ScreeningSourceScan

+ const SendAttemptStaleWindow

+ const SensitivityHigh

+ const SensitivityLow

+ const SensitivityMedium

+ const SensitivityOff

+ const SessionTTL

+ const WebhookStatusAutoDisabled

+ const WebhookStatusDisabled

+ const WebhookStatusFailing

+ const WebhookStatusHealthy

+ const WebhookStatusNone

+ var ErrAPIKeyNotFound = errors.New("api key not found")

+ var ErrAgentNotFound = fmt.Errorf("agent not found or not owned by user")

+ var ErrDomainHasAgents = fmt.Errorf("cannot delete domain: agents still exist")

+ var ErrDomainNotFound = fmt.Errorf("domain not found or not owned by user")

+ var ErrDomainTaken = fmt.Errorf("domain not available: already claimed by another account")

+ var ErrIntakeAlreadyProcessed = errors.New("inbound intake already processed")

+ var ErrLabelLimitExceeded = errors.New("label limit exceeded")

+ var ErrMessageHeld = fmt.Errorf("message is held for review")

+ var ErrMessageNotFound = fmt.Errorf("message not found")

+ var ErrNotInTrash = fmt.Errorf("resource is not in the trash")

+ var ErrNotPendingApproval = fmt.Errorf("message is not pending approval")

+ var ErrNotPendingReview = fmt.Errorf("message is not pending review")

+ var ErrRecipientGone = errors.New("recipient no longer resolves to an agent")

+ var ErrReservedDomain = fmt.Errorf("domain is reserved for managed infrastructure")

+ var ErrSendInProgress = errors.New("send already in progress for this message")

+ var ErrTemplateAliasTaken = errors.New("template alias already in use")

+ var ErrTemplateLimitReached = errors.New("template count limit reached for this user")

+ var ErrTemplateNotFound = errors.New("template not found")

+ var ErrWebhookCapReached = errors.New("webhook count limit reached for this user")

+ var ErrWebhookCooldown = errors.New("webhook was auto-disabled within the last 5 minutes; wait before re-enabling")

+ var ErrWebhookNotFound = errors.New("webhook not found")

+ var TrashRetention = 30 * 24 * time.Hour

+ func ContentScanEnabled() bool

+ func DeterministicProtectionEventID(messageID, source, reason, detector string) string

+ func NewConversationID() string

+ func NewInboundIntakeID() string

+ func NewMessageID() string

+ func NewProtectionEventID() string

+ func NormalizeEmail(email string) string

+ func NormalizeMailboxAddress(value string) string

+ func RunMigrations(ctx context.Context, pool *pgxpool.Pool, migrationsFS fs.FS, ...) error

+ func ValidScope(s string) bool

+ func ValidateAgentName(name string) error

+ func ValidateHITLConfig(ttlSeconds int, expirationAction string) error

+ func ValidateProtectionConfig(c ProtectionConfig) error

+ func ValidateScanConfig(c ScanConfig) error

+ type APIKey struct

+ AgentID *string

+ CreatedAt time.Time

+ ExpiresAt *time.Time

+ ID string

+ KeyPrefix string

+ LastUsedAt *time.Time

+ Name string

+ PlaintextKey string

+ Scope string

+ UserID string

+ type APIKeyExportEntry struct

+ CreatedAt time.Time

+ ID string

+ KeyPrefix string

+ LastUsedAt *time.Time

+ Name string

+ RevokedAt *time.Time

+ type AcceptedSend struct

+ BCC []string

+ CC []string

+ EnvelopeFrom string

+ Method string

+ Raw []byte

+ SentAs string

+ Subject string

+ To []string

+ type AgentIdentity struct

+ AssertionVersion int

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ Domain string

+ DomainVerified bool

+ Email string

+ HITLExpirationAction string

+ HITLTTLSeconds int

+ ID string

+ Inbound7d int

+ InboundAllowlist []string

+ InboundPolicy string

+ InboundPolicyAction string

+ InboundScan string

+ InboundScanBlockThreshold float64

+ InboundScanReviewThreshold float64

+ InboundScanSensitivity string

+ LastDeliveryAt *time.Time

+ Name string

+ Outbound7d int

+ OutboundAllowlist []string

+ OutboundPolicy string

+ OutboundPolicyAction string

+ OutboundScan string

+ OutboundScanBlockThreshold float64

+ OutboundScanReviewThreshold float64

+ OutboundScanSensitivity string

+ PendingCount int

+ Public bool

+ RegisteredDomain string

+ SuppressNotifications bool

+ UserID string

+ WebhookStatus string

+ func (a *AgentIdentity) ActualDomain() string

+ func (a *AgentIdentity) EmailAddress() string

+ func (a *AgentIdentity) IsSharedDomain(sharedDomain string) bool

+ func (a *AgentIdentity) RegisteredDomainName() string

+ type AgentSuppression struct

+ Address string

+ AgentEmail string

+ CreatedAt time.Time

+ Reason string

+ Source string

+ type AgentSuppressionHookScope struct

+ Address string

+ AgentID string

+ Source string

+ UserID string

+ type AgentSuppressionTxHook func(context.Context, pgx.Tx, AgentSuppressionHookScope) error

+ type ConversationDetail struct

+ Labels []string

+ Messages []Message

+ Participants []string

+ type ConversationListFilter struct

+ AfterConversationID string

+ AfterLastMessageAt time.Time

+ AgentID string

+ Limit int

+ Since time.Time

+ Until time.Time

+ type ConversationSummary struct

+ FirstMessageAt time.Time

+ HasUnread bool

+ ID string

+ InboundCount int

+ LastMessageAt time.Time

+ LatestSender string

+ LatestSubject string

+ MessageCount int

+ OutboundCount int

+ type DKIMCipher struct

+ func NewDKIMCipher(master []byte) (*DKIMCipher, error)

+ type DashboardPendingStats struct

+ Count int

+ OldestSeconds int

+ type DashboardStats struct

+ DeliverySuccessPct float64

+ InboundWindow int

+ OutboundWindow int

+ Pending DashboardPendingStats

+ SampleWindowDays int

+ Today DashboardTodayStats

+ type DashboardTodayStats struct

+ Inbound int

+ InboundDeltaPct int

+ Outbound int

+ OutboundDeltaPct int

+ type DeleteUserDataResult struct

+ APIKeysDeleted int64

+ AgentSuppressionsDeleted int64

+ AgentUnsubscribeTokensDeleted int64

+ AgentsDeleted int64

+ Deleted bool

+ DomainsDeleted int64

+ MessagesDeleted int64

+ OAuthAccessTokensDeleted int64

+ OAuthAuthCodesDeleted int64

+ OAuthRefreshTokensDeleted int64

+ SessionsDeleted int64

+ UsageEventsDeleted int64

+ UsageSummariesDeleted int64

+ UserDeleted bool

+ type Domain struct

+ AgentCount int

+ CreatedAt time.Time

+ DKIMPublicKey string

+ DKIMSelector string

+ Domain string

+ IsPrimary bool

+ LastCheckedAt *time.Time

+ SendingDNSRecordsJSON []byte

+ SendingDkimStatus string

+ SendingError string

+ SendingLastCheckedAt *time.Time

+ SendingMailFromStatus string

+ SendingStatus string

+ UserID *string

+ VerificationToken string

+ Verified bool

+ VerifiedAt *time.Time

+ type ExpirationCandidate struct

+ AgentID string

+ ExpirationAction string

+ MessageID string

+ type InboundAuth struct

+ Authentication *emailauth.Authentication

+ EnvelopeFrom string

+ HeaderFrom string

+ StoredSender string

+ type InboundIntake struct

+ ContentHash string

+ CreatedAt time.Time

+ EnvelopeFrom string

+ HELODomain string

+ ID string

+ MessageID string

+ Raw []byte

+ Recipient string

+ RemoteIP string

+ Status string

+ type InboundScreening struct

+ ApprovalExpiresAt *time.Time

+ ReviewReason string

+ ScanAction string

+ ScanScore *float64

+ Status string

+ type LocalDeliveryTxHook func(ctx context.Context, tx pgx.Tx, outbound, inbound *Message, result SendResult) error

+ type Message struct

+ AgentID string

+ ApprovalExpiresAt *time.Time

+ Attachments []eventpayload.AttachmentMetaView

+ AttachmentsJSON json.RawMessage

+ Auth *emailauth.AuthVerdict

+ AuthHeaders map[string]string

+ Authentication *emailauth.Authentication

+ BCC []string

+ BodyHTML string

+ BodyText string

+ CC []string

+ ConversationID string

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ DeliveryDetail string

+ DeliveryStatus string

+ Direction string

+ Edited bool

+ EmailMessageID string

+ EnvelopeFrom string

+ ExpiresAt *time.Time

+ FlagReason string

+ Flagged bool

+ HeaderFrom string

+ ID string

+ InboxStatus string

+ Labels []string

+ ManagedUnsubscribe bool

+ Method string

+ ProviderMessageID string

+ RawMessage []byte

+ Recipient string

+ RejectionReason string

+ ReplyTo []string

+ ReviewReason string

+ ReviewedAt *time.Time

+ ReviewedByName *string

+ ReviewedByUserID *string

+ ScanAction string

+ ScanScore *float64

+ Sender string

+ SentAs string

+ SizeBytes int

+ Status string

+ Subject string

+ ToRecipients []string

+ Type string

+ VerifiedDomain *string

+ WebhookAttempts int

+ WebhookError string

+ WebhookStatus string

+ func (m *Message) ThreadMessageID() string

+ func (m Message) MarshalJSON() ([]byte, error)

+ type MessageListFilter struct

+ AfterID string

+ AfterTime time.Time

+ AgentID string

+ ConversationID string

+ Deleted bool

+ Descending bool

+ Direction string

+ From string

+ Labels []string

+ Limit int

+ Since time.Time

+ Status string

+ SubjectContains string

+ Until time.Time

+ type MigrationMode string

+ const ModeAuto

+ const ModeSkip

+ const ModeVerify

+ func ParseMigrationMode(s string) (MigrationMode, error)

+ type OAuthConnectionEntry struct

+ AgentEmail string

+ ClientID string

+ ClientName string

+ ExpiresAt *time.Time

+ IssuedAt time.Time

+ RevokedAt *time.Time

+ Scope string

+ type OutboundSendPayload struct

+ AgentID string

+ CreatedAt time.Time

+ DeliveryStatus string

+ Domain string

+ EnvelopeFrom string

+ ID string

+ MessageType string

+ ProviderAccepted bool

+ ProviderMessageID string

+ Raw []byte

+ Recipients []string

+ SentAs string

+ UserID string

+ type OutboundSentInfo struct

+ Domain string

+ Message *Message

+ UserID string

+ type PendingApprovalEdit struct

+ AttachmentsJSON []byte

+ AttachmentsSet bool

+ BCC []string

+ BodyHTML *string

+ BodyText *string

+ CC []string

+ Subject *string

+ To []string

+ func (e PendingApprovalEdit) Apply(msg *Message) bool

+ type PendingNotify struct

+ Agent *AgentIdentity

+ Message *Message

+ Notified bool

+ type Principal struct

+ AgentID string

+ Scope string

+ User *User

+ type ProtectionConfig struct

+ HITLExpirationAction string

+ HITLTTLSeconds int

+ InboundAllowlist []string

+ InboundGateAction string

+ InboundGatePolicy string

+ InboundScanSensitivity string

+ OutboundAllowlist []string

+ OutboundGateAction string

+ OutboundGatePolicy string

+ OutboundScanSensitivity string

+ SuppressNotifications bool

+ type ProtectionEvent struct

+ Action string

+ AgentID string

+ Categories json.RawMessage

+ CreatedAt time.Time

+ Detector string

+ Direction string

+ ID string

+ MessageID string

+ Raw json.RawMessage

+ Reason string

+ Score *float64

+ Source string

+ Spans json.RawMessage

+ SubjectAddr string

+ type ProtectionEventExportEntry struct

+ Action string

+ AgentID string

+ CreatedAt time.Time

+ Detector string

+ Direction string

+ ID string

+ MessageID string

+ Reason string

+ Score *float64

+ Source string

+ SubjectAddr string

+ type ReviewListItem struct

+ AgentID string

+ Authentication *emailauth.Authentication

+ ConversationID string

+ CreatedAt time.Time

+ Direction string

+ EnvelopeFrom string

+ FlagReason string

+ Flagged bool

+ HeaderFrom string

+ ID string

+ ReviewReason string

+ Sender string

+ Status string

+ Subject string

+ To []string

+ type ReviewMessageMeta struct

+ AgentID string

+ Direction string

+ ID string

+ Recipient string

+ Sender string

+ Status string

+ Subject string

+ Type string

+ type ScanConfig struct

+ InboundPolicyAction string

+ InboundScan string

+ InboundScanBlockThreshold float64

+ InboundScanReviewThreshold float64

+ OutboundAllowlist []string

+ OutboundPolicy string

+ OutboundPolicyAction string

+ OutboundScan string

+ OutboundScanBlockThreshold float64

+ OutboundScanReviewThreshold float64

+ type SendAttemptOutcome int

+ const SendAttemptAcquired

+ const SendAttemptAlreadySent

+ const SendAttemptInFlight

+ type SendAttemptResult struct

+ Outcome SendAttemptOutcome

+ Sent SendResult

+ type SendOutcome struct

+ DeliveryDetail string

+ DeliveryStatus string

+ ProviderMessageID string

+ SentAs string

+ type SendResult struct

+ BCC []string

+ CC []string

+ Method string

+ ProviderMessageID string

+ Raw []byte

+ Sender string

+ To []string

+ type Store struct

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

+ func (s *Store) AddAgentSuppression(ctx context.Context, userID, agentID, address, reason, source string, ...) (sp AgentSuppression, added bool, err error)

+ func (s *Store) AddAgentSuppressionFromTokenScope(ctx context.Context, scope UnsubscribeScope, onAdded AgentSuppressionTxHook) (AgentSuppression, bool, error)

+ func (s *Store) AddSuppression(ctx context.Context, userID, address, reason, source, sourceMessageID string) (bool, error)

+ func (s *Store) AdoptSharedDomain(ctx context.Context, domain, userID string) (*Domain, error)

+ func (s *Store) ApproveAndAccept(ctx context.Context, messageID, reviewedByUserID, targetStatus string, ...) (*Message, error)

+ func (s *Store) ApproveAndDeliverLocal(ctx context.Context, messageID, userID string, edits PendingApprovalEdit, ...) (*Message, error)

+ func (s *Store) ApproveAndSend(ctx context.Context, messageID, userID string, edits PendingApprovalEdit, ...) (*Message, error)

+ func (s *Store) ApproveInboundReview(ctx context.Context, messageID, agentID, reviewerID string) error

+ func (s *Store) AutoDisableFailingWebhooks(ctx context.Context) (int, error)

+ func (s *Store) BootstrapUser(ctx context.Context, email string) (*User, error)

+ func (s *Store) ClaimOrCreateDomain(ctx context.Context, domain, userID string) (*Domain, error)

+ func (s *Store) ClaimOutboundForSend(ctx context.Context, messageID string, jobID int64) (*OutboundSendPayload, error)

+ func (s *Store) ClaimSendAttempt(ctx context.Context, messageID string) (SendAttemptResult, error)

+ func (s *Store) ClearExpiredPrevSecrets(ctx context.Context) (int64, error)

+ func (s *Store) CorrelateByE2AMessageID(ctx context.Context, e2aMessageID string) (*delivery.CorrelatedMessage, bool, error)

+ func (s *Store) CorrelateBySESMessageID(ctx context.Context, sesMessageID string) (*delivery.CorrelatedMessage, bool, error)

+ func (s *Store) CountTemplatesByUser(ctx context.Context, userID string) (int, error)

+ func (s *Store) CountWebhooksByUser(ctx context.Context, userID string) (int, error)

+ func (s *Store) CreateAPIKey(ctx context.Context, userID, name string, expiresAt *time.Time) (*APIKey, error)

+ func (s *Store) CreateAgent(ctx context.Context, ...) (*AgentIdentity, error)

+ func (s *Store) CreateAgentTx(ctx context.Context, tx pgx.Tx, ...) (*AgentIdentity, error)

+ func (s *Store) CreateInboundMessage(ctx context.Context, ...) (*Message, error)

+ func (s *Store) CreateInboundMessageAuthenticated(ctx context.Context, id, agentID string, auth InboundAuth, ...) (*Message, error)

+ func (s *Store) CreateInboundMessageAuthenticatedInTx(ctx context.Context, tx pgx.Tx, id, agentID string, auth InboundAuth, ...) (*Message, error)

+ func (s *Store) CreateInboundMessageInTx(ctx context.Context, tx pgx.Tx, ...) (*Message, error)

+ func (s *Store) CreateOrGetUser(ctx context.Context, email, name, googleSub string) (*User, error)

+ func (s *Store) CreateOutboundMessage(ctx context.Context, agentID string, toRecipients []string, cc []string, ...) (*Message, error)

+ func (s *Store) CreateOutboundMessageTx(ctx context.Context, tx pgx.Tx, agentID string, toRecipients, cc, bcc []string, ...) (*Message, error)

+ func (s *Store) CreatePendingOutboundMessage(ctx context.Context, agentID string, toRecipients, cc, bcc []string, ...) (*Message, error)

+ func (s *Store) CreatePendingOutboundMessageManaged(ctx context.Context, agentID string, toRecipients, cc, bcc []string, ...) (*Message, error)

+ func (s *Store) CreatePendingOutboundMessageManagedTx(ctx context.Context, tx pgx.Tx, agentID string, toRecipients, cc, bcc []string, ...) (*Message, error)

+ func (s *Store) CreatePendingOutboundMessageTx(ctx context.Context, tx pgx.Tx, agentID string, toRecipients, cc, bcc []string, ...) (*Message, error)

+ func (s *Store) CreateProtectionEvent(ctx context.Context, ev ProtectionEvent) error

+ func (s *Store) CreateScopedAPIKey(ctx context.Context, userID, name, scope, agentID string, expiresAt *time.Time) (*APIKey, error)

+ func (s *Store) CreateTemplate(ctx context.Context, userID string, in TemplateCreate) (*Template, error)

+ func (s *Store) CreateUserSession(ctx context.Context, userID string) (string, error)

+ func (s *Store) CreateWebhook(ctx context.Context, userID, url, description string, events []string, ...) (*Webhook, error)

+ func (s *Store) CreateWebhookIdem(ctx context.Context, userID, url, description string, events []string, ...) (*Webhook, error)

+ func (s *Store) DeferOutboundTerminalFailure(ctx context.Context, messageID string, jobID int64, detail string) error

+ func (s *Store) DeleteAPIKey(ctx context.Context, keyID, userID string) error

+ func (s *Store) DeleteAgent(ctx context.Context, agentID, userID string) (messagesDeleted int64, err error)

+ func (s *Store) DeleteDomain(ctx context.Context, domain, userID string) error

+ func (s *Store) DeleteDomainTx(ctx context.Context, domain, userID string, ...) error

+ func (s *Store) DeleteExpiredMessages(ctx context.Context) (int64, error)

+ func (s *Store) DeleteExpiredUserSessions(ctx context.Context) (int64, error)

+ func (s *Store) DeleteTemplate(ctx context.Context, templateID, userID string) error

+ func (s *Store) DeleteUserData(ctx context.Context, userID string) (*DeleteUserDataResult, error)

+ func (s *Store) DeleteUserDataTx(ctx context.Context, userID string, ...) (*DeleteUserDataResult, error)

+ func (s *Store) DeleteUserSession(ctx context.Context, token string) error

+ func (s *Store) DeleteWebhook(ctx context.Context, webhookID, userID string) error

+ func (s *Store) DomainExists(ctx context.Context, domain string) (bool, error)

+ func (s *Store) DomainOwner(ctx context.Context, domain string) (string, error)

+ func (s *Store) EffectiveSuppressions(ctx context.Context, userID, agentID string, addresses []string) ([]string, error)

+ func (s *Store) EncryptLegacyDKIMKeys(ctx context.Context) (int, error)

+ func (s *Store) EnsureSharedDomain(ctx context.Context, domain string) error

+ func (s *Store) ExpireAndDeliverLocal(ctx context.Context, messageID string, ...) (*Message, error)

+ func (s *Store) ExpireApproveAndSend(ctx context.Context, messageID string, ...) (*Message, error)

+ func (s *Store) ExpireApproveReview(ctx context.Context, messageID string) error

+ func (s *Store) ExpireReject(ctx context.Context, messageID, reason string) (*Message, error)

+ func (s *Store) ExpireRejectReview(ctx context.Context, messageID, reason string) error

+ func (s *Store) ExportUserData(ctx context.Context, userID string) (*UserExport, error)

+ func (s *Store) GetAgentByEmail(ctx context.Context, email string) (*AgentIdentity, error)

+ func (s *Store) GetAgentByID(ctx context.Context, id string) (*AgentIdentity, error)

+ func (s *Store) GetAgentByIDAnyState(ctx context.Context, id string) (*AgentIdentity, error)

+ func (s *Store) GetConversationByID(ctx context.Context, agentID, conversationID string) (*ConversationDetail, error)

+ func (s *Store) GetDKIMKeyInternal(ctx context.Context, domain string) (string, []byte, error)

+ func (s *Store) GetDashboardStats(ctx context.Context, userID string, windowDays int) (*DashboardStats, error)

+ func (s *Store) GetEventEnvelope(ctx context.Context, messageID, eventType string) ([]byte, error)

+ func (s *Store) GetInboundByEmailMessageID(ctx context.Context, agentID, emailMessageID string) (*Message, error)

+ func (s *Store) GetInboundMessage(ctx context.Context, id string) (*Message, error)

+ func (s *Store) GetMessageByEmailMessageID(ctx context.Context, agentID, messageID string) (*Message, error)

+ func (s *Store) GetMessageWithContent(ctx context.Context, messageID, agentID string) (*Message, error)

+ func (s *Store) GetMessagesByAgent(ctx context.Context, f MessageListFilter) ([]Message, error)

+ func (s *Store) GetOutboundMessageForUser(ctx context.Context, messageID, userID string) (*Message, error)

+ func (s *Store) GetPrincipalByAPIKey(ctx context.Context, apiKey string) (*Principal, error)

+ func (s *Store) GetRepliableMessage(ctx context.Context, id string) (*Message, error)

+ func (s *Store) GetReviewMessage(ctx context.Context, messageID, agentID string) (*ReviewMessageMeta, error)

+ func (s *Store) GetReviewWithContent(ctx context.Context, userID, messageID string) (*Message, error)

+ func (s *Store) GetSendOutcome(ctx context.Context, messageID string) (SendOutcome, error)

+ func (s *Store) GetSendingStatus(ctx context.Context, domain string) (string, error)

+ func (s *Store) GetTemplateByAlias(ctx context.Context, alias, userID string) (*Template, error)

+ func (s *Store) GetTemplateByID(ctx context.Context, templateID, userID string) (*Template, error)

+ func (s *Store) GetUserByAPIKey(ctx context.Context, apiKey string) (*User, error)

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

+ func (s *Store) GetUserSession(ctx context.Context, token string) (*User, error)

+ func (s *Store) GetWebhookByID(ctx context.Context, webhookID, userID string) (*Webhook, error)

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

+ func (s *Store) HasAgentsOnDomain(ctx context.Context, domain, userID string) (bool, error)

+ func (s *Store) InsertInboundIntakeTx(ctx context.Context, tx pgx.Tx, ...) (inserted bool, err error)

+ func (s *Store) ListAPIKeys(ctx context.Context, userID string, limit int, afterCreatedAt time.Time, ...) ([]APIKey, error)

+ func (s *Store) ListActivityByAgent(ctx context.Context, agentID string, limit int) ([]Message, error)

+ func (s *Store) ListAgentSuppressions(ctx context.Context, userID, agentID string, limit int, after time.Time, ...) ([]AgentSuppression, error)

+ func (s *Store) ListAgentsByUser(ctx context.Context, userID string, limit int, afterCreatedAt time.Time, ...) ([]AgentIdentity, error)

+ func (s *Store) ListConversationsByAgent(ctx context.Context, f ConversationListFilter) ([]ConversationSummary, error)

+ func (s *Store) ListDeletedAgentsByUser(ctx context.Context, userID string, limit int, afterCreatedAt time.Time, ...) ([]AgentIdentity, error)

+ func (s *Store) ListDomainsByUser(ctx context.Context, userID string, limit int, afterCreatedAt time.Time, ...) ([]Domain, error)

+ func (s *Store) ListEnabledWebhooksForRouting(ctx context.Context, userID, eventType string) ([]Webhook, error)

+ func (s *Store) ListExpiredPending(ctx context.Context, limit int) ([]ExpirationCandidate, error)

+ func (s *Store) ListExpiredReviews(ctx context.Context, limit int) ([]ExpirationCandidate, error)

+ func (s *Store) ListPendingOutboundForUser(ctx context.Context, userID string, limit int) ([]Message, error)

+ func (s *Store) ListProtectionEventsByAgent(ctx context.Context, agentID string, limit int) ([]ProtectionEvent, error)

+ func (s *Store) ListProtectionEventsByMessage(ctx context.Context, messageID string) ([]ProtectionEvent, error)

+ func (s *Store) ListReviews(ctx context.Context, userID string, limit int, afterCreatedAt time.Time, ...) ([]ReviewListItem, error)

+ func (s *Store) ListSuppressions(ctx context.Context, userID string, limit int, afterCreatedAt time.Time, ...) ([]Suppression, error)

+ func (s *Store) ListTemplatesByUser(ctx context.Context, userID string, limit int, afterCreatedAt time.Time, ...) ([]TemplateSummary, error)

+ func (s *Store) ListWebhooksByUser(ctx context.Context, userID string, limit int, afterCreatedAt time.Time, ...) ([]Webhook, error)

+ func (s *Store) LoadInboundIntake(ctx context.Context, intakeID string) (*InboundIntake, error)

+ func (s *Store) LoadOutboundDraft(ctx context.Context, messageID string) (*Message, error)

+ func (s *Store) LoadOutboundForSend(ctx context.Context, messageID string) (*OutboundSendPayload, error)

+ func (s *Store) LoadPendingNotify(ctx context.Context, messageID string) (*PendingNotify, error)

+ func (s *Store) LookupConversationID(ctx context.Context, agentID string, messageIDs []string) (string, error)

+ func (s *Store) LookupCoveringDomain(ctx context.Context, sub, userID string) (*Domain, error)

+ func (s *Store) LookupDomain(ctx context.Context, domain, userID string) (*Domain, error)

+ func (s *Store) MarkInboundIntakeFailed(ctx context.Context, intakeID, detail string) error

+ func (s *Store) MarkInboundIntakeProcessedTx(ctx context.Context, tx pgx.Tx, intakeID, messageFK string) error

+ func (s *Store) MarkMessageNotified(ctx context.Context, messageID string) error

+ func (s *Store) MarkMessageSent(ctx context.Context, messageID, sentAs string, to, cc, bcc []string) error

+ func (s *Store) MarkOutboundFailedTx(ctx context.Context, tx pgx.Tx, messageID, detail string, ...) (*OutboundSentInfo, error)

+ func (s *Store) MarkOutboundSentTx(ctx context.Context, tx pgx.Tx, messageID, providerMessageID string) (*OutboundSentInfo, error)

+ func (s *Store) MarkSendFailed(ctx context.Context, messageID, errMsg string) error

+ func (s *Store) MarkSendSucceeded(ctx context.Context, messageID string, r SendResult) error

+ func (s *Store) MarkSendSucceededWithRetry(messageID string, r SendResult) error

+ func (s *Store) MaxTemplatesForUser(ctx context.Context, userID string) (int, error)

+ func (s *Store) MaxWebhooksForUser(ctx context.Context, userID string) (int, error)

+ func (s *Store) ModifyMessageLabels(ctx context.Context, messageID, agentID string, add, remove []string) ([]string, error)

+ func (s *Store) PruneProcessedIntake(ctx context.Context, olderThan time.Duration) (int64, error)

+ func (s *Store) PurgeDeletedAgents(ctx context.Context) (int64, error)

+ func (s *Store) PurgeMessage(ctx context.Context, messageID, agentID string) error

+ func (s *Store) PutUnsubscribeToken(ctx context.Context, tokenHash []byte, userID, agentID, address string) error

+ func (s *Store) RecordDeliveryOutcome(ctx context.Context, messageID, address string, status delivery.Status, ...) error

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

+ func (s *Store) RejectInboundReview(ctx context.Context, messageID, agentID, reviewerID, reason string) error

+ func (s *Store) RejectPending(ctx context.Context, messageID, userID, reason string) (*Message, error)

+ func (s *Store) ReleaseOutboundSendClaim(ctx context.Context, messageID string, jobID int64) error

+ func (s *Store) RemoveAgentSuppression(ctx context.Context, userID, agentID, address string) (bool, error)

+ func (s *Store) RemoveSuppression(ctx context.Context, userID, address string) (bool, error)

+ func (s *Store) ResolveOutboundOwner(ctx context.Context, messageID string) (userID, agentID string, err error)

+ func (s *Store) ResolveOutboundProviderAcceptedTx(ctx context.Context, tx pgx.Tx, messageID string) (*OutboundSentInfo, string, error)

+ func (s *Store) ResolveUnsubscribeToken(ctx context.Context, tokenHash []byte) (*UnsubscribeScope, error)

+ func (s *Store) RestoreAgent(ctx context.Context, agentID, userID string) error

+ func (s *Store) RestoreMessage(ctx context.Context, messageID, agentID string) error

+ func (s *Store) RotateSecret(ctx context.Context, webhookID, userID string) (newPlaintext string, prevExpiresAt time.Time, err error)

+ func (s *Store) SendingProvisionInputs(ctx context.Context, domain string) (selector string, privateKeyDER []byte, ok bool, err error)

+ func (s *Store) SetAccountClass(ctx context.Context, userID, class string) error

+ func (s *Store) SetDKIMCipher(c *DKIMCipher)

+ func (s *Store) SetMessageScreening(ctx context.Context, messageID, agentID, reviewReason string, ...) error

+ func (s *Store) SetSendingStatus(ctx context.Context, domain, status, dkimStatus, mailFromStatus, errMsg string, ...) error

+ func (s *Store) SoftDeleteAgent(ctx context.Context, agentID, userID string) error

+ func (s *Store) SoftDeleteMessage(ctx context.Context, messageID, agentID string) error

+ func (s *Store) StampInboundIntakeJobIDTx(ctx context.Context, tx pgx.Tx, intakeID string, jobID int64) error

+ func (s *Store) StampNotifyJobIDTx(ctx context.Context, tx pgx.Tx, messageID string, jobID int64) error

+ func (s *Store) StampSendJobIDTx(ctx context.Context, tx pgx.Tx, messageID string, jobID int64) error

+ func (s *Store) SuppressedAddresses(ctx context.Context, userID string, addrs []string) ([]string, error)

+ func (s *Store) TouchDomainLastChecked(ctx context.Context, domain, userID string) error

+ func (s *Store) TouchSendingChecked(ctx context.Context, domain string) error

+ func (s *Store) UpdateAgentHITL(ctx context.Context, agentID, userID string, ttlSeconds int, ...) error

+ func (s *Store) UpdateAgentInboundPolicy(ctx context.Context, agentID, userID, policy string, allowlist []string) error

+ func (s *Store) UpdateAgentName(ctx context.Context, agentID, userID, name string) error

+ func (s *Store) UpdateAgentProtection(ctx context.Context, agentID, userID string, c ProtectionConfig) error

+ func (s *Store) UpdateAgentScanConfig(ctx context.Context, agentID, userID string, c ScanConfig) error

+ func (s *Store) UpdateMessageDeliveryStatus(ctx context.Context, messageID, agentID, status string) error

+ func (s *Store) UpdateTemplate(ctx context.Context, templateID, userID string, u TemplateUpdate) (*Template, error)

+ func (s *Store) UpdateUserName(ctx context.Context, userID, name string) (*User, error)

+ func (s *Store) UpdateWebhook(ctx context.Context, webhookID, userID string, u WebhookUpdate) (*Webhook, error)

+ func (s *Store) VerifyDomain(ctx context.Context, domain, userID string) error

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

+ type Suppression struct

+ Address string

+ CreatedAt time.Time

+ Reason string

+ Source string

+ SourceMessageID string

+ type SuppressionExportEntry struct

+ Address string

+ AgentEmail string

+ CreatedAt time.Time

+ Reason string

+ Source string

+ type Template struct

+ Alias string

+ Body string

+ CreatedAt time.Time

+ FromStarterAlias string

+ FromStarterVersion string

+ HTMLBody string

+ ID string

+ Name string

+ Subject string

+ UpdatedAt time.Time

+ UserID string

+ type TemplateCreate struct

+ Alias string

+ Body string

+ FromStarterAlias string

+ FromStarterVersion string

+ HTMLBody string

+ Name string

+ Subject string

+ type TemplateSummary struct

+ Alias string

+ CreatedAt time.Time

+ ID string

+ Name string

+ Subject string

+ UpdatedAt time.Time

+ UserID string

+ type TemplateUpdate struct

+ Alias *string

+ Body *string

+ HTMLBody *string

+ Name *string

+ Subject *string

+ type UnsubscribeScope struct

+ Address string

+ AgentID string

+ UserID string

+ type UsageEventEntry struct

+ AgentID string

+ CreatedAt time.Time

+ Direction string

+ Domain string

+ EventType string

+ ID string

+ type User struct

+ AccountClass string

+ CreatedAt time.Time

+ Email string

+ GoogleSubject string

+ ID string

+ Name string

+ type UserExport struct

+ APIKeys []APIKeyExportEntry

+ Agents []AgentIdentity

+ Domains []Domain

+ GeneratedAt time.Time

+ Messages []Message

+ OAuthConnections []OAuthConnectionEntry

+ ProtectionEvents []ProtectionEventExportEntry

+ SchemaVersion string

+ Suppressions []SuppressionExportEntry

+ UsageEvents []UsageEventEntry

+ User UserExportUser

+ type UserExportUser struct

+ CreatedAt time.Time

+ Email string

+ ID string

+ Name string

+ type Webhook struct

+ AutoDisabledAt *time.Time

+ CreatedAt time.Time

+ Description string

+ Enabled bool

+ Events []string

+ Filters WebhookFilters

+ ID string

+ LastDeliveredAt *time.Time

+ SigningSecret string

+ SigningSecretPrev string

+ SigningSecretPrevExpiresAt *time.Time

+ URL string

+ UserID string

+ type WebhookFilters struct

+ AgentIDs []string

+ ConversationIDs []string

+ Labels []string

+ type WebhookIdemCompleter func(ctx context.Context, tx pgx.Tx, wh *Webhook) error

+ type WebhookUpdate struct

+ Description *string

+ Enabled *bool

+ Events *[]string

+ Filters *WebhookFilters

+ URL *string

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