Enum StateAnomaly 

pub enum StateAnomaly {
    MissingBroadcast {
        contract_key: String,
        transaction: Transaction,
        sender: SocketAddr,
        missing_targets: Vec<SocketAddr>,
        state_hash: Option<String>,
        source_op: BroadcastSource,
    },
    BroadcastNotApplied {
        contract_key: String,
        transaction: Transaction,
        peer: SocketAddr,
        received_state_hash: Option<String>,
    },
    UnexpectedStateChange {
        contract_key: String,
        peer: SocketAddr,
        transaction: Transaction,
        previous_hash: String,
        new_hash: String,
        transition_kind: TransitionKind,
    },
    FinalDivergence {
        contract_key: String,
        peer_states: Vec<(SocketAddr, String)>,
        first_divergence_point: Option<DivergencePoint>,
    },
    SuspectedPartition {
        contract_key: String,
        sending_group: Vec<SocketAddr>,
        isolated_group: Vec<SocketAddr>,
        first_missed: DateTime<Utc>,
        last_missed: DateTime<Utc>,
        missed_count: usize,
    },
    StalePeer {
        contract_key: String,
        peer: SocketAddr,
        stuck_on_hash: String,
        last_event_time: DateTime<Utc>,
        missed_updates: usize,
    },
    OneWayPropagationFailure {
        contract_key: String,
        sender: SocketAddr,
        receiver: SocketAddr,
        forward_deliveries: usize,
        reverse_deliveries: usize,
    },
    StateOscillation {
        contract_key: String,
        peer: SocketAddr,
        oscillating_hashes: Vec<String>,
        flip_count: usize,
    },
    UpdateOrderingAnomaly {
        contract_key: String,
        tx_a: Transaction,
        tx_b: Transaction,
        peer_ab: SocketAddr,
        hash_ab: String,
        peer_ba: SocketAddr,
        hash_ba: String,
    },
    ZombieTransaction {
        operation_type: String,
        transaction: Transaction,
        peer: SocketAddr,
        started_at: DateTime<Utc>,
    },
    BroadcastStorm {
        contract_key: String,
        transaction: Transaction,
        broadcast_count: usize,
        expected_max: usize,
        source_op: BroadcastSource,
    },
    DeltaSyncFailureCascade {
        contract_key: String,
        resync_count: usize,
        requesting_peers: Vec<SocketAddr>,
        window_start: DateTime<Utc>,
        window_end: DateTime<Utc>,
        total_resync_bytes: usize,
    },
    SubscriptionAsymmetry {
        contract_key: String,
        peer: SocketAddr,
        subscribe_tx: Transaction,
        broadcasts_without_peer: usize,
    },
}

A detected anomaly in the state propagation.

Variants

MissingBroadcast

A broadcast was emitted but never received by one or more targets.

Fields

contract_key: String

transaction: Transaction

sender: SocketAddr

missing_targets: Vec<SocketAddr>

state_hash: Option<String>

source_op: BroadcastSource

BroadcastNotApplied

A broadcast was received but never applied (no corresponding BroadcastApplied).

Fields

contract_key: String

transaction: Transaction

peer: SocketAddr

received_state_hash: Option<String>

UnexpectedStateChange

A peer’s state hash changed to a value not consistent with the expected progression (potential state regression or corruption).

Fields

contract_key: String

peer: SocketAddr

transaction: Transaction

previous_hash: String

new_hash: String

transition_kind: TransitionKind

FinalDivergence

After all events, peers hold different states for the same contract. Includes the likely root cause transition.

Fields

contract_key: String

peer_states: Vec<(SocketAddr, String)>

(peer_addr, state_hash) for each replica.

first_divergence_point: Option<DivergencePoint>

The first transition where states started to diverge.

SuspectedPartition

Multiple broadcasts from different senders all fail to reach the same set of target peers, suggesting a network partition.

Fields

contract_key: String

sending_group: Vec<SocketAddr>

Peers that emitted broadcasts during the window.

isolated_group: Vec<SocketAddr>

Peers that never received those broadcasts.

first_missed: DateTime<Utc>

Time window of the suspected partition.

last_missed: DateTime<Utc>

missed_count: usize

Number of broadcasts missed during this window.

StalePeer

A peer received the initial contract state but has not received any subsequent updates while other peers have progressed.

Fields

contract_key: String

peer: SocketAddr

The peer that appears stale.

stuck_on_hash: String

The hash the peer is stuck on.

last_event_time: DateTime<Utc>

When the peer last had any state event.

missed_updates: usize

How many subsequent update transitions this peer missed.

OneWayPropagationFailure

Broadcasts from peer A reach peer B, but broadcasts from peer B never reach peer A (asymmetric / unidirectional link).

Fields

contract_key: String

sender: SocketAddr

Peer whose broadcasts are received.

receiver: SocketAddr

Peer that never receives from the other direction.

forward_deliveries: usize

Broadcasts from sender that receiver got.

reverse_deliveries: usize

Broadcasts from receiver that sender got (should be 0).

StateOscillation

A peer’s state hash oscillates between the same values, indicating conflicting updates applied alternately without converging.

Fields

contract_key: String

peer: SocketAddr

oscillating_hashes: Vec<String>

The hashes that are oscillating.

flip_count: usize

Number of times the state reverted to a previously-seen hash.

UpdateOrderingAnomaly

Two updates applied in different order on different peers produced different state hashes, indicating a non-commutative merge (CRDT bug).

Fields

contract_key: String

tx_a: Transaction

tx_b: Transaction

peer_ab: SocketAddr

Peer that applied A then B.

hash_ab: String

peer_ba: SocketAddr

Peer that applied B then A.

hash_ba: String

ZombieTransaction

A transaction has a Request event but never completed (no Success, Failure, or Timeout). Indicates a stuck operation / leaked resource.

Fields

operation_type: String

transaction: Transaction

peer: SocketAddr

started_at: DateTime<Utc>

BroadcastStorm

A single transaction triggered an unexpectedly large number of broadcast emissions, suggesting a re-broadcast loop.

Fields

contract_key: String

transaction: Transaction

broadcast_count: usize

Number of BroadcastEmitted events for this transaction.

expected_max: usize

Expected maximum (unique peers holding the contract).

source_op: BroadcastSource

DeltaSyncFailureCascade

Multiple peers requested full state resync for the same contract within a short window, indicating systematic delta application failure.

Fields

contract_key: String

resync_count: usize

requesting_peers: Vec<SocketAddr>

window_start: DateTime<Utc>

window_end: DateTime<Utc>

total_resync_bytes: usize

SubscriptionAsymmetry

A peer subscribed to a contract but is never listed in any broadcast_to targets for that contract.

Fields

contract_key: String

peer: SocketAddr

subscribe_tx: Transaction

broadcasts_without_peer: usize

Trait Implementations

impl Clone for StateAnomaly

fn clone(&self) -> StateAnomaly

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StateAnomaly

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

Formats the value using the given formatter.

impl Display for StateAnomaly

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

Formats the value using the given formatter.