(requests: Option<u64>, window_seconds: Option<u64>)
| 663 | } |
| 664 | |
| 665 | fn validate_grpc_rate_limit_args(requests: Option<u64>, window_seconds: Option<u64>) -> Result<()> { |
| 666 | let disabled = matches!(requests, Some(0)) || matches!(window_seconds, Some(0)); |
| 667 | if disabled { |
| 668 | return Ok(()); |
| 669 | } |
| 670 | if matches!( |
| 671 | (requests, window_seconds), |
| 672 | (Some(requests), None) if requests > 0 |
| 673 | ) || matches!( |
| 674 | (requests, window_seconds), |
| 675 | (None, Some(window_seconds)) if window_seconds > 0 |
| 676 | ) { |
| 677 | return Err(miette::miette!( |
| 678 | "gRPC rate limiting requires both --grpc-rate-limit-requests and --grpc-rate-limit-window-seconds (TOML keys grpc_rate_limit_requests and grpc_rate_limit_window_seconds) to be positive; set either value to 0 to disable" |
| 679 | )); |
| 680 | } |
| 681 | Ok(()) |
| 682 | } |
| 683 | |
| 684 | fn normalize_compute_driver_socket_args(args: &mut RunArgs, matches: &ArgMatches) -> Result<()> { |
| 685 | let Some(socket) = args.compute_driver_socket.as_ref() else { |
no outgoing calls
no test coverage detected