tyra 1.0.0

Typed Actor System
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

use std::path::Path;
use crate::config::global_config::GeneralConfig;
use crate::config::pool_config::PoolConfig;

use config::{Config, ConfigError, File, FileFormat};
use serde::{Deserialize, Serialize};

pub const DEFAULT_POOL: &str = "default";

/// See [default.toml](https://github.com/sers-dev/tyra/blob/master/src/config/default.toml) for documentation of all configurations & their defaults
#[derive(Debug, Serialize, Deserialize, Clone)]
pub struct TyraConfig {
    pub general: GeneralConfig,
    pub thread_pool: PoolConfig,
}

impl TyraConfig {
    /// Required for [ActorSystem.new](../prelude/struct.ActorSystem.html#method.new)
    ///
    /// Loads default config from [default.toml](https://github.com/sers-dev/tyra/blob/master/src/config/default.toml)
    /// Overwrites defaults through environment variables. Replace toml `.` with `_CONFIG_`, i.e. `TYRACTORSAUR_GENERAL_CONFIG_DEFAULT_MAILBOX_SIZE=1`
    ///
    /// Replaces `$HOSTNAME` with the actual hostname of the system for the `TYRACTORSAUR_GENERAL_CONFIG_NAME`
    ///
    /// # Examples
    ///
    /// Basic usage:
    ///
    /// ```rust
    ///
    /// use tyra::prelude::TyraConfig;
    ///
    /// let mut config = TyraConfig::new().unwrap();
    /// config.general.name = String::from("HelloWorld");
    /// ```
    pub fn new() -> Result<Self, ConfigError> {

        let default: &str = std::include_str!("default.toml");

        let mut config = Config::builder();

        config = config.add_source(File::from_str(default, FileFormat::Toml));
        let path = Path::new("config/tyra.toml");
        if path.exists() {
            config = config.add_source(File::from(Path::new("config/tyra.toml")));
        }

        let conf = config.build().expect("Could not fetch Config");
        let mut parsed: TyraConfig = conf.try_deserialize().expect("Could not parse Config");
        if parsed.general.name == "$HOSTNAME" {
            parsed.general.name = String::from(hostname::get().unwrap().to_str().unwrap());
        }

        Ok(parsed)
    }
}