Struct wasmbus_rpc::provider::HostBridge

source · [−]

pub struct HostBridge { /* private fields */ }

Expand description

HostBridge manages the NATS connection to the host, and processes subscriptions for links, health-checks, and rpc messages. Callbacks from HostBridge are implemented by the provider in the [ProviderHandler] implementation.

Implementations

source

impl HostBridge

source

pub fn new(
nats: Connection,
host_data: &HostData
) -> Result<HostBridge, RpcError>

source

pub fn provider_key(&self) -> &str

Returns the provider’s public key

source

pub fn host_id(&self) -> &str

Returns the host id that launched this provider

source

pub fn link_name(&self) -> &str

Returns the link_name for this provider

source

impl HostBridge

source

pub async fn put_link(&self, ld: LinkDefinition)

Stores actor with link definition

source

pub async fn delete_link(&self, actor_id: &str)

Deletes link

source

pub async fn is_linked(&self, actor_id: &str) -> bool

Returns true if the actor is linked

source

pub async fn get_link(&self, actor_id: &str) -> Option<LinkDefinition>

Returns copy of LinkDefinition, or None,if the actor is not linked

source

pub async fn connect(
 &'static self,
 provider: P,
 shutdown_tx: Sender<HostShutdownEvent>
) -> Result<JoinAll<JoinHandle<Result<(), RpcError>>>, RpcError> where
 P: ProviderDispatch + Send + Sync + Clone + 'static,

Implement subscriber listener threads and provider callbacks

source

pub async fn validate_invocation(&self, inv: &Invocation) -> Result<(), String>

Trait Implementations

source

impl Clone for HostBridge

source

fn clone(&self) -> HostBridge

Returns a copy of the value. Read more

1.0.0 · source

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

Performs copy-assignment from source. Read more

source

impl Deref for HostBridge

type Target = HostBridgeInner

The resulting type after dereferencing.

source

fn deref(&self) -> &Self::Target

Dereferences the value.

Auto Trait Implementations

impl !RefUnwindSafe for HostBridge

impl Send for HostBridge

impl Sync for HostBridge

impl Unpin for HostBridge

impl !UnwindSafe for HostBridge

Blanket Implementations

source

impl<T> Any for T where
T: 'static + ?Sized,

source

pub fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

pub fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

pub fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source

impl<T> From<T> for T

const: unstable · source

pub fn from(t: T) -> T

Performs the conversion.

source

impl<T, U> Into for T where
U: From<T>,

const: unstable · source

pub fn into(self) -> U

Performs the conversion.

impl<T> Pointable for T

pub const ALIGN: usize

The alignment of pointer.

type Init = T

The type for initializers.

pub unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more

pub unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more

pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more

pub unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more

source

impl<T> Same<T> for T

type Output = T

Should always be Self

source

impl<T> ToOwned for T where
T: Clone,

type Owned = T

The resulting type after obtaining ownership.

source

pub fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

source

pub fn clone_into(&self, target: &mut T)

🔬 This is a nightly-only experimental API. (toowned_clone_into)

Uses borrowed data to replace owned data, usually by cloning. Read more

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

Struct wasmbus_rpc::provider::HostBridge

Implementations

impl HostBridge

pub fn new( nats: Connection, host_data: &HostData) -> Result<HostBridge, RpcError>

pub fn provider_key(&self) -> &str

pub fn host_id(&self) -> &str

pub fn link_name(&self) -> &str

impl HostBridge

pub async fn put_link(&self, ld: LinkDefinition)

pub async fn delete_link(&self, actor_id: &str)

pub async fn is_linked(&self, actor_id: &str) -> bool

pub async fn get_link(&self, actor_id: &str) -> Option<LinkDefinition>

pub async fn connect<P>( &'static self, provider: P, shutdown_tx: Sender<HostShutdownEvent>) -> Result<JoinAll<JoinHandle<Result<(), RpcError>>>, RpcError> where P: ProviderDispatch + Send + Sync + Clone + 'static,

pub async fn validate_invocation(&self, inv: &Invocation) -> Result<(), String>

Trait Implementations

impl Clone for HostBridge

fn clone(&self) -> HostBridge

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

impl Deref for HostBridge

type Target = HostBridgeInner

fn deref(&self) -> &Self::Target

Auto Trait Implementations

impl !RefUnwindSafe for HostBridge

impl Send for HostBridge

impl Sync for HostBridge

impl Unpin for HostBridge

impl !UnwindSafe for HostBridge

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

pub fn from(t: T) -> T

impl<T, U> Into<U> for T where U: From<T>,

pub fn into(self) -> U

impl<T> Pointable for T

pub const ALIGN: usize

type Init = T

pub unsafe fn init(init: <T as Pointable>::Init) -> usize

pub unsafe fn deref<'a>(ptr: usize) -> &'a T

pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

pub unsafe fn drop(ptr: usize)

impl<T> Same<T> for T

type Output = T

impl<T> ToOwned for T where T: Clone,

type Owned = T

pub fn to_owned(&self) -> T

pub fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for T where V: MultiLane<T>,

pub fn vzip(self) -> V

pub fn new(
nats: Connection,
host_data: &HostData
) -> Result<HostBridge, RpcError>

pub async fn connect<P>(
&'static self,
provider: P,
shutdown_tx: Sender<HostShutdownEvent>
) -> Result<JoinAll<JoinHandle<Result<(), RpcError>>>, RpcError> where
P: ProviderDispatch + Send + Sync + Clone + 'static,

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T> ToOwned for T where
T: Clone,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

impl<V, T> VZip<V> for T where
V: MultiLane<T>,