Struct LimitsConfig 

pub struct LimitsConfig {

    pub max_tasks_per_batch: usize,
    pub max_pending_total: usize,
    pub max_pending_per_pool: usize,
    pub max_message_bytes: usize,
    pub max_http_body_bytes: usize,
    pub max_key_len: usize,
    pub max_kind_len: usize,
    pub max_tags: usize,
    pub max_tag_len: usize,
    pub max_deps: usize,
    pub max_resources: usize,
    pub max_wait_s: f64,
    pub request_timeout_s: f64,
    pub max_concurrent_requests: usize,
    pub max_concurrent_streams: u32,
    pub max_slots_per_worker: u32,
    pub keepalive_interval_s: f64,
    pub keepalive_timeout_s: f64,
    pub key_retention_s: f64,
    pub key_retention_max: usize,
    pub max_list: usize,
}

Request and resource limits (defaults are safe for a shared deployment).

Fields

max_tasks_per_batch: usize

Tasks per SubmitBatch call.

max_pending_total: usize

Pending tasks across all pools.

max_pending_per_pool: usize

Default per-pool pending bound (overridable per pool with max_pending).

max_message_bytes: usize

Largest gRPC message accepted or sent (payloads and outputs ride in these).

max_http_body_bytes: usize

Largest HTTP request body.

max_key_len: usize

Longest task key.

max_kind_len: usize

Longest task kind.

max_tags: usize

Most tags per task.

max_tag_len: usize

Longest tag key or value.

max_deps: usize

Most dependencies per task.

max_resources: usize

Most resource entries per task.

max_wait_s: f64

Longest server-side wait for a task result (Wait, Submit{wait}).

request_timeout_s: f64

Timeout for any other request.

max_concurrent_requests: usize

Requests processed concurrently per listener (excess requests queue).

max_concurrent_streams: u32

HTTP/2 streams per connection.

max_slots_per_worker: u32

Slots a single worker may register (also capped by the pool’s max).

keepalive_interval_s: f64

HTTP/2 keepalive ping interval (evicts half-open workers and clients).

keepalive_timeout_s: f64

HTTP/2 keepalive ping timeout.

key_retention_s: f64

How long a finished task’s key keeps deduplicating submissions: resubmitting it returns the finished task (and its stored output). Also how far back a new leader loads finished tasks from the store.

key_retention_max: usize

Most finished tasks kept for key deduplication (bounds memory).

max_list: usize

Most tasks one ListTasks page returns.

Implementations

impl LimitsConfig

pub fn key_retention(&self) -> Duration

key_retention_s as a duration.

pub fn max_wait(&self) -> Duration

max_wait_s as a duration.

pub fn request_timeout(&self) -> Duration

request_timeout_s as a duration.

pub fn keepalive_interval(&self) -> Duration

keepalive_interval_s as a duration.

pub fn keepalive_timeout(&self) -> Duration

keepalive_timeout_s as a duration.

Trait Implementations

impl Clone for LimitsConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LimitsConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for LimitsConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for LimitsConfig

where LimitsConfig: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.