pub enum RingKernelError {
Show 66 variants
KernelNotFound(String),
KernelAlreadyActive(String),
KernelNotActive(String),
KernelTerminated(String),
InvalidStateTransition {
from: String,
to: String,
},
InvalidState {
expected: String,
actual: String,
},
LaunchFailed(String),
CompilationError(String),
QueueFull {
capacity: usize,
},
QueueEmpty,
SerializationError(String),
DeserializationError(String),
ValidationError(String),
MessageTooLarge {
size: usize,
max: usize,
},
Timeout(Duration),
AllocationFailed {
size: usize,
reason: String,
},
HostAllocationFailed {
size: usize,
},
TransferFailed(String),
InvalidAlignment {
expected: usize,
actual: usize,
},
OutOfMemory {
requested: usize,
available: usize,
},
PoolExhausted,
InvalidIndex(usize),
MemoryError(String),
BackendUnavailable(String),
BackendInitFailed(String),
NoDeviceFound,
DeviceSelectionFailed(String),
BackendError(String),
DeadlockDetected,
LockPoisoned,
ChannelClosed,
ClockSkew {
skew_ms: u64,
max_ms: u64,
},
InvalidTimestamp,
K2KError(String),
K2KDestinationNotFound(String),
K2KDeliveryFailed(String),
PubSubError(String),
TopicNotFound(String),
SubscriptionError(String),
MultiGpuError(String),
DeviceNotAvailable(String),
CrossDeviceTransferFailed(String),
TelemetryError(String),
MetricsCollectionFailed(String),
InvalidConfig(String),
MissingConfig(String),
StdIoError(Error),
IoError(String),
InvalidCheckpoint(String),
CheckpointSaveFailed(String),
CheckpointRestoreFailed(String),
CheckpointNotFound(String),
HealthCheckFailed {
name: String,
reason: String,
},
CircuitBreakerOpen {
name: String,
},
RetryExhausted {
attempts: u32,
reason: String,
},
WatchdogTimeout {
kernel_id: String,
},
LoadSheddingRejected {
level: String,
},
MigrationFailed(String),
MigrationSourceNotReady {
kernel_id: String,
},
MigrationDestinationUnavailable {
device_id: usize,
},
TracingError(String),
SpanNotFound(String),
MetricsExportFailed(String),
Internal(String),
NotSupported(String),
Cancelled,
}Expand description
Comprehensive error type for RingKernel operations.
Variants§
KernelNotFound(String)
Kernel not found with the given ID.
KernelAlreadyActive(String)
Kernel is already active.
KernelNotActive(String)
Kernel is not active.
KernelTerminated(String)
Kernel has already terminated.
InvalidStateTransition
Invalid kernel state transition.
InvalidState
Invalid kernel state.
LaunchFailed(String)
Kernel launch failed.
CompilationError(String)
Kernel compilation failed (NVRTC, shader compilation, etc.).
QueueFull
Queue is full, message cannot be enqueued.
QueueEmpty
Queue is empty, no message to dequeue.
SerializationError(String)
Message serialization failed.
DeserializationError(String)
Message deserialization failed.
ValidationError(String)
Message validation failed.
MessageTooLarge
Message too large.
Timeout(Duration)
Message timeout.
AllocationFailed
GPU memory allocation failed.
HostAllocationFailed
Host memory allocation failed.
TransferFailed(String)
Memory transfer failed.
InvalidAlignment
Invalid memory alignment.
OutOfMemory
Out of GPU memory.
PoolExhausted
Memory pool exhausted.
InvalidIndex(usize)
Invalid index (out of bounds).
MemoryError(String)
Generic memory error.
Backend not available.
BackendInitFailed(String)
Backend initialization failed.
NoDeviceFound
No suitable GPU device found.
DeviceSelectionFailed(String)
Device selection failed.
BackendError(String)
Backend operation failed.
DeadlockDetected
Deadlock detected.
LockPoisoned
Lock poisoned.
ChannelClosed
Channel closed.
ClockSkew
Clock skew too large.
InvalidTimestamp
Invalid timestamp.
K2KError(String)
K2K messaging error.
K2KDestinationNotFound(String)
K2K destination not found.
K2KDeliveryFailed(String)
K2K delivery failed.
PubSubError(String)
Pub/sub error.
TopicNotFound(String)
Topic not found.
SubscriptionError(String)
Subscription error.
MultiGpuError(String)
Multi-GPU coordination error.
DeviceNotAvailable(String)
Device not available.
CrossDeviceTransferFailed(String)
Cross-device transfer failed.
TelemetryError(String)
Telemetry error.
MetricsCollectionFailed(String)
Metrics collection failed.
InvalidConfig(String)
Invalid configuration.
MissingConfig(String)
Missing required configuration.
StdIoError(Error)
I/O error wrapper.
IoError(String)
I/O error with string message.
InvalidCheckpoint(String)
Invalid checkpoint format or data.
CheckpointSaveFailed(String)
Checkpoint save failed.
CheckpointRestoreFailed(String)
Checkpoint restore failed.
CheckpointNotFound(String)
Checkpoint not found.
HealthCheckFailed
Health check failed.
CircuitBreakerOpen
Circuit breaker is open.
RetryExhausted
Retry attempts exhausted.
WatchdogTimeout
Kernel watchdog timeout.
LoadSheddingRejected
Load shedding rejected request.
MigrationFailed(String)
Kernel migration failed.
MigrationSourceNotReady
Migration source not ready.
Migration destination unavailable.
TracingError(String)
Tracing error.
SpanNotFound(String)
Span not found.
MetricsExportFailed(String)
Metrics export failed.
Internal(String)
Internal error.
NotSupported(String)
Feature not supported.
Cancelled
Operation cancelled.
Implementations§
Source§impl RingKernelError
impl RingKernelError
Sourcepub fn is_recoverable(&self) -> bool
pub fn is_recoverable(&self) -> bool
Returns true if this error is recoverable.
Sourcepub fn is_resource_error(&self) -> bool
pub fn is_resource_error(&self) -> bool
Returns true if this error indicates a resource issue.
Sourcepub fn is_health_error(&self) -> bool
pub fn is_health_error(&self) -> bool
Returns true if this is a health/resilience related error.
Sourcepub fn is_migration_error(&self) -> bool
pub fn is_migration_error(&self) -> bool
Returns true if this is a migration-related error.
Sourcepub fn is_observability_error(&self) -> bool
pub fn is_observability_error(&self) -> bool
Returns true if this is an observability-related error.
Trait Implementations§
Source§impl Debug for RingKernelError
impl Debug for RingKernelError
Source§impl Display for RingKernelError
impl Display for RingKernelError
Source§impl Error for RingKernelError
impl Error for RingKernelError
Source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
1.0.0 · Source§fn description(&self) -> &str
fn description(&self) -> &str
Source§impl From<Error> for RingKernelError
impl From<Error> for RingKernelError
Source§fn from(source: Error) -> RingKernelError
fn from(source: Error) -> RingKernelError
Auto Trait Implementations§
impl Freeze for RingKernelError
impl !RefUnwindSafe for RingKernelError
impl Send for RingKernelError
impl Sync for RingKernelError
impl Unpin for RingKernelError
impl !UnwindSafe for RingKernelError
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
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
Source§impl<F, W, T, D> Deserialize<With<T, W>, D> for F
impl<F, W, T, D> Deserialize<With<T, W>, D> for F
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more