Struct WebSocketConfig 

pub struct WebSocketConfig {
    pub ping_interval: Duration,
    pub max_connections: usize,
    pub message_buffer_size: usize,
    pub max_message_size: usize,
    pub live_update_interval: Duration,
    pub live_update_max_jobs: u32,
}

WebSocket configuration

Fields

ping_interval: Duration

Ping interval to keep connections alive

max_connections: usize

Maximum number of concurrent WebSocket connections

message_buffer_size: usize

Outgoing messages queued per connection; further messages for a client that does not keep up are dropped

max_message_size: usize

Maximum size in bytes of a message (and of a frame) received from a client

live_update_interval: Duration

How often the dashboard polls the database for job state changes and queue statistics to push to connected clients (JobUpdate and QueueUpdate messages). Polling only happens while at least one client is connected. Zero disables live updates. Optional in configuration files (default 2 seconds).

live_update_max_jobs: u32

The most changed jobs one poll reads and pushes; further changes in the same interval are not pushed individually (the queue statistics still reflect them). Optional in configuration files (default 100).

Trait Implementations

impl Clone for WebSocketConfig

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 WebSocketConfig

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

Formats the value using the given formatter.

impl Default for WebSocketConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for WebSocketConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WebSocketConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.