behest 0.3.1

A Rust-native cloud agent runtime with typed tools, pluggable memory, queues, and observability.
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

//! gRPC server configuration section.

use serde::{Deserialize, Serialize};

/// gRPC server configuration.
///
/// Controls listen address, TLS, authentication, and concurrency limits.
/// By default the server listens on `[::1]:50051` with no TLS or auth.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct GrpcConfig {
    /// Socket address to listen on. Default: `"[::1]:50051"`.
    #[serde(default = "default_listen_addr")]
    pub listen_addr: String,

    /// TLS configuration. `None` means plaintext (no encryption).
    #[serde(default)]
    pub tls: Option<GrpcTlsConfig>,

    /// Bearer token for request authentication. `None` means no auth.
    #[serde(default)]
    pub auth_token: Option<String>,

    /// Maximum number of concurrent runs. `None` means unlimited.
    #[serde(default)]
    pub max_concurrent_runs: Option<usize>,
}

impl Default for GrpcConfig {
    fn default() -> Self {
        Self {
            listen_addr: default_listen_addr(),
            tls: None,
            auth_token: None,
            max_concurrent_runs: None,
        }
    }
}

/// TLS configuration for the gRPC server.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct GrpcTlsConfig {
    /// Path to the server certificate (PEM).
    pub cert_path: String,
    /// Path to the server private key (PEM).
    pub key_path: String,
    /// Path to the client CA certificate (PEM) for mTLS.
    #[serde(default)]
    pub client_ca_path: Option<String>,
}

fn default_listen_addr() -> String {
    "[::1]:50051".to_owned()
}