lightning::chain::chainmonitor

Struct AsyncPersister

Source 
pub struct AsyncPersister<K: Deref + MaybeSend + MaybeSync + 'static, S: FutureSpawner, L: Deref + MaybeSend + MaybeSync + 'static, ES: Deref + MaybeSend + MaybeSync + 'static, SP: Deref + MaybeSend + MaybeSync + 'static, BI: Deref + MaybeSend + MaybeSync + 'static, FE: Deref + MaybeSend + MaybeSync + 'static>
where
    K::Target: KVStore + MaybeSync,
    L::Target: Logger,
    ES::Target: EntropySource + Sized,
    SP::Target: SignerProvider + Sized,
    BI::Target: BroadcasterInterface,
    FE::Target: FeeEstimator,
{ /* private fields */ }
Expand description

An unconstructable Persister which is used under the hood when you call ChainMonitor::new_async_beta.

This is not exported to bindings users as async is not supported outside of Rust.

Trait Implementations§

Source§

impl<K: Deref + MaybeSend + MaybeSync + 'static, S: FutureSpawner, L: Deref + MaybeSend + MaybeSync + 'static, ES: Deref + MaybeSend + MaybeSync + 'static, SP: Deref + MaybeSend + MaybeSync + 'static, BI: Deref + MaybeSend + MaybeSync + 'static, FE: Deref + MaybeSend + MaybeSync + 'static> Deref for AsyncPersister<K, S, L, ES, SP, BI, FE>
where K::Target: KVStore + MaybeSync, L::Target: Logger, ES::Target: EntropySource + Sized, SP::Target: SignerProvider + Sized, BI::Target: BroadcasterInterface, FE::Target: FeeEstimator,

Source§

type Target = AsyncPersister<K, S, L, ES, SP, BI, FE>

The resulting type after dereferencing.
Source§

fn deref(&self) -> &Self

Dereferences the value.
Source§

impl<K: Deref + MaybeSend + MaybeSync + 'static, S: FutureSpawner, L: Deref + MaybeSend + MaybeSync + 'static, ES: Deref + MaybeSend + MaybeSync + 'static, SP: Deref + MaybeSend + MaybeSync + 'static, BI: Deref + MaybeSend + MaybeSync + 'static, FE: Deref + MaybeSend + MaybeSync + 'static> Persist<<<SP as Deref>::Target as SignerProvider>::EcdsaSigner> for AsyncPersister<K, S, L, ES, SP, BI, FE>
where K::Target: KVStore + MaybeSync, L::Target: Logger, ES::Target: EntropySource + Sized, SP::Target: SignerProvider + Sized, BI::Target: BroadcasterInterface, FE::Target: FeeEstimator, <SP::Target as SignerProvider>::EcdsaSigner: MaybeSend + 'static,

Source§

fn persist_new_channel( &self, monitor_name: MonitorName, monitor: &ChannelMonitor<<SP::Target as SignerProvider>::EcdsaSigner>, ) -> ChannelMonitorUpdateStatus

Persist a new channel’s data in response to a chain::Watch::watch_channel call. This is called by ChannelManager for new channels, or may be called directly, e.g. on startup, with the monitor_name returned by ChannelMonitor::persistence_key. Read more
Source§

fn update_persisted_channel( &self, monitor_name: MonitorName, monitor_update: Option<&ChannelMonitorUpdate>, monitor: &ChannelMonitor<<SP::Target as SignerProvider>::EcdsaSigner>, ) -> ChannelMonitorUpdateStatus

Update one channel’s data. The provided ChannelMonitor has already applied the given update. Read more
Source§

fn archive_persisted_channel(&self, monitor_name: MonitorName)

Prevents the channel monitor from being loaded on startup. Read more

Auto Trait Implementations§

§

impl<K, S, L, ES, SP, BI, FE> Freeze for AsyncPersister<K, S, L, ES, SP, BI, FE>
where <SP as Deref>::Target: Sized, <ES as Deref>::Target: Sized,

§

impl<K, S, L, ES, SP, BI, FE> RefUnwindSafe for AsyncPersister<K, S, L, ES, SP, BI, FE>
where <SP as Deref>::Target: Sized, <ES as Deref>::Target: Sized, K: RefUnwindSafe, S: RefUnwindSafe, L: RefUnwindSafe, ES: RefUnwindSafe, SP: RefUnwindSafe, BI: RefUnwindSafe, FE: RefUnwindSafe,

§

impl<K, S, L, ES, SP, BI, FE> Send for AsyncPersister<K, S, L, ES, SP, BI, FE>
where <SP as Deref>::Target: Sized, <ES as Deref>::Target: Sized,

§

impl<K, S, L, ES, SP, BI, FE> Sync for AsyncPersister<K, S, L, ES, SP, BI, FE>
where <SP as Deref>::Target: Sized, <ES as Deref>::Target: Sized,

§

impl<K, S, L, ES, SP, BI, FE> Unpin for AsyncPersister<K, S, L, ES, SP, BI, FE>
where <SP as Deref>::Target: Sized, <ES as Deref>::Target: Sized,

§

impl<K, S, L, ES, SP, BI, FE> UnwindSafe for AsyncPersister<K, S, L, ES, SP, BI, FE>
where <SP as Deref>::Target: Sized, <ES as Deref>::Target: Sized, K: RefUnwindSafe, S: RefUnwindSafe, L: RefUnwindSafe, ES: RefUnwindSafe, SP: RefUnwindSafe, BI: RefUnwindSafe, FE: RefUnwindSafe,

Blanket Implementations§

Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<P, T> Receiver for P
where P: Deref<Target = T> + ?Sized, T: ?Sized,

Source§

type Target = T

🔬This is a nightly-only experimental API. (arbitrary_self_types)
The target type on which the method may be called.
Source§

impl<S, T> ScoreLookUp for T
where S: ScoreLookUp, T: Deref<Target = S>,

Source§

type ScoreParams = <S as ScoreLookUp>::ScoreParams

A configurable type which should contain various passed-in parameters for configuring the scorer, on a per-routefinding-call basis through to the scorer methods, which are used to determine the parameters for the suitability of channels for use.
Source§

fn channel_penalty_msat( &self, candidate: &CandidateRouteHop<'_>, usage: ChannelUsage, score_params: &<T as ScoreLookUp>::ScoreParams, ) -> u64

Returns the fee in msats willing to be paid to avoid routing send_amt_msat through the given channel in the direction from source to target. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

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

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

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

Source§

fn vzip(self) -> V