Skip to main content

Health

Struct Health 

Source
pub struct Health<A, K, Route>
where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = HealthReport<K>>>,
{ /* private fields */ }
Expand description

Versioned typed health aggregation behavior.

State is an insertion-ordered product of ComponentHealthState values. A greater version replaces the prior state. An identical observation is idempotent. A lower version is HealthError::Stale, and a same-version contradiction is HealthError::ConflictingVersion; both preserve the complete prior state. Removal retains a tombstone, so stale evidence cannot resurrect a component. Query emits one named typed delivery and never mutates state. Initialization is empty, the behavior never terminates by policy, and it requires only ordinary typed delivery interpretation. Versioning, aggregate ordering, and empty-set health are Bombay policy, not actor-model laws. No method has a semantic panic condition.

Implementations§

Source§

impl<A, K, Route> Health<A, K, Route>
where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = HealthReport<K>>>,

Source

pub const fn new() -> Self

Construct an empty health definition.

Source

pub fn components(&self) -> &[ComponentHealthState<K>]

Borrow every retained present or removed component state.

Trait Implementations§

Source§

impl<A, K, Route> Behavior for Health<A, K, Route>
where A: Address, K: Clone + Eq, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = HealthReport<K>>>, Route::Sends: SendsFor<User<A, HealthMessage<K, Route>>>,

Source§

type Protocol = Health<A, K, Route>

Stable public communication identity owned by this actor template. Read more
Source§

type Event = User<A, <<Health<A, K, Route> as Behavior>::Protocol as Protocol>::Msg>

Source§

type Sends = <Route as DeliveryRoute>::Sends

Source§

type Ph = Never

Source§

type Error = HealthError<K>

Source§

type Birth = NoBirths

Source§

fn transition( &mut self, _: ActiveTurn, event: Self::Event, ) -> BehaviorActed<Self>

Fold exactly one event into explicit actions and the next behavior. Read more
Source§

fn init( &mut self, _turn: InitializationTurn, ) -> Result<Actions<<Self::Protocol as Protocol>::Addr, Self::Ph, Self::Sends, Self::Birth>, Self::Error>
where Self: Sized,

Produce initialization actions before the first event is accepted. Read more
Source§

fn layer<L>(self, layer: L) -> <L as BehaviorLayer<Self>>::Output
where Self: Sized, L: BehaviorLayer<Self>,

Apply one statically dispatched construction layer. Read more
Source§

impl<A, K, Route> BehaviorBase for Health<A, K, Route>
where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = HealthReport<K>>>,

Source§

type Base = Health<A, K, Route>

Source§

fn base(&self) -> &Self

Source§

impl<A, K, Route> Default for Health<A, K, Route>
where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = HealthReport<K>>>,

Source§

fn default() -> Self

Returns the “default value” for a type. Read more
Source§

impl<A, K, Route> Protocol for Health<A, K, Route>
where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = HealthReport<K>>>,

Source§

type Addr = A

Source§

type Msg = HealthMessage<K, Route>

Auto Trait Implementations§

§

impl<A, K, Route> Freeze for Health<A, K, Route>

§

impl<A, K, Route> RefUnwindSafe for Health<A, K, Route>
where K: RefUnwindSafe,

§

impl<A, K, Route> Send for Health<A, K, Route>
where K: Send,

§

impl<A, K, Route> Sync for Health<A, K, Route>
where K: Sync,

§

impl<A, K, Route> Unpin for Health<A, K, Route>
where K: Unpin,

§

impl<A, K, Route> UnsafeUnpin for Health<A, K, Route>

§

impl<A, K, Route> UnwindSafe for Health<A, K, Route>
where K: UnwindSafe,

Blanket Implementations§

Source§

impl<B> Activate for B
where B: Behavior,

Source§

fn initialize(self) -> Result<Initialized<Self>, Self::Error>

Consume this definition, perform its one initialization fold, and return the active behavior together with the ordered initialization effects. Read more
Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<B> BeginShutdownPhases for B
where B: Behavior, <<B as Behavior>::Birth as BirthMode>::Child: ChildOccurrenceProduct<AvailableChildren>,

Source§

impl<Node> BirthNodeAppend<Never> for Node
where Node: NonEmptyBirthNode,

Source§

type Output = Node

Closed child algebra containing the complete prefix followed by the complete appended tail.
Source§

fn append_prefix(self) -> <Node as BirthNodeAppend<Never>>::Output

Inject one child from the existing prefix without changing its structural occurrence.
Source§

fn append_tail(tail: Never) -> <Node as BirthNodeAppend<Never>>::Output

Inject one child from the appended tail after every prefix occurrence.
Source§

fn append_creations<A>( prefix: Creations<CreateChild<A, Self>>, tail: Creations<CreateChild<A, Tail>>, ) -> Creations<CreateChild<A, Self::Output>>
where A: Address,

Preserve and concatenate two ordered creation batches.
Source§

impl<Child, Tail> BirthNodeAppend<Tail> for Child
where Child: Behavior, Tail: NonEmptyBirthNode,

Source§

type Output = ChildChoice<Child, Tail>

Closed child algebra containing the complete prefix followed by the complete appended tail.
Source§

fn append_prefix(self) -> <Child as BirthNodeAppend<Tail>>::Output

Inject one child from the existing prefix without changing its structural occurrence.
Source§

fn append_tail(tail: Tail) -> <Child as BirthNodeAppend<Tail>>::Output

Inject one child from the appended tail after every prefix occurrence.
Source§

fn append_creations<A>( prefix: Creations<CreateChild<A, Self>>, tail: Creations<CreateChild<A, Tail>>, ) -> Creations<CreateChild<A, Self::Output>>
where A: Address,

Preserve and concatenate two ordered creation batches.
Source§

impl<B> BirthProtocols for B
where B: Behavior, <B as Behavior>::Birth: BirthModeProtocols,

Source§

type Protocols = BirthProtocol<<B as Behavior>::Protocol, <<B as Behavior>::Birth as BirthModeProtocols>::Protocols>

Source§

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

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

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

Source§

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

Mutably borrows from an owned value. Read more
Source§

impl<Node, Shape> ChildOccurrenceProduct<Shape> for Node
where Node: ChildOccurrenceProductAt<ChildHead, Shape>, Shape: ChildOccurrenceShape,

Source§

type Product = <Node as ChildOccurrenceProductAt<ChildHead, Shape>>::Product

Complete shape-owned representation of this closed birth node.
Source§

impl<A, Child, Host> DispatchBirth<A, Host> for Child
where A: Address, Child: CreateSelectedChild<A, ChildHead, Host>,

Source§

fn dispatch_birth( self, id: CreationId, route: <A as Address>::Nonce, kind: CreationKind, host: &mut Host, ) -> impl Future<Output = ItemSettlement<RoutedCreation<A, Child>, <Child as ChildCreationProduct<A, ChildHead>>::Result, CreationRejection, Never>> + Send

Select exactly one concrete child host while preserving creation data in every non-accepted settlement.
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

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

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

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

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

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

Source§

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

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.