Enum kafka_json_processor_core::error::ErrorKind

pub enum ErrorKind {
    InvalidObjectTree {
        invalid_key: Vec<ObjectKey>,
        reason: String,
    },
    EmptyKey,
    OtherError {
        err: Box<dyn Error>,
    },
    FieldNotFound {
        key: Vec<ObjectKey>,
    },
    ProcessorSkipped {
        reason: String,
    },
}

Variants

InvalidObjectTree

Fields

invalid_key: Vec<ObjectKey>

reason: String

Key is invalid for given object. This may mean that something is wrong with messages in the topic (or with the processor config).

EmptyKey

Object key is empty - this should not be allowed. This means that an empty key was supplied - and there is no way to extract the field from JSON object.

OtherError

Fields

err: Box<dyn Error>

Default wrapper for any error.

FieldNotFound

Fields

key: Vec<ObjectKey>

Low priority error - Field not found and thus, cannot use this message processor. Example: requested to copy $.foo into $.bar, but no $.foo field was present.

ProcessorSkipped

Fields

reason: String

Lowe priority error - processor was skipped for any arbitrary reason. Example: some processor condition was not met.

Trait Implementations

impl Debug for ErrorKind

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

Formats the value using the given formatter.

impl Display for ErrorKind

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

Formats the value using the given formatter.

impl From<ErrorKind> for ProcessingError

fn from(e: ErrorKind) -> Self

Converts to this type from the input type.

impl<T: Error + 'static> From<T> for ErrorKind

fn from(err: T) -> Self

Converts to this type from the input type.