Struct ChainInstance 

pub struct ChainInstance {
    pub config: IndexerConfig,
    pub state: IndexerState,
    pub head_block: u64,
    pub events_processed: u64,
    pub last_error: Option<String>,
    pub started_at: Option<i64>,
}

Runtime state for a single chain managed by the coordinator.

Fields

config: IndexerConfig

The configuration driving this chain.

state: IndexerState

Current runtime state of this chain’s indexer.

head_block: u64

Latest block number that has been fully processed.

events_processed: u64

Total number of events emitted so far by this chain.

last_error: Option<String>

The last error message if state == IndexerState::Error.

started_at: Option<i64>

Unix timestamp (seconds) when the chain was started, if it has been.

Implementations

impl ChainInstance

pub fn new(config: IndexerConfig) -> Self

Construct a new idle instance from a config.

pub fn is_active(&self) -> bool

Returns true when the chain is actively making progress.

pub fn is_error(&self) -> bool

Returns true when the chain is in an error state.

pub fn transition(&mut self, new_state: IndexerState, error: Option<String>)

Transition to a new state, recording errors if appropriate.

Trait Implementations

impl Clone for ChainInstance

fn clone(&self) -> ChainInstance

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChainInstance

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ChainInstance

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ChainInstance

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.