Struct TaskReorg 

pub struct TaskReorg { /* private fields */ }

Background task that handles chain reorg processing.

Processes deactivated block headers by finding ProvenTx records that reference those blocks and attempting to get updated merkle proofs. Uses an aging pattern to delay processing, allowing the chain to stabilize.

Implementations

impl TaskReorg

pub fn new( storage: WalletStorageManager, services: Arc<dyn WalletServices>, deactivated_headers: Arc<Mutex<Vec<DeactivatedHeader>>>, ) -> Self

Create a new TaskReorg with default intervals.

pub fn with_intervals( storage: WalletStorageManager, services: Arc<dyn WalletServices>, deactivated_headers: Arc<Mutex<Vec<DeactivatedHeader>>>, aged_msecs: u64, max_retries: u32, trigger_msecs: u64, ) -> Self

Create with custom intervals.

Trait Implementations

impl WalletMonitorTask for TaskReorg

fn name(&self) -> &str

Returns the name of this task (used for logging and lookup).

fn trigger(&mut self, now_msecs_since_epoch: u64) -> bool

Return true if run_task needs to be called now. This is NOT async – it must be a fast, synchronous check.

fn run_task<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<String, WalletError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the task’s work. Returns a log string describing what was done.

fn async_setup<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), WalletError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Override to handle async task setup configuration. Called before the first call to trigger.