/msgflo-rust

Participant support for Rust lang

Primary LanguageRustMIT LicenseMIT

Build Status

msgflo-rust: Rust participant support for MsgFlo

MsgFlo is a distributed, polyglot FBP (flow-based-programming) runtime. It integrates with other FBP tools like the Flowhub visual programming IDE. msgflo-rust makes it easy to create MsgFlo participants in Rust.

Status

Working prototype

  • Can expose a Rust function on AMQP with a single in/outport
  • Sends the MsgFlo participant discovery message on startup
  • Passes MsgFlo participant tests
  • Not used in any applications yet (as far as we know)

See below TODO section for more notes

Installing

Add to your Cargo.toml

[dependencies.msgflo]
git = "https://github.com/msgflo/msgflo-rust"

API

See ./examples

License

MIT

TODO

0.1

  • Allow any number of in/outports
  • Allow sending multiple messages out
  • Make error handling sane
  • Add example of consuming/sending JSON data
  • Add test for NACK on error condition
  • Publish as Rust crate on http://crates.io

Later

  • Support 'hidden' ports (not associated with a queue), used as proxies
  • Support other transports, like MQTT