Struct Collection 

pub struct Collection { /* private fields */ }

Available on crate feature inspect only.

An owned collection. Dropping its last capability or reader releases its storage. Read handles pin their underlying data independently of registry eviction.

Implementations

impl Collection

pub fn new<S>(service: S) -> Collection

where S: Clone + Service<AppendRecord, Output = RecordId, Error = Box<dyn Error + Send + Sync>, Output = Pin<Box<dyn AsyncRead + Send>>, Error = Box<dyn Error + Send + Sync>, Output = Vec<RecordId>, Error = Box<dyn Error + Send + Sync>> + Service<ReadRecord> + Service<ListRecords>,

Adapt a custom backend using Rama services. No filesystem or crypto required.

pub fn split(self) -> (CollectionReader, CollectionWriter)

Separate read and append capabilities without allocating or cloning services.

pub async fn append( &self, source: impl AsyncRead + Send + 'static, ) -> Result<RecordId, Box<dyn Error + Send + Sync>>

pub async fn read( &self, id: RecordId, ) -> Result<Pin<Box<dyn AsyncRead + Send>>, Box<dyn Error + Send + Sync>>

pub async fn snapshot( &self, ) -> Result<Vec<RecordId>, Box<dyn Error + Send + Sync>>

Trait Implementations

impl Clone for Collection

fn clone(&self) -> Collection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Collection

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

Formats the value using the given formatter.

impl Service<AppendRecord> for Collection

type Output = RecordId

The type of the output returned by the service.

type Error = Box<dyn Error + Send + Sync>

The type of error returned by the service.

async fn serve( &self, input: AppendRecord, ) -> Result<<Collection as Service<AppendRecord>>::Output, <Collection as Service<AppendRecord>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.

impl Service<ListRecords> for Collection

type Output = Vec<RecordId>

The type of the output returned by the service.

type Error = Box<dyn Error + Send + Sync>

The type of error returned by the service.

async fn serve( &self, input: ListRecords, ) -> Result<<Collection as Service<ListRecords>>::Output, <Collection as Service<ListRecords>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.

impl Service<ReadRecord> for Collection

type Output = Pin<Box<dyn AsyncRead + Send>>

The type of the output returned by the service.

type Error = Box<dyn Error + Send + Sync>

The type of error returned by the service.

async fn serve( &self, input: ReadRecord, ) -> Result<<Collection as Service<ReadRecord>>::Output, <Collection as Service<ReadRecord>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.