libblobd-direct 0.6.0

Library for blobd, direct variant
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

use super::OpError;
use super::OpResult;
use crate::ctx::Ctx;
use chrono::DateTime;
use chrono::Utc;
use std::sync::atomic::Ordering::Relaxed;
use std::sync::Arc;

pub struct OpInspectObjectInput {
  pub key: Vec<u8>,
  // Only useful if versioning is enabled.
  pub id: Option<u128>,
}

pub struct OpInspectObjectOutput {
  pub id: u128,
  pub size: u64,
  pub created: DateTime<Utc>,
}

pub(crate) async fn op_inspect_object(
  ctx: Arc<Ctx>,
  req: OpInspectObjectInput,
) -> OpResult<OpInspectObjectOutput> {
  let Some(obj) = ctx
    .committed_objects
    .get(&req.key)
    .filter(|o| req.id.is_none() || Some(o.id()) == req.id)
    .map(|e| e.value().clone())
  else {
    return Err(OpError::ObjectNotFound);
  };
  ctx.metrics.0.inspect_op_count.fetch_add(1, Relaxed);
  Ok(OpInspectObjectOutput {
    id: obj.id(),
    size: obj.size,
    created: obj.created,
  })
}