pubsub-server 0.1.3

Pubsub message broker server binary
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69

# pubsub-server

Standalone pub/sub message broker binary.

Run it as a long-lived process; any number of clients connect to it over TCP using the [`pubsub`](https://crates.io/crates/pubsub) client library.

## Install

```sh
cargo install pubsub-server
```

## Run

```sh
# Default: binds to 127.0.0.1:4222
pubsub-server

# Listen on all interfaces
pubsub-server --bind 0.0.0.0:4222

# With logging
RUST_LOG=info pubsub-server
```

## CLI reference

```
Usage: pubsub-server [OPTIONS]

Options:
  -b, --bind <ADDR>              Address to bind the listener to [default: 127.0.0.1:4222]
      --max-connections <N>      Maximum number of concurrent connections [default: 1024]
      --channel-buffer <N>       Per-session message channel buffer size [default: 256]
      --max-frame-size <BYTES>   Maximum wire frame size in bytes [default: 65536]
  -h, --help                     Print help
  -V, --version                  Print version
```

## Connecting clients

```toml
[dependencies]
pubsub = "0.1"
```

```rust
use pubsub::{Client, ConnectOptions};

let client = Client::connect(ConnectOptions::from_host("localhost:4222")).await?;
client.publish("hello", "world").await?;
```

## Signals

The server handles `SIGINT` (Ctrl+C) and `SIGTERM` gracefully. Active sessions are given a short drain period before the process exits.

## Logging

Log level is controlled via the `RUST_LOG` environment variable:

```sh
RUST_LOG=debug pubsub-server   # verbose
RUST_LOG=warn  pubsub-server   # errors and warnings only
```

## License

MIT or Apache-2.0