pub struct StatementHandlerPrototype { /* private fields */ }
Expand description
Prototype for a StatementHandler
.
Implementations§
source§impl StatementHandlerPrototype
impl StatementHandlerPrototype
sourcepub fn new<Hash: AsRef<[u8]>>(genesis_hash: Hash, fork_id: Option<&str>) -> Self
pub fn new<Hash: AsRef<[u8]>>(genesis_hash: Hash, fork_id: Option<&str>) -> Self
Create a new instance.
sourcepub fn set_config(&self) -> NonDefaultSetConfig
pub fn set_config(&self) -> NonDefaultSetConfig
Returns the configuration of the set to put in the network configuration.
sourcepub fn build<N: NetworkPeers + NetworkEventStream + NetworkNotification, S: SyncEventStream + SyncOracle>(
self,
network: N,
sync: S,
statement_store: Arc<dyn StatementStore>,
metrics_registry: Option<&Registry>,
executor: impl Fn(Pin<Box<dyn Future<Output = ()> + Send>>) + Send
) -> Result<StatementHandler<N, S>>
pub fn build<N: NetworkPeers + NetworkEventStream + NetworkNotification, S: SyncEventStream + SyncOracle>( self, network: N, sync: S, statement_store: Arc<dyn StatementStore>, metrics_registry: Option<&Registry>, executor: impl Fn(Pin<Box<dyn Future<Output = ()> + Send>>) + Send ) -> Result<StatementHandler<N, S>>
Turns the prototype into the actual handler.
Important: the statements handler is initially disabled and doesn’t gossip statements. Gossiping is enabled when major syncing is done.
Auto Trait Implementations§
impl RefUnwindSafe for StatementHandlerPrototype
impl Send for StatementHandlerPrototype
impl Sync for StatementHandlerPrototype
impl Unpin for StatementHandlerPrototype
impl UnwindSafe for StatementHandlerPrototype
Blanket Implementations§
§impl<T> AnySync for T
impl<T> AnySync for T
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> CheckedConversion for T
impl<T> CheckedConversion for T
§fn checked_from<T>(t: T) -> Option<Self>where
Self: TryFrom<T>,
fn checked_from<T>(t: T) -> Option<Self>where
Self: TryFrom<T>,
§fn checked_into<T>(self) -> Option<T>where
Self: TryInto<T>,
fn checked_into<T>(self) -> Option<T>where
Self: TryInto<T>,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T, Outer> IsWrappedBy<Outer> for T
impl<T, Outer> IsWrappedBy<Outer> for T
§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> SaturatedConversion for T
impl<T> SaturatedConversion for T
§fn saturated_from<T>(t: T) -> Selfwhere
Self: UniqueSaturatedFrom<T>,
fn saturated_from<T>(t: T) -> Selfwhere
Self: UniqueSaturatedFrom<T>,
§fn saturated_into<T>(self) -> Twhere
Self: UniqueSaturatedInto<T>,
fn saturated_into<T>(self) -> Twhere
Self: UniqueSaturatedInto<T>,
Consume self to return an equivalent value of
T
. Read more§impl<S, T> UncheckedInto<T> for Swhere
T: UncheckedFrom<S>,
impl<S, T> UncheckedInto<T> for Swhere
T: UncheckedFrom<S>,
§fn unchecked_into(self) -> T
fn unchecked_into(self) -> T
The counterpart to
unchecked_from
.§impl<T, S> UniqueSaturatedInto<T> for S
impl<T, S> UniqueSaturatedInto<T> for S
§fn unique_saturated_into(self) -> T
fn unique_saturated_into(self) -> T
Consume self to return an equivalent value of
T
.