Struct RuntimeConfig 

pub struct RuntimeConfig {
    pub num_worker_threads: Option<usize>,
    pub max_blocking_threads: usize,
    pub system_host: String,
    pub system_port: u16,
    pub system_enabled: bool,
    pub starting_health_status: HealthStatus,
    pub use_endpoint_health_status: Vec<String>,
    pub system_health_path: String,
    pub system_live_path: String,
    pub health_check_enabled: bool,
    pub canary_wait_time_secs: u64,
    pub health_check_request_timeout_secs: u64,
}

Runtime configuration Defines the configuration for Tokio runtimes

Fields

num_worker_threads: Option<usize>

Number of async worker threads If set to 1, the runtime will run in single-threaded mode Set this at runtime with environment variable DYN_RUNTIME_NUM_WORKER_THREADS. Defaults to number of cores.

max_blocking_threads: usize

Maximum number of blocking threads Blocking threads are used for blocking operations, this value must be greater than 0. Set this at runtime with environment variable DYN_RUNTIME_MAX_BLOCKING_THREADS. Defaults to 512.

system_host: String

System status server host for health and metrics endpoints Set this at runtime with environment variable DYN_SYSTEM_HOST

system_port: u16

System status server port for health and metrics endpoints If set to 0, the system will assign a random available port Set this at runtime with environment variable DYN_SYSTEM_PORT

system_enabled: bool

Health and metrics System status server enabled Set this at runtime with environment variable DYN_SYSTEM_ENABLED

starting_health_status: HealthStatus

Starting Health Status Set this at runtime with environment variable DYN_SYSTEM_STARTING_HEALTH_STATUS

use_endpoint_health_status: Vec<String>

Use Endpoint Health Status When using endpoint health status, health status is the AND of individual endpoint health Set this at runtime with environment variable DYN_SYSTEM_USE_ENDPOINT_HEALTH_STATUS with the list of endpoints to consider for system health

system_health_path: String

Health endpoint paths Set this at runtime with environment variable DYN_SYSTEM_HEALTH_PATH

system_live_path: String

Set this at runtime with environment variable DYN_SYSTEM_LIVE_PATH

health_check_enabled: bool

Enable active health checking with payloads Set this at runtime with environment variable DYN_HEALTH_CHECK_ENABLED

canary_wait_time_secs: u64

Canary wait time in seconds (time to wait before sending health check when no activity) Set this at runtime with environment variable DYN_CANARY_WAIT_TIME

health_check_request_timeout_secs: u64

Health check request timeout in seconds Set this at runtime with environment variable DYN_HEALTH_CHECK_REQUEST_TIMEOUT

Implementations

impl RuntimeConfig

pub fn builder() -> RuntimeConfigBuilder

pub fn from_settings() -> Result<RuntimeConfig>

Load the runtime configuration from the environment and configuration files Configuration is priorities in the following order, where the last has the lowest priority:

1. Environment variables (top priority) TO DO: Add documentation for configuration files. Paths should be configurable.
2. /opt/dynamo/etc/runtime.toml
3. /opt/dynamo/defaults/runtime.toml (lowest priority)

Environment variables are prefixed with DYN_RUNTIME_ and DYN_SYSTEM

pub fn system_server_enabled(&self) -> bool

Check if System server should be enabled System server is disabled by default, but can be enabled by setting DYN_SYSTEM_ENABLED to true

pub fn single_threaded() -> Self

Trait Implementations

impl Clone for RuntimeConfig

fn clone(&self) -> RuntimeConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RuntimeConfig

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

Formats the value using the given formatter.

impl Default for RuntimeConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RuntimeConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for RuntimeConfig

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

Formats the value using the given formatter.

impl Serialize for RuntimeConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Validate for RuntimeConfig

fn validate(&self) -> Result<(), ValidationErrors>

impl<'v_a> ValidateArgs<'v_a> for RuntimeConfig

type Args = ()

fn validate_with_args(&self, args: Self::Args) -> Result<(), ValidationErrors>