Struct CallableCache

Source
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

Source

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:

  1. Checks if the trunk-DDI combination exists in the local cache
  2. If found, retrieves the account ID and uses it to look up the account
  3. If not found in local cache, falls back to Redis lookup
  4. 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
Source

pub async fn get_account_by_id( self, id: &str, ) -> Result<Option<Arc<AccountLite>>, RedisError>

Retrieves an account by its ID, first checking the local cache and then Redis.

§Arguments
  • id - Account ID to look up
§Returns
  • Result<Option<AccountLite>, RedisError> - Account if found, None if not found, or a Redis error
Source

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

Source

pub async fn agent_status_set( &self, account_id: &str, status: &AgentStatus, ) -> Result<(), RedisError>

Store complete agent status

Source

pub async fn agent_status_get( &self, account_id: &str, user_id: &str, ) -> Result<Option<AgentStatus>, RedisError>

Get complete agent status

Source

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

Source

pub async fn remove_connected_agent( &self, account_id: &str, user_id: &str, agent_id: &str, ws_connection_id: &str, ) -> Result<(), RedisError>

Source

pub async fn get_connected_agents( &self, account_id: &str, ) -> Result<Vec<String>, RedisError>

Get all connected agents for an account

Source§

impl CallableCache

Source

pub async fn get_assets( self, account_id: &str, ) -> Result<Vec<Asset>, RedisError>

Retrieves all assets for an account.

§Arguments
  • account_id - Account ID
§Returns
  • Result<Vec<Asset>, RedisError> - List of assets or a Redis error
Source

pub async fn get_asset( self, account_id: &str, asset_id: &str, ) -> Result<Option<Asset>, RedisError>

Retrieves a specific asset for an account.

§Arguments
  • account_id - Account ID
  • asset_id - Asset ID to retrieve
§Returns
  • Result<Option<Asset>, RedisError> - The asset if found, None if not found, or a Redis error
Source§

impl CallableCache

Source

pub async fn get_device_by_ident( self, account_id: &str, ident: &str, ) -> Result<Option<Arc<DeviceStruct>>, RedisError>

Source

pub async fn get_devices( self, account_id: &str, ) -> Result<Arc<Vec<DeviceStruct>>, RedisError>

Retrieves all devices for an account.

§Arguments
  • account_id - Account ID
§Returns
  • Result<Vec<DeviceStruct>, RedisError> - List of devices or a Redis error
Source

pub async fn get_device( self, account_id: &str, device_id: &str, ) -> Result<Option<Arc<DeviceStruct>>, RedisError>

Retrieves a specific device for an account.

§Arguments
  • account_id - Account ID
  • device_id - Device ID to retrieve
§Returns
  • Result<Option<DeviceStruct>, RedisError> - The device if found, None if not found, or a Redis error
Source§

impl CallableCache

Source

pub async fn get_ddis(self, account_id: &str) -> Result<Vec<DDI>, RedisError>

Retrieves all DDIs for an account.

§Arguments
  • account_id - Account ID
§Returns
  • Result<Vec<DDI>, RedisError> - List of DDIs or a Redis error
Source

pub async fn get_ddi( self, account_id: &str, ddi_id: &str, ) -> Result<Option<DDI>, RedisError>

Retrieves a specific DDI for an account.

§Arguments
  • account_id - Account ID
  • ddi_id - DDI ID to retrieve
§Returns
  • Result<Option<DDI>, RedisError> - The DDI if found, None if not found, or a Redis error
Source§

impl CallableCache

Source

pub async fn get_hooks(self, account_id: &str) -> Result<Vec<Hook>, RedisError>

Retrieves all hooks for an account.

§Arguments
  • account_id - Account ID
§Returns
  • Result<Vec<Hook>, RedisError> - List of hooks or a Redis error
Source

pub async fn get_hook( self, account_id: &str, hook_id: &str, ) -> Result<Option<Hook>, RedisError>

Retrieves a specific hook for an account.

§Arguments
  • account_id - Account ID
  • hook_id - Hook ID to retrieve
§Returns
  • Result<Option<Hook>, RedisError> - The hook if found, None if not found, or a Redis error
Source§

impl CallableCache

Source

pub async fn get_proxy_by_id( &mut self, id: &str, ) -> Result<Option<Arc<Proxy>>, RedisError>

