Struct breez_sdk_core::lightning::util::test_utils::TestPersister
pub struct TestPersister {
pub update_rets: Mutex<VecDeque<ChannelMonitorUpdateStatus>>,
pub chain_sync_monitor_persistences: Mutex<HashMap<OutPoint, HashSet<MonitorUpdateId>>>,
pub offchain_monitor_updates: Mutex<HashMap<OutPoint, HashSet<MonitorUpdateId>>>,
}
Fields§
§update_rets: Mutex<VecDeque<ChannelMonitorUpdateStatus>>
The queue of update statuses we’ll return. If none are queued, ::Completed will always be returned.
chain_sync_monitor_persistences: Mutex<HashMap<OutPoint, HashSet<MonitorUpdateId>>>
When we get an update_persisted_channel call with no ChannelMonitorUpdate, we insert the MonitorUpdateId here.
offchain_monitor_updates: Mutex<HashMap<OutPoint, HashSet<MonitorUpdateId>>>
When we get an update_persisted_channel call with a ChannelMonitorUpdate, we insert the MonitorUpdateId here.
Implementations§
§impl TestPersister
impl TestPersister
pub fn new() -> TestPersister
pub fn set_update_ret(&self, next_ret: ChannelMonitorUpdateStatus)
pub fn set_update_ret(&self, next_ret: ChannelMonitorUpdateStatus)
Queue an update status to return.
Trait Implementations§
§impl<Signer> Persist<Signer> for TestPersisterwhere
Signer: WriteableEcdsaChannelSigner,
impl<Signer> Persist<Signer> for TestPersisterwhere
Signer: WriteableEcdsaChannelSigner,
§fn persist_new_channel(
&self,
_funding_txo: OutPoint,
_data: &ChannelMonitor<Signer>,
_id: MonitorUpdateId,
) -> ChannelMonitorUpdateStatus
fn persist_new_channel( &self, _funding_txo: OutPoint, _data: &ChannelMonitor<Signer>, _id: MonitorUpdateId, ) -> 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. Read more§fn update_persisted_channel(
&self,
funding_txo: OutPoint,
_update: Option<&ChannelMonitorUpdate>,
_data: &ChannelMonitor<Signer>,
update_id: MonitorUpdateId,
) -> ChannelMonitorUpdateStatus
fn update_persisted_channel( &self, funding_txo: OutPoint, _update: Option<&ChannelMonitorUpdate>, _data: &ChannelMonitor<Signer>, update_id: MonitorUpdateId, ) -> ChannelMonitorUpdateStatus
Update one channel’s data. The provided
ChannelMonitor
has already applied the given
update. Read moreAuto Trait Implementations§
impl !Freeze for TestPersister
impl RefUnwindSafe for TestPersister
impl Send for TestPersister
impl Sync for TestPersister
impl Unpin for TestPersister
impl UnwindSafe for TestPersister
Blanket Implementations§
§impl<T> AnySync for T
impl<T> AnySync for T
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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> Downcast for Twhere
T: AsAny + ?Sized,
impl<T> Downcast for Twhere
T: AsAny + ?Sized,
§fn downcast_ref<T>(&self) -> Option<&T>where
T: AsAny,
fn downcast_ref<T>(&self) -> Option<&T>where
T: AsAny,
Forward to the method defined on the type
Any
.§fn downcast_mut<T>(&mut self) -> Option<&mut T>where
T: AsAny,
fn downcast_mut<T>(&mut self) -> Option<&mut T>where
T: AsAny,
Forward to the method defined on the type
Any
.§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request