nodedb 0.4.0

Local-first, real-time, edge-to-cloud hybrid database for multi-modal workloads
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

// SPDX-License-Identifier: BUSL-1.1

//! Wires Origin's concrete [`SurrogateAssigner`] into the
//! `nodedb_physical::SurrogateAssigner` trait so the shared converter
//! can allocate surrogates without depending on Origin internals.

use nodedb_physical::{SurrogateAssignError, SurrogateAssigner as PhysicalSurrogateAssigner};

use super::assign::SurrogateAssigner;

impl PhysicalSurrogateAssigner for SurrogateAssigner {
    fn current_hwm(&self) -> u32 {
        Self::current_hwm(self)
    }

    fn assign(
        &self,
        database_id: nodedb_types::DatabaseId,
        tenant_id: nodedb_types::TenantId,
        collection: &str,
        pk_bytes: &[u8],
    ) -> Result<nodedb_types::Surrogate, SurrogateAssignError> {
        Self::assign(self, database_id, tenant_id, collection, pk_bytes)
            .map_err(|e| SurrogateAssignError::Backend(e.to_string()))
    }

    fn assign_fresh(
        &self,
        database_id: nodedb_types::DatabaseId,
        tenant_id: nodedb_types::TenantId,
        collection: &str,
    ) -> Result<nodedb_types::Surrogate, SurrogateAssignError> {
        Self::assign_fresh(self, database_id, tenant_id, collection)
            .map_err(|e| SurrogateAssignError::Backend(e.to_string()))
    }
}