Retrieves a proxy by its ID, first checking the local cache and then Redis.

§Arguments
  • id - Proxy ID to look up
§Returns
  • Result<Option<Proxy>, RedisError> - Proxy if found, None if not found, or a Redis error
Source

pub async fn get_proxies(&mut self) -> Result<Arc<Vec<Proxy>>, RedisError>

Source

pub async fn get_proxies_local(self) -> Result<Arc<Vec<Proxy>>, RedisError>

Source§

impl CallableCache

Source

pub async fn queue_group_set( &self, queue: &QueueGroup, ) -> Result<(), RedisError>

Store a QueueGroup

Source

pub async fn queue_group_get( &self, account_id: &str, queue_name: &str, ) -> Result<Option<QueueGroup>, RedisError>

Get a QueueGroup

Source

pub async fn queue_group_delete( &self, account_id: &str, queue_name: &str, ) -> Result<(), RedisError>

Delete a QueueGroup

Source

pub async fn queue_group_list( &self, account_id: &str, ) -> Result<Vec<String>, RedisError>

Get all active queue names for an account

Source

pub async fn queue_groups_get_all( &self, account_id: &str, ) -> Result<Vec<QueueGroup>, RedisError>

Get all QueueGroups for an account

Source§

impl CallableCache

Source

pub async fn get_region_by_id( self, id: &str, ) -> Result<Option<Arc<Region>>, RedisError>

Retrieves a region by its ID, first checking the local cache and then Redis.

§Arguments
  • id - Region ID to look up
§Returns
  • Result<Option<Region>, RedisError> - Region if found, None if not found, or a Redis error
Source

pub async fn get_regions_local(self) -> Result<Arc<Vec<Region>>, RedisError>

Retrieves all regions from Local.

§Returns
  • Result<Vec<Region>, RedisError> - Arc Vec of Regions
Source

pub async fn get_regions(self) -> Result<Arc<Vec<Region>>, RedisError>

Retrieves all regions from Redis.

§Returns
  • Result<Vec<Region>, RedisError> - Vec of Regions
Source§

impl CallableCache

Source

pub async fn session_set( &self, account_id: &str, session_data: &SessionData, ) -> Result<(), RedisError>

Store session with account isolation using SessionData struct

Source

pub async fn session_get( &self, account_id: &str, session_id: &str, ) -> Result<Option<SessionData>, RedisError>

Get session with account validation, returns SessionData

Source

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

Source

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)

Source

pub async fn session_delete( &self, account_id: &str, session_id: &str, ) -> Result<(), RedisError>

Delete session

Source

pub async fn session_get_active( &self, account_id: &str, ) -> Result<Vec<SessionData>, RedisError>

Get all active sessions for an account

Source

pub async fn session_cleanup_expired( &self, account_id: &str, ) -> Result<u32, RedisError>

Clean up expired sessions for an account

Source§

impl CallableCache

Source

pub async fn get_trunks( self, account_id: &str, ) -> Result<Vec<Trunk>, RedisError>

Retrieves all trunks for an account.

§Arguments
  • account_id - Account ID
§Returns
  • Result<Vec<Trunk>, RedisError> - List of trunks or a Redis error
Source

pub async fn get_trunk( self, account_id: &str, trunk_id: &str, ) -> Result<Option<Trunk>, RedisError>

Retrieves a specific trunk for an account.

§Arguments
  • account_id - Account ID
  • trunk_id - Trunk ID to retrieve
§Returns
  • Result<Option<Trunk>, RedisError> - The trunk if found, None if not found, or a Redis error
Source§

impl CallableCache

Source

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.

Source

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

pub async fn get_users(&self) -> Result<Arc<Vec<User>>, RedisError>

Retrieves all users from Redis.

Source§

impl CallableCache

Source

pub async fn get_ws_account( &self, ws_connection_id: &str, ) -> Result<Option<String>, RedisError>

Get account_id for a WebSocket connection

Source

pub async fn get_account_connections( &self, account_id: &str, ) -> Result<Vec<String>, RedisError>

Get all WebSocket connections for an account

Source

pub async fn publish_account_event( &self, account_id: &str, event: &RedisEvent, ) -> Result<(), RedisError>

Publish event to account-specific channel

Source§

impl CallableCache

Source

