Skip to main content

Readiness

Struct Readiness 

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

Fixed-dependency, versioned admission-readiness policy.

Construction normalizes dependencies by first occurrence and initializes each to ReadinessEvidence::Unknown. Greater evidence versions replace the prior classification, identical evidence is idempotent, and stale or same-version contradictory evidence is rejected without mutation. A report is ready exactly when every configured dependency is Ready; the empty set is ready. Initialization emits no effects, the template creates no actors, never terminates by policy, and requires only typed result delivery. Fixed membership, version ordering, and empty-set readiness are deliberate Bombay policy. Export through HTTP or orchestration remains a System adapter responsibility. No method has a semantic panic condition.

Implementations§

Source§

impl<A, K, Route> Readiness<A, K, Route>
where A: Address, K: Clone + Eq, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = ReadinessReport<K>>>,

Source

pub fn new(dependencies: impl IntoIterator<Item = K>) -> Self

Construct readiness policy for a fixed dependency set.

Source

pub fn dependencies(&self) -> &[DependencyReadiness<K>]

Borrow configured dependencies and their complete current evidence.

Trait Implementations§

Source§

impl<A, K, Route> Behavior for Readiness<A, K, Route>
where A: Address, K: Clone + Eq, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = ReadinessReport<K>>>, Route::Sends: SendsFor<User<A, ReadinessMessage<K, Route>>>,

Source§

type Protocol = Readiness<A, K, Route>

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

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

Source§

type Sends = <Route as DeliveryRoute>::Sends

Source§

type Ph = Never

Source§

type Error = ReadinessError<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 Readiness<A, K, Route>
where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = ReadinessReport<K>>>,

Source§

type Base = Readiness<A, K, Route>

Source§

fn base(&self) -> &Self

Source§

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

Source§

type Addr = A

Source§

type Msg = ReadinessMessage<K, Route>

Auto Trait Implementations§

§

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

§

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

§

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

§

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

§

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

§

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

§

impl<A, K, Route> UnwindSafe for Readiness<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.