rustvello-proto 0.1.6

Data transfer objects and wire types for Rustvello
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

use serde::{Deserialize, Serialize};
use std::fmt;

/// Concurrency control strategy for a task.
///
/// Determines how concurrent invocations of the same task are handled.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
#[non_exhaustive]
pub enum ConcurrencyControlType {
    /// No concurrency restrictions
    Unlimited,
    /// Only one invocation per (task_id, key_args) at a time
    Task,
    /// Only one invocation per exact argument set
    Argument,
    /// No concurrent invocations allowed at all
    None,
}

impl Default for ConcurrencyControlType {
    fn default() -> Self {
        Self::Unlimited
    }
}

impl fmt::Display for ConcurrencyControlType {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            Self::Unlimited => f.write_str("Unlimited"),
            Self::Task => f.write_str("Task"),
            Self::Argument => f.write_str("Argument"),
            Self::None => f.write_str("None"),
        }
    }
}

impl std::str::FromStr for ConcurrencyControlType {
    type Err = String;

    fn from_str(s: &str) -> Result<Self, Self::Err> {
        match s.to_uppercase().as_str() {
            "UNLIMITED" | "DISABLED" => Ok(Self::Unlimited),
            "TASK" => Ok(Self::Task),
            "ARGUMENT" | "ARGUMENTS" | "KEYS" => Ok(Self::Argument),
            "NONE" => Ok(Self::None),
            _ => Err(format!("unknown ConcurrencyControlType: {s:?}")),
        }
    }
}