pub async fn insert_jambonz_entry( &self, entry: JambonzEntry, ) -> Result<(), RedisError>

Inserts a Jambonz entry into Redis.

§Arguments
  • entry - The Jambonz entry to insert
§Returns
  • Result<(), RedisError> - Ok if successful, or a Redis error
Source

pub async fn get_jambonz_entry( &self, sip_realm: &str, ) -> Result<Option<Arc<JambonzEntry>>, RedisError>

Retrieves a Jambonz entry by SIP realm.

§Arguments
  • sip_realm - The SIP realm (e.g., insurancesearch.connect.callable.io)
§Returns
  • Result<Option<Arc<JambonzEntry>>, RedisError> - The entry if found, None if not found, or a Redis error
Source

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
Source

pub async fn delete_jambonz_entry( &self, sip_realm: &str, ) -> Result<bool, RedisError>

Deletes a Jambonz entry from Redis.

§Arguments
  • sip_realm - The SIP realm to delete
§Returns
  • Result<bool, RedisError> - true if deleted, false if not found
Source

pub async fn insert_jambonz_entries( &self, entries: Vec<JambonzEntry>, ) -> Result<(), RedisError>

Batch insert multiple Jambonz entries.

§Arguments
  • entries - Vector of Jambonz entries to insert
§Returns
  • Result<(), RedisError> - Ok if successful, or a Redis error
Source§

impl CallableCache

Source

pub async fn insert_contact(&self, contact: Contact) -> Result<(), RedisError>

Inserts a contact into Redis.

§Arguments
  • contact - The contact to insert
§Returns
  • Result<(), RedisError> - Ok if successful, or a Redis error
Source

pub async fn get_contact_by_id( &self, account_id: &str, contact_id: &str, ) -> Result<Option<Arc<Contact>>, RedisError>

Retrieves a contact by ID.

§Arguments
  • account_id - The account ID
  • contact_id - The contact ID
§Returns
  • Result<Option<Arc<Contact>>, RedisError> - The contact if found
Source

pub async fn get_contact_by_ident( &self, account_id: &str, identifier: &str, ) -> Result<Option<Arc<Contact>>, RedisError>

Retrieves a contact by identifier (phone number or email).

§Arguments
  • account_id - The account ID
  • identifier - The phone number or email
§Returns
  • Result<Option<Arc<Contact>>, RedisError> - The contact if found
Source

pub async fn get_contacts_by_account( &self, account_id: &str, ) -> Result<Vec<Arc<Contact>>, RedisError>

Retrieves all contacts for an account.

§Arguments
  • account_id - The account ID
§Returns
  • Result<Vec<Arc<Contact>>, RedisError> - List of contacts
Source

pub async fn get_contacts_by_group( &self, account_id: &str, group: &str, ) -> Result<Vec<Arc<Contact>>, RedisError>

Retrieves contacts by group.

§Arguments
  • account_id - The account ID
  • group - The group name
§Returns
  • Result<Vec<Arc<Contact>>, RedisError> - List of contacts in the group
Source

pub async fn delete_contact( &self, account_id: &str, contact_id: &str, ) -> Result<bool, RedisError>

Deletes a contact from Redis.

§Arguments
  • account_id - The account ID
  • contact_id - The contact ID
§Returns
  • Result<bool, RedisError> - true if deleted, false if not found
Source

pub async fn insert_contacts( &self, contacts: Vec<Contact>, ) -> Result<(), RedisError>

Batch insert multiple contacts.

§Arguments
  • contacts - Vector of contacts to insert
§Returns
  • Result<(), RedisError> - Ok if successful, or a Redis error
Source§

impl CallableCache

Source

pub async fn new() -> CallableCache

Creates a new CallableCache instance with local and remote caches.

§Returns
  • CallableCache - The new cache instance
Source

pub fn redis_connection(&self) -> MultiplexedConnection

Raw Redis connection access for custom operations

Source

pub async fn get_str(self, key: &str) -> Result<Option<String>, RedisError>

Retrieves a string value from Redis.

§Arguments
  • key - Redis key
§Returns
  • Result<Option<String>, RedisError> - String value if found, None if not found, or a Redis error
Source

pub async fn get_hash( self, key: &str, field: &str, ) -> Result<Option<String>, RedisError>

Retrieves a field from a Redis hash.

§Arguments
  • key - Redis hash key
  • field - Field to retrieve
