Enum fluvio::ProducerError
source · #[non_exhaustive]pub enum ProducerError {
RecordTooLarge(usize),
SendRecordMetadata(SendError<RecordMetadata>),
GetRecordMetadata(Option<RecvError>),
PartitionNotFound(PartitionId),
Internal(String),
SpuErrorCode(ErrorCode),
InvalidConfiguration(String),
ProduceRequestRetryTimeout(TimeoutError),
BatchQueueWaitTimeout,
}
Variants (Non-exhaustive)§
This enum is marked as non-exhaustive
Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.
RecordTooLarge(usize)
SendRecordMetadata(SendError<RecordMetadata>)
GetRecordMetadata(Option<RecvError>)
PartitionNotFound(PartitionId)
Internal(String)
SpuErrorCode(ErrorCode)
InvalidConfiguration(String)
ProduceRequestRetryTimeout(TimeoutError)
BatchQueueWaitTimeout
Trait Implementations§
source§impl Clone for ProducerError
impl Clone for ProducerError
source§fn clone(&self) -> ProducerError
fn clone(&self) -> ProducerError
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for ProducerError
impl Debug for ProducerError
source§impl Display for ProducerError
impl Display for ProducerError
source§impl Error for ProducerError
impl Error for ProducerError
source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
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<ErrorCode> for ProducerError
impl From<ErrorCode> for ProducerError
source§impl From<ProducerError> for FluvioError
impl From<ProducerError> for FluvioError
source§fn from(source: ProducerError) -> Self
fn from(source: ProducerError) -> Self
Converts to this type from the input type.
source§impl From<RecvError> for ProducerError
impl From<RecvError> for ProducerError
source§impl From<SendError<RecordMetadata>> for ProducerError
impl From<SendError<RecordMetadata>> for ProducerError
source§fn from(source: SendError<RecordMetadata>) -> Self
fn from(source: SendError<RecordMetadata>) -> Self
Converts to this type from the input type.
source§impl From<TimeoutError> for ProducerError
impl From<TimeoutError> for ProducerError
source§fn from(source: TimeoutError) -> Self
fn from(source: TimeoutError) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
impl !Freeze for ProducerError
impl RefUnwindSafe for ProducerError
impl Send for ProducerError
impl Sync for ProducerError
impl Unpin for ProducerError
impl UnwindSafe for ProducerError
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