pub struct CallableCache {
pub local_cache: LocalCache,
pub remote_cache: RedisCache,
}
Expand description
Main cache structure that combines local in-memory caching with remote Redis storage.
Provides a unified interface for accessing data with automatic fallback to Redis when items aren’t found in the local cache.
Fields§
§local_cache: LocalCache
§remote_cache: RedisCache
Implementations§
Source§impl CallableCache
impl CallableCache
Sourcepub async fn get_account_by_trunk_ddi(
self,
ddi_id: &str,
trunk_ip: &str,
) -> Result<Option<Arc<AccountLite>>, RedisError>
pub async fn get_account_by_trunk_ddi( self, ddi_id: &str, trunk_ip: &str, ) -> Result<Option<Arc<AccountLite>>, RedisError>
Retrieves an account by trunk IP and DDI, first checking the local cache and then Redis.
This function:
- Checks if the trunk-DDI combination exists in the local cache
- If found, retrieves the account ID and uses it to look up the account
- If not found in local cache, falls back to Redis lookup
- Caches the result for future use
§Arguments
ddi_id
- DDI identifier (typically a phone number)trunk_ip
- IP address of the trunk
§Returns
Result<Option<AccountLite>, RedisError>
- Account if found, None if not found, or a Redis error
Sourcepub async fn get_account_by_id(
self,
id: &str,
) -> Result<Option<Arc<AccountLite>>, RedisError>
pub async fn get_account_by_id( self, id: &str, ) -> Result<Option<Arc<AccountLite>>, RedisError>
Sourcepub async fn get_accounts(self) -> Result<Arc<Vec<AccountLite>>, RedisError>
pub async fn get_accounts(self) -> Result<Arc<Vec<AccountLite>>, RedisError>
Retrieves all accounts from Redis.
§Returns
Result<Vec<AccountLite>, RedisError>
- Vec of AccountLite
Source§impl CallableCache
impl CallableCache
Sourcepub async fn agent_status_set(
&self,
account_id: &str,
status: &AgentStatus,
) -> Result<(), RedisError>
pub async fn agent_status_set( &self, account_id: &str, status: &AgentStatus, ) -> Result<(), RedisError>
Store complete agent status
Sourcepub async fn agent_status_get(
&self,
account_id: &str,
user_id: &str,
) -> Result<Option<AgentStatus>, RedisError>
pub async fn agent_status_get( &self, account_id: &str, user_id: &str, ) -> Result<Option<AgentStatus>, RedisError>
Get complete agent status
Sourcepub async fn add_connected_agent(
&self,
account_id: &str,
user_id: &str,
agent_id: &str,
ws_connection_id: &str,
) -> Result<(), RedisError>
pub async fn add_connected_agent( &self, account_id: &str, user_id: &str, agent_id: &str, ws_connection_id: &str, ) -> Result<(), RedisError>
Track connected agents per account
pub async fn remove_connected_agent( &self, account_id: &str, user_id: &str, agent_id: &str, ws_connection_id: &str, ) -> Result<(), RedisError>
Sourcepub async fn get_connected_agents(
&self,
account_id: &str,
) -> Result<Vec<String>, RedisError>
pub async fn get_connected_agents( &self, account_id: &str, ) -> Result<Vec<String>, RedisError>
Get all connected agents for an account
Source§impl CallableCache
impl CallableCache
Sourcepub async fn get_assets(
self,
account_id: &str,
) -> Result<Vec<Asset>, RedisError>
pub async fn get_assets( self, account_id: &str, ) -> Result<Vec<Asset>, RedisError>
Source§impl CallableCache
impl CallableCache
pub async fn get_device_by_ident( self, account_id: &str, ident: &str, ) -> Result<Option<Arc<DeviceStruct>>, RedisError>
Sourcepub async fn get_devices(
self,
account_id: &str,
) -> Result<Arc<Vec<DeviceStruct>>, RedisError>
pub async fn get_devices( self, account_id: &str, ) -> Result<Arc<Vec<DeviceStruct>>, RedisError>
Sourcepub async fn get_device(
self,
account_id: &str,
device_id: &str,
) -> Result<Option<Arc<DeviceStruct>>, RedisError>
pub async fn get_device( self, account_id: &str, device_id: &str, ) -> Result<Option<Arc<DeviceStruct>>, RedisError>
Source§impl CallableCache
impl CallableCache
Source§impl CallableCache
impl CallableCache
Source§impl CallableCache
impl CallableCache
Sourcepub async fn get_proxy_by_id(
&mut self,
id: &str,
) -> Result<Option<Arc<Proxy>>, RedisError>
pub async fn get_proxy_by_id( &mut self, id: &str, ) -> Result<Option<Arc<Proxy>>, RedisError>
pub async fn get_proxies(&mut self) -> Result<Arc<Vec<Proxy>>, RedisError>
pub async fn get_proxies_local(self) -> Result<Arc<Vec<Proxy>>, RedisError>
Source§impl CallableCache
impl CallableCache
Sourcepub async fn queue_group_set(
&self,
queue: &QueueGroup,
) -> Result<(), RedisError>
pub async fn queue_group_set( &self, queue: &QueueGroup, ) -> Result<(), RedisError>
Store a QueueGroup
Sourcepub async fn queue_group_get(
&self,
account_id: &str,
queue_name: &str,
) -> Result<Option<QueueGroup>, RedisError>
pub async fn queue_group_get( &self, account_id: &str, queue_name: &str, ) -> Result<Option<QueueGroup>, RedisError>
Get a QueueGroup
Sourcepub async fn queue_group_delete(
&self,
account_id: &str,
queue_name: &str,
) -> Result<(), RedisError>
pub async fn queue_group_delete( &self, account_id: &str, queue_name: &str, ) -> Result<(), RedisError>
Delete a QueueGroup
Sourcepub async fn queue_group_list(
&self,
account_id: &str,
) -> Result<Vec<String>, RedisError>
pub async fn queue_group_list( &self, account_id: &str, ) -> Result<Vec<String>, RedisError>
Get all active queue names for an account
Sourcepub async fn queue_groups_get_all(
&self,
account_id: &str,
) -> Result<Vec<QueueGroup>, RedisError>
pub async fn queue_groups_get_all( &self, account_id: &str, ) -> Result<Vec<QueueGroup>, RedisError>
Get all QueueGroups for an account
Source§impl CallableCache
impl CallableCache
Sourcepub async fn get_region_by_id(
self,
id: &str,
) -> Result<Option<Arc<Region>>, RedisError>
pub async fn get_region_by_id( self, id: &str, ) -> Result<Option<Arc<Region>>, RedisError>
Sourcepub async fn get_regions_local(self) -> Result<Arc<Vec<Region>>, RedisError>
pub async fn get_regions_local(self) -> Result<Arc<Vec<Region>>, RedisError>
Sourcepub async fn get_regions(self) -> Result<Arc<Vec<Region>>, RedisError>
pub async fn get_regions(self) -> Result<Arc<Vec<Region>>, RedisError>
Source§impl CallableCache
impl CallableCache
Sourcepub async fn session_set(
&self,
account_id: &str,
session_data: &SessionData,
) -> Result<(), RedisError>
pub async fn session_set( &self, account_id: &str, session_data: &SessionData, ) -> Result<(), RedisError>
Store session with account isolation using SessionData struct
Sourcepub async fn session_get(
&self,
account_id: &str,
session_id: &str,
) -> Result<Option<SessionData>, RedisError>
pub async fn session_get( &self, account_id: &str, session_id: &str, ) -> Result<Option<SessionData>, RedisError>
Get session with account validation, returns SessionData
Sourcepub async fn session_create(
&self,
account_id: &str,
user_id: &str,
agent_id: &str,
ttl_seconds: u64,
) -> Result<SessionData, RedisError>
pub async fn session_create( &self, account_id: &str, user_id: &str, agent_id: &str, ttl_seconds: u64, ) -> Result<SessionData, RedisError>
Create and store a new session
Sourcepub async fn session_refresh(
&self,
account_id: &str,
session_id: &str,
ttl_seconds: u64,
) -> Result<Option<SessionData>, RedisError>
pub async fn session_refresh( &self, account_id: &str, session_id: &str, ttl_seconds: u64, ) -> Result<Option<SessionData>, RedisError>
Update session expiry (for session refresh)
Sourcepub async fn session_delete(
&self,
account_id: &str,
session_id: &str,
) -> Result<(), RedisError>
pub async fn session_delete( &self, account_id: &str, session_id: &str, ) -> Result<(), RedisError>
Delete session
Sourcepub async fn session_get_active(
&self,
account_id: &str,
) -> Result<Vec<SessionData>, RedisError>
pub async fn session_get_active( &self, account_id: &str, ) -> Result<Vec<SessionData>, RedisError>
Get all active sessions for an account
Sourcepub async fn session_cleanup_expired(
&self,
account_id: &str,
) -> Result<u32, RedisError>
pub async fn session_cleanup_expired( &self, account_id: &str, ) -> Result<u32, RedisError>
Clean up expired sessions for an account
Source§impl CallableCache
impl CallableCache
Sourcepub async fn get_trunks(
self,
account_id: &str,
) -> Result<Vec<Trunk>, RedisError>
pub async fn get_trunks( self, account_id: &str, ) -> Result<Vec<Trunk>, RedisError>
Source§impl CallableCache
impl CallableCache
Sourcepub async fn get_user_by_id(
&self,
id: &str,
) -> Result<Option<Arc<User>>, RedisError>
pub async fn get_user_by_id( &self, id: &str, ) -> Result<Option<Arc<User>>, RedisError>
Retrieves a user by its ID, first checking the local cache and then Redis.
Sourcepub async fn get_user_by_ident(
&self,
ident: &str,
) -> Result<Option<Arc<User>>, RedisError>
pub async fn get_user_by_ident( &self, ident: &str, ) -> Result<Option<Arc<User>>, RedisError>
Retrieves a user by identifier (email), first checking the local cache and then Redis.
Source§impl CallableCache
impl CallableCache
Sourcepub async fn get_ws_account(
&self,
ws_connection_id: &str,
) -> Result<Option<String>, RedisError>
pub async fn get_ws_account( &self, ws_connection_id: &str, ) -> Result<Option<String>, RedisError>
Get account_id for a WebSocket connection
Sourcepub async fn get_account_connections(
&self,
account_id: &str,
) -> Result<Vec<String>, RedisError>
pub async fn get_account_connections( &self, account_id: &str, ) -> Result<Vec<String>, RedisError>
Get all WebSocket connections for an account
Sourcepub async fn publish_account_event(
&self,
account_id: &str,
event: &RedisEvent,
) -> Result<(), RedisError>
pub async fn publish_account_event( &self, account_id: &str, event: &RedisEvent, ) -> Result<(), RedisError>
Publish event to account-specific channel
Source§impl CallableCache
impl CallableCache
Sourcepub async fn insert_jambonz_entry(
&self,
entry: JambonzEntry,
) -> Result<(), RedisError>
pub async fn insert_jambonz_entry( &self, entry: JambonzEntry, ) -> Result<(), RedisError>
Sourcepub async fn get_jambonz_entry(
&self,
sip_realm: &str,
) -> Result<Option<Arc<JambonzEntry>>, RedisError>
pub async fn get_jambonz_entry( &self, sip_realm: &str, ) -> Result<Option<Arc<JambonzEntry>>, RedisError>
Sourcepub async fn get_all_jambonz_entries(
&self,
) -> Result<Vec<Arc<JambonzEntry>>, RedisError>
pub async fn get_all_jambonz_entries( &self, ) -> Result<Vec<Arc<JambonzEntry>>, RedisError>
Retrieves all Jambonz entries.
§Returns
Result<Vec<Arc<JambonzEntry>>, RedisError>
- List of all entries
Sourcepub async fn delete_jambonz_entry(
&self,
sip_realm: &str,
) -> Result<bool, RedisError>
pub async fn delete_jambonz_entry( &self, sip_realm: &str, ) -> Result<bool, RedisError>
Sourcepub async fn insert_jambonz_entries(
&self,
entries: Vec<JambonzEntry>,
) -> Result<(), RedisError>
pub async fn insert_jambonz_entries( &self, entries: Vec<JambonzEntry>, ) -> Result<(), RedisError>
Source§impl CallableCache
impl CallableCache
Sourcepub async fn insert_contact(&self, contact: Contact) -> Result<(), RedisError>
pub async fn insert_contact(&self, contact: Contact) -> Result<(), RedisError>
Sourcepub async fn get_contact_by_id(
&self,
account_id: &str,
contact_id: &str,
) -> Result<Option<Arc<Contact>>, RedisError>
pub async fn get_contact_by_id( &self, account_id: &str, contact_id: &str, ) -> Result<Option<Arc<Contact>>, RedisError>
Sourcepub async fn get_contact_by_ident(
&self,
account_id: &str,
identifier: &str,
) -> Result<Option<Arc<Contact>>, RedisError>
pub async fn get_contact_by_ident( &self, account_id: &str, identifier: &str, ) -> Result<Option<Arc<Contact>>, RedisError>
Sourcepub async fn get_contacts_by_account(
&self,
account_id: &str,
) -> Result<Vec<Arc<Contact>>, RedisError>
pub async fn get_contacts_by_account( &self, account_id: &str, ) -> Result<Vec<Arc<Contact>>, RedisError>
Sourcepub async fn get_contacts_by_group(
&self,
account_id: &str,
group: &str,
) -> Result<Vec<Arc<Contact>>, RedisError>
pub async fn get_contacts_by_group( &self, account_id: &str, group: &str, ) -> Result<Vec<Arc<Contact>>, RedisError>
Sourcepub async fn delete_contact(
&self,
account_id: &str,
contact_id: &str,
) -> Result<bool, RedisError>
pub async fn delete_contact( &self, account_id: &str, contact_id: &str, ) -> Result<bool, RedisError>
Sourcepub async fn insert_contacts(
&self,
contacts: Vec<Contact>,
) -> Result<(), RedisError>
pub async fn insert_contacts( &self, contacts: Vec<Contact>, ) -> Result<(), RedisError>
Source§impl CallableCache
impl CallableCache
Sourcepub async fn new() -> CallableCache
pub async fn new() -> CallableCache
Creates a new CallableCache instance with local and remote caches.
§Returns
CallableCache
- The new cache instance
Sourcepub fn redis_connection(&self) -> MultiplexedConnection
pub fn redis_connection(&self) -> MultiplexedConnection
Raw Redis connection access for custom operations
Trait Implementations§
Source§impl Clone for CallableCache
impl Clone for CallableCache
Source§fn clone(&self) -> CallableCache
fn clone(&self) -> CallableCache
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl RedisHelpers for CallableCache
impl RedisHelpers for CallableCache
fn set_session<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
session_data: &'life2 SessionData,
) -> Pin<Box<dyn Future<Output = Result<(), RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn get_session<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
session_id: &'life2 str,
) -> Pin<Box<dyn Future<Output = Result<Option<SessionData>, RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn create_session<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
user_id: &'life2 str,
agent_id: &'life3 str,
ttl_seconds: u64,
) -> Pin<Box<dyn Future<Output = Result<SessionData, RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn refresh_session<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
session_id: &'life2 str,
ttl_seconds: u64,
) -> Pin<Box<dyn Future<Output = Result<Option<SessionData>, RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn delete_session<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
session_id: &'life2 str,
) -> Pin<Box<dyn Future<Output = Result<(), RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn get_active_sessions<'life0, 'life1, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
) -> Pin<Box<dyn Future<Output = Result<Vec<SessionData>, RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn cleanup_expired_sessions<'life0, 'life1, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
) -> Pin<Box<dyn Future<Output = Result<u32, RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn set_agent_status<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
status: &'life2 AgentStatus,
) -> Pin<Box<dyn Future<Output = Result<(), RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn get_agent_status<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
user_id: &'life2 str,
) -> Pin<Box<dyn Future<Output = Result<Option<AgentStatus>, RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn add_connected_agent<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
user_id: &'life2 str,
agent_id: &'life3 str,
ws_connection_id: &'life4 str,
) -> Pin<Box<dyn Future<Output = Result<(), RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
fn remove_connected_agent<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
user_id: &'life2 str,
agent_id: &'life3 str,
ws_connection_id: &'life4 str,
) -> Pin<Box<dyn Future<Output = Result<(), RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
'life4: 'async_trait,
fn get_connected_agents<'life0, 'life1, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
) -> Pin<Box<dyn Future<Output = Result<Vec<String>, RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn queue_add<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
queue_name: &'life2 str,
item: &'life3 str,
priority: f64,
) -> Pin<Box<dyn Future<Output = Result<(), RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn queue_pop<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
queue_name: &'life2 str,
) -> Pin<Box<dyn Future<Output = Result<Option<String>, RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn queue_length<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
queue_name: &'life2 str,
) -> Pin<Box<dyn Future<Output = Result<usize, RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn publish_account_event<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
account_id: &'life1 str,
event: &'life2 RedisEvent,
) -> Pin<Box<dyn Future<Output = Result<(), RedisError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Auto Trait Implementations§
impl Freeze for CallableCache
impl !RefUnwindSafe for CallableCache
impl Send for CallableCache
impl Sync for CallableCache
impl Unpin for CallableCache
impl !UnwindSafe for CallableCache
Blanket Implementations§
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FmtForward for T
impl<T> FmtForward for T
Source§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self
to use its Binary
implementation when Debug
-formatted.Source§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self
to use its Display
implementation when
Debug
-formatted.Source§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self
to use its LowerExp
implementation when
Debug
-formatted.Source§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self
to use its LowerHex
implementation when
Debug
-formatted.Source§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self
to use its Octal
implementation when Debug
-formatted.Source§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self
to use its Pointer
implementation when
Debug
-formatted.Source§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self
to use its UpperExp
implementation when
Debug
-formatted.Source§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self
to use its UpperHex
implementation when
Debug
-formatted.Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
Source§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Source§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read moreSource§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read moreSource§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
Source§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
Source§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self
, then passes self.as_ref()
into the pipe function.Source§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self
, then passes self.as_mut()
into the pipe
function.Source§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self
, then passes self.deref()
into the pipe function.Source§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> Tap for T
impl<T> Tap for T
Source§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B>
of a value. Read moreSource§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B>
of a value. Read moreSource§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R>
view of a value. Read moreSource§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R>
view of a value. Read moreSource§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target
of a value. Read moreSource§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target
of a value. Read moreSource§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap()
only in debug builds, and is erased in release builds.Source§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut()
only in debug builds, and is erased in release
builds.Source§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow()
only in debug builds, and is erased in release
builds.Source§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut()
only in debug builds, and is erased in release
builds.Source§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref()
only in debug builds, and is erased in release
builds.Source§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut()
only in debug builds, and is erased in release
builds.Source§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref()
only in debug builds, and is erased in release
builds.