Enum PubSubError 

pub enum PubSubError {
    PublishError {
        message: String,
        source: Option<Box<dyn Error + Send + Sync>>,
    },
    SubscriptionError {
        message: String,
        source: Option<Box<dyn Error + Send + Sync>>,
    },
    AcknowledgmentError {
        message: String,
        source: Option<Box<dyn Error + Send + Sync>>,
    },
    BatchingError {
        message: String,
        batch_size: usize,
    },
    FlowControlError {
        message: String,
        current_count: usize,
        max_count: usize,
    },
    DeadLetterQueueError {
        message: String,
        message_id: String,
    },
    OrderingKeyError {
        message: String,
        ordering_key: String,
    },
    AuthenticationError {
        message: String,
        source: Option<Box<dyn Error + Send + Sync>>,
    },
    ConfigurationError {
        message: String,
        parameter: String,
    },
    TopicNotFound {
        topic_name: String,
    },
    SubscriptionNotFound {
        subscription_name: String,
    },
    MessageTooLarge {
        size: usize,
        max_size: usize,
    },
    InvalidMessageFormat {
        message: String,
    },
    Timeout {
        duration_ms: u64,
    },
    NetworkError {
        message: String,
        source: Option<Box<dyn Error + Send + Sync>>,
    },
    ResourceExhausted {
        resource: String,
        retry_after: Option<u64>,
    },
    PermissionDenied {
        operation: String,
    },
    InternalError {
        message: String,
    },
    Io(Error),
    Json(Error),
    ClientError(String),
}

Errors that can occur during Pub/Sub operations.

Variants

PublishError

Error during message publishing.

Fields

message: String

Error message

source: Option<Box<dyn Error + Send + Sync>>

Optional source error

SubscriptionError

Error during message subscription.

Fields

message: String

Error message

source: Option<Box<dyn Error + Send + Sync>>

Optional source error

AcknowledgmentError

Error during message acknowledgment.

Fields

message: String

Error message

source: Option<Box<dyn Error + Send + Sync>>

Optional source error

BatchingError

Batching error.

Fields

message: String

Error message

batch_size: usize

Number of messages in failed batch

FlowControlError

Flow control error.

Fields

message: String

Error message

current_count: usize

Current message count

max_count: usize

Maximum allowed count

DeadLetterQueueError

Dead letter queue error.

Fields

message: String

Error message

message_id: String

Message ID that failed

OrderingKeyError

Ordering key error.

Fields

message: String

Error message

ordering_key: String

Ordering key that caused the error

AuthenticationError

Authentication error.

Fields

message: String

Error message

source: Option<Box<dyn Error + Send + Sync>>

Optional source error

ConfigurationError

Configuration error.

Fields

message: String

Error message

parameter: String

Parameter name

TopicNotFound

Topic not found error.

Fields

topic_name: String

Topic name

SubscriptionNotFound

Subscription not found error.

Fields

subscription_name: String

Subscription name

MessageTooLarge

Message too large error.

Fields

size: usize

Actual message size

max_size: usize

Maximum allowed size

InvalidMessageFormat

Invalid message format.

Fields

message: String

Error message

Timeout

Timeout error.

Fields

duration_ms: u64

Timeout duration in milliseconds

NetworkError

Network error.

Fields

message: String

Error message

source: Option<Box<dyn Error + Send + Sync>>

Optional source error

ResourceExhausted

Resource exhausted error.

Fields

resource: String

Resource name

retry_after: Option<u64>

Optional retry after duration in seconds

PermissionDenied

Permission denied error.

Fields

operation: String

Operation that was denied

InternalError

Internal error.

Fields

message: String

Error message

Io(Error)

I/O error.

Json(Error)

JSON serialization/deserialization error.

ClientError(String)

Google Cloud Pub/Sub client error.

Implementations

impl PubSubError

pub fn publish<S: Into<String>>(message: S) -> Self

Creates a publish error from a message.

pub fn publish_with_source<S: Into<String>>( message: S, source: Box<dyn Error + Send + Sync>, ) -> Self

Creates a publish error with a source error.

pub fn subscription<S: Into<String>>(message: S) -> Self

Creates a subscription error from a message.

pub fn subscription_with_source<S: Into<String>>( message: S, source: Box<dyn Error + Send + Sync>, ) -> Self

Creates a subscription error with a source error.

pub fn acknowledgment<S: Into<String>>(message: S) -> Self

Creates an acknowledgment error from a message.

pub fn configuration<S: Into<String>, P: Into<String>>( message: S, parameter: P, ) -> Self

Creates a configuration error.

pub fn batching<S: Into<String>>(message: S, batch_size: usize) -> Self

Creates a batching error.

pub fn flow_control<S: Into<String>>( message: S, current_count: usize, max_count: usize, ) -> Self

Creates a flow control error.

pub fn dead_letter<S: Into<String>, M: Into<String>>( message: S, message_id: M, ) -> Self

Creates a dead letter queue error.

pub fn ordering_key<S: Into<String>, K: Into<String>>( message: S, ordering_key: K, ) -> Self

Creates an ordering key error.

pub fn topic_not_found<S: Into<String>>(topic_name: S) -> Self

Creates a topic not found error.

pub fn subscription_not_found<S: Into<String>>(subscription_name: S) -> Self

Creates a subscription not found error.

pub fn message_too_large(size: usize, max_size: usize) -> Self

Creates a message too large error.

pub fn timeout(duration_ms: u64) -> Self

Creates a timeout error.

pub fn resource_exhausted<S: Into<String>>( resource: S, retry_after: Option<u64>, ) -> Self

Creates a resource exhausted error.

pub fn permission_denied<S: Into<String>>(operation: S) -> Self

Creates a permission denied error.

pub fn is_retryable(&self) -> bool

Checks if the error is retryable.

pub fn retry_after(&self) -> Option<u64>

Gets the retry after duration if available.

Trait Implementations

impl Debug for PubSubError

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

Formats the value using the given formatter.

impl Display for PubSubError

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

Formats the value using the given formatter.

impl Error for PubSubError

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<Error> for PubSubError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for PubSubError

fn from(source: Error) -> Self

Converts to this type from the input type.