Struct vapcore_sync::VapSync[−][src]

pub struct VapSync { /* fields omitted */ }

Vapory network protocol handler

Implementations

`impl VapSync`[src]

`pub fn new( params: Params, connection_filter: Option<Arc<dyn ConnectionFilter>> ) -> Result<Arc<VapSync>, Error>`[src]

Creates and register protocol with the network service

`pub fn priority_tasks(&self) -> Sender<PriorityTask>`[src]

Priority tasks producer

Trait Implementations

`impl ChainNotify for VapSync`[src]

`fn block_pre_import(&self, bytes: &Bytes, hash: &H256, difficulty: &U256)`[src]

`fn new_blocks(&self, new_blocks: NewBlocks)`[src]

`fn start(&self)`[src]

`fn stop(&self)`[src]

`fn broadcast(&self, message_type: ChainMessageType)`[src]

`fn transactions_received(&self, txs: &[UnverifiedTransaction], peer_id: PeerId)`[src]

`impl ManageNetwork for VapSync`[src]

`fn accept_unreserved_peers(&self)`[src]

`fn deny_unreserved_peers(&self)`[src]

`fn remove_reserved_peer(&self, peer: String) -> Result<(), String>`[src]

`fn add_reserved_peer(&self, peer: String) -> Result<(), String>`[src]

`fn start_network(&self)`[src]

`fn stop_network(&self)`[src]

`fn num_peers_range(&self) -> RangeInclusive<u32>`[src]

`fn with_proto_context( &self, proto: ProtocolId, f: &mut dyn FnMut(&dyn NetworkContext) )`[src]

`impl SyncProvider for VapSync`[src]

`fn status(&self) -> VapSyncStatus`[src]

Get sync status

`fn peers(&self) -> Vec<PeerInfo>`[src]

Get sync peers

`fn enode(&self) -> Option<String>`[src]

`fn transactions_stats(&self) -> BTreeMap<H256, TransactionStats>`[src]

`fn sync_notification(&self) -> Notification<SyncState>`[src]

`fn is_major_syncing(&self) -> bool`[src]

Auto Trait Implementations

`impl !RefUnwindSafe for VapSync`

`impl Send for VapSync`

`impl Sync for VapSync`

`impl Unpin for VapSync`

`impl !UnwindSafe for VapSync`

Blanket Implementations

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`pub fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`pub fn borrow(&self) -> &T`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`pub fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> Erased for T`

`impl<T> From<T> for T`[src]

`pub fn from(t: T) -> T`[src]

`impl<T, U> Into for T where U: From<T>,` [src]

`pub fn into(self) -> U`[src]

`impl<T> Pointable for T`

`pub const ALIGN: usize`

`type Init = T`

The type for initializers.

`pub unsafe fn init(init: <T as Pointable>::Init) -> usize`

`pub unsafe fn deref<'a>(ptr: usize) -> &'a T`

`pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T`

`pub unsafe fn drop(ptr: usize)`

`impl<T> Same<T> for T`

`type Output = T`

Should always be Self

`impl<T, U> TryFrom for T where U: Into<T>,` [src]

`type Error = Infallible`

The type returned in the event of a conversion error.

`pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>`[src]

`impl<T, U> TryInto for T where U: TryFrom<T>,` [src]

`type Error = >::Error`

The type returned in the event of a conversion error.

`pub fn try_into(self) -> Result<U, >::Error>`[src]

`impl<V, T> VZip<V> for T where V: MultiLane<T>,`

`pub fn vzip(self) -> V`

Struct vapcore_sync::VapSync[−][src]

Implementations

impl VapSync[src]

pub fn new( params: Params, connection_filter: Option<Arc<dyn ConnectionFilter>>) -> Result<Arc<VapSync>, Error>[src]

pub fn priority_tasks(&self) -> Sender<PriorityTask>[src]

Trait Implementations

impl ChainNotify for VapSync[src]

fn block_pre_import(&self, bytes: &Bytes, hash: &H256, difficulty: &U256)[src]

fn new_blocks(&self, new_blocks: NewBlocks)[src]

fn start(&self)[src]

fn stop(&self)[src]

fn broadcast(&self, message_type: ChainMessageType)[src]

fn transactions_received(&self, txs: &[UnverifiedTransaction], peer_id: PeerId)[src]

impl ManageNetwork for VapSync[src]

fn accept_unreserved_peers(&self)[src]

fn deny_unreserved_peers(&self)[src]

fn remove_reserved_peer(&self, peer: String) -> Result<(), String>[src]

fn add_reserved_peer(&self, peer: String) -> Result<(), String>[src]

fn start_network(&self)[src]

fn stop_network(&self)[src]

fn num_peers_range(&self) -> RangeInclusive<u32>[src]

fn with_proto_context( &self, proto: ProtocolId, f: &mut dyn FnMut(&dyn NetworkContext))[src]

impl SyncProvider for VapSync[src]

fn status(&self) -> VapSyncStatus[src]

fn peers(&self) -> Vec<PeerInfo>[src]

fn enode(&self) -> Option<String>[src]

fn transactions_stats(&self) -> BTreeMap<H256, TransactionStats>[src]

fn sync_notification(&self) -> Notification<SyncState>[src]

fn is_major_syncing(&self) -> bool[src]

Auto Trait Implementations

impl !RefUnwindSafe for VapSync

impl Send for VapSync

impl Sync for VapSync

impl Unpin for VapSync

impl !UnwindSafe for VapSync

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized, [src]

pub fn type_id(&self) -> TypeId[src]

impl<T> Borrow<T> for T where T: ?Sized, [src]

pub fn borrow(&self) -> &T[src]

impl<T> BorrowMut<T> for T where T: ?Sized, [src]

pub fn borrow_mut(&mut self) -> &mut T[src]

impl<T> Erased for T

impl<T> From<T> for T[src]

pub fn from(t: T) -> T[src]

impl<T, U> Into<U> for T where U: From<T>, [src]

pub fn into(self) -> U[src]

impl<T> Pointable for T

pub const ALIGN: usize

type Init = T

pub unsafe fn init(init: <T as Pointable>::Init) -> usize

pub unsafe fn deref<'a>(ptr: usize) -> &'a T

pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

pub unsafe fn drop(ptr: usize)

impl<T> Same<T> for T

type Output = T

impl<T, U> TryFrom<U> for T where U: Into<T>, [src]

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]

impl<T, U> TryInto<U> for T where U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]

impl<V, T> VZip<V> for T where V: MultiLane<T>,

pub fn vzip(self) -> V