pub struct PullRegistrationError {
pub queue: String,
pub status: Status,
}Expand description
Permanent rejection that leaves a pull queue without any registered stream.
Use SdkError::pull_registration_error on errors from crate::Worker::wait_pull_registered or
crate::Worker::start to inspect the queue and original gRPC status.
fn report(error: dex_sdk::SdkError) {
if let Some(rejection) = error.pull_registration_error() {
eprintln!("queue {}: {}", rejection.queue, rejection.status.code());
}
}Fields§
§queue: StringRejected Flow type or app Worker ID queue.
status: StatusOriginal permanent gRPC rejection, preserving its code and details.
Trait Implementations§
Source§impl Clone for PullRegistrationError
impl Clone for PullRegistrationError
Source§impl Debug for PullRegistrationError
impl Debug for PullRegistrationError
Source§impl Display for PullRegistrationError
impl Display for PullRegistrationError
Source§impl Error for PullRegistrationError
impl Error for PullRegistrationError
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()
Auto Trait Implementations§
impl !RefUnwindSafe for PullRegistrationError
impl !UnwindSafe for PullRegistrationError
impl Freeze for PullRegistrationError
impl Send for PullRegistrationError
impl Sync for PullRegistrationError
impl Unpin for PullRegistrationError
impl UnsafeUnpin for PullRegistrationError
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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::Request