Struct SqliteBackedCache

pub struct SqliteBackedCache {
    pub connection: Arc<Mutex<Connection>>,
    pub cache_storage_dir: PathBuf,
}

Fields

connection: Arc<Mutex<Connection>>

cache_storage_dir: PathBuf

Implementations

impl SqliteBackedCache

pub fn new(cache_storage_dir: PathBuf) -> Result<Self, CacheError>

Trait Implementations

impl Cache for SqliteBackedCache

fn storage_open<'life0, 'async_trait>( &'life0 self, cache_name: String, ) -> Pin<Box<dyn Future<Output = Result<i64, CacheError>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Open a cache storage. Internally, this creates a row in the sqlite db if the cache doesn’t exist and returns the internal id of the cache.

fn storage_has<'life0, 'async_trait>( &'life0 self, cache_name: String, ) -> Pin<Box<dyn Future<Output = Result<bool, CacheError>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check if a cache with the provided name exists. Note: this doesn’t check the disk, it only checks the sqlite db.

fn storage_delete<'life0, 'async_trait>( &'life0 self, cache_name: String, ) -> Pin<Box<dyn Future<Output = Result<bool, CacheError>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete a cache storage. Internally, this deletes the row in the sqlite db.

type CacheMatchResourceType = CacheResponseResource

fn put<'life0, 'async_trait>( &'life0 self, request_response: CachePutRequest, resource: Option<Rc<dyn Resource>>, ) -> Pin<Box<dyn Future<Output = Result<(), CacheError>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Put a resource into the cache.

fn match<'life0, 'async_trait>( &'life0 self, request: CacheMatchRequest, ) -> Pin<Box<dyn Future<Output = Result<Option<(CacheMatchResponseMeta, Option<CacheResponseResource>)>, CacheError>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn delete<'life0, 'async_trait>( &'life0 self, request: CacheDeleteRequest, ) -> Pin<Box<dyn Future<Output = Result<bool, CacheError>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl Clone for SqliteBackedCache

fn clone(&self) -> SqliteBackedCache

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Resource for SqliteBackedCache

fn name(&self) -> Cow<'_, str>

Returns a string representation of the resource which is made available to JavaScript code through op_resources. The default implementation returns the Rust type name, but specific resource types may override this trait method.

fn read( self: Rc<Self>, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<BufView, Error>>>>

Read a single chunk of data from the resource. This operation returns a BufView that represents the data that was read. If a zero length buffer is returned, it indicates that the resource has reached EOF.

fn read_byob( self: Rc<Self>, buf: BufMutView, ) -> Pin<Box<dyn Future<Output = Result<(usize, BufMutView), Error>>>>

Read a single chunk of data from the resource into the provided BufMutView.

fn write_error( self: Rc<Self>, _error: Error, ) -> Pin<Box<dyn Future<Output = Result<(), Error>>>>

Write an error state to this resource, if the resource supports it.

fn write( self: Rc<Self>, buf: BufView, ) -> Pin<Box<dyn Future<Output = Result<WriteOutcome, Error>>>>

Write a single chunk of data to the resource. The operation may not be able to write the entire chunk, in which case it should return the number of bytes written. Additionally it should return the BufView that was passed in.

fn write_all( self: Rc<Self>, view: BufView, ) -> Pin<Box<dyn Future<Output = Result<(), Error>>>>

Write an entire chunk of data to the resource. Unlike write(), this will ensure the entire chunk is written. If the operation is not able to write the entire chunk, an error is to be returned.

fn read_byob_sync(self: Rc<Self>, data: &mut [u8]) -> Result<usize, Error>

The same as read_byob(), but synchronous.

fn write_sync(self: Rc<Self>, data: &[u8]) -> Result<usize, Error>

The same as write(), but synchronous.

fn shutdown(self: Rc<Self>) -> Pin<Box<dyn Future<Output = Result<(), Error>>>>

The shutdown method can be used to asynchronously close the resource. It is not automatically called when the resource is dropped or closed.

fn close(self: Rc<Self>)

Resources may implement the close() trait method if they need to do resource specific clean-ups, such as cancelling pending futures, after a resource has been removed from the resource table.

fn backing_handle(self: Rc<Self>) -> Option<ResourceHandle>

Resources backed by a file descriptor or socket handle can let ops know to allow for low-level optimizations.

fn backing_fd(self: Rc<Self>) -> Option<i32>

👎Deprecated: Use backing_handle

Resources backed by a file descriptor can let ops know to allow for low-level optimizations.

fn size_hint(&self) -> (u64, Option<u64>)