Struct DagBuilder 

pub struct DagBuilder { /* private fields */ }

DagBuilder API

Usage:

DAG Building

let context = Arc::new(Context::new_for_test(4).0);
let mut dag_builder = DagBuilder::new(context);
dag_builder.layer(1).build(); // Round 1 is fully connected with parents by default.
dag_builder.layers(2..=10).build(); // Rounds 2 ~ 10 are fully connected with parents by default.
dag_builder.layer(11).min_parent_links().build(); // Round 11 is minimally and randomly connected with parents, without weak links.
dag_builder.layer(12).no_leader_block(0).build(); // Round 12 misses leader block. Other blocks are fully connected with parents.
dag_builder.layer(13).no_leader_link(12, 0).build(); // Round 13 misses votes for leader block. Other blocks are fully connected with parents.
dag_builder.layer(14).authorities(vec![3,5]).skip_block().build(); // Round 14 authorities 3 and 5 will not propose any block.
dag_builder.layer(15).authorities(vec![3,5]).skip_ancestor_links(vec![1,2]).build(); // Round 15 authorities 3 and 5 will not link to ancestors 1 and 2
dag_builder.layer(16).authorities(vec![3,5]).equivocate(3).build(); // Round 16 authorities 3 and 5 will produce 3 equivocating blocks.

Persisting to DagState by Layer

let dag_state = Arc::new(RwLock::new(DagState::new(
   dag_builder.context.clone(),
   Arc::new(MemStore::new()),
)));
let context = Arc::new(Context::new_for_test(4).0);
let mut dag_builder = DagBuilder::new(context);
dag_builder.layer(1).build().persist_layers(dag_state.clone()); // persist the layer

Persisting entire DAG to DagState

let dag_state = Arc::new(RwLock::new(DagState::new(
   dag_builder.context.clone(),
   Arc::new(MemStore::new()),
)));
let context = Arc::new(Context::new_for_test(4).0);
let mut dag_builder = DagBuilder::new(context);
dag_builder.layer(1).build();
dag_builder.layers(2..=10).build();
dag_builder.persist_all_blocks(dag_state.clone()); // persist entire DAG

Printing DAG

let context = Arc::new(Context::new_for_test(4).0);
let mut dag_builder = DagBuilder::new(context);
dag_builder.layer(1).build();
dag_builder.print(); // pretty print the entire DAG

Implementations

impl DagBuilder

pub fn new(context: Arc<Context>) -> Self

pub fn blocks(&self, rounds: RangeInclusive<Round>) -> Vec<VerifiedBlock>

pub fn all_blocks(&self) -> Vec<VerifiedBlock>

pub fn get_sub_dag_and_commits( &mut self, leader_rounds: RangeInclusive<Round>, ) -> Vec<(CommittedSubDag, TrustedCommit)>

pub fn leader_blocks( &self, rounds: RangeInclusive<Round>, ) -> Vec<Option<VerifiedBlock>>

pub fn leader_block(&self, round: Round) -> Option<VerifiedBlock>

pub fn layer(&mut self, round: Round) -> LayerBuilder<'_>

pub fn layers(&mut self, rounds: RangeInclusive<Round>) -> LayerBuilder<'_>

pub fn persist_all_blocks(&self, dag_state: Arc<RwLock<DagState>>)

pub fn print(&self)

pub fn layer_with_connections( &mut self, connections: Vec<(AuthorityIndex, Vec<BlockRef>)>, round: Round, )

pub fn get_uncommitted_blocks_at_slot(&self, slot: Slot) -> Vec<VerifiedBlock>

Gets all uncommitted blocks in a slot.

pub fn genesis_block_refs(&self) -> Vec<BlockRef>