pub enum CommitLogError {
Show 15 variants
Storage(StorageError),
Diesel(Error),
Api(ApiError),
Connection(ConnectionError),
Prost(DecodeError),
KeystoreError(SqlKeyStoreError),
GroupError(GroupError),
CryptoError(CryptoError),
TryFromSliceError(TryFromSliceError),
Conversion(ConversionError),
GroupReaddValidationError(String),
SyncError(SyncSummary),
FailedToSendReadd {
group_id: GroupId,
source: Box<CommitLogError>,
},
FailedReadds {
errors: Vec<CommitLogError>,
},
MissingLatestCommitSequenceId {
group_id: GroupId,
},
}Variants§
Storage(StorageError)
Diesel(Error)
Api(ApiError)
Connection(ConnectionError)
Prost(DecodeError)
KeystoreError(SqlKeyStoreError)
GroupError(GroupError)
CryptoError(CryptoError)
TryFromSliceError(TryFromSliceError)
Conversion(ConversionError)
GroupReaddValidationError(String)
SyncError(SyncSummary)
FailedToSendReadd
FailedReadds
Fields
§
errors: Vec<CommitLogError>MissingLatestCommitSequenceId
Trait Implementations§
Source§impl Debug for CommitLogError
impl Debug for CommitLogError
Source§impl Display for CommitLogError
impl Display for CommitLogError
Source§impl Error for CommitLogError
impl Error for CommitLogError
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<ApiError> for CommitLogError
impl From<ApiError> for CommitLogError
Source§impl From<ConnectionError> for CommitLogError
impl From<ConnectionError> for CommitLogError
Source§impl From<ConversionError> for CommitLogError
impl From<ConversionError> for CommitLogError
Source§fn from(source: ConversionError) -> Self
fn from(source: ConversionError) -> Self
Converts to this type from the input type.
Source§impl From<CryptoError> for CommitLogError
impl From<CryptoError> for CommitLogError
Source§impl From<DecodeError> for CommitLogError
impl From<DecodeError> for CommitLogError
Source§fn from(source: DecodeError) -> Self
fn from(source: DecodeError) -> Self
Converts to this type from the input type.
Source§impl From<Error> for CommitLogError
impl From<Error> for CommitLogError
Source§impl From<GroupError> for CommitLogError
impl From<GroupError> for CommitLogError
Source§fn from(source: GroupError) -> Self
fn from(source: GroupError) -> Self
Converts to this type from the input type.
Source§impl From<SqlKeyStoreError> for CommitLogError
impl From<SqlKeyStoreError> for CommitLogError
Source§impl From<StorageError> for CommitLogError
impl From<StorageError> for CommitLogError
Source§impl From<SyncSummary> for CommitLogError
impl From<SyncSummary> for CommitLogError
Source§fn from(source: SyncSummary) -> Self
fn from(source: SyncSummary) -> Self
Converts to this type from the input type.
Source§impl From<TryFromSliceError> for CommitLogError
impl From<TryFromSliceError> for CommitLogError
Source§fn from(source: TryFromSliceError) -> Self
fn from(source: TryFromSliceError) -> Self
Converts to this type from the input type.
Source§impl NeedsDbReconnect for CommitLogError
impl NeedsDbReconnect for CommitLogError
Source§fn restart_delay(&self) -> Option<Duration>
fn restart_delay(&self) -> Option<Duration>
The least time to wait before restarting a worker that failed with
this error: a rate-limit rejection’s delay (RATE-041).
fn needs_db_reconnect(&self) -> bool
Source§impl RetryableError for CommitLogError
impl RetryableError for CommitLogError
fn is_retryable(&self) -> bool
Source§fn rate_limit_delay(&self) -> Option<Duration>
fn rate_limit_delay(&self) -> Option<Duration>
The least time to wait before a retry, when the error says so. A
rate-limit rejection carries one; [
retry_async!] never retries sooner.Auto Trait Implementations§
impl Freeze for CommitLogError
impl !RefUnwindSafe for CommitLogError
impl Send for CommitLogError
impl Sync for CommitLogError
impl Unpin for CommitLogError
impl UnsafeUnpin for CommitLogError
impl !UnwindSafe for CommitLogError
Blanket Implementations§
§impl<T> AggregateExpressionMethods for T
impl<T> AggregateExpressionMethods for T
§fn aggregate_distinct(self) -> Self::Outputwhere
Self: DistinctDsl,
fn aggregate_distinct(self) -> Self::Outputwhere
Self: DistinctDsl,
DISTINCT modifier for aggregate functions Read more§fn aggregate_all(self) -> Self::Outputwhere
Self: AllDsl,
fn aggregate_all(self) -> Self::Outputwhere
Self: AllDsl,
ALL modifier for aggregate functions Read more§fn aggregate_filter<P>(self, f: P) -> Self::Outputwhere
P: AsExpression<Bool>,
Self: FilterDsl<<P as AsExpression<Bool>>::Expression>,
fn aggregate_filter<P>(self, f: P) -> Self::Outputwhere
P: AsExpression<Bool>,
Self: FilterDsl<<P as AsExpression<Bool>>::Expression>,
Add an aggregate function filter Read more
§fn aggregate_order<O>(self, o: O) -> Self::Outputwhere
Self: OrderAggregateDsl<O>,
fn aggregate_order<O>(self, o: O) -> Self::Outputwhere
Self: OrderAggregateDsl<O>,
Add an aggregate function order Read more
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
§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Converts
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>, which can then be
downcast into Box<dyn ConcreteType> where ConcreteType implements Trait.§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Converts
Rc<Trait> (where Trait: Downcast) to Rc<Any>, which can then be further
downcast into Rc<ConcreteType> where ConcreteType implements Trait.§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Converts
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
Converts
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.§impl<T> DowncastSend for T
impl<T> DowncastSend for T
§impl<T> DowncastSync for T
impl<T> DowncastSync for T
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Identity for Twhere
T: ?Sized,
impl<T> Identity for Twhere
T: ?Sized,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<T> IntoSql for T
impl<T> IntoSql for T
§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].Source§impl<TraitVariantBlanketType> LocalNeedsDbReconnect for TraitVariantBlanketTypewhere
TraitVariantBlanketType: NeedsDbReconnect,
impl<TraitVariantBlanketType> LocalNeedsDbReconnect for TraitVariantBlanketTypewhere
TraitVariantBlanketType: NeedsDbReconnect,
fn needs_db_reconnect(&self) -> bool
Source§fn restart_delay(&self) -> Option<Duration>
fn restart_delay(&self) -> Option<Duration>
The least time to wait before restarting a worker that failed with
this error: a rate-limit rejection’s delay (RATE-041).
§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<S, T> Upcast<T> for S
impl<S, T> Upcast<T> for S
§impl<T> WindowExpressionMethods for T
impl<T> WindowExpressionMethods for T
§fn over(self) -> Self::Outputwhere
Self: OverDsl,
fn over(self) -> Self::Outputwhere
Self: OverDsl,
Turn a function call into a window function call Read more
§fn window_filter<P>(self, f: P) -> Self::Outputwhere
P: AsExpression<Bool>,
Self: FilterDsl<<P as AsExpression<Bool>>::Expression>,
fn window_filter<P>(self, f: P) -> Self::Outputwhere
P: AsExpression<Bool>,
Self: FilterDsl<<P as AsExpression<Bool>>::Expression>,
Add a filter to the current window function Read more
§fn partition_by<E>(self, expr: E) -> Self::Outputwhere
Self: PartitionByDsl<E>,
fn partition_by<E>(self, expr: E) -> Self::Outputwhere
Self: PartitionByDsl<E>,
Add a partition clause to the current window function Read more
§fn window_order<E>(self, expr: E) -> Self::Outputwhere
Self: OrderWindowDsl<E>,
fn window_order<E>(self, expr: E) -> Self::Outputwhere
Self: OrderWindowDsl<E>,
Add a order clause to the current window function Read more