Struct DagConsensus 

pub struct DagConsensus { /* private fields */ }

DAG-based consensus engine

Implementations

impl DagConsensus

pub fn new(node_id: String, min_quorum_size: usize) -> Self

Create a new DAG consensus engine

pub fn submit_transaction( &self, tx_type: TransactionType, data: Vec<u8>, ) -> Result<String>

Submit a transaction to the consensus system

pub fn create_vertex(&self) -> Result<Option<DagVertex>>

Create a new vertex for pending transactions

pub fn add_vertex(&self, vertex: DagVertex) -> Result<()>

Add a vertex from another node

pub fn is_finalized(&self, vertex_id: &str) -> bool

Check if a vertex is finalized

pub fn finalize_vertices(&self) -> Result<Vec<String>>

Finalize vertices using the wave algorithm

pub fn get_finalized_order(&self) -> Vec<Transaction>

Get the total order of finalized transactions

pub fn detect_conflicts(&self, tx1: &Transaction, tx2: &Transaction) -> bool

Detect conflicts between transactions

pub fn get_stats(&self) -> ConsensusStats

Get consensus statistics

pub fn prune_old_vertices(&self, keep_count: usize)

Prune old finalized vertices to save memory