Struct QueueAutoScaler

Source

pub struct QueueAutoScaler { /* private fields */ }

Expand description

Auto-scaler that manages dynamic queue resizing

Implementations§

Source §

impl QueueAutoScaler

Source

pub fn new(config: AutoScaleConfig) -> Self

Create a new auto-scaler with the given configuration

Source

pub fn on_event_processed<M: Message>( &mut self, queue: &mut PriorityEventQueue<M>, ) -> Option<ScalingDecision>

Process an event and potentially trigger scaling

Source

pub fn evaluate_scaling<M: Message>( &mut self, queue: &mut PriorityEventQueue<M>, ) -> Option<ScalingDecision>

Evaluate whether scaling is needed

Source

pub fn metrics(&self) -> ScalingMetrics

Get current scaling metrics for monitoring

Auto Trait Implementations§

§

impl UnwindSafe for QueueAutoScaler

Blanket Implementations§

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> From<T> for T

Source §

fn from(t: T) -> T

Returns the argument unchanged.

Source §

impl<T> Inspectable for T

Source §

fn inspect(self, label: &str) -> Self
where Self: Debug,

Inspect this value with a label

Source §

fn inspect_if(self, condition: bool, label: &str) -> Self
where Self: Debug,

Conditionally inspect this value

Source §

fn inspect_with<F>(self, label: &str, f: F) -> Self
where F: FnOnce(&Self) -> String,

Inspect with a custom formatter

Source §

fn tap<F>(self, f: F) -> Self
where F: FnOnce(&Self),

Tap into the value for side effects

Source §

fn tap_if<F>(self, condition: bool, f: F) -> Self
where F: FnOnce(&Self),

Conditionally tap into the value

Source §

impl<T, U> Into 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, U> TryFrom 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>::Error>

Performs the conversion.

Source §

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

Source §

type Error = >::Error

The type returned in the event of a conversion error.

Source §

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

Performs the conversion.

Source §

QueueAutoScaler

Struct QueueAutoScaler

Implementations§

impl QueueAutoScaler

pub fn new(config: AutoScaleConfig) -> Self

pub fn on_event_processed<M: Message>( &mut self, queue: &mut PriorityEventQueue<M>, ) -> Option<ScalingDecision>

pub fn evaluate_scaling<M: Message>( &mut self, queue: &mut PriorityEventQueue<M>, ) -> Option<ScalingDecision>

pub fn metrics(&self) -> ScalingMetrics

Auto Trait Implementations§

impl Freeze for QueueAutoScaler

impl RefUnwindSafe for QueueAutoScaler

impl Send for QueueAutoScaler

impl Sync for QueueAutoScaler

impl Unpin for QueueAutoScaler

impl UnwindSafe for QueueAutoScaler

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Inspectable for T

fn inspect(self, label: &str) -> Self
where Self: Debug,

fn inspect_if(self, condition: bool, label: &str) -> Self
where Self: Debug,

fn inspect_with<F>(self, label: &str, f: F) -> Self
where F: FnOnce(&Self) -> String,

fn tap<F>(self, f: F) -> Self
where F: FnOnce(&Self),

fn tap_if<F>(self, condition: bool, f: F) -> Self
where F: FnOnce(&Self),

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

fn into(self) -> U

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

type Error = Infallible

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

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

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

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

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

QueueAutoScaler

Struct QueueAutoScaler Copy item path

Implementations§

impl QueueAutoScaler

pub fn new(config: AutoScaleConfig) -> Self

pub fn on_event_processed<M: Message>( &mut self, queue: &mut PriorityEventQueue<M>, ) -> Option<ScalingDecision>

pub fn evaluate_scaling<M: Message>( &mut self, queue: &mut PriorityEventQueue<M>, ) -> Option<ScalingDecision>

pub fn metrics(&self) -> ScalingMetrics

Auto Trait Implementations§

impl Freeze for QueueAutoScaler

impl RefUnwindSafe for QueueAutoScaler

impl Send for QueueAutoScaler

impl Sync for QueueAutoScaler

impl Unpin for QueueAutoScaler

impl UnwindSafe for QueueAutoScaler

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Inspectable for T

fn inspect(self, label: &str) -> Selfwhere Self: Debug,

fn inspect_if(self, condition: bool, label: &str) -> Selfwhere Self: Debug,

fn inspect_with<F>(self, label: &str, f: F) -> Selfwhere F: FnOnce(&Self) -> String,

fn tap<F>(self, f: F) -> Selfwhere F: FnOnce(&Self),

fn tap_if<F>(self, condition: bool, f: F) -> Selfwhere F: FnOnce(&Self),

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

fn into(self) -> U

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

type Error = Infallible

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

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

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

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

impl<T> Message for Twhere T: Send + 'static,

Struct QueueAutoScaler

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

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

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

fn inspect(self, label: &str) -> Self
where Self: Debug,

fn inspect_if(self, condition: bool, label: &str) -> Self
where Self: Debug,

fn inspect_with<F>(self, label: &str, f: F) -> Self
where F: FnOnce(&Self) -> String,

fn tap<F>(self, f: F) -> Self
where F: FnOnce(&Self),

fn tap_if<F>(self, condition: bool, f: F) -> Self
where F: FnOnce(&Self),

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

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

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

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