maelstrom-worker 0.14.0

The Maelstrom worker. This process executes jobs as directed by the broker.
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

use maelstrom_macro::Config;
use maelstrom_util::{
    config::common::{
        BrokerAddr, CacheSize, ClusterCommunicationStrategy, InlineLimit, LogLevel, Slots,
    },
    root::RootBuf,
};
use url::Url;
use xdg::BaseDirectories;

pub struct CacheDir;

#[derive(Config, Debug)]
pub struct Config {
    /// Socket address of broker.
    #[config(
        option,
        short = 'b',
        value_name = "SOCKADDR",
        default = r#""no default, must be specified if cluster-communication-strategy is tcp (the default)""#
    )]
    pub broker: Option<BrokerAddr>,

    /// The number of job slots available.
    #[config(value_name = "N", default = "Slots::default()")]
    pub slots: Slots,

    /// The directory to use for the cache.
    #[config(
        value_name = "PATH",
        default = r#"|bd: &BaseDirectories| {
            bd.get_cache_home()
                .into_os_string()
                .into_string()
                .unwrap()
        }"#
    )]
    pub cache_root: RootBuf<CacheDir>,

    /// The target amount of disk space to use for the cache. This bound won't be followed
    /// strictly, so it's best to be conservative. SI and binary suffixes are supported.
    #[config(value_name = "BYTES", default = "CacheSize::default()")]
    pub cache_size: CacheSize,

    /// The maximum amount of bytes to return inline for captured stdout and stderr.
    #[config(value_name = "BYTES", default = "InlineLimit::default()")]
    pub inline_limit: InlineLimit,

    /// Minimum log level to output.
    #[config(short = 'L', value_name = "LEVEL", default = r#""info""#)]
    pub log_level: LogLevel,

    /// The cluster communication strategy: TCP or GitHub.
    #[config(
        value_name = "CLUSTER_COMMUNICATION_STRATEGY",
        default = r#""tcp""#,
        hide
    )]
    pub cluster_communication_strategy: ClusterCommunicationStrategy,

    /// This is required with `cluster-communication-strategy=github`. This is passed to JavaScript
    /// GitHub actions as `ACTIONS_RUNTIME_TOKEN`.
    #[config(
        option,
        value_name = "GITHUB_ACTIONS_TOKEN",
        default = r#""no default, must be specified if cluster-communication-strategy is github""#,
        hide
    )]
    pub github_actions_token: Option<String>,

    /// This is required with `cluster-communication-strategy=github`. This is passed to JavaScript
    /// GitHub actions as `ACTIONS_RESULTS_URL`.
    #[config(
        option,
        value_name = "GITHUB_ACTIONS_URL",
        default = r#""no default, must be specified if cluster-communication-strategy is github""#,
        hide
    )]
    pub github_actions_url: Option<Url>,
}