Struct Quota

struct Quota {
    leases: FnvHashMap<Rc<str>, Lease>,
    dim_count: FnvHashMap<Rc<str>, u64>,
    expiry_timeouts: BTreeSet<(NonZeroU64, Rc<str>)>,
}

Fields

leases: FnvHashMap<Rc<str>, Lease>

dim_count: FnvHashMap<Rc<str>, u64>

expiry_timeouts: BTreeSet<(NonZeroU64, Rc<str>)>

Implementations

impl Quota

fn rdb_load(rdb: &mut RdbLoadIo, version: i32) -> RedisResult<Self>

fn rdb_save(&mut self, rdb: &mut RdbSaveIo)

fn aof_rewrite( &mut self, aof: &mut AofRewriteIo, key: RedisString, ) -> RedisResult<()>

fn mem_usage(&self) -> usize

impl Quota

fn gc(&mut self, now_ts: NonZeroU64)

fn expires_at(&self) -> Option<NonZeroU64>

fn remove_lease(&mut self, id: &str) -> bool

fn insert_lease(&mut self, lease: Lease)

fn renew_lease( &mut self, id: &str, now: NonZeroU64, expires_at: Option<NonZeroU64>, ) -> bool

Trait Implementations

impl AofRewrite<Tmp> for Quota

const FN: AofRewriteFn<Self> = {quota::Quota::aof_rewrite as for<'a, 'b> fn(&'a mut quota::Quota, &'b mut redis_module_ext::data_type::AofRewriteIo, redis_module::RedisString) -> std::result::Result<(), redis_module::RedisError>}

fn extern_fn() -> Option<unsafe extern "C" fn(*mut RedisModuleIO, *mut RedisModuleString, *mut c_void)>

impl Clone for Quota

fn clone(&self) -> Quota

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C> Decode<C> for Quota

fn decode<D: Decoder<Context = C>>(decoder: &mut D) -> Result<Self, DecodeError>

Attempt to decode this type with the given Decode.

impl DeepSizeOf for Quota

fn deep_size_of_children(&self, context: &mut Context) -> usize

Returns an estimation of the heap-managed storage of this object. This does not include the size of the object itself.

fn deep_size_of(&self) -> usize

Returns an estimation of a total size of memory owned by the object, including heap-managed storage.

impl Default for Quota

fn default() -> Quota

Returns the “default value” for a type.

impl Encode for Quota

fn encode<E: Encoder>(&self, encoder: &mut E) -> Result<(), EncodeError>

Encode a given type.

impl MemUsage<Tmp> for Quota

const FN: MemUsageFn<Self> = {quota::Quota::mem_usage as for<'a> fn(&'a quota::Quota) -> usize}

fn extern_fn() -> Option<unsafe extern "C" fn(*const c_void) -> usize>

impl RdbLoad<Tmp> for Quota

const FN: RdbLoadFn<Self> = {quota::Quota::rdb_load as for<'a> fn(&'a mut redis_module_ext::data_type::RdbLoadIo, i32) -> std::result::Result<quota::Quota, redis_module::RedisError>}

fn extern_fn() -> Option<unsafe extern "C" fn(*mut RedisModuleIO, i32) -> *mut c_void>

impl RdbSave<Tmp> for Quota

const FN: RdbSaveFn<Self> = {quota::Quota::rdb_save as for<'a, 'b> fn(&'a mut quota::Quota, &'b mut redis_module_ext::data_type::RdbSaveIo)}

fn extern_fn() -> Option<unsafe extern "C" fn(*mut RedisModuleIO, *mut c_void)>

impl RedisDataType for Quota

const NAME: &'static str = "scufquota"

const VERSION: i32 = 0i32

fn module_methods(_: &Context) -> RedisModuleTypeMethods

#[doc(hidden)] fn register(ctx: &Context) -> Result<(), &'static str>

#[doc(hidden)] fn redis_ty(ptr: *mut RedisModuleType) -> Option<RedisType>