wasmflow-sdk 0.10.0

WaPC-related functions for Wasmflow
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

/// The crate's error module
pub mod error;

/// Module that exposes [wasmflow_packet] APIs.
pub mod packet {
  pub use wasmflow_packet::{Packet, PacketMap, PacketWrapper};
  /// v1 Packets
  pub mod v1 {
    pub use wasmflow_packet::v1::{Failure, Packet, PacketMap, Serialized, Signal};
  }
}

/// Utility type for a [std::pin::Pin<Box<Future>>]
pub type BoxedFuture<T> = std::pin::Pin<Box<dyn std::future::Future<Output = T> + Send + 'static>>;

/// Utility type for a [Box<Error + Send + Sync>]
pub type BoxedError = Box<dyn std::error::Error + Send + Sync>;

pub use futures::{Stream, StreamExt};
pub use wasmflow_boundary::IncomingPayload;
pub use wasmflow_collection_link::CollectionLink;
pub use wasmflow_entity::{Entity, SystemEntity};
#[cfg(not(target_arch = "wasm32"))]
pub use wasmflow_invocation::{InherentData, Invocation};
pub use wasmflow_output::{ComponentOutput, PortOutput};
pub use wasmflow_streams::PacketStream;
pub use wasmflow_traits::{Component, IntoInputs, PortChannel, Writable};

/// Module that exposes [wasmflow_transport] APIs.
pub mod transport {
  pub use wasmflow_transport::{
    Failure,
    JsonError,
    MessageSignal,
    MessageTransport,
    Serialized,
    TransportJson,
    TransportMap,
    TransportStream,
    TransportWrapper,
  };
}

/// Module that exposes runtime interfaces.
pub mod runtime {
  pub use wasmflow_component::{HostCommand, LogLevel, OutputSignal};
}

/// Module that exposes handlers to deal with payloads from different sources.
pub mod payload {
  #[cfg(not(target_arch = "wasm32"))]
  pub use wasmflow_boundary::native::v1::from_invocation;
  #[cfg(target_arch = "wasm32")]
  pub use wasmflow_boundary::wasm::from_buffer;
}

/// Module for stateful components.
pub mod stateful {
  #[cfg(not(target_arch = "wasm32"))]
  pub use wasmflow_component::guest::stateful::native::Dispatcher as NativeDispatcher;
  #[cfg(target_arch = "wasm32")]
  pub use wasmflow_component::guest::stateful::wasm::Dispatcher as WasmDispatcher;
  pub use wasmflow_component::guest::stateful::BatchedJobExecutor;
  pub use wasmflow_traits::stateful::BatchedComponent;
}

/// Module for ephemeral components.
pub mod ephemeral {
  #[cfg(not(target_arch = "wasm32"))]
  pub use wasmflow_component::guest::ephemeral::native::Dispatcher as NativeDispatcher;
  #[cfg(target_arch = "wasm32")]
  pub use wasmflow_component::guest::ephemeral::wasm::Dispatcher as WasmDispatcher;
  pub use wasmflow_component::guest::ephemeral::BatchedJobExecutor;
  pub use wasmflow_traits::ephemeral::BatchedComponent;
}

#[cfg(target_arch = "wasm32")]
/// Module for components targeting wasm32.
pub mod wasm {
  pub use wasmflow_boundary::wasm::EncodedMap;
  /// Module for the wasm32 runtime.
  pub mod runtime {
    pub use wasmflow_component::guest::wasm::runtime::register_dispatcher;
  }
  pub use wasmflow_component::guest::wasm::runtime::{port_send, port_send_close};
}

/// Module that exposes [wasmflow_codec] APIs.
pub mod codec {
  pub use wasmflow_codec::{json, messagepack, raw};
}

/// Module that exposes [wasmflow_interface] APIs.
pub mod types {
  pub use wasmflow_interface::*;
}

#[macro_use]
pub use wasmflow_component::console_log;