Struct Subscribe

Source

pub struct Subscribe(pub PortRef<Option<MeshFailure>>);

Expand description

Subscribe me to updates about a mesh. If a duplicate is subscribed, only a single message is sent. Will send None if there are no failures on the mesh periodically. This guarantees the listener that the controller is still alive. Make sure to filter such events out as not useful.

Tuple Fields§

§0: PortRef<Option<MeshFailure>>

Subscribe

Struct Subscribe Copy item path

Tuple Fields§

Trait Implementations§

impl Bind for Subscribe

fn bind(&mut self, bindings: &mut Bindings) -> Result<()>

impl Clone for Subscribe

fn clone(&self) -> Subscribe

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

impl Debug for Subscribe

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

impl<'de> Deserialize<'de> for Subscribe

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

impl<A: Referable> Handler<Subscribe> for ActorMeshController<A>

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, Self>, message: Subscribe, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Named for Subscribe

fn typename() -> &'static str

fn typehash() -> u64

fn typeid() -> TypeId

fn port() -> u64

fn arm(&self) -> Option<&'static str>

unsafe fn arm_unchecked(self_: *const ()) -> Option<&'static str>

impl PartialEq for Subscribe

fn eq(&self, other: &Subscribe) -> bool

fn ne(&self, other: &Rhs) -> bool

impl Serialize for Subscribe

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where __S: Serializer,

impl Unbind for Subscribe

fn unbind(&self, bindings: &mut Bindings) -> Result<()>

impl<A> RemoteHandles<Subscribe> for ActorMeshController<A>where A: Referable,

impl StructuralPartialEq for Subscribe

Auto Trait Implementations§

impl !Freeze for Subscribe

impl !RefUnwindSafe for Subscribe

impl Send for Subscribe

impl Sync for Subscribe

impl Unpin for Subscribe

impl !UnwindSafe for Subscribe

Blanket Implementations§

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

fn type_id(&self) -> TypeId

impl<T> Any for Twhere T: Any,

fn into_any(self: Box<T>) -> Box<dyn Any>

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

fn type_name(&self) -> &'static str

impl<T> AnySync for Twhere T: Any + Send + Sync,

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync>

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

fn borrow(&self) -> &T

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

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

impl<T> Checkpointable for Twhere T: RemoteMessage + Clone,

type State = T

fn save<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<<T as Checkpointable>::State, CheckpointError>> + Send + 'async_trait>>where 'life0: 'async_trait, T: 'async_trait,

fn load<'async_trait>( state: <T as Checkpointable>::State, ) -> Pin<Box<dyn Future<Output = Result<T, CheckpointError>> + Send + 'async_trait>>where T: 'async_trait,

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<A, M> Handler<IndexedErasedUnbound<M>> for Awhere A: Handler<M>, M: Castable,

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, A>, msg: IndexedErasedUnbound<M>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where 'life0: 'async_trait, 'life1: 'async_trait, A: 'async_trait,

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

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

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

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

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

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

unsafe fn drop(ptr: usize)

impl<T> QuoteExt for Twhere T: ?Sized,

Struct Subscribe

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, Self>, message: Subscribe, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

impl<A> RemoteHandles<Subscribe> for ActorMeshController<A>
where A: Referable,

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

impl<T> Any for T
where T: Any,

impl<T> AnySync for T
where T: Any + Send + Sync,

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

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

impl<T> Checkpointable for T
where T: RemoteMessage + Clone,

fn save<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<<T as Checkpointable>::State, CheckpointError>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: 'async_trait,

fn load<'async_trait>( state: <T as Checkpointable>::State, ) -> Pin<Box<dyn Future<Output = Result<T, CheckpointError>> + Send + 'async_trait>>
where T: 'async_trait,

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

impl<A, M> Handler<IndexedErasedUnbound<M>> for A
where A: Handler<M>, M: Castable,

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, A>, msg: IndexedErasedUnbound<M>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, A: 'async_trait,

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

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

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

fn push_quoted<'q, Q, S>(&mut self, _q: Q, s: S)
where Q: QuoteInto<T>, S: Into<Quotable<'q>>,

impl<T> Serialize for T
where T: Serialize + ?Sized,

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>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<T> Castable for T
where T: RemoteMessage + Bind + Unbind,

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

impl<M> Message for M
where M: Send + Sync + 'static,

impl<M> RemoteMessage for M
where M: Message + Named + Serialize + DeserializeOwned,