§Returns
  • Result<Option<String>, RedisError> - Field value if found, None if not found, or a Redis error

Trait Implementations§

Source§

impl Clone for CallableCache

Source§

fn clone(&self) -> CallableCache

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl RedisHelpers for CallableCache

Source§

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,

Source§

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,

Source§

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,

Source§

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,

Source§

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,

Source§

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,

Source§

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,

Source§

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,

Source§

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,

Source§

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,

Source§

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,

Source§

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,

Source§

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,

Source§

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,

Source§

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,

Source§

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§

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> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> Conv for T

Source§

fn conv<T>(self) -> T
where Self: Into<T>,

Converts self into T using Into<T>. Read more
Source§

impl<T> FmtForward for T

Source§

fn fmt_binary(self) -> FmtBinary<Self>
where Self: Binary,

Causes self to use its Binary implementation when Debug-formatted.
Source§

fn fmt_display(self) -> FmtDisplay<Self>
where Self: Display,

Causes self to use its Display implementation when Debug-formatted.
Source§

fn fmt_lower_exp(self) -> FmtLowerExp<Self>
where Self: LowerExp,

Causes self to use its LowerExp implementation when Debug-formatted.
Source§

fn fmt_lower_hex(self) -> FmtLowerHex<Self>
where Self: LowerHex,

Causes self to use its LowerHex implementation when Debug-formatted.
Source§

fn fmt_octal(self) -> FmtOctal<Self>
where Self: Octal,

Causes self to use its Octal implementation when Debug-formatted.
Source§

fn fmt_pointer(self) -> FmtPointer<Self>
where Self: Pointer,

Causes self to use its Pointer implementation when Debug-formatted.
Source§

fn fmt_upper_exp(self) -> FmtUpperExp<Self>
where Self: UpperExp,

Causes self to use its UpperExp implementation when Debug-formatted.
Source§

fn fmt_upper_hex(self) -> FmtUpperHex<Self>
where Self: UpperHex,

Causes self to use its UpperHex implementation when Debug-formatted.
Source§

fn fmt_list(self) -> FmtList<Self>
where &'a Self: for<'a> IntoIterator,

Formats each item in a sequence. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> 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> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts 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 more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts 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 more
Source§

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

Source§

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

Pipes by value. This is generally the method you want to use. Read more
Source§

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

Borrows self and passes that borrow into the pipe function. Read more
Source§

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

Mutably borrows self and passes that borrow into the pipe function. Read more
Source§

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

Borrows self, then passes self.borrow() into the pipe function. Read more
Source§

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.borrow_mut() into the pipe function. Read more
Source§

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

Borrows 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
where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

Mutably borrows 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
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

Borrows self, then passes self.deref() into the pipe function.
Source§

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.deref_mut() into the pipe function.
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> Tap for T

Source§

fn tap(self, func: impl FnOnce(&Self)) -> Self

Immutable access to a value. Read more
Source§

fn tap_mut(self, func: impl FnOnce(&mut Self)) -> Self

Mutable access to a value. Read more
Source§

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Immutable access to the Borrow<B> of a value. Read more
Source§

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Mutable access to the BorrowMut<B> of a value. Read more
Source§

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Immutable access to the AsRef<R> view of a value. Read more
Source§

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Mutable access to the AsMut<R> view of a value. Read more
Source§

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Immutable access to the Deref::Target of a value. Read more
Source§

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Mutable access to the Deref::Target of a value. Read more
Source§

fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self

Calls .tap() only in debug builds, and is erased in release builds.
Source§

fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self

Calls .tap_mut() only in debug builds, and is erased in release builds.
Source§

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Calls .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
where Self: BorrowMut<B>, B: ?Sized,

Calls .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
where Self: AsRef<R>, R: ?Sized,

Calls .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
where Self: AsMut<R>, R: ?Sized,

Calls .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
where Self: Deref<Target = T>, T: ?Sized,

Calls .tap_deref() only in debug builds, and is erased in release builds.
Source§

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Calls .tap_deref_mut() only in debug builds, and is erased in release builds.
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T> TryConv for T

Source§

fn try_conv<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

Attempts to convert self into T using TryInto<T>. Read more
Source§

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

Performs the conversion.
Source§

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

Source§

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

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> ErasedDestructor for T
where T: 'static,