pub struct Configuration<A: Address, C, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = ConfigurationState<C>>>> { /* private fields */ }Expand description
Atomic versioned-configuration behavior.
The first candidate is accepted. A greater version atomically replaces the
prior value, an identical version and value is idempotent, and stale or
same-version contradictory candidates return ownership in a concrete
ConfigurationError without mutation. Query clones the explicit
ConfigurationState to one typed recipient. Initialization is empty, no
actor is created, and the template does not terminate its host. Version
ordering and idempotence are Bombay policy; acquiring, decoding, validating,
or exporting external configuration remains an application/System adapter
responsibility. No method has a semantic panic condition.
Implementations§
Source§impl<A, C, Route> Configuration<A, C, Route>where
A: Address,
C: Clone + Eq,
Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = ConfigurationState<C>>>,
impl<A, C, Route> Configuration<A, C, Route>where
A: Address,
C: Clone + Eq,
Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = ConfigurationState<C>>>,
Sourcepub const fn state(&self) -> &ConfigurationState<C>
pub const fn state(&self) -> &ConfigurationState<C>
Borrow the complete current state.
Trait Implementations§
Source§impl<A, C, Route> Behavior for Configuration<A, C, Route>where
A: Address,
C: Clone + Eq,
Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = ConfigurationState<C>>>,
Route::Sends: SendsFor<User<A, ConfigurationMessage<C, Route>>>,
impl<A, C, Route> Behavior for Configuration<A, C, Route>where
A: Address,
C: Clone + Eq,
Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = ConfigurationState<C>>>,
Route::Sends: SendsFor<User<A, ConfigurationMessage<C, Route>>>,
Source§type Protocol = Configuration<A, C, Route>
type Protocol = Configuration<A, C, Route>
Stable public communication identity owned by this actor template. Read more
type Event = User<A, <<Configuration<A, C, Route> as Behavior>::Protocol as Protocol>::Msg>
type Sends = <Route as DeliveryRoute>::Sends
type Ph = Never
type Error = ConfigurationError<C>
type Birth = NoBirths
Source§fn transition(
&mut self,
_: ActiveTurn,
event: Self::Event,
) -> BehaviorActed<Self>
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,
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>>::Outputwhere
Self: Sized,
L: BehaviorLayer<Self>,
fn layer<L>(self, layer: L) -> <L as BehaviorLayer<Self>>::Outputwhere
Self: Sized,
L: BehaviorLayer<Self>,
Apply one statically dispatched construction layer. Read more
Source§impl<A, C, Route> BehaviorBase for Configuration<A, C, Route>
impl<A, C, Route> BehaviorBase for Configuration<A, C, Route>
Source§impl<A, C, Route> Default for Configuration<A, C, Route>where
A: Address,
C: Clone + Eq,
Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = ConfigurationState<C>>>,
impl<A, C, Route> Default for Configuration<A, C, Route>where
A: Address,
C: Clone + Eq,
Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = ConfigurationState<C>>>,
Source§impl<A, C, Route> Protocol for Configuration<A, C, Route>
impl<A, C, Route> Protocol for Configuration<A, C, Route>
Auto Trait Implementations§
impl<A, C, Route> Freeze for Configuration<A, C, Route>where
C: Freeze,
impl<A, C, Route> RefUnwindSafe for Configuration<A, C, Route>where
C: RefUnwindSafe,
impl<A, C, Route> Send for Configuration<A, C, Route>where
C: Send,
impl<A, C, Route> Sync for Configuration<A, C, Route>where
C: Sync,
impl<A, C, Route> Unpin for Configuration<A, C, Route>where
C: Unpin,
impl<A, C, Route> UnsafeUnpin for Configuration<A, C, Route>where
C: UnsafeUnpin,
impl<A, C, Route> UnwindSafe for Configuration<A, C, Route>where
C: UnwindSafe,
Blanket Implementations§
Source§impl<B> Activate for Bwhere
B: Behavior,
impl<B> Activate for Bwhere
B: Behavior,
Source§fn initialize(self) -> Result<Initialized<Self>, Self::Error>
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<B> BeginShutdownPhases for B
impl<B> BeginShutdownPhases for B
type Output = ChildShutdownPhases<B, <<<B as Behavior>::Birth as BirthMode>::Child as ChildOccurrenceProduct<AvailableChildren>>::Product, NoPhases>
fn begin_shutdown_phases(self) -> <B as BeginShutdownPhases>::Output
Source§impl<Node> BirthNodeAppend<Never> for Nodewhere
Node: NonEmptyBirthNode,
impl<Node> BirthNodeAppend<Never> for Nodewhere
Node: NonEmptyBirthNode,
Source§type Output = Node
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
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
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,
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 Childwhere
Child: Behavior,
Tail: NonEmptyBirthNode,
impl<Child, Tail> BirthNodeAppend<Tail> for Childwhere
Child: Behavior,
Tail: NonEmptyBirthNode,
Source§type Output = ChildChoice<Child, Tail>
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
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
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,
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
impl<B> BirthProtocols for B
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<Node, Shape> ChildOccurrenceProduct<Shape> for Nodewhere
Node: ChildOccurrenceProductAt<ChildHead, Shape>,
Shape: ChildOccurrenceShape,
impl<Node, Shape> ChildOccurrenceProduct<Shape> for Nodewhere
Node: ChildOccurrenceProductAt<ChildHead, Shape>,
Shape: ChildOccurrenceShape,
Source§impl<A, Child, Host> DispatchBirth<A, Host> for Child
impl<A, Child, Host> DispatchBirth<A, Host> for Child
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
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.