use std::time::Duration;
use data_encoding::{Encoding, HEXLOWER_PERMISSIVE};
use crate::config::{DEFAULT_BATCH_SIZE, DEFAULT_STATUS_INTERVAL};
use crate::config::ServerConfig;
use crate::key::KmsProtection;
const HEX: Encoding = HEXLOWER_PERMISSIVE;
pub struct MemoryConfig {
pub port: u16,
pub interface: String,
pub seed: Vec<u8>,
pub batch_size: u8,
pub status_interval: Duration,
pub kms_protection: KmsProtection,
pub health_check_port: Option<u16>,
pub client_stats: bool,
pub fault_percentage: u8,
}
impl MemoryConfig {
pub fn new(port: u16) -> Self {
let seed = b"a32049da0ffde0ded92ce10a0230d35fe615ec8461c14986baa63fe3b3bac3db";
MemoryConfig {
port,
interface: "127.0.0.1".to_string(),
seed: HEX.decode(seed).unwrap(),
batch_size: DEFAULT_BATCH_SIZE,
status_interval: DEFAULT_STATUS_INTERVAL,
kms_protection: KmsProtection::Plaintext,
health_check_port: None,
client_stats: false,
fault_percentage: 0,
}
}
}
impl ServerConfig for MemoryConfig {
fn interface(&self) -> &str {
self.interface.as_ref()
}
fn port(&self) -> u16 {
self.port
}
fn seed(&self) -> Vec<u8> {
self.seed.clone()
}
fn batch_size(&self) -> u8 {
self.batch_size
}
fn status_interval(&self) -> Duration {
self.status_interval
}
fn kms_protection(&self) -> &KmsProtection {
&self.kms_protection
}
fn health_check_port(&self) -> Option<u16> {
self.health_check_port
}
fn client_stats_enabled(&self) -> bool {
self.client_stats
}
fn fault_percentage(&self) -> u8 {
self.fault_percentage
}
}