Skip to main content

CorsaEvent

Enum CorsaEvent 

Source
#[non_exhaustive]
pub enum CorsaEvent { JsonRpcRequestTimedOut { method: CompactString, timeout: Duration, }, JsonRpcOutboundQueueFull, JsonRpcLocalHandlerPanicked { method: CompactString, }, JsonRpcPendingRequestsFailed { error: CompactString, count: usize, }, MsgpackRequestTimedOut { method: CompactString, timeout: Duration, }, MsgpackWorkerQueueFull { method: CompactString, }, MsgpackWorkerTerminated { reason: CompactString, }, OrchestratorSnapshotEvicted { key: CompactString, }, OrchestratorResultEvicted { key: CompactString, }, }
Expand description

Structured runtime events that embedders can observe.

The enum intentionally focuses on operationally relevant state transitions such as timeouts, queue saturation, and cache eviction. Variants may be added over time as the workspace exposes more subsystems.

Variants (Non-exhaustive)§

This enum is marked as non-exhaustive
Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.
§

JsonRpcRequestTimedOut

A JSON-RPC request exceeded its configured timeout.

Fields

§method: CompactString

JSON-RPC method name that timed out.

§timeout: Duration

Configured request timeout that was exceeded.

§

JsonRpcOutboundQueueFull

The JSON-RPC writer queue rejected a message because it was full.

§

JsonRpcLocalHandlerPanicked

A locally registered JSON-RPC handler panicked while processing a peer message.

Fields

§method: CompactString

JSON-RPC method name whose local handler panicked.

§

JsonRpcPendingRequestsFailed

Pending JSON-RPC requests were failed because the transport broke.

Fields

§error: CompactString

Transport error propagated to pending callers.

§count: usize

Number of pending requests failed together.

§

MsgpackRequestTimedOut

A sync msgpack request exceeded its configured timeout.

Fields

§method: CompactString

Msgpack API method name that timed out.

§timeout: Duration

Configured request timeout that was exceeded.

§

MsgpackWorkerQueueFull

The msgpack worker queue rejected a request because it was full.

Fields

§method: CompactString

Msgpack API method that could not be queued.

§

MsgpackWorkerTerminated

The msgpack worker process was explicitly terminated.

Fields

§reason: CompactString

Human-readable termination reason.

§

OrchestratorSnapshotEvicted

A cached snapshot was evicted to stay within configured limits.

Fields

§key: CompactString

Caller-provided snapshot cache key that was evicted.

§

OrchestratorResultEvicted

A cached result was evicted to stay within configured limits.

Fields

§key: CompactString

Caller-provided result cache key that was evicted.

Trait Implementations§

Source§

impl Clone for CorsaEvent

Source§

fn clone(&self) -> CorsaEvent

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for CorsaEvent

Source§

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

Formats the value using the given formatter. Read more
Source§

impl PartialEq for CorsaEvent

Source§

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

Tests for self and other values to be equal, and is used by ==.
1.0.0 (const: unstable) · Source§

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
Source§

impl Eq for CorsaEvent

Source§

impl StructuralPartialEq for CorsaEvent

Auto Trait Implementations§

Blanket Implementations§

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<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<T> CloneToUninit for T
where T: Clone,

Source§

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

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
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> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
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.