msgflo-rust: Rust participant support for MsgFlo

Flowhub visual programming IDE

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
Issues

Collection of the latest Issues

greenkeeper[bot]

greenkeeper[bot]

greenkeeper
3

The devDependency amqplib was updated from 0.5.3 to 0.5.4.

🚨 View failing branch.

This version is covered by your current version range and after updating it in your project the build failed.

amqplib is a devDependency of this project. It might not break your production code or affect downstream projects, but probably breaks your build or test tools, which may prevent deploying or publishing.

Status Details

  • continuous-integration/travis-ci/push: The Travis CI build failed (Details).

Commits

The new version differs by 13 commits.

  • 524e707 Correct spelling of tags condition in travis conf
  • dbcdaa1 Merge pull request #533 from squaremo/release-v0.5.4
  • 3181ee5 Release notes and version bump for 0.5.4
  • 12a830c Merge pull request #532 from squaremo/publish-from-ci
  • fc6e749 Deploy in separate stage
  • 58ad7db Add deploy stanza to .travis.yml
  • 7adaea0 Merge pull request #525 from tingwai/update-engines
  • 160b793 Update package.json to reflect supported node versions
  • bb426eb Merge pull request #526 from squaremo/travis-xenial
  • 6a05907 Install RabbitMQ as prereq of CI
  • 773eb92 Merge pull request #498 from johanneswuerbach/error-unacked-on-close
  • 16439ea Error pending confirmation callbacks on channel close
  • 099673e Generate defs on prepare

See the full diff

FAQ and help

There is a collection of frequently asked questions. If those don’t help, you can always ask the humans behind Greenkeeper.


Your Greenkeeper Bot :palm_tree:

Information - Updated Oct 05, 2021

Stars: 7
Forks: 0
Issues: 7

This is an example of a Rust server that functions as a remote schema for...

Rust + Hasura Rust server that functions as a Hasura

This is an example of a Rust server that functions as a remote schema for...

Newport Engine is a modular 2D and 3D game engine built in Rust for Rust

It is designed to be easily extendable and easy to use

Newport Engine is a modular 2D and 3D game engine built in Rust for Rust

Newport Engine is a modular 2D and 3D game engine built in Rust for Rust

It is designed to be easily extendable and easy to use

Newport Engine is a modular 2D and 3D game engine built in Rust for Rust

liboqs-rust: Rust bindings for liboqs

Qyantum Safe liboqs rust bindings

liboqs-rust: Rust bindings for liboqs

Trojan-rust is a rust implementation for Trojan protocol that is targeted to circumvent GFW

Trojan protocol that is targeted to circumvent tokio-rs to achieve high performance async io

Trojan-rust is a rust implementation for Trojan protocol that is targeted to circumvent GFW
Actix

1.0K

How to be a full stack Rust Developer

Read Rust the Rust blog posts at Steadylearner

How to be a full stack Rust Developer

Rust library translation (rust-src/rust-std/stdlib/rustlib translation)

This is the place to translate Having a documentation in your native language is essential if you don't speak English, and still enjoyable even if...

Rust library translation (rust-src/rust-std/stdlib/rustlib translation)

False Positive for rust-lang/rust#83583

The deprecation lint proc_macro_derive_resolution_fallback is intended to catch proc macro generated code that refers to items from parent modules that should not be in scope:

False Positive for rust-lang/rust#83583

A CHIP-8 & SuperChip interpreter written in Rust using rust-sdl2

If you're getting compile errors it may be because

A CHIP-8 & SuperChip interpreter written in Rust using rust-sdl2

Rust-Svelte-on-Rust

Starter template for Rocket backend server

Rust-Svelte-on-Rust
Facebook Instagram Twitter GitHub Dribbble
Privacy