swift_mt_message/plugin/
mod.rs

1//! # Dataflow Plugin
2//!
3//! Dataflow-rs integration for SWIFT MT message processing.
4//! Provides async function handlers for parse, validate, generate, and publish operations.
5
6pub mod generate;
7pub mod parse;
8pub mod publish;
9pub mod validate;
10
11use dataflow_rs::engine::AsyncFunctionHandler;
12
13// Re-export the main plugin functions
14pub use generate::Generate;
15pub use parse::Parse;
16pub use publish::Publish;
17pub use validate::Validate;
18
19/// Register all SWIFT MT plugin functions for use in dataflow engine
20pub fn register_swift_mt_functions()
21-> Vec<(&'static str, Box<dyn AsyncFunctionHandler + Send + Sync>)> {
22    vec![
23        ("parse_mt", Box::new(Parse)),
24        ("publish_mt", Box::new(Publish)),
25        ("validate_mt", Box::new(Validate)),
26        ("generate_mt", Box::new(Generate)),
27    ]
28}
swift_mt_message/plugin/mod.rs

swift_mt_message/plugin/
mod.rs
