Struct wasmcloud_streams_redis::RedisStreamsProvider [−][src]
pub struct RedisStreamsProvider { /* fields omitted */ }
Expand description
Redis implementation of the wasmcloud:eventstreams
provider contract
Implementations
Trait Implementations
impl CapabilityProvider for RedisStreamsProvider
[src]
impl CapabilityProvider for RedisStreamsProvider
[src]fn configure_dispatch(
&self,
dispatcher: Box<dyn Dispatcher>
) -> Result<(), Box<dyn Error + Send + Sync>>
[src]
fn configure_dispatch(
&self,
dispatcher: Box<dyn Dispatcher>
) -> Result<(), Box<dyn Error + Send + Sync>>
[src]This function will be called on the provider when the host runtime is ready and has configured a dispatcher. This function is only ever called once for a capability provider, regardless of the number of actors being managed in the host Read more
fn handle_call(
&self,
actor: &str,
op: &str,
msg: &[u8]
) -> Result<Vec<u8>, Box<dyn Error + Send + Sync>>
[src]
fn handle_call(
&self,
actor: &str,
op: &str,
msg: &[u8]
) -> Result<Vec<u8>, Box<dyn Error + Send + Sync>>
[src]Invoked when an actor has requested that a provider perform a given operation
fn stop(&self)
[src]
fn stop(&self)
[src]This function is called to let the capability provider know that it is being removed from the host runtime. This gives the provider an opportunity to clean up any resources and stop any running threads. WARNING: do not do anything in this function that can cause a panic, including attempting to write to STDOUT while the host process is terminating Read more
impl Clone for RedisStreamsProvider
[src]
impl Clone for RedisStreamsProvider
[src]fn clone(&self) -> RedisStreamsProvider
[src]
fn clone(&self) -> RedisStreamsProvider
[src]Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]Performs copy-assignment from source
. Read more
Auto Trait Implementations
impl RefUnwindSafe for RedisStreamsProvider
impl Send for RedisStreamsProvider
impl Sync for RedisStreamsProvider
impl Unpin for RedisStreamsProvider
impl UnwindSafe for RedisStreamsProvider
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<T> ToOwned for T where
T: Clone,
[src]
impl<T> ToOwned for T where
T: Clone,
[src]type Owned = T
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn to_owned(&self) -> T
[src]Creates owned data from borrowed data, usually by cloning. Read more
pub fn clone_into(&self, target: &mut T)
[src]
pub fn clone_into(&self, target: &mut T)
[src]🔬 This is a nightly-only experimental API. (toowned_clone_into
)
recently added
Uses borrowed data to replace owned data, usually by cloning. Read more