Enum PipelineError

pub enum PipelineError {
    Generic(String),
    EdgeAlreadySet,
    NoEdge,
    NoNetworkEdge,
    DetatchedStreamReceiver,
    DetatchedStreamSender,
    SerializationError(String),
    DeserializationError(String),
    ControlPlaneRequestError(String),
    ConnectionFailed(String),
    GenerateError(Error),
    InvalidEndpointFormat,
    NatsRequestError(Error<RequestErrorKind>),
    NatsGetStreamError(Error<GetStreamErrorKind>),
    NatsCreateStreamError(Error<CreateStreamErrorKind>),
    NatsConsumerError(Error<ConsumerErrorKind>),
    NatsBatchError(Error<BatchErrorKind>),
    NatsPublishError(Error<PublishErrorKind>),
    NatsConnectError(Error<ConnectErrorKind>),
    NatsSubscriberError(SubscribeError),
    LocalIpAddressError(Error),
    PrometheusError(Error),
    NatsError(Box<dyn Error + Send + Sync>),
    TwoPartCodec(TwoPartCodecError),
    SerdeJsonError(Error),
    KeyValueError(String, String),
}

Variants

Generic(String)

For starter, to remove as code matures.

EdgeAlreadySet

Edges can only be set once. This error is thrown on subsequent attempts to set an edge.s

NoEdge

The source node is not connected to an edge.

NoNetworkEdge

DetatchedStreamReceiver

In the interim between when a request was made and when the stream was received, the requesting task was dropped. This maybe a logic error in the pipeline; and become a panic/fatal error in the future. This error is thrown when the on_data method of a terminating sink either cannot find the oneshot channel sender or the corresponding receiver was dropped

DetatchedStreamSender

SerializationError(String)

DeserializationError(String)

ControlPlaneRequestError(String)

ConnectionFailed(String)

GenerateError(Error)

InvalidEndpointFormat

NatsRequestError(Error<RequestErrorKind>)

NatsGetStreamError(Error<GetStreamErrorKind>)

NatsCreateStreamError(Error<CreateStreamErrorKind>)

NatsConsumerError(Error<ConsumerErrorKind>)

NatsBatchError(Error<BatchErrorKind>)

NatsPublishError(Error<PublishErrorKind>)

NatsConnectError(Error<ConnectErrorKind>)

NatsSubscriberError(SubscribeError)

LocalIpAddressError(Error)

PrometheusError(Error)

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

TwoPartCodec(TwoPartCodecError)

SerdeJsonError(Error)

KeyValueError(String, String)

Trait Implementations

impl Debug for PipelineError

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

Formats the value using the given formatter.

impl Display for PipelineError

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

Formats the value using the given formatter.

impl Error for PipelineError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0: use the Display impl or to_string()

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

👎Deprecated since 1.33.0: replaced by Error::source, which can support downcasting

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.

impl From<Box<dyn Error + Sync + Send>> for PipelineError

fn from(source: Box<dyn Error + Send + Sync>) -> Self

Converts to this type from the input type.

impl From<Error<BatchErrorKind>> for PipelineError

fn from(source: NatsError<BatchErrorKind>) -> Self

Converts to this type from the input type.

impl From<Error<ConnectErrorKind>> for PipelineError

fn from(source: NatsError<ConnectErrorKind>) -> Self

Converts to this type from the input type.

impl From<Error<ConsumerErrorKind>> for PipelineError

fn from(source: NatsError<ConsumerErrorKind>) -> Self

Converts to this type from the input type.

impl From<Error<CreateStreamErrorKind>> for PipelineError

fn from(source: NatsError<CreateStreamErrorKind>) -> Self

Converts to this type from the input type.

impl From<Error<GetStreamErrorKind>> for PipelineError

fn from(source: NatsError<GetStreamErrorKind>) -> Self

Converts to this type from the input type.

impl From<Error<PublishErrorKind>> for PipelineError

fn from(source: NatsError<PublishErrorKind>) -> Self

Converts to this type from the input type.

impl From<Error<RequestErrorKind>> for PipelineError

fn from(source: NatsError<RequestErrorKind>) -> Self

Converts to this type from the input type.

impl From<Error> for PipelineError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for PipelineError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for PipelineError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<SubscribeError> for PipelineError

fn from(source: SubscribeError) -> Self

Converts to this type from the input type.

impl From<TwoPartCodecError> for PipelineError

fn from(source: TwoPartCodecError) -> Self

Converts to this type from the input type.