librados 0.2.0

Idiomatic (async) rust bindings for librados
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

use std::ffi::CString;

use crate::{
    ExtendedAttributes, IoCtx, RadosCompletion, Result,
    error::maybe_err,
    librados::{rados_aio_getxattrs, rados_xattrs_iter_t},
};

impl<'rados> IoCtx<'rados> {
    /// Get the extended attributes of `object`.
    ///
    // TODO: blocking version
    pub async fn get_xattrs<'io, 's>(&'io self, object: &'s str) -> Result<ExtendedAttributes> {
        let oid = CString::new(object).expect("Object name had interior NUL.");

        let completion = unsafe {
            RadosCompletion::new_with(
                false,
                rados_xattrs_iter_t::default(),
                |completion, mut iter| {
                    maybe_err(rados_aio_getxattrs(
                        self.inner(),
                        oid.as_ptr(),
                        completion,
                        &raw mut *iter,
                    ))
                },
            )?
        };

        let (_, iterator) = completion.wait_for().await?;

        assert!(
            !iterator.is_null(),
            "Created iterator was null despite future returning Poll::Ready(Ok)"
        );

        // SAFETY: `iterator` is not null.
        Ok(unsafe { ExtendedAttributes::new(iterator) })
    }
}