mx_message/plugin/
mod.rs

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

mx_message/plugin/
mod.rs
