Struct InsurancePoolUpdate 

pub struct InsurancePoolUpdate {
    pub topic: String,
    pub event_type: String,
    pub timestamp: u64,
    pub data: Vec<InsurancePool>,
}

Represents a WebSocket insurance pool update event.

Contains real-time updates to insurance pool balances for various symbols. Push frequency: 1 second for USDT contracts, USDC contracts, and inverse contracts.

Fields

topic: String

The WebSocket topic for the event (e.g., “insurance.USDT”, “insurance.USDC”, “insurance.inverse”).

Specifies the data stream for the insurance pool update. Bots use this to determine which contract group the update belongs to.

event_type: String

The event type (e.g., “snapshot”, “delta”).

Snapshot contains the full current state, delta contains incremental changes. Bots should use snapshot to initialize state and delta to update it.

timestamp: u64

The timestamp of the event in milliseconds.

Indicates when the insurance pool update was generated by the system. Bots use this to ensure data freshness and time-based analysis.

data: Vec<InsurancePool>

The insurance pool data.

Contains a list of insurance pool entries. Each entry represents the balance for a specific symbol or group of symbols. No event will be published if all insurance pool balances remain unchanged.

Implementations

impl InsurancePoolUpdate

pub fn contract_group(&self) -> Option<&str>

Returns the contract group from the topic.

Extracts the contract group identifier from the WebSocket topic. Examples:

• “insurance.USDT” -> “USDT”
• “insurance.USDC” -> “USDC”
• “insurance.inverse” -> “inverse”

pub fn is_snapshot(&self) -> bool

Returns true if this is a snapshot update.

Snapshot updates contain the full insurance pool state and should replace the local state for the corresponding contract group.

pub fn is_delta(&self) -> bool

Returns true if this is a delta update.

Delta updates contain incremental changes and should be applied to the local insurance pool state.

pub fn timestamp_datetime(&self) -> DateTime<Utc>

Returns the timestamp as a chrono DateTime.

pub fn count(&self) -> usize

Returns the number of insurance pool entries in this update.

pub fn is_empty(&self) -> bool

Returns true if there are no insurance pool entries in this update.

pub fn find_by_symbol(&self, symbol: &str) -> Option<&InsurancePool>

Finds an insurance pool entry for a specific symbol.

Returns the first matching insurance pool entry for the given symbol. Note: For shared insurance pools, the symbols field may contain multiple symbols or a group identifier, so this may not find all relevant entries.

pub fn filter_by_coin(&self, coin: &str) -> Vec<&InsurancePool>

Finds all insurance pool entries for a specific coin.

pub fn total_balance(&self) -> f64

Returns the total balance across all insurance pools in this update.

Sums the balances of all insurance pool entries in this update. Useful for monitoring the overall health of a contract group’s insurance.

pub fn count_positive(&self) -> usize

Returns the number of insurance pools with positive balance.

pub fn count_non_positive(&self) -> usize

Returns the number of insurance pools with non-positive balance.

These are pools that may be at risk of triggering ADL (Auto-Deleveraging).

pub fn min_balance(&self) -> Option<f64>

Returns the minimum balance among all insurance pools.

pub fn max_balance(&self) -> Option<f64>

Returns the maximum balance among all insurance pools.

pub fn average_balance(&self) -> Option<f64>

Returns the average balance across all insurance pools.

pub fn stale_pools(&self) -> Vec<&InsurancePool>

Returns all insurance pools that are stale (older than 5 minutes).

Note: The WebSocket pushes updates every 1 second when changes occur, so stale entries in a fresh update may indicate issues with specific symbols.

pub fn latest_update_time(&self) -> Option<u64>

Returns the time of the most recent update among all insurance pools.

pub fn earliest_update_time(&self) -> Option<u64>

Returns the time of the oldest update among all insurance pools.

Trait Implementations

impl Clone for InsurancePoolUpdate

fn clone(&self) -> InsurancePoolUpdate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InsurancePoolUpdate

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for InsurancePoolUpdate

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for InsurancePoolUpdate

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

where __S: Serializer,

Serialize this value into the given Serde serializer.