Skip to main content

classify_pending_processor_charges

Function classify_pending_processor_charges 

Source
pub async fn classify_pending_processor_charges(
    pool: &PgPool,
    gateway_account_id: GatewayAccountId,
    max_transitions: u64,
) -> Result<ProcessorChargeClassificationSummary, Error>
Expand description

Classifies one bounded batch of durable pending processor charges.

Candidate reads are account-scoped and stable for the duration of this pass. Each subscription candidate enters its persisted subscriber/plan aggregate before locking the attempt and charge. Busy aggregate or row locks are skipped without consuming the transition budget.