Struct ckb_shared::shared::Shared

pub struct Shared { /* private fields */ }

TODO(doc): @quake

Implementations

impl Shared

pub fn new(
    store: ChainDB,
    tx_pool_controller: TxPoolController,
    notify_controller: NotifyController,
    txs_verify_cache: Arc<TokioRwLock<TxVerificationCache>>,
    consensus: Arc<Consensus>,
    snapshot_mgr: Arc<SnapshotMgr>,
    async_handle: Handle,
    ibd_finished: Arc<AtomicBool>
) -> Shared

Construct new Shared

pub fn spawn_freeze(&self) -> Option<FreezerClose>

Spawn freeze background thread that periodically checks and moves ancient data from the kv database into the freezer.

pub fn tx_pool_controller(&self) -> &TxPoolController

TODO(doc): @quake

pub fn txs_verify_cache(&self) -> Arc<TokioRwLock<TxVerificationCache>>

TODO(doc): @quake

pub fn notify_controller(&self) -> &NotifyController

TODO(doc): @quake

pub fn snapshot(&self) -> Guard<Arc<Snapshot>>

TODO(doc): @quake

pub fn store_snapshot(&self, snapshot: Arc<Snapshot>)

TODO(doc): @quake

pub fn refresh_snapshot(&self)

TODO(doc): @quake

pub fn new_snapshot(
    &self,
    tip_header: HeaderView,
    total_difficulty: U256,
    epoch_ext: EpochExt,
    proposals: ProposalView
) -> Arc<Snapshot>

TODO(doc): @quake

pub fn consensus(&self) -> &Consensus

TODO(doc): @quake

pub fn async_handle(&self) -> &Handle

Return async runtime handle

pub fn genesis_hash(&self) -> Byte32

TODO(doc): @quake

pub fn store(&self) -> &ChainDB

TODO(doc): @quake

pub fn is_initial_block_download(&self) -> bool

Return whether chain is in initial block download

pub fn get_block_template(
    &self,
    bytes_limit: Option<u64>,
    proposals_limit: Option<u64>,
    max_version: Option<Version>
) -> Result<Result<BlockTemplate, AnyError>, AnyError>

Generate and return block_template

Trait Implementations

impl Clone for Shared

fn clone(&self) -> Shared

Returns a copy of the value.

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

Performs copy-assignment from source.