Struct jormungandr::fragment::Pool

pub struct Pool {
    logs: Logs,
    pool: Pool,
    network_msg_box: MessageBox<NetworkMsg>,
    persistent_log: Option<BufWriter<File>>,
    metrics: Metrics,
}

Fields

logs: Logs

pool: Pool

network_msg_box: MessageBox<NetworkMsg>

persistent_log: Option<BufWriter<File>>

metrics: Metrics

Implementations

impl Pool

pub fn new( max_entries: usize, logs: Logs, network_msg_box: MessageBox<NetworkMsg>, persistent_log: Option<File>, metrics: Metrics ) -> Self

pub fn logs(&mut self) -> &mut Logs

pub fn set_persistent_log(&mut self, file: File)

Sets the persistent log to a file. The file must be opened for writing.

pub async fn close_persistent_log(&mut self)

Synchronizes the persistent log file contents and metadata to the file system and closes the file.

async fn filter_fragment( &mut self, fragment: &Fragment, id: FragmentId ) -> Result<(), FragmentRejectionReason>

pub async fn insert_and_propagate_all( &mut self, origin: FragmentOrigin, fragments: Vec<Fragment>, fail_fast: bool ) -> Result<FragmentsProcessingSummary, Error>

Returns number of registered fragments. Setting fail_fast to true will force this method to reject all fragments after the first invalid fragments was met.

pub fn remove_added_to_block( &mut self, fragment_ids: Vec<FragmentId>, status: FragmentStatus )

pub async fn select( &mut self, ledger: ApplyBlockLedger, selection_alg: FragmentSelectionAlgorithmParams, soft_deadline_future: Receiver<()>, hard_deadline_future: Receiver<()> ) -> (Contents, ApplyBlockLedger)

pub fn prune_after_ledger_branch(&mut self, branch_date: BlockDateDto)

fn update_metrics(&self)