state.rs

use graph::{
    components::store::EntityLfuCache, prelude::BlockPtr, util::backoff::ExponentialBackoff,
};
use std::time::Instant;

pub struct IndexingState {
    /// `true` -> `false` on the first run
    pub should_try_unfail_non_deterministic: bool,
    /// Backoff used for the retry mechanism on non-deterministic errors
    pub backoff: ExponentialBackoff,
    /// Related to field above `backoff`
    ///
    /// Resets to `Instant::now` every time:
    /// - The time THRESHOLD is passed
    /// - Or the subgraph has triggers for the block
    pub skip_ptr_updates_timer: Instant,
    pub entity_lfu_cache: EntityLfuCache,
    pub cached_head_ptr: Option<BlockPtr>,
    /// Set to `true` once postponed indexes have been created. This
    /// ensures we only trigger index creation once per subgraph run.
    pub postponed_indexes_created: bool,
}