pub enum XervError {
Show 51 variants
ArenaCreate {
path: PathBuf,
cause: String,
},
ArenaMmap {
path: PathBuf,
cause: String,
},
ArenaWrite {
trace_id: TraceId,
offset: ArenaOffset,
cause: String,
},
ArenaRead {
offset: ArenaOffset,
cause: String,
},
ArenaCapacity {
requested: u64,
available: u64,
},
ArenaInvalidOffset {
offset: ArenaOffset,
cause: String,
},
ArenaCorruption {
offset: ArenaOffset,
cause: String,
},
SelectorResolution {
selector: String,
node_id: NodeId,
cause: String,
},
NonDeterministicLayout {
type_name: String,
cause: String,
},
SelectorSyntax {
selector: String,
cause: String,
},
SelectorTargetNotFound {
field: String,
node_id: NodeId,
},
SelectorTypeMismatch {
selector: String,
expected: String,
actual: String,
},
SchemaVersionNotFound {
schema: String,
version: String,
},
SchemaIncompatible {
from: String,
to: String,
cause: String,
},
MigrationFailed {
from: String,
to: String,
cause: String,
},
BreakingSchemaChange {
schema: String,
change: String,
},
MigrationPathTooLong {
from: String,
to: String,
max_hops: u32,
},
MissingBinary {
binary: String,
cause: String,
},
RuntimeMismatch {
runtime: String,
required: String,
found: String,
},
ContainerImageUnavailable {
image: String,
},
UnsupportedProfile {
profile: String,
},
NodeExecution {
node_id: NodeId,
trace_id: TraceId,
cause: String,
},
NodeTimeout {
node_id: NodeId,
trace_id: TraceId,
timeout_ms: u64,
},
NodePanic {
node_id: NodeId,
trace_id: TraceId,
message: String,
},
NodeConfig {
node_id: NodeId,
cause: String,
},
NodeNotFound {
node_name: String,
},
NoCompatibleVersion {
trace_id: TraceId,
cause: String,
},
InvalidTopology {
cause: String,
},
UncontrolledCycle {
nodes: Vec<NodeId>,
},
InvalidPort {
port: String,
node_id: NodeId,
},
MissingEdge {
from_node: NodeId,
from_port: String,
to_node: NodeId,
to_port: String,
},
InvalidEdge {
from_node: NodeId,
from_port: String,
to_node: NodeId,
to_port: String,
},
PipelineNotFound {
pipeline_id: String,
},
PipelineExists {
pipeline_id: String,
},
ConcurrencyLimit {
pipeline_id: String,
current: u32,
max: u32,
},
CircuitBreakerOpen {
pipeline_id: String,
error_rate: f64,
},
DrainTimeout {
pipeline_id: String,
pending_traces: u32,
},
WalWrite {
trace_id: TraceId,
cause: String,
},
WalRead {
cause: String,
},
WalCorruption {
position: u64,
cause: String,
},
WalReplay {
trace_id: TraceId,
cause: String,
},
WasmLoad {
module: String,
cause: String,
},
WasmExecution {
node_id: NodeId,
cause: String,
},
WasmMemoryAlloc {
requested: u64,
},
WasmHostFunction {
function: String,
cause: String,
},
YamlParse {
path: PathBuf,
cause: String,
},
ConfigValue {
field: String,
cause: String,
},
SchemaValidation {
schema: String,
cause: String,
},
Serialization(String),
Io {
path: PathBuf,
cause: String,
},
Network {
cause: String,
},
}Expand description
The main error type for XERV operations.
Variants§
ArenaCreate
Failed to create or open arena file.
ArenaMmap
Failed to memory-map the arena file.
ArenaWrite
Arena write operation failed.
Fields
offset: ArenaOffsetThe offset where write was attempted.
ArenaRead
Arena read operation failed.
Fields
offset: ArenaOffsetThe offset that could not be read.
ArenaCapacity
Arena capacity exceeded.
ArenaInvalidOffset
Invalid arena offset.
ArenaCorruption
Arena corruption detected.
Fields
offset: ArenaOffsetThe offset where corruption was detected.
SelectorResolution
Failed to resolve a selector expression.
Fields
NonDeterministicLayout
Non-deterministic layout detected (unstable offsets).
Fields
SelectorSyntax
Invalid selector syntax.
Fields
SelectorTargetNotFound
Selector target not found.
Fields
SelectorTypeMismatch
Type mismatch in selector.
Fields
SchemaVersionNotFound
Schema version not found.
SchemaIncompatible
Schema incompatible with no migration.
Fields
MigrationFailed
Migration failed.
Fields
BreakingSchemaChange
Breaking schema change without migration.
MigrationPathTooLong
Migration path too long.
Fields
MissingBinary
Missing binary dependency.
Fields
RuntimeMismatch
Runtime version mismatch.
Fields
Container image unavailable.
UnsupportedProfile
Unsupported execution profile.
NodeExecution
Node execution failed.
Fields
NodeTimeout
Node timeout.
Fields
NodePanic
Node panic.
Fields
NodeConfig
Invalid node configuration.
Fields
NodeNotFound
Node not found.
NoCompatibleVersion
No compatible version for migration.
Fields
InvalidTopology
Invalid flow topology.
UncontrolledCycle
Cycle detected without loop controller.
InvalidPort
Invalid port reference.
MissingEdge
Missing required edge.
Fields
InvalidEdge
Invalid edge (references non-existent node or port).
Fields
PipelineNotFound
Pipeline not found.
PipelineExists
Pipeline already exists.
ConcurrencyLimit
Pipeline concurrency limit reached.
Fields
CircuitBreakerOpen
Pipeline circuit breaker triggered.
Fields
DrainTimeout
Pipeline drain timeout.
Fields
WalWrite
WAL write failed.
Fields
WalRead
WAL read failed.
WalCorruption
WAL corruption detected.
Fields
WalReplay
WAL replay failed.
Fields
WasmLoad
WASM module loading failed.
Fields
WasmExecution
WASM execution failed.
Fields
WasmMemoryAlloc
WASM memory allocation failed.
WasmHostFunction
WASM host function error.
Fields
YamlParse
YAML parsing failed.
ConfigValue
Invalid configuration value.
Fields
SchemaValidation
Schema validation failed.
Serialization(String)
Serialization/deserialization error.
Io
File I/O error.
Fields
Network
Network error.
Implementations§
Source§impl XervError
impl XervError
Sourcepub fn is_retriable(&self) -> bool
pub fn is_retriable(&self) -> bool
Check if this error is retriable.
Sourcepub fn is_config_error(&self) -> bool
pub fn is_config_error(&self) -> bool
Check if this error is a configuration/validation error.
Sourcepub fn is_schema_error(&self) -> bool
pub fn is_schema_error(&self) -> bool
Check if this error is a schema evolution error.
Trait Implementations§
Source§impl Error for XervError
impl Error for XervError
1.30.0 · 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
Auto Trait Implementations§
impl Freeze for XervError
impl RefUnwindSafe for XervError
impl Send for XervError
impl Sync for XervError
impl Unpin for XervError
impl UnwindSafe for XervError
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<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> LayoutRaw for T
impl<T> LayoutRaw for T
Source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Source§impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
Source§unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
Source§fn resolve_niched(out: Place<NichedOption<T, N1>>)
fn resolve_niched(out: Place<NichedOption<T, N1>>)
out indicating that a T is niched.