Struct TimingSender

pub struct TimingSender<T: Transport> { /* private fields */ }

TimingSender sends messages to a Timing service Provides the capability to read the system time. client for sending Timing messages

Implementations

impl<T: Transport> TimingSender<T>

pub fn via(transport: T) -> Self

Constructs a TimingSender with the specified transport

pub fn set_timeout(&self, interval: Duration)

Trait Implementations

impl<T: Clone + Transport> Clone for TimingSender<T>

fn clone(&self) -> TimingSender<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Transport> Debug for TimingSender<T>

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

Formats the value using the given formatter.

impl<T: Transport + Sync + Send> Timing for TimingSender<T>

fn now<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 Context, ) -> Pin<Box<dyn Future<Output = RpcResult<Timestamp>> + Send + 'async_trait>>

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

Returns the current time as a wasmbus_rpc::Timestamp struct.

The returned timestamp has nanosecond precision, so care should be taken to avoid timing attacks. If the timestamp will be made visible to users, it’s recommended to reduce the precision by truncating or removing the nsec field.

let timing = TimingSender::new();
let now = timing.now(ctx).await?;

fn contract_id() -> &'static str

returns the capability contract id for this interface