Skip to main content

CatalogError

Enum CatalogError 

Source
#[non_exhaustive]
pub enum CatalogError {
Show 40 variants InvalidJobType { job_type: String, source: IdentifierValidationError, }, InvalidHandlerJobType { handler_job_type: String, source: IdentifierValidationError, }, HandlerJobTypeMismatch { declared: String, handler: String, }, DuplicateJobType { job_type: String, }, InvalidDefinitionValue { field: &'static str, }, InvalidJobDefinitionValue { job_type: String, field: &'static str, }, InvalidFailureCode, InvalidRetryDelay, InvalidExactSyncScope, InvalidExactSyncScopeJobType { job_type: String, source: IdentifierValidationError, }, EmptyExactSyncCatalog, JobTypeOutsideExactSyncScope { job_type: String, }, ActiveScheduleForAbsentJobType { schedule_name: String, job_type: String, }, ActiveScheduleForDisabledJobType { schedule_name: String, job_type: String, }, UnknownJobType { job_type: String, }, DisabledJobType { job_type: String, }, WorkflowBuild(WorkflowBuildError), SyncFailure(Box<Error>), DefinitionCatalogSyncFailure(Box<dyn Error + Send + Sync>), DefinitionSyncFailure { job_type: String, source: Box<Error>, }, CommitFailure(Error), CriticalSectionTimeoutFailure(Box<Error>), DefinitionSyncValidationFailure(Box<Error>), ScheduleLockFailure(Box<Error>), DefinitionLockFailure(Box<Error>), ScheduleCheckFailure(Box<Error>), DefinitionInspectFailure(Box<Error>), DisableAbsentFailure(Box<Error>), InvalidExactScheduleSyncScope, InvalidExactScheduleSyncScopeName { name: String, }, DuplicateExactScheduleSyncScopeName { name: String, }, ScheduleNameOutsideExactSyncScope { name: String, }, DuplicateScheduleName { name: String, }, InvalidScheduleSpec { name: String, field: &'static str, }, DuplicateScheduleNameInSyncBatch { name: String, }, ScheduleSyncFailure(Box<Error>), ScheduleSyncCriticalSectionFailure(Box<Error>), ScheduleSyncEntryFailure { name: String, source: Box<Error>, }, DeactivateAbsentSchedulesFailure(Box<Error>), ScheduleSyncCommitFailure(Box<Error>),
}
Expand description

Error returned by super::JobCatalog validation, sync, and helper methods.

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.
§

InvalidJobType

A caller supplied an invalid catalog job type.

Fields

§job_type: String

Invalid job type value supplied by the caller.

§source: IdentifierValidationError

Identifier validation failure reported by runledger-core.

§

InvalidHandlerJobType

A registered handler returned an invalid job type.

Fields

§handler_job_type: String

Invalid job type returned by the handler.

§source: IdentifierValidationError

Identifier validation failure reported by runledger-core.

§

HandlerJobTypeMismatch

The declared catalog job type did not match the handler’s job type.

Fields

§declared: String

Job type declared at the catalog registration site.

§handler: String

Job type returned by the handler.

§

DuplicateJobType

The catalog already contains the requested job type.

Fields

§job_type: String

Duplicate job type.

§

InvalidDefinitionValue

A catalog definition default failed validation.

Fields

§field: &'static str

Name of the invalid defaults field.

§

InvalidJobDefinitionValue

A job-specific catalog definition override failed validation.

Fields

§job_type: String

Job type whose effective definition values are invalid.

§field: &'static str

Name of the invalid definition field.

§

InvalidFailureCode

Retry-delay override failure codes must be non-empty.

§

InvalidRetryDelay

Retry-delay override values must be positive.

§

InvalidExactSyncScope

Exact sync requires a non-empty owned job-type scope.

§

InvalidExactSyncScopeJobType

Exact sync scope construction received an invalid job type.

Fields

§job_type: String

Invalid job type supplied for the exact-sync scope.

§source: IdentifierValidationError

Identifier validation failure reported by runledger-core.

§

EmptyExactSyncCatalog

Exact sync cannot run against an empty catalog.

§

JobTypeOutsideExactSyncScope

A catalog job was not included in the exact-sync scope.

Fields

§job_type: String

Catalog job type missing from the exact-sync scope.

§

ActiveScheduleForAbsentJobType

An active schedule still references an enabled definition absent from the catalog.

Fields

§schedule_name: String

Active schedule name that blocks disabling the absent definition.

§job_type: String

Absent catalog job type referenced by the active schedule.

§

ActiveScheduleForDisabledJobType

An active schedule still references a catalog job that would be disabled.

Fields

§schedule_name: String

Active schedule name that blocks disabling the catalog definition.

§job_type: String

Catalog job type referenced by the active schedule.

§

UnknownJobType

The requested job type is not registered in the catalog.

Fields

§job_type: String

Missing job type.

§

DisabledJobType

The requested job type is disabled by effective catalog definition values.

Fields

§job_type: String

Disabled job type.

§

WorkflowBuild(WorkflowBuildError)

Workflow enqueue construction failed.

§

SyncFailure(Box<Error>)

Starting a catalog sync transaction failed.

§

DefinitionCatalogSyncFailure(Box<dyn Error + Send + Sync>)

A persistence-layer catalog sync failure had no runtime-specific mapping.

§

DefinitionSyncFailure

Syncing a specific catalog job definition failed.

Fields

§job_type: String

Catalog job type whose definition failed to sync.

§source: Box<Error>

Persistence-layer failure that occurred while syncing the definition.

§

CommitFailure(Error)

Committing a catalog sync transaction failed.

§

CriticalSectionTimeoutFailure(Box<Error>)

Applying the transaction-local bounds for definition-disabling sync failed.

§

DefinitionSyncValidationFailure(Box<Error>)

Catalog definition sync input failed persistence-layer validation.

§

ScheduleLockFailure(Box<Error>)

Locking schedules before disabling definitions failed.

§

DefinitionLockFailure(Box<Error>)

Locking definitions before checking and disabling definitions failed.

§

ScheduleCheckFailure(Box<Error>)

Checking active schedules before disabling definitions failed.

§

DefinitionInspectFailure(Box<Error>)

Inspecting existing job definitions before sync failed.

§

DisableAbsentFailure(Box<Error>)

Disabling absent job definitions failed.

§

InvalidExactScheduleSyncScope

Exact schedule sync requires a non-empty owned schedule-name scope.

§

InvalidExactScheduleSyncScopeName

Exact schedule sync scope construction received an invalid schedule name.

Fields

§name: String

Invalid schedule name supplied for the exact-sync scope.

§

DuplicateExactScheduleSyncScopeName

Exact schedule sync scope construction received a duplicate schedule name.

Fields

§name: String

Duplicate schedule name supplied for the exact-sync scope.

§

ScheduleNameOutsideExactSyncScope

A catalog schedule was not included in the exact-sync scope.

Fields

§name: String

Catalog schedule name missing from the exact-sync scope.

§

DuplicateScheduleName

The catalog already contains the requested schedule name.

Fields

§name: String

Duplicate schedule name.

§

InvalidScheduleSpec

A catalog schedule spec failed validation.

Fields

§name: String

Schedule name from the invalid spec.

§field: &'static str

Name of the invalid schedule field.

§

DuplicateScheduleNameInSyncBatch

Duplicate schedule names were supplied in one sync batch.

Fields

§name: String

Duplicate schedule name in the sync batch.

§

ScheduleSyncFailure(Box<Error>)

Starting a catalog schedule sync transaction failed.

§

ScheduleSyncCriticalSectionFailure(Box<Error>)

Applying the transaction-local bounds for exact schedule sync failed.

§

ScheduleSyncEntryFailure

Syncing a specific catalog schedule failed.

Fields

§name: String

Schedule name whose sync failed.

§source: Box<Error>

Persistence-layer failure that occurred while syncing the schedule.

§

DeactivateAbsentSchedulesFailure(Box<Error>)

Deactivating absent catalog schedules failed.

§

ScheduleSyncCommitFailure(Box<Error>)

Committing a catalog schedule sync transaction failed.

Trait Implementations§

Source§

impl Debug for CatalogError

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Display for CatalogError

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Error for CatalogError

Source§

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

👎Deprecated since 1.42.0:

use the Display impl or to_string()

1.0.0 · Source§

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

Source§

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. Read more
Source§

impl From<WorkflowBuildError> for CatalogError

Source§

fn from(source: WorkflowBuildError) -> Self

Converts to this type from the input type.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

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 more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

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
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToString for T
where T: Display + ?Sized,

Source§

fn to_string(&self) -> String

Converts the given value to a String. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more