MCPcopy Create free account
hub / github.com/Mnexa-AI/e2a / EnqueueProvision

Method EnqueueProvision

internal/senderidentity/manager.go:114–117  ·  view source on GitHub ↗

EnqueueProvision schedules sending-identity provisioning for a domain (called when a domain becomes verified, or on a forced re-check via POST /domains/{domain}/verify). Intentionally NOT unique: River's job uniqueness can't drop `completed` from its state set (only `retryable` is safely removable)

(ctx context.Context, domain string)

Source from the content-addressed store, hash-verified

112// the domain is already verified, and SES CreateEmailIdentity treats an
113// existing identity as success. Concurrent duplicate enqueues are harmless.
114func (m *Manager) EnqueueProvision(ctx context.Context, domain string) error {
115 _, err := m.client.Insert(ctx, ProvisionArgs{Domain: domain}, nil)
116 return err
117}
118
119// EnqueueDeprovisionTx enqueues sending-identity teardown WITHIN the caller's
120// delete transaction, so the job is committed atomically with the domain-row

Callers 3

TestProvisionToVerifiedFunction · 0.95
TestProvisionFailsClosedFunction · 0.95

Calls

no outgoing calls

Tested by 3

TestProvisionToVerifiedFunction · 0.76
TestProvisionFailsClosedFunction · 0.76