Struct ApplicationConf 

pub struct ApplicationConf {

    pub execution_mode: ExecutionMode,
    pub base_dir: PathBuf,
    pub arcon_logger_type: LoggerType,
    pub kompact_logger_type: LoggerType,
    pub epoch_interval: u64,
    pub watermark_interval: u64,
    pub max_key: u64,
    pub node_metrics_interval: u64,
    pub buffer_pool_size: usize,
    pub buffer_pool_limit: usize,
    pub channel_batch_size: usize,
    pub allocator_capacity: usize,
    pub ctrl_system_host: Option<String>,
    pub kompact_threads: usize,
    pub kompact_throughput: usize,
    pub kompact_msg_priority: f32,
    pub kompact_network_host: Option<String>,
    pub kompact_chunk_size: usize,
    pub kompact_initial_chunk_count: usize,
    pub kompact_max_chunk_count: usize,
    pub kompact_encode_buf_min_free_space: usize,
}

Configuration for an Arcon Application

Fields

execution_mode: ExecutionMode

Either a Local or Distributed Execution Mode

base_dir: PathBuf

Base directory for the application

arcon_logger_type: LoggerType

LoggerType for arcon related logging

kompact_logger_type: LoggerType

LoggerType for kompact related logging

epoch_interval: u64

Generation interval in milliseconds for Epochs

watermark_interval: u64

Generation interval in milliseconds for Watermarks at sources

max_key: u64

The highest possible key value for a keyed stream

This should not be set too low or ridiculously high

node_metrics_interval: u64

Interval in milliseconds for sending off metrics from nodes

buffer_pool_size: usize

Amount of buffers pre-allocated to a BufferPool

buffer_pool_limit: usize

A limit for amount of buffers in a BufferPool

channel_batch_size: usize

Batch size for channels

allocator_capacity: usize

Max amount of bytes allowed to be allocated by the Arcon Allocator

ctrl_system_host: Option<String>

kompact_threads: usize

Amount of threads for Kompact’s threadpool

kompact_throughput: usize

Controls the amount of messages a component processes per schedule iteration

kompact_msg_priority: f32

Float value that sets message priority

kompact_network_host: Option<String>

Host address for the KompactSystem

It is set as optional as it is not necessary for local deployments

kompact_chunk_size: usize

kompact_initial_chunk_count: usize

kompact_max_chunk_count: usize

kompact_encode_buf_min_free_space: usize

Implementations

impl ApplicationConf

pub fn state_dir(&self) -> PathBuf

pub fn checkpoints_dir(&self) -> PathBuf

pub fn arcon_logger(&self) -> ArconLogger

pub fn data_system_conf(&self) -> KompactConfig

Returns a KompactConfig based on loaded ApplicationConf

Trait Implementations

impl Clone for ApplicationConf

fn clone(&self) -> ApplicationConf

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ApplicationConf

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

Formats the value using the given formatter.

impl Default for ApplicationConf

fn default() -> Self

Returns the “default value” for a type.