flow-graph-interpreter 0.22.0

An intepreter for flow-based programs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use flow_component::ComponentError;
use tokio::task::JoinError;
use uuid::Uuid;

use crate::interpreter::error::StateError;

#[derive(thiserror::Error, Debug)]
pub enum ExecutionError {
  #[error("Error in internal channel: {0}")]
  ChannelError(crate::interpreter::channel::error::Error),

  #[error(transparent)]
  InvalidState(#[from] StateError),

  #[error("Payload does not contain message for port '{0}'")]
  MissingInput(String),

  #[error("Channel send failure")]
  ChannelSend,

  #[error("Execution id:{0} hung and error_on_hung set")]
  HungTransaction(Uuid),

  #[error("{0}")]
  ComponentError(ComponentError),

  #[error("{0}")]
  OperationFailure(JoinError),
}

impl From<wasmrs_rx::Error> for ExecutionError {
  fn from(_e: wasmrs_rx::Error) -> Self {
    Self::ChannelSend
  }
}