Struct EntropyConfig 

pub struct EntropyConfig {
    pub key_file: PathBuf,
    pub iv_file: PathBuf,
    pub listen_addr: SocketAddr,
    pub send_addr: Option<SocketAddr>,
    pub peer_endpoint: SocketAddr,
    pub buffer_size: usize,
    pub header_size: usize,
    pub encrypt: bool,
}

Operator-facing configuration for the entropy worker.

Examples

use std::path::PathBuf;
use dynomite::entropy::EntropyConfig;
let cfg = EntropyConfig {
    key_file: PathBuf::from("conf/recon_key.pem"),
    iv_file: PathBuf::from("conf/recon_iv.pem"),
    listen_addr: "127.0.0.1:8105".parse().unwrap(),
    send_addr: None,
    peer_endpoint: "127.0.0.1:8105".parse().unwrap(),
    buffer_size: 16 * 1024,
    header_size: 1024,
    encrypt: true,
};
assert_eq!(cfg.buffer_size, 16 * 1024);

Fields

key_file: PathBuf

On-disk path to the AES-128 key file.

iv_file: PathBuf

On-disk path to the AES-128-CBC IV file.

listen_addr: SocketAddr

Address the EntropyReceiver binds to.

send_addr: Option<SocketAddr>

Optional local bind address for the EntropySender. When None the kernel assigns an ephemeral port on the wildcard address.

peer_endpoint: SocketAddr

Address the EntropySender dials.

buffer_size: usize

Plaintext chunk size (bytes). Must be a multiple of 16 when encryption is enabled and must not exceed MAX_BUFFER_SIZE.

header_size: usize

Snapshot header size (bytes). Must not exceed MAX_HEADER_SIZE.

encrypt: bool

Whether per-chunk payloads are AES-128-CBC encrypted.

Implementations

impl EntropyConfig

pub fn validate(&self) -> Result<(), EntropyError>

Validate the cross-field invariants the protocol demands.

Errors

EntropyError::Config when any invariant is violated.

Examples

use std::path::PathBuf;
use dynomite::entropy::EntropyConfig;
let mut cfg = EntropyConfig {
    key_file: PathBuf::from("k"),
    iv_file: PathBuf::from("v"),
    listen_addr: "127.0.0.1:0".parse().unwrap(),
    send_addr: None,
    peer_endpoint: "127.0.0.1:0".parse().unwrap(),
    buffer_size: 32,
    header_size: 64,
    encrypt: true,
};
assert!(cfg.validate().is_ok());
cfg.buffer_size = 0;
assert!(cfg.validate().is_err());

Trait Implementations

impl Clone for EntropyConfig

fn clone(&self) -> EntropyConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EntropyConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.