Struct RuntimeSnapshotInput 

pub struct RuntimeSnapshotInput {

    pub instance_id: Uuid,
    pub hostname: Option<String>,
    pub pid: i32,
    pub version: String,
    pub started_at: DateTime<Utc>,
    pub snapshot_interval_ms: i64,
    pub healthy: bool,
    pub postgres_connected: bool,
    pub poll_loop_alive: bool,
    pub heartbeat_alive: bool,
    pub maintenance_alive: bool,
    pub shutting_down: bool,
    pub leader: bool,
    pub global_max_workers: Option<u32>,
    pub queues: Vec<QueueRuntimeSnapshot>,
}

Data written by a worker runtime into the observability snapshot table.

Fields

instance_id: Uuid

hostname: Option<String>

pid: i32

version: String

started_at: DateTime<Utc>

snapshot_interval_ms: i64

healthy: bool

postgres_connected: bool

poll_loop_alive: bool

heartbeat_alive: bool

maintenance_alive: bool

shutting_down: bool

leader: bool

global_max_workers: Option<u32>

queues: Vec<QueueRuntimeSnapshot>

Trait Implementations

impl Clone for RuntimeSnapshotInput

fn clone(&self) -> RuntimeSnapshotInput

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RuntimeSnapshotInput

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RuntimeSnapshotInput

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RuntimeSnapshotInput

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

where __S: Serializer,

Serialize this value into the given Serde serializer.