Enum KvError 

pub enum KvError {
    NotConnected,
    ConnectionFailed(String),
    KeyNotFound,
    AlreadyExists,
    RevisionMismatch,
    DeserializationError(String),
    SerializationError(String),
    WatchError(String),
    OperationFailed(String),
    Timeout,
    CursorExpired,
}

Error type for KV operations.

KvError is Clone so a single failure can fan out to multiple waiters (e.g. callers blocked on a shared connect result). The underlying backend errors — std::io::Error, the async-nats error types — are not Clone, so their detail is flattened into the message string at this boundary rather than retained as a #[source] cause. Keeping KvError: Clone across the object-safe async_trait surface is the deliberate trade-off; the cost is a structured cause chain, which is why the String variants carry pre-rendered context instead of a nested error.

Variants

NotConnected

ConnectionFailed(String)

KeyNotFound

AlreadyExists

Key already exists (create-if-not-exists conflict).

RevisionMismatch

CAS conflict: current version doesn’t match expected.

DeserializationError(String)

SerializationError(String)

WatchError(String)

OperationFailed(String)

Timeout

CursorExpired

The watch cursor/revision is too old — the backend has compacted past it. Callers should fall back to a full scan + watch.

Trait Implementations

impl Clone for KvError

fn clone(&self) -> KvError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KvError

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

Formats the value using the given formatter.

impl Display for KvError

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

Formats the value using the given formatter.

impl Error for KvError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.