Struct garage_model_010b::block::BlockManager

pub struct BlockManager {
    pub replication: TableShardedReplication,
    pub data_dir: PathBuf,
    pub data_dir_lock: Mutex<()>,
    pub rc: Tree,
    pub resync_queue: Tree,
    pub resync_notify: Notify,
    pub system: Arc<System>,
    pub garage: ArcSwapOption<Garage>,
    // some fields omitted
}

Fields

replication: TableShardedReplication

data_dir: PathBuf

data_dir_lock: Mutex<()>

rc: Tree

resync_queue: Tree

resync_notify: Notify

system: Arc<System>

garage: ArcSwapOption<Garage>

Implementations

impl BlockManager

pub fn new(
    db: &Db,
    data_dir: PathBuf,
    replication: TableShardedReplication,
    system: Arc<System>,
    rpc_server: &mut RpcServer
) -> Arc<Self>

pub async fn spawn_background_worker(self: Arc<Self>)

pub async fn write_block(
    &self,
    hash: &Hash,
    data: &[u8]
) -> Result<Message, Error>

pub async fn read_block(&self, hash: &Hash) -> Result<Message, Error>

pub async fn need_block(&self, hash: &Hash) -> Result<bool, Error>

pub fn block_incref(&self, hash: &Hash) -> Result<(), Error>

pub fn block_decref(&self, hash: &Hash) -> Result<(), Error>

pub async fn rpc_get_block(&self, hash: &Hash) -> Result<Vec<u8>, Error>

pub async fn rpc_put_block(
    &self,
    hash: Hash,
    data: Vec<u8>
) -> Result<(), Error>

pub async fn repair_data_store(
    &self,
    must_exit: &Receiver<bool>
) -> Result<(), Error>