Skip to main content

MemoryReport

Struct MemoryReport 

Source
#[non_exhaustive]
pub struct MemoryReport {
Show 42 fields pub group_cache: CollectionStats, pub device_registry_cache: CollectionStats, pub lid_pn_lid_entries: CollectionStats, pub lid_pn_pn_entries: CollectionStats, pub recent_messages: CollectionStats, pub sender_key_device_cache: CollectionStats, pub group_devices_memo: CollectionStats, pub dm_devices_memo: CollectionStats, pub message_retry_counts: u64, pub undecryptable_dispatched: u64, pub pdo_pending_requests: u64, pub pdo_requested: u64, pub history_sync_tasks: CollectionStats, pub history_sync_tasks_peak: u64, pub history_sync_payload_bytes_peak: u64, pub session_locks: u64, pub chat_lanes: u64, pub group_distribution_locks: u64, pub group_distribution_lock_evictions: u64, pub group_distribution_lock_eviction_blocks: u64, pub resend_rate_limiter_chats: u64, pub transport_ack_queue: usize, pub delivery_receipt_queue: usize, pub response_waiters: usize, pub node_waiters: usize, pub pending_retries: usize, pub presence_subscriptions: usize, pub app_state_key_requests: usize, pub app_state_syncing: usize, pub signal_sessions: CollectionStats, pub signal_identities: CollectionStats, pub signal_sender_keys: CollectionStats, pub plugins: u64, pub plugin_install_tasks: u64, pub plugin_connection_tasks: u64, pub plugin_connection_generations: u64, pub plugin_core_event_subscriptions: u64, pub plugin_event_endpoints: u64, pub plugin_event_endpoint_capacity: u64, pub plugin_event_queue: CollectionStats, pub chatstate_handlers: usize, pub custom_enc_handlers: usize,
}
Expand description

On-demand report of the client’s internal collections: entry counts plus estimated retained heap bytes for the memory-dominant caches.

Counts are approximate (caches may have pending evictions); byte figures are honest estimates (encoded-size proxies for Signal records, payload sums elsewhere — see wacore::stats::HeapSize), suitable for per-session attribution and leak detection, not byte-exact accounting. Store-backed caches report bytes: 0 — their entries live outside this process.

Call Client::memory_report to obtain one. Nothing is computed unless called.

Fields (Non-exhaustive)§

This struct is marked as non-exhaustive
Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.
§group_cache: CollectionStats§device_registry_cache: CollectionStats§lid_pn_lid_entries: CollectionStats§lid_pn_pn_entries: CollectionStats

Entry count of the PN-direction map. Both maps share the same Arc<LidPnEntry> payloads, attributed to Self::lid_pn_lid_entries; bytes here cover only entries the LID map no longer holds (normally 0), so the total counts each once.

§recent_messages: CollectionStats§sender_key_device_cache: CollectionStats§group_devices_memo: CollectionStats§dm_devices_memo: CollectionStats§message_retry_counts: u64§undecryptable_dispatched: u64§pdo_pending_requests: u64§pdo_requested: u64§history_sync_tasks: CollectionStats

Queued/running history-sync tasks and their logical compressed-payload byte sum. A shared Bytes slice may retain a larger backing allocation, whose capacity is not exposed by the type.

§history_sync_tasks_peak: u64

Lifetime high-water mark of queued/running history-sync tasks.

§history_sync_payload_bytes_peak: u64

Lifetime high-water mark of logical compressed-payload bytes.

§session_locks: u64§chat_lanes: u64§group_distribution_locks: u64§group_distribution_lock_evictions: u64

Cumulative capacity evictions; poll successive reports to derive a rate.

§group_distribution_lock_eviction_blocks: u64

Cumulative attempts that kept a live lane and temporarily exceeded capacity.

§resend_rate_limiter_chats: u64§transport_ack_queue: usize

Deferred acks queued for the transport-ack worker. Unbounded, and each entry retains the full inbound node plus a flush guard, so a stalled transport shows up here as a growing backlog.

§delivery_receipt_queue: usize

Delivery receipts queued for their worker, same shape as above.

