Enum ConnectorError 

pub enum ConnectorError {
    ConnectionFailed(String),
    ConfigurationError(String),
    ReadError(String),
    WriteError(String),
    Serde(SerdeError),
    TransactionError(String),
    InvalidState {
        expected: String,
        actual: String,
    },
    SchemaMismatch(String),
    Timeout(u64),
    Closed,
    Internal(String),
    Io(Error),
}

Errors that can occur during connector operations.

Callers that need to distinguish “retry may work” from “propagate” should use ConnectorError::is_transient rather than matching variants directly — the variant set has changed in the past.

Variants

ConnectionFailed(String)

Failed to connect to the external system (network error, DNS failure, TLS negotiation failure, auth rejection).

ConfigurationError(String)

Invalid, missing, or contradictory connector configuration.

ReadError(String)

Error reading data from a source.

WriteError(String)

Error writing data to a sink.

Serde(SerdeError)

Serialization or deserialization error.

TransactionError(String)

Transaction error (begin/commit/rollback).

Kept separate from Self::WriteError because transactional failures are classified as non-transient by default; a write error is transient. Per-connector retry policy can override, but the default must not loop forever on bad transactional state.

InvalidState

The connector is not in the expected state.

Fields

expected: String

The expected state.

actual: String

The actual state.

SchemaMismatch(String)

Schema mismatch between expected and actual data.

Timeout(u64)

Operation timed out.

Closed

The connector has been closed.

Internal(String)

An internal error that doesn’t fit other categories.

Io(Error)

An I/O error from the underlying system.

Implementations

impl ConnectorError

pub fn missing_config(key: impl Into<String>) -> Self

Construct a “missing required config” error. Thin helper around Self::ConfigurationError so every “missing required config: {key}” message is shaped the same way.

pub fn is_transient(&self) -> bool

Returns true if this error is likely transient and the operation may succeed on retry (e.g., network timeout, throttled request). Returns false for configuration, schema, and state errors that will not resolve without user intervention.

Trait Implementations

impl Debug for ConnectorError

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

Formats the value using the given formatter.

impl Display for ConnectorError

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

Formats the value using the given formatter.

impl Error for ConnectorError

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.

impl From<ConnectorError> for SchemaError

fn from(err: ConnectorError) -> Self

Converts to this type from the input type.

impl From<Error> for ConnectorError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<LookupError> for ConnectorError

fn from(err: LookupError) -> Self

Converts to this type from the input type.

impl From<ResumeTokenStoreError> for ConnectorError

fn from(e: ResumeTokenStoreError) -> Self

Converts to this type from the input type.

impl From<SchemaError> for ConnectorError

fn from(err: SchemaError) -> Self

Converts to this type from the input type.

impl From<SerdeError> for ConnectorError

fn from(source: SerdeError) -> Self

Converts to this type from the input type.