pub enum FixedDiagnostic<Role, Worker, Plan, Source>where
Role: Send + Sync,
Worker: Behavior + Send,
Plan: ActivationPlan,
Source: WorkerSource<Role, Worker, Plan>,
BehaviorAddr<Worker>: EndpointAddress,
StableProxy<Worker, Plan>: Behavior<Protocol = Worker::Protocol>,{
ProxyOutcomeFailed(ProxyOutcomeFailure<Role, Worker, Plan>),
ProxyInputRejected(ProxyInputFailure<Role, Worker, Plan>),
WorkerPreparationFailed(WorkerPreparationFailure<Role, Worker, Plan, Source::WorkerRejection, Source::SourceRejection>),
RecoveryDenied(RecoveryDenied<Role, Worker>),
RestartScheduleFailed(RestartScheduleFailure<Role>),
WorkerUnavailable(WorkerUnavailable<Role, Worker>),
UnexpectedInput {
input: FixedSupervisorEvent<Role, Worker, Plan, ActionItemResult<PrepareWorkers<Source, Role, Worker, Plan>>, WorkerPreparation<Source, Role, Worker, Plan>>,
},
}Expand description
One operational diagnostic emitted by a fixed supervisor.
Variants§
ProxyOutcomeFailed(ProxyOutcomeFailure<Role, Worker, Plan>)
The exact initial StableProxy operation could not make its worker ready.
ProxyInputRejected(ProxyInputFailure<Role, Worker, Plan>)
An exact replacement input was rejected and returned complete.
WorkerPreparationFailed(WorkerPreparationFailure<Role, Worker, Plan, Source::WorkerRejection, Source::SourceRejection>)
An operating recovery could not prepare every selected worker.
RecoveryDenied(RecoveryDenied<Role, Worker>)
An otherwise prepared recovery was denied by restart policy.
RestartScheduleFailed(RestartScheduleFailure<Role>)
A delayed recovery’s exact timer request was rejected.
A service command reached an exact proxy without a ready worker.
UnexpectedInput
One complete typed input did not belong to the current supervisor state.
Fields
§
input: FixedSupervisorEvent<Role, Worker, Plan, ActionItemResult<PrepareWorkers<Source, Role, Worker, Plan>>, WorkerPreparation<Source, Role, Worker, Plan>>Complete unexpected input, unchanged.
Auto Trait Implementations§
impl<Role, Worker, Plan, Source> Freeze for FixedDiagnostic<Role, Worker, Plan, Source>where
<<Worker as Behavior>::Protocol as Protocol>::Addr: Sized + Freeze,
<<Worker as Behavior>::Protocol as Protocol>::Msg: Freeze,
<Source as WorkerSource<Role, Worker, Plan>>::WorkerRejection: Freeze,
<Source as WorkerSource<Role, Worker, Plan>>::SourceRejection: Freeze,
Worker: Freeze,
Plan: Freeze,
Role: Freeze,
Source: Freeze,
<Plan as ActivationPlan>::Ready: Freeze,
<Worker as Behavior>::Error: Freeze,
<Plan as ActivationPlan>::Rejection: Freeze,
<<<Worker as Behavior>::Protocol as Protocol>::Addr as EndpointAddress>::Established<MessageProtocol<<<Worker as Behavior>::Protocol as Protocol>::Addr, FixedSnapshot<<Worker as Behavior>::Protocol>>>: Freeze,
<<<Worker as Behavior>::Protocol as Protocol>::Addr as EndpointAddress>::Established<MessageProtocol<<<Worker as Behavior>::Protocol as Protocol>::Addr, CapabilityResult<Role, <Worker as Behavior>::Protocol>>>: Freeze,
<<<Worker as Behavior>::Protocol as Protocol>::Addr as EndpointAddress>::Installed<StableProxy<Worker, Plan>>: Freeze,
<<<Worker as Behavior>::Protocol as Protocol>::Addr as EndpointAddress>::Established<<Worker as Behavior>::Protocol>: Freeze,
<Worker as Behavior>::Sends: Freeze,
<Worker as Behavior>::Ph: Freeze,
impl<Role, Worker, Plan, Source> !RefUnwindSafe for FixedDiagnostic<Role, Worker, Plan, Source>
impl<Role, Worker, Plan, Source> !Send for FixedDiagnostic<Role, Worker, Plan, Source>
impl<Role, Worker, Plan, Source> !Sync for FixedDiagnostic<Role, Worker, Plan, Source>
impl<Role, Worker, Plan, Source> !Unpin for FixedDiagnostic<Role, Worker, Plan, Source>
impl<Role, Worker, Plan, Source> UnsafeUnpin for FixedDiagnostic<Role, Worker, Plan, Source>where
<<Worker as Behavior>::Protocol as Protocol>::Addr: Sized + UnsafeUnpin,
<<Worker as Behavior>::Protocol as Protocol>::Msg: UnsafeUnpin,
<Source as WorkerSource<Role, Worker, Plan>>::WorkerRejection: UnsafeUnpin,
<Source as WorkerSource<Role, Worker, Plan>>::SourceRejection: UnsafeUnpin,
Worker: UnsafeUnpin,
Plan: UnsafeUnpin,
Role: UnsafeUnpin,
Source: UnsafeUnpin,
<Plan as ActivationPlan>::Ready: UnsafeUnpin,
<Worker as Behavior>::Error: UnsafeUnpin,
<Plan as ActivationPlan>::Rejection: UnsafeUnpin,
<<<Worker as Behavior>::Protocol as Protocol>::Addr as EndpointAddress>::Established<MessageProtocol<<<Worker as Behavior>::Protocol as Protocol>::Addr, FixedSnapshot<<Worker as Behavior>::Protocol>>>: UnsafeUnpin,
<<<Worker as Behavior>::Protocol as Protocol>::Addr as EndpointAddress>::Established<MessageProtocol<<<Worker as Behavior>::Protocol as Protocol>::Addr, CapabilityResult<Role, <Worker as Behavior>::Protocol>>>: UnsafeUnpin,
<<<Worker as Behavior>::Protocol as Protocol>::Addr as EndpointAddress>::Installed<StableProxy<Worker, Plan>>: UnsafeUnpin,
<<<Worker as Behavior>::Protocol as Protocol>::Addr as EndpointAddress>::Established<<Worker as Behavior>::Protocol>: UnsafeUnpin,
<Worker as Behavior>::Sends: UnsafeUnpin,
<Worker as Behavior>::Ph: UnsafeUnpin,
impl<Role, Worker, Plan, Source> !UnwindSafe for FixedDiagnostic<Role, Worker, Plan, Source>
Blanket Implementations§
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