§response_waiters: usize§node_waiters: usize§pending_retries: usize§presence_subscriptions: usize§app_state_key_requests: usize§app_state_syncing: usize§signal_sessions: CollectionStats§signal_identities: CollectionStats§signal_sender_keys: CollectionStats§plugins: u64
Available on crate feature plugins only.
§plugin_install_tasks: u64
Available on crate feature plugins only.
§plugin_connection_tasks: u64
Available on crate feature plugins only.
§plugin_connection_generations: u64
Available on crate feature plugins only.
§plugin_core_event_subscriptions: u64
Available on crate feature plugins only.
§plugin_event_endpoints: u64
Available on crate feature plugins only.
§plugin_event_endpoint_capacity: u64
Available on crate feature plugins only.
§plugin_event_queue: CollectionStats
Available on crate feature plugins only.

Unique custom-event envelopes and payload bytes still retained in endpoint queues.

§chatstate_handlers: usize§custom_enc_handlers: usize

Implementations§

Source§

impl MemoryReport

Source

pub fn total_estimated_bytes(&self) -> u64

Sum of every estimated byte figure in the report.

Trait Implementations§

Source§

impl Clone for MemoryReport

Source§

fn clone(&self) -> MemoryReport

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for MemoryReport

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Display for MemoryReport

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> AggregateExpressionMethods for T

Source§

fn aggregate_distinct(self) -> Self::Output
where Self: DistinctDsl,

DISTINCT modifier for aggregate functions Read more
Source§

fn aggregate_all(self) -> Self::Output
where Self: AllDsl,

ALL modifier for aggregate functions Read more
Source§

fn aggregate_filter<P>(self, f: P) -> Self::Output
where P: AsExpression<Bool>, Self: FilterDsl<<P as AsExpression<Bool>>::Expression>,

Add an aggregate function filter Read more
Source§

fn aggregate_order<O>(self, o: O) -> Self::Output
where Self: OrderAggregateDsl<O>,

Add an aggregate function order Read more
Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> Downcast for T
where T: Any,

Source§

fn into_any(self: Box<T>) -> Box<dyn Any>

Converts Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>, which can then be downcast into Box<dyn ConcreteType> where ConcreteType implements Trait.
Source§

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

Converts Rc<Trait> (where Trait: Downcast) to Rc<Any>, which can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait.
Source§

fn as_any(&self) -> &(dyn Any + 'static)

Converts &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s.
Source§

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Converts &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s.
Source§

impl<T> DowncastSend for T
where T: Any + Send,

Source§

fn into_any_send(self: Box<T>) -> Box<dyn Any + Send>

Converts Box<Trait> (where Trait: DowncastSend) to Box<dyn Any + Send>, which can then be downcast into Box<ConcreteType> where ConcreteType implements Trait.
Source§

impl<T> DowncastSync for T
where T: Any + Send + Sync,

Source§

fn into_any_sync(self: Box<T>) -> Box<dyn Any + Send + Sync>

Converts Box<Trait> (where Trait: DowncastSync) to Box<dyn Any + Send + Sync>, which can then be downcast into Box<ConcreteType> where ConcreteType implements Trait.
Source§

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync>

Converts Arc<Trait> (where Trait: DowncastSync) to Arc<Any>, which can then be downcast into Arc<ConcreteType> where ConcreteType implements Trait.
Source§

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoSql for T

Source§

fn into_sql<T>(self) -> Self::Expression

Convert self to an expression for Diesel’s query builder. Read more
Source§

fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression
where &'a Self: AsExpression<T>, T: SqlType + TypedExpressionType,

Convert &self to an expression for Diesel’s query builder. Read more
Source§

impl<T> MaybeSend for T
where T: Send + ?Sized,

Source§

impl<T> MaybeSendSync for T
where T: Send + Sync + ?Sized,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> Spawnable for T
where T: Send + 'static,

Source§

impl<T> ToCompactString for T
where T: Display,

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T> ToString for T
where T: Display + ?Sized,

Source§

fn to_string(&self) -> String

Converts the given value to a String. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WindowExpressionMethods for T

Source§

fn over(self) -> Self::Output
where Self: OverDsl,

Turn a function call into a window function call Read more
Source§

fn window_filter<P>(self, f: P) -> Self::Output
where P: AsExpression<Bool>, Self: FilterDsl<<P as AsExpression<Bool>>::Expression>,

Add a filter to the current window function Read more
Source§

fn partition_by<E>(self, expr: E) -> Self::Output
where Self: PartitionByDsl<E>,

Add a partition clause to the current window function Read more
Source§

fn window_order<E>(self, expr: E) -> Self::Output
where Self: OrderWindowDsl<E>,

Add a order clause to the current window function Read more
Source§

fn frame_by<E>(self, expr: E) -> Self::Output
where Self: FrameDsl<E>,

Add a frame clause to the current window function Read more