watchctl 0.1.0

Process supervisor with wait, watch, and retry phases
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
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117

use clap::Parser;

#[derive(Parser, Debug)]
#[command(name = "watchctl")]
#[command(about = "Process supervisor with wait, watch, and retry phases")]
#[command(version)]
pub struct Args {
    // WAIT PHASE
    #[arg(long = "wait-tcp", value_name = "HOST:PORT", action = clap::ArgAction::Append)]
    pub wait_tcp: Vec<String>,

    #[arg(
        long = "wait-tcp-timeout",
        value_name = "DURATION",
        default_value = "5s"
    )]
    pub wait_tcp_timeout: String,

    #[arg(long = "wait-http", value_name = "URL", action = clap::ArgAction::Append)]
    pub wait_http: Vec<String>,

    #[arg(
        long = "wait-http-timeout",
        value_name = "DURATION",
        default_value = "5s"
    )]
    pub wait_http_timeout: String,

    #[arg(long = "wait-file", value_name = "PATH", action = clap::ArgAction::Append)]
    pub wait_file: Vec<String>,

    #[arg(long = "wait-delay", value_name = "DURATION", action = clap::ArgAction::Append)]
    pub wait_delay: Vec<String>,

    #[arg(long = "wait-timeout", value_name = "DURATION", default_value = "30s")]
    pub wait_timeout: String,

    // WATCH PHASE
    #[arg(long = "watch-http", value_name = "URL", action = clap::ArgAction::Append)]
    pub watch_http: Vec<String>,

    #[arg(
        long = "watch-http-interval",
        value_name = "DURATION",
        default_value = "10s"
    )]
    pub watch_http_interval: String,

    #[arg(
        long = "watch-http-timeout",
        value_name = "DURATION",
        default_value = "5s"
    )]
    pub watch_http_timeout: String,

    #[arg(long = "watch-tcp", value_name = "HOST:PORT", action = clap::ArgAction::Append)]
    pub watch_tcp: Vec<String>,

    #[arg(
        long = "watch-tcp-interval",
        value_name = "DURATION",
        default_value = "10s"
    )]
    pub watch_tcp_interval: String,

    #[arg(
        long = "watch-tcp-timeout",
        value_name = "DURATION",
        default_value = "5s"
    )]
    pub watch_tcp_timeout: String,

    #[arg(long = "watch-file", value_name = "PATH", action = clap::ArgAction::Append)]
    pub watch_file: Vec<String>,

    #[arg(
        long = "watch-file-interval",
        value_name = "DURATION",
        default_value = "10s"
    )]
    pub watch_file_interval: String,

    #[arg(long = "watch-timeout", value_name = "DURATION")]
    pub watch_timeout: Option<String>,

    // RETRY PHASE
    #[arg(long = "retry-times", value_name = "N", default_value = "0")]
    pub retry_times: u32,

    #[arg(long = "retry-delay", value_name = "DURATION", default_value = "1s")]
    pub retry_delay: String,

    #[arg(long = "retry-backoff")]
    pub retry_backoff: bool,

    #[arg(long = "retry-if", value_name = "CODES", action = clap::ArgAction::Append)]
    pub retry_if: Vec<String>,

    #[arg(long = "retry-with-wait")]
    pub retry_with_wait: bool,

    // LOGGING
    #[arg(
        long = "log",
        value_name = "FILE",
        help = "Log watchctl messages to file"
    )]
    pub log: Option<String>,

    // COMMAND
    #[arg(last = true, required = true)]
    pub command: Vec<String>,
}

pub fn parse() -> Args {
    Args::parse()
}