pub struct PressureHandler {
reaction: PressureReaction,
current_level: Mutex<MemoryPressureLevel>,
}Expand description
Memory pressure handler for stratified pools.
Monitors memory pressure levels and triggers configured reactions.
Fields§
§reaction: PressureReactionConfigured reaction.
current_level: Mutex<MemoryPressureLevel>Current pressure level.
Implementations§
Source§impl PressureHandler
impl PressureHandler
Sourcepub fn new(reaction: PressureReaction) -> Self
pub fn new(reaction: PressureReaction) -> Self
Create a new pressure handler with the specified reaction.
Sourcepub fn no_reaction() -> Self
pub fn no_reaction() -> Self
Create a handler with no reaction.
Sourcepub fn shrink_to(target_utilization: f64) -> Self
pub fn shrink_to(target_utilization: f64) -> Self
Create a handler that shrinks to target utilization.
Sourcepub fn with_callback<F>(callback: F) -> Self
pub fn with_callback<F>(callback: F) -> Self
Create a handler with a custom callback.
Sourcepub fn current_level(&self) -> MemoryPressureLevel
pub fn current_level(&self) -> MemoryPressureLevel
Get the current pressure level.
Sourcepub fn on_pressure_change(
&self,
new_level: MemoryPressureLevel,
max_per_bucket: usize,
) -> Option<usize>
pub fn on_pressure_change( &self, new_level: MemoryPressureLevel, max_per_bucket: usize, ) -> Option<usize>
Handle a pressure level change.
Returns the number of buffers to retain per bucket (if shrinking).
Sourcefn is_higher_pressure(
new: MemoryPressureLevel,
old: MemoryPressureLevel,
) -> bool
fn is_higher_pressure( new: MemoryPressureLevel, old: MemoryPressureLevel, ) -> bool
Check if new pressure level is higher than old.
Sourcefn pressure_ordinal(level: MemoryPressureLevel) -> u8
fn pressure_ordinal(level: MemoryPressureLevel) -> u8
Get ordinal value for pressure level comparison.
Sourcefn pressure_severity(level: MemoryPressureLevel) -> f64
fn pressure_severity(level: MemoryPressureLevel) -> f64
Get severity factor (0.0 to 1.0) for pressure level.
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for PressureHandler
impl !RefUnwindSafe for PressureHandler
impl Send for PressureHandler
impl Sync for PressureHandler
impl Unpin for PressureHandler
impl !UnwindSafe for PressureHandler
Blanket Implementations§
§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<F, W, T, D> Deserialize<With<T, W>, D> for F
impl<F, W, T, D> Deserialize<With<T, W>, D> for F
§fn deserialize(
&self,
deserializer: &mut D,
) -> Result<With<T, W>, <D as Fallible>::Error>
fn deserialize( &self, deserializer: &mut D, ) -> Result<With<T, W>, <D as Fallible>::Error>
Deserializes using the given deserializer
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Gets the layout of the type.