ceph-rust 0.1.4

Ceph-rust is a rust-lang specific interface to Ceph librados. You can create a Ceph development environment with the Chef automation tools I created from the following: https://github.com/bloomberg/chef-bcs. It uses the ceph-chef cookbook I created and manage at github.com/ceph/ceph-chef. It will build out a full Ceph environment which you can then use for development etc. See README.md for details.
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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

// Copyright 2016 LambdaStack All rights reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

#![cfg(target_os = "linux")]
use std::slice;
use std::io::Error;

use rados::*;

/// Returns back a collection of Rados Pools
///
/// pool_buffer should be allocated with:
/// ```
/// let pool_buffer: Vec<u8> = Vec::with_capacity(<whatever size>);
/// ```
/// buf_size should be the value used with_capacity
///
/// Returns Ok(Vec<String>) - A list of Strings of the pool names.
///
#[allow(unused_variables)]
pub fn rados_pools(cluster: rados_t)
                   -> Result<Vec<String>, Error> {
  let mut pools: Vec<String> = Vec::new();
  let pool_slice: &[u8];
  let buf_size: usize = 500;
  let mut pool_buffer: Vec<u8> = Vec::with_capacity(buf_size);

  unsafe {
    // Don't need len but did it anyway
    let len = rados_pool_list(cluster,
                              pool_buffer.as_mut_ptr() as *mut i8,
                              buf_size);

    pool_slice = slice::from_raw_parts(pool_buffer.as_mut_ptr(), buf_size);

    // NOTE: Pushed for time so did this. If anyone knows of a better way then please issue a PR.
    let mut new: bool =  true;
    let mut new_word_slice: Vec<u8> = Vec::with_capacity(50);
    let mut s: String;

    for p in pool_slice.chunks(1) {
      if p[0] == b'\0' {
        if new {
          break;
        }
        new = true;
        s = String::from_utf8(new_word_slice.clone()).unwrap();
        pools.push(s.clone());
        new_word_slice.clear();
        continue;
      }

      new_word_slice.push(p[0]);
      new = false;
    }
  }

  Ok(pools)
}