flowrlib 0.80.0

Flow Runner Library (flowrlib) for 'flow' 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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

#![deny(missing_docs)]
#![deny(clippy::unwrap_used)]
#![deny(clippy::indexing_slicing)]
//! Runtime library for flow execution. This will be linked with other code to produce a
//! or runner, such as `flowr` command line runner.
//!
//! It is responsible for reading a flow definition in a `Manifest` file, loading the required
//! libraries from `LibraryManifest` files and then coordinating the execution by dispatching `Jobs`
//! to be executed by `Function` `Implementations`, providing them the `Inputs` required to run and
//! gathering the `Outputs` produced and passing those `Outputs` to other connected `Functions` in
//! the network of `Functions`.

/// `coordinator` is the module that coordinates the execution of flows submitted to it
pub mod coordinator;

/// `info` offers methods to get information about this library
pub mod info;

/// Structure that defines/tracks the current runtime state
pub mod run_state;

/// Trait for a set of methods a server using the library must supply
pub mod protocols;

#[cfg(feature = "debugger")]
mod debugger;
#[cfg(feature = "debugger")]
/// `debug_command` provides the `DebugCommand` enum for commands from debug client to debug server
pub mod debug_command;

/// Dispatcher module takes care of dispatching jobs for execution and gathering results
pub mod dispatcher;

/// Executor module receives jobs for execution, executes them and returns results
pub mod executor;

/// `wasmtime` module contains a number of implementations of the wasm execution
mod wasm;

/// We'll put our errors in an `errors` module, and other modules in this crate will `use errors::*;`
/// to get access to everything `error_chain` creates.
pub mod errors;

/// module providing `Block` struct from runtime that is required for debugging and tracing
pub mod block;

/// module providing `Job` struct from runtime that is required for debugging and tracing
pub mod job;

/// Service names common across multiple binary crates
pub mod services;

#[cfg(debug_assertions)]
mod checks;