Struct SupervisorClient 

pub struct SupervisorClient { /* private fields */ }

Available on crate features node-api and node only.

Implementation of the supervisor trait for the interop.

Implementations

impl SupervisorClient

pub fn builder( supervisor_endpoint: impl Into<String>, ) -> SupervisorClientBuilder

Returns a new SupervisorClientBuilder.

pub fn timeout(&self) -> Duration

Returns configured timeout. See SupervisorClientInner.

pub fn safety(&self) -> SafetyLevel

Returns configured minimum safety level. See SupervisorClient.

pub fn check_access_list<'a>( &self, inbox_entries: &'a [FixedBytes<32>], executing_descriptor: ExecutingDescriptor, ) -> CheckAccessListRequest<'a>

Executes a supervisor_checkAccessList with the configured safety level.

pub async fn is_valid_cross_tx( &self, access_list: Option<&AccessList>, hash: &FixedBytes<32>, timestamp: u64, timeout: Option<u64>, is_interop_active: bool, ) -> Option<Result<(), InvalidCrossTx>>

Extracts commitment from access list entries, pointing to 0x420..022 and validates them against supervisor.

If commitment present pre-interop tx rejected.

Returns: None - if tx is not cross chain, Some(Ok(()) - if tx is valid cross chain, Some(Err(e)) - if tx is not valid or interop is not active

pub fn revalidate_interop_txs_stream<'a, TItem, InputIter>( &'a self, txs_to_revalidate: InputIter, current_timestamp: u64, revalidation_window: u64, max_concurrent_queries: usize, ) -> impl Stream<Item = (TItem, Option<Result<(), InvalidCrossTx>>)> + Send + 'a

where InputIter: IntoIterator<Item = TItem> + Send + 'a, <InputIter as IntoIterator>::IntoIter: Send + 'a, TItem: MaybeInteropTransaction + PoolTransaction + Transaction + Clone + Send + Sync + 'static,

Creates a stream that revalidates interop transactions against the supervisor. Returns An implementation of Stream that is Send-able and tied to the lifetime 'a of self. Each item yielded by the stream is a tuple (TItem, Option<Result<(), InvalidCrossTx>>).

• The first element is the original TItem that was revalidated.
• The second element is the Option<Result<(), InvalidCrossTx>> describes the outcome
  • None: Transaction was not identified as a cross-chain candidate by initial checks.
  • Some(Ok(())): Supervisor confirmed the transaction is valid.
  • Some(Err(InvalidCrossTx)): Supervisor indicated the transaction is invalid.

Trait Implementations

impl Clone for SupervisorClient

fn clone(&self) -> SupervisorClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SupervisorClient

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

Formats the value using the given formatter.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 8 bytes