Scaproust is an implementation of the nanomsg "Scalability Protocols" in the Rust programming language.

Quoting from nanomsg's site:

nanomsg is a socket library that provides several common communication patterns. It aims to make the networking layer fast, scalable, and easy to use. Implemented in C, it works on a wide range of operating systems with no further dependencies.

The communication patterns, also called "scalability protocols", are basic blocks for building distributed systems. By combining them you can create a vast array of distributed applications.

Experimental work ! For working stuff, please see nanomsg-rs.

API Documentation

• Support for all of nanomsg's protocols.
• Support for TCP and IPC transports.
• Idiomatic rust API first, mimic the original C API second.
• Extensibility: allow user code to define additional protocols and transports

First, add this to your Cargo.toml:

[dependencies]
scaproust = "0.2.0"

Next, add this to your crate:

extern crate scaproust;

• Protocols

  • PAIR
  • BUS
  • REQREP
    • REQ
    • REQ resend
    • REQ prefetch replies
    • REP
  • PUBSUB
    • PUB
    • SUB
    • SUB subscription filter
  • PIPELINE
    • PUSH
    • PULL
  • SURVEY
    • SURVEYOR
    • SURVEYOR deadline
    • RESPONDENT

• Transports

  • TCP
  • IPC (*nix)
  • IPC (Windows)

• Socket options

  • Linger
  • Recv max size
  • Send timeout
  • Recv timeout
  • Reconnect interval
  • Reconnect interval max
  • Send priority
  • Recv priority
  • IPV4 only
  • Socket name

• Protocol options

  • REQ resend interval
  • SURVEYOR deadline
  • SUB subscribe
  • SUB unsubscribe

• Transport options

  • TCP no delay

Licensed under either of

• Apache License, Version 2.0 (LICENSE-APACHE or http://www.apache.org/licenses/LICENSE-2.0)
• MIT license (LICENSE-MIT or http://opensource.org/licenses/MIT) at your option.

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you shall be dual licensed as above, without any additional terms or conditions.