Struct Backend 

pub struct Backend { /* private fields */ }

Sequence slots by watching an Ethereum JSON-RPC compatible chain.

Implementations

impl Backend

pub fn new( config: Config, client: ClientHandle, shutdown: CancellationToken, ) -> Self

pub fn client(&self) -> &ClientHandle

Trait Implementations

impl Clone for Backend

fn clone(&self) -> Backend

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Backend

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl SequenceBackend for Backend

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stop streaming. This will terminate the active WebSocket connection gracefully.

fn fetch_oracle_info(&self) -> OracleInfoService

Backend-level pull endpoint for oracle epoch/config queries.

fn start_lyquid( &mut self, lyquid: &LyquidID, seq: Sequence, store: Arc<dyn KVStore>, ) -> Result<LyquidBackendHandle, Error>

Start backend tracking for the given lyquid and return a client handle for call submission.

fn stop_lyquid(&mut self, lyquid: &LyquidID) -> Result<(), Error>

Stop backend tracking for a given lyquid.

fn prune<'life0, 'async_trait>( &'life0 self, until: u64, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait,

Let the backend prune all its persisted data prior to the given block number (exclusive).