actaeon 0.1.3

Decentralized PubSub & messaging protocol inspired by Kademlia.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

# Actaeon

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:

``` rust
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.
-   Handle crashed threads.