Struct rad::rados::Context

pub struct Context { /* fields omitted */ }

A wrapper around a rados_ioctx_t, which also counts as a reference to the underlying Connection.

Methods

impl Context

fn get_xattr(&mut self, obj: &str, key: &str, size: usize) -> Result<Vec<u8>>

Fetch an extended attribute on a given RADOS object using rados_getxattr.

• size - the size in bytes of the extended attribute.

fn set_xattr(&mut self, obj: &str, key: &str, value: &[u8]) -> Result<()>

Set an extended attribute on a given RADOS object using rados_setxattr.

fn write(&mut self, obj: &str, buf: &[u8], offset: u64) -> Result<()>

Write to a RADOS object using rados_write.

fn write_full(&mut self, obj: &str, buf: &[u8]) -> Result<()>

Write the entirety of a RADOS object, overwriting if necessary, using rados_write_full.

fn append(&mut self, obj: &str, buf: &[u8]) -> Result<()>

Append to a RADOS object using rados_append.

fn read(&mut self, obj: &str, buf: &mut [u8], offset: u64) -> Result<usize>

Read from a RADOS object using rados_read.

fn remove(&mut self, obj: &str) -> Result<()>

Delete a RADOS object using rados_remove.

fn resize(&mut self, obj: &str, size: u64) -> Result<()>

Resize a RADOS object, filling with zeroes if necessary, using rados_trunc.

fn stat(&mut self, obj: &str) -> Result<Stat>

Get the statistics of a given RADOS object using rados_stat.

fn write_async(&mut self, obj: &str, buf: &[u8], offset: u64) -> UnitFuture

Asynchronously write to a RADOS object using rados_aio_write.

fn append_async(&mut self, obj: &str, buf: &[u8]) -> UnitFuture

Asynchronously append to a RADOS object using rados_aio_append.

fn write_full_async(&mut self, obj: &str, buf: &[u8]) -> UnitFuture

Asynchronously set the contents of a RADOS object using rados_aio_write_full.

fn remove_async(&mut self, obj: &str) -> UnitFuture

Asynchronously remove a RADOS object from the cluster using rados_aio_remove.

fn read_async<B>(&mut self, obj: &str, buf: B, offset: u64) -> ReadFuture<B> where
    B: StableDeref + DerefMut<Target = [u8]>, 

Asynchronously read from a RADOS object using rados_aio_read.

fn stat_async(&mut self, obj: &str) -> StatFuture

Asynchronously retrieve statistics of a specific object from the cluster using rados_aio_stat.

fn exists(&mut self, obj: &str) -> Result<bool>

Check whether or not a RADOS object exists under a given name, using rados_stat and checking the error code for ENOENT.

fn exists_async(&mut self, obj: &str) -> ExistsFuture

Asynchronously check for object existence by using rados_aio_stat and checking for ENOENT.

fn flush(&mut self) -> Result<()>

Flush all asynchronous I/O actions on the given context, blocking until they are complete.

fn flush_async(&mut self) -> UnitFuture

Construct a future which will complete when all I/O actions on the given context are complete.

Trait Implementations

impl Send for Context

impl Drop for Context

fn drop(&mut self)

Executes the destructor for this type.