Enum WorkerError 

pub enum WorkerError {
    Connect {
        source: Error,
    },
    Handshake {
        source: Status,
    },
    Registration {
        source: Box<dyn Error + Send + Sync + 'static>,
    },
    Decode {
        source: Box<dyn Error + Send + Sync + 'static>,
    },
    Encode {
        source: Box<dyn Error + Send + Sync + 'static>,
    },
    Transport {
        source: Status,
    },
    CleanCloseExhausted,
}

Errors produced by worker configuration, protocol, transport, and payload boundaries.

Variants

Connect

The worker could not connect to the configured endpoint.

Fields

source: Error

Transport connection failure reported by tonic.

Handshake

The worker could not perform the initial protocol handshake.

Fields

source: Status

Handshake failure reported by the underlying transport.

Registration

The worker could not register activity types.

Fields

source: Box<dyn Error + Send + Sync + 'static>

Registration failure source.

Decode

A payload or wire value could not be decoded.

Fields

source: Box<dyn Error + Send + Sync + 'static>

Decode failure source.

Encode

A payload or wire value could not be encoded.

Fields

source: Box<dyn Error + Send + Sync + 'static>

Encode failure source.

Transport

An established worker transport failed.

Fields

source: Status

Transport failure reported by tonic.

CleanCloseExhausted

The server kept closing the worker stream cleanly until the cumulative session-drop budget ran out without any session proving healthy.

A single clean close is a retryable drop (the worker redials through the budgeted backoff cycle); this error surfaces only when a persistent clean-close loop exhausts reconnect.max_attempts.

Implementations

impl WorkerError

pub fn registration(source: impl Error + Send + Sync + 'static) -> Self

Creates a registration error from any source error.

pub fn grpc_status(&self) -> Option<&Status>

Returns the underlying gRPC status carried by this error, if any.

Handshake and transport failures carry a tonic::Status directly; registration failures preserve the status as their boxed source when the server rejected the registration over the wire.

pub fn is_retryable(&self) -> bool

Returns whether retrying connection or registration can ever succeed.

PermissionDenied and Unauthenticated are deterministic server denials (ungranted namespace, rejected credentials): retrying them only burns the reconnect budget and delays the surfaced error. Every other failure (transport unavailability, decode faults, local validation) is treated as transient for the bounded backoff loop.

pub fn decode(source: impl Error + Send + Sync + 'static) -> Self

Creates a decode error from any source error.

pub fn encode(source: impl Error + Send + Sync + 'static) -> Self

Creates an encode error from any source error.

Trait Implementations

impl Debug for WorkerError

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

Formats the value using the given formatter.

impl Display for WorkerError

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

Formats the value using the given formatter.

impl Error for WorkerError

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.