d-engine-proto 0.2.3

gRPC protocol definitions - for building non-Rust d-engine clients
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

use std::error::Error;

use bytes::Bytes;

use crate::server::storage::SnapshotMetadata;

impl SnapshotMetadata {
    pub fn checksum_array(&self) -> Result<[u8; 32], Box<dyn Error>> {
        if self.checksum.len() == 32 {
            let mut array = [0u8; 32];
            array.copy_from_slice(&self.checksum);
            Ok(array)
        } else {
            Err(format!("Invalid checksum length: {}", self.checksum.len()).into())
        }
    }

    pub fn set_checksum_array(
        &mut self,
        array: [u8; 32],
    ) {
        self.checksum = Bytes::copy_from_slice(&array);
    }
}