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)
| 112 | // the domain is already verified, and SES CreateEmailIdentity treats an |
| 113 | // existing identity as success. Concurrent duplicate enqueues are harmless. |
| 114 | func (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 |
no outgoing calls