topiq-server 0.1.3

Topiq 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

use std::net::SocketAddr;

use clap::Parser;

/// A lightweight pub-sub message broker.
#[derive(Parser, Debug)]
#[command(name = "topiq-server", version, about)]
pub struct Cli {
    /// Address to bind the listener to.
    #[arg(short, long, default_value = "127.0.0.1:4222")]
    pub bind: SocketAddr,

    /// Maximum number of concurrent connections.
    #[arg(long, default_value = "1024")]
    pub max_connections: usize,

    /// Per-session message channel buffer size.
    #[arg(long, default_value = "256")]
    pub channel_buffer: usize,

    /// Maximum wire frame size in bytes.
    #[arg(long, default_value = "65536")]
    pub max_frame_size: usize,
}