pub enum PubSubError {
Transport(Status),
Avro(String),
SchemaNotFound {
schema_id: String,
},
Auth(ForceError),
ReconnectFailed {
attempts: u32,
last_error: Box<Self>,
},
Connect(Error),
Config(String),
}Expand description
All errors from the force-pubsub crate.
Variants§
Transport(Status)
gRPC transport or protocol error.
Avro(String)
Avro encoding or decoding failure.
SchemaNotFound
Schema not found for the given ID.
Auth(ForceError)
Authentication or token error from the force crate.
ReconnectFailed
Reconnection to the subscribe stream was exhausted.
Fields
Connect(Error)
gRPC channel setup failed.
Config(String)
Invalid configuration.
Trait Implementations§
Source§impl Debug for PubSubError
impl Debug for PubSubError
Source§impl Display for PubSubError
impl Display for PubSubError
Source§impl Error for PubSubError
impl Error for PubSubError
Source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
Returns the lower-level source of this error, if any. Read more
1.0.0 · Source§fn description(&self) -> &str
fn description(&self) -> &str
👎Deprecated since 1.42.0:
use the Display impl or to_string()
Source§impl From<Error> for PubSubError
impl From<Error> for PubSubError
Source§impl From<ForceError> for PubSubError
impl From<ForceError> for PubSubError
Source§fn from(source: ForceError) -> Self
fn from(source: ForceError) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
impl !Freeze for PubSubError
impl !RefUnwindSafe for PubSubError
impl Send for PubSubError
impl Sync for PubSubError
impl Unpin for PubSubError
impl UnsafeUnpin for PubSubError
impl !UnwindSafe for PubSubError
Blanket Implementations§
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
Mutably borrows from an owned value. Read more
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::RequestSource§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> ToStringFallible for Twhere
T: Display,
impl<T> ToStringFallible for Twhere
T: Display,
Source§fn try_to_string(&self) -> Result<String, TryReserveError>
fn try_to_string(&self) -> Result<String, TryReserveError>
ToString::to_string, but without panic on OOM.