Struct StatusCheckContext

pub struct StatusCheckContext {
    pub consecutive_failures: u32,
    pub total_failures: u32,
    pub total_retries: u32,
    pub max_consecutive_failures: u32,
    pub max_total_failures: u32,
    pub network_type: NetworkType,
}

Context for status check circuit breaker decisions.

This struct is passed to network handlers during status checks to provide failure tracking information. Handlers can use this to decide whether to force-finalize a transaction that has exceeded the maximum retry attempts.

The circuit breaker triggers when EITHER threshold is exceeded:

• consecutive_failures >= max_consecutive_failures (RPC completely down)
• total_failures >= max_total_failures (flaky RPC, safety net)

Example

let context = StatusCheckContext::new(
    consecutive_failures,
    total_failures,
    total_retries,
    max_consecutive_failures,
    max_total_failures,
    NetworkType::Stellar,
);

if context.should_force_finalize() {
    // Mark transaction as Failed with appropriate reason
}

Fields

consecutive_failures: u32

Number of consecutive failures since last successful status check. Resets to 0 when a status check succeeds (even if transaction not final).

total_failures: u32

Total number of failures across all status check attempts. Never resets - serves as safety net for flaky RPC connections.

total_retries: u32

Total number of retries (from Apalis attempt counter). Includes both successful and failed attempts.

max_consecutive_failures: u32

Maximum consecutive failures allowed before forcing finalization. Network-specific value from constants.

max_total_failures: u32

Maximum total failures allowed before forcing finalization. Safety net for flaky RPC that occasionally succeeds (resetting consecutive counter).

network_type: NetworkType

The network type for this transaction.

Implementations

impl StatusCheckContext

pub fn new( consecutive_failures: u32, total_failures: u32, total_retries: u32, max_consecutive_failures: u32, max_total_failures: u32, network_type: NetworkType, ) -> Self

Creates a new StatusCheckContext with the specified failure counts and limits.

Arguments

• consecutive_failures - Current count of consecutive failures
• total_failures - Total count of all failures
• total_retries - Total Apalis retry attempts (includes successes)
• max_consecutive_failures - Network-specific consecutive max before force-finalization
• max_total_failures - Network-specific total max (safety net)
• network_type - The blockchain network type

pub fn should_force_finalize(&self) -> bool

Determines if the circuit breaker should force-finalize the transaction.

Returns true if EITHER threshold is exceeded:

• Consecutive failures reached the network-specific maximum (RPC completely down)
• Total failures reached the network-specific maximum (flaky RPC safety net)

pub fn triggered_by_consecutive(&self) -> bool

Returns true if triggered by consecutive failures threshold.

pub fn triggered_by_total(&self) -> bool

Returns true if triggered by total failures threshold (safety net).

Trait Implementations

impl Clone for StatusCheckContext

fn clone(&self) -> StatusCheckContext

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StatusCheckContext

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StatusCheckContext

fn default() -> Self

Returns the “default value” for a type.