Struct ServerInfo 

pub struct ServerInfo {

    pub version: String,
    pub supported_protocol_versions: Vec<String>,
    pub server_time: SystemTime,
    pub restricts_encodings: bool,
    pub allowed_encodings: Vec<String>,
    pub max_payload_bytes: u64,
    pub max_custom_entries: u32,
    pub max_custom_total_bytes: u64,
    pub max_custom_key_bytes: u32,
    pub max_queue_name_bytes: u32,
    pub max_job_type_bytes: u32,
    pub max_idempotency_key_bytes: u32,
    pub max_schedule_horizon: Duration,
    pub max_enqueue_batch: u32,
    pub max_reserve_batch: u32,
    pub max_reserve_queues: u32,
    pub max_wait_timeout: Duration,
    pub max_lease_duration: Duration,
    pub strict_queues: bool,
    pub dead_letter_retention_enabled: bool,
}

The server’s version, capabilities, and limits, as returned by get_server_info.

The various max_* fields mirror the limits behind the JobRejection variants. Fetching this once at startup lets a producer validate jobs locally and avoid round-trips that would only be rejected. The limits are the server’s defaults; an individual queue may be configured more or less strictly.

Fields

version: String

Server version (a semver string).

supported_protocol_versions: Vec<String>

Protocol versions the server supports.

server_time: SystemTime

The server’s current wall-clock time, useful for detecting clock skew.

restricts_encodings: bool

If true, only encodings in allowed_encodings are accepted; if false, any encoding is accepted.

allowed_encodings: Vec<String>

The accepted encodings when restricts_encodings is set.

max_payload_bytes: u64

Maximum payload size in bytes (→ JobRejection::PayloadTooLarge).

max_custom_entries: u32

Maximum entries in the custom map (→ JobRejection::CustomEntriesTooMany).

max_custom_total_bytes: u64

Maximum total bytes across the custom map (→ JobRejection::CustomMapTooLarge).

max_custom_key_bytes: u32

Maximum bytes in a single custom key (→ JobRejection::CustomKeyTooLong).

max_queue_name_bytes: u32

Maximum bytes in a queue name (→ JobRejection::QueueNameTooLong).

max_job_type_bytes: u32

Maximum bytes in a job type (→ JobRejection::JobTypeNameTooLong).

max_idempotency_key_bytes: u32

Maximum bytes in an idempotency key (→ JobRejection::IdempotencyKeyTooLong).

max_schedule_horizon: Duration

How far ahead a job may be scheduled (→ JobRejection::ScheduledTooFar).

max_enqueue_batch: u32

Maximum jobs in one enqueue batch; larger batches fail the whole request.

max_reserve_batch: u32

Maximum jobs returned by one reserve; larger requests are clamped, not rejected.

max_reserve_queues: u32

Maximum queues one reserve may list; exceeding this is an error.

max_wait_timeout: Duration

Maximum long-poll wait; larger requests are clamped.

max_lease_duration: Duration

Maximum lease duration; larger requests are clamped.

strict_queues: bool

If true, enqueueing to an undeclared queue is rejected with JobRejection::UnknownQueue; if false, queues are created on demand.

dead_letter_retention_enabled: bool

If true, the server retains dead-lettered jobs and drain_dead_letters can return them; if false, dead jobs are deleted and drain always returns empty.

Trait Implementations

impl Clone for ServerInfo

fn clone(&self) -> ServerInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ServerInfo

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

Formats the value using the given formatter.

impl PartialEq for ServerInfo

fn eq(&self, other: &ServerInfo) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ServerInfo