Struct throttling::token_bucket::TokenBucket

pub struct TokenBucket { /* private fields */ }

Implementations

impl TokenBucket

pub fn new( max_cpu_tokens: u64, cur_cpu_tokens: u64, cpu_token_recharge_rate: u64, default_cpu_cost: u64, max_message_tokens: u64, cur_message_tokens: u64, message_token_recharge_rate: u64, default_message_cost: u64 ) -> Self

pub fn full( max_cpu_tokens: u64, cpu_token_recharge_rate: u64, default_cpu_cost: u64, max_message_tokens: u64, message_token_recharge_rate: u64, default_message_cost: u64 ) -> Self

pub fn empty( max_cpu_tokens: u64, cpu_token_recharge_rate: u64, default_cpu_cost: u64, max_message_tokens: u64, message_token_recharge_rate: u64, default_message_cost: u64 ) -> Self

pub fn set_max_throttled_counter(&mut self, max_throttled_counter: u64)

pub fn throttle_default(&mut self) -> ThrottleResult

pub fn throttle( &mut self, cpu_cost: u64, message_size_cost: u64 ) -> ThrottleResult

Trait Implementations

impl FromStr for TokenBucket

type Err = String

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<Self, String>

Parses a string s to return a value of this type.

impl MallocSizeOf for TokenBucket

fn size_of(&self, ops: &mut MallocSizeOfOps) -> usize

Measure the heap usage of all descendant heap-allocated structures, but not the space taken up by the value itself.