Struct StorageHandle 

pub struct StorageHandle { /* private fields */ }

Open storage resources shared by crawler contexts.

let storage = StorageHandle::new(c, d, k, q);
let _default_dataset = storage.dataset();

Implementations

impl StorageHandle

pub fn new( client: Arc<dyn StorageClient>, dataset: Arc<dyn Dataset>, key_value_store: Arc<dyn KeyValueStore>, request_queue: Arc<dyn RequestQueue>, ) -> Self

Wraps a client and its already-opened default resources.

pub fn dataset(&self) -> &Arc<dyn Dataset>

Returns the default dataset.

pub fn key_value_store(&self) -> &Arc<dyn KeyValueStore>

Returns the default key-value store.

pub fn request_queue(&self) -> &Arc<dyn RequestQueue>

Returns the default request queue.

pub async fn dataset_named(&self, name: &str) -> StorageResult<Arc<dyn Dataset>>

Opens a named dataset through the underlying client.

pub async fn kvs_named( &self, name: &str, ) -> StorageResult<Arc<dyn KeyValueStore>>

Opens a named key-value store through the underlying client.

pub fn client(&self) -> &Arc<dyn StorageClient>

Returns the storage backend client.

Trait Implementations

impl Clone for StorageHandle

fn clone(&self) -> StorageHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StorageHandle

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.