pub struct DummyPersistentTxooSource { /* private fields */ }
Expand description
A dummy TXOO source that can be used for testing. Uses DUMMY_SECRET as the oracle secret key.
Note that the [TxooFollower
] will automatically provide blocks to the source
via the [on_new_block
] method, except for the genesis block that must be provided
by the caller.
Implementations§
Source§impl DummyPersistentTxooSource
impl DummyPersistentTxooSource
Sourcepub fn new(
datadir: PathBuf,
network: Network,
start_block: u32,
block: &Block,
prev_filter_header: &FilterHeader,
) -> Self
pub fn new( datadir: PathBuf, network: Network, start_block: u32, block: &Block, prev_filter_header: &FilterHeader, ) -> Self
Create a new source
Sourcepub fn from_checkpoint(
datadir: PathBuf,
network: Network,
start_block: u32,
block_hash: BlockHash,
filter_header: FilterHeader,
) -> Self
pub fn from_checkpoint( datadir: PathBuf, network: Network, start_block: u32, block_hash: BlockHash, filter_header: FilterHeader, ) -> Self
Create a new source at a checkpoint, where the filter_header is known
Trait Implementations§
Source§impl Source for DummyPersistentTxooSource
impl Source for DummyPersistentTxooSource
Source§fn get_unchecked<'life0, 'life1, 'async_trait>(
&'life0 self,
block_height: u32,
block_hash: &'life1 BlockHash,
) -> Pin<Box<dyn Future<Output = Result<SignedAttestation, TxooSourceError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_unchecked<'life0, 'life1, 'async_trait>(
&'life0 self,
block_height: u32,
block_hash: &'life1 BlockHash,
) -> Pin<Box<dyn Future<Output = Result<SignedAttestation, TxooSourceError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Get an attestation for the given block, without checking it
Source§fn oracle_setup<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = &OracleSetup> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn oracle_setup<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = &OracleSetup> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get the oracle configuration
Source§fn on_new_block<'life0, 'life1, 'async_trait>(
&'life0 self,
block_height: u32,
block: &'life1 Block,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn on_new_block<'life0, 'life1, 'async_trait>(
&'life0 self,
block_height: u32,
block: &'life1 Block,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Notify the source of a new block, in case the source passively updates
Source§fn get<'life0, 'life1, 'async_trait>(
&'life0 self,
height: u32,
block: &'life1 Block,
) -> Pin<Box<dyn Future<Output = Result<(SignedAttestation, FilterHeader), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn get<'life0, 'life1, 'async_trait>(
&'life0 self,
height: u32,
block: &'life1 Block,
) -> Pin<Box<dyn Future<Output = Result<(SignedAttestation, FilterHeader), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Get an attestation for the given block, with full validation
Also returns the previous filter header
Auto Trait Implementations§
impl Freeze for DummyPersistentTxooSource
impl RefUnwindSafe for DummyPersistentTxooSource
impl Send for DummyPersistentTxooSource
impl Sync for DummyPersistentTxooSource
impl Unpin for DummyPersistentTxooSource
impl UnwindSafe for DummyPersistentTxooSource
Blanket Implementations§
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