actaeon 0.1.2

Distributed PubSub and messaging protocol for decentralized real time applications.

This library offers users a simple to use, easy to understand API for a mostly automatically managed decentralized messaging system based on the Kademlia paper. Fast and reliable message exchange is possible through both direct and indirect TCP messaging.

A very simple example of how to use the library to broadcast messages on a specific topic:

use actaeon::{
    config::Config,
    node::{Center, ToAddress},
    Interface,
};
use sodiumoxide::crypto::box_;

fn main() {
    let config = Config::new(20, 1, 100, "example.com".to_string(), 4242);
    let (_, secret) = box_::gen_keypair();
    let center = Center::new(secret, String::from("127.0.0.1"), 1234);

    let interface = Interface::new(config, center).unwrap();

    let mut topic = interface.subscribe(&"example".to_string().to_address().unwrap());

    let _ = topic.broadcast("hello world".as_bytes().to_vec());
}

There are still some unresolved issues:

• Active connections can sometimes fail without reason.
• Error handling for signaling & multiple signaling servers.
• General documentation (and minor error handling).
• Add more detailed logging & tracing.