Struct Config 

pub struct Config {
    pub bind_address: String,
    pub port: u16,
    pub default_partitions: u32,
    pub enable_persistence: bool,
    pub data_dir: String,
    pub max_segment_size: u64,
    pub log_level: String,
}

Configuration for Rivven

Fields

bind_address: String

Server bind address

port: u16

Server port

default_partitions: u32

Default number of partitions for new topics

enable_persistence: bool

Enable disk persistence

data_dir: String

Data directory for persistence

max_segment_size: u64

Maximum segment size in bytes

log_level: String

Log level

Implementations

impl Config

pub fn new() -> Self

Create a new configuration

pub fn with_bind_address(self, address: String) -> Self

Set the bind address

pub fn with_port(self, port: u16) -> Self

Set the port

pub fn with_default_partitions(self, partitions: u32) -> Self

Set the default partitions

pub fn with_persistence(self, enabled: bool) -> Self

Enable or disable persistence

pub fn with_data_dir(self, data_dir: String) -> Self

Set the data directory

pub fn server_address(&self) -> String

Get the server address

Trait Implementations

impl Clone for Config

fn clone(&self) -> Config

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Config

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

Formats the value using the given formatter.

impl Default for Config

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Config

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Config

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.