Struct cocaine::service::storage::Storage

pub struct Storage { /* fields omitted */ }

Storage service wrapper.

Methods

impl Storage

pub fn new(service: Service) -> Self

Constructs a new storage service wrapper using the specified service.

pub fn into_inner(self) -> Service

Consumes this wrapper, yielding an underlying service.

pub fn read(     &self,     collection: &str,     key: &str ) -> impl Future<Item = Vec<u8>, Error = Error>

Reads the data that is kept at the specified collection and key.

Examples

use cocaine::{Core, Service};
use cocaine::service::Storage;

let mut core = Core::new().unwrap();
let storage = Storage::new(Service::new("storage", &core.handle()));

let future = storage.read("collection", "key");

let data = core.run(future).unwrap();

pub fn write(     &self,     collection: &str,     key: &str,     data: &[u8],     indexes: &[&str] ) -> impl Future<Item = (), Error = Error>

Writes the specified data into the storage.

Optional indexes can also be associated with the data written.

Returns a future, which will be resolved either when the data is successfully written into the storage or some error occurred.

Examples

use cocaine::{Core, Service};
use cocaine::service::Storage;

let mut core = Core::new().unwrap();
let storage = Storage::new(Service::new("storage", &core.handle()));

let future = storage.write("collection", "key", "le message".as_bytes(), &[]);

core.run(future).unwrap();

Trait Implementations

impl Clone for Storage

fn clone(&self) -> Storage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Storage

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.