ockam_command 0.104.0

End-to-end encryption and mutual authentication for distributed applications.
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

use std::{net::SocketAddr, str::FromStr};

use ockam_api::{port_range::PortRange, DefaultAddress};
use ockam_multiaddr::MultiAddr;

pub(crate) mod consumer;
pub(crate) mod direct;
pub(crate) mod outlet;
pub(crate) mod producer;
pub(crate) mod util;

const KAFKA_DEFAULT_BOOTSTRAP_ADDRESS: &str = "127.0.0.1:9092";
const KAFKA_DEFAULT_PROJECT_ROUTE: &str = "/project/default";
const KAFKA_DEFAULT_CONSUMER_SERVER: &str = "127.0.0.1:4000";
const KAFKA_DEFAULT_CONSUMER_PORT_RANGE: &str = "4001-4100";
const KAFKA_DEFAULT_PRODUCER_SERVER: &str = "127.0.0.1:5000";
const KAFKA_DEFAULT_PRODUCER_PORT_RANGE: &str = "5001-5100";

fn kafka_default_outlet_addr() -> String {
    DefaultAddress::KAFKA_OUTLET.to_string()
}

fn kafka_consumer_default_addr() -> String {
    DefaultAddress::KAFKA_CONSUMER.to_string()
}

fn kafka_direct_default_addr() -> String {
    DefaultAddress::KAFKA_DIRECT.to_string()
}

fn kafka_producer_default_addr() -> String {
    DefaultAddress::KAFKA_PRODUCER.to_string()
}

fn kafka_default_project_route() -> MultiAddr {
    MultiAddr::from_str(KAFKA_DEFAULT_PROJECT_ROUTE).expect("Failed to parse default project route")
}

fn kafka_default_outlet_server() -> SocketAddr {
    SocketAddr::from_str(KAFKA_DEFAULT_BOOTSTRAP_ADDRESS)
        .expect("Failed to parse default bootstrap address")
}

fn kafka_default_consumer_server() -> SocketAddr {
    SocketAddr::from_str(KAFKA_DEFAULT_CONSUMER_SERVER)
        .expect("Failed to parse default consumer server")
}

fn kafka_default_consumer_port_range() -> PortRange {
    PortRange::from_str(KAFKA_DEFAULT_CONSUMER_PORT_RANGE)
        .expect("Failed to parse default consumer port range")
}

fn kafka_default_producer_server() -> SocketAddr {
    SocketAddr::from_str(KAFKA_DEFAULT_PRODUCER_SERVER)
        .expect("Failed to parse default producer server")
}

fn kafka_default_producer_port_range() -> PortRange {
    PortRange::from_str(KAFKA_DEFAULT_PRODUCER_PORT_RANGE)
        .expect("Failed to parse default producer port range")
}