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

use serde::{Deserialize, Serialize};
use std::collections::HashMap;

/// 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 ThreadPoolConfig {
    pub actor_limit: usize,
    pub threads_min: usize,
    pub threads_max: usize,
    pub threads_factor: f32,
}

impl ThreadPoolConfig {
    /// Required for [ActorSystem.add_pool_with_config](../prelude/struct.ActorSystem.html#method.add_pool_with_config)
    ///
    /// # Examples
    ///
    /// Basic usage:
    ///
    /// ```rust
    /// use tyra::prelude::ThreadPoolConfig;
    ///
    /// let config = ThreadPoolConfig::new(0, 1, 2, 1.0);
    /// ```
    pub fn new(
        actor_limit: usize,
        threads_min: usize,
        threads_max: usize,
        threads_factor: f32,
    ) -> Self {
        Self {
            actor_limit,
            threads_min,
            threads_max,
            threads_factor,
        }
    }
}

#[derive(Debug, Serialize, Deserialize, Clone)]
pub struct PoolConfig {
    pub config: HashMap<String, ThreadPoolConfig>,
}