Struct RBucket 

pub struct RBucket<V> { /* private fields */ }

Implementations

impl<V> RBucket<V>

where V: Serialize + DeserializeOwned + Send + Sync + 'static,

pub fn new( connection_manager: Arc<SyncRedisConnectionManager>, name: String, ) -> Self

pub fn with_ttl(self, ttl: Duration) -> Self

pub fn set(&self, value: &V) -> RedissonResult<()>

pub fn set_with_ttl(&self, value: &V, ttl: Duration) -> RedissonResult<()>

pub fn get(&self) -> RedissonResult<Option<V>>

pub fn get_and_set(&self, value: &V) -> RedissonResult<Option<V>>

pub fn compare_and_set( &self, expect: Option<&V>, update: &V, ) -> RedissonResult<bool>

pub fn increment(&self, delta: i64) -> RedissonResult<i64>

where V: From<i64> + Into<i64>,

pub fn decrement(&self, delta: i64) -> RedissonResult<i64>

where V: From<i64> + Into<i64>,

Trait Implementations

impl<V> RLockable for RBucket<V>

where V: Serialize + DeserializeOwned + Send + Sync + 'static,

fn get_lock(&self) -> RLock

Acquire a distributed lock on an object

fn get_fair_lock(&self) -> RFairLock

Acquires a fair lock on an object

fn lock(&self) -> RedissonResult<()>

Locking objects

fn try_lock(&self) -> RedissonResult<bool>

Attempt to lock the object

fn try_lock_timeout(&self, wait_time: Duration) -> RedissonResult<bool>

Attempt to lock the object with a timeout

fn lock_lease(&self, lease_time: Duration) -> RedissonResult<()>

Lock the object and set the lease time

fn unlock(&self) -> RedissonResult<bool>

Unlocking the object

fn force_unlock(&self) -> RedissonResult<bool>

Force unlocking an object

fn is_locked(&self) -> RedissonResult<bool>

Check if it is locked

fn is_held_by_current_thread(&self) -> bool

Checks whether the current thread holds the lock

impl<V> RObject for RBucket<V>

where V: Serialize + DeserializeOwned + Send + Sync + 'static,

fn get_name(&self) -> &str

Getting the object name

fn delete(&self) -> RedissonResult<bool>

Deleting objects

fn rename(&self, new_name: &str) -> RedissonResult<()>

Renaming Objects

fn is_exists(&self) -> RedissonResult<bool>

Checks if the object exists

fn move_to_db(&self, db_index: i32) -> RedissonResult<bool>

Move objects to other databases

fn get_expire_time(&self) -> RedissonResult<Option<Duration>>

Getting the expiration time

fn expire(&self, duration: Duration) -> RedissonResult<bool>

Set an expiration time

fn expire_at(&self, timestamp: i64) -> RedissonResult<bool>

Set an expiration point

fn clear_expire(&self) -> RedissonResult<bool>

Clear the expiration time