reifydb-routine 0.4.12

Built-in routines (functions and procedures) for ReifyDB
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

// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2025 ReifyDB

pub mod context;
pub mod error;
pub mod identity;
pub mod registry;
pub mod subscription;
pub mod testing;

pub mod clock;
pub mod set;

use error::ProcedureError;
use registry::{Procedures, ProceduresConfigurator};
use reifydb_core::value::column::columns::Columns;
use reifydb_transaction::transaction::Transaction;

/// A server-side procedure that can mutate database state within a transaction.
pub trait Procedure: Send + Sync {
	fn call(&self, ctx: &context::ProcedureContext, tx: &mut Transaction<'_>) -> Result<Columns, ProcedureError>;
}

pub fn default_procedures() -> ProceduresConfigurator {
	let builder = Procedures::builder()
		.with_procedure("system::config::set", set::config::SetConfigProcedure::new)
		.with_procedure("clock::set", clock::set::ClockSetProcedure::new)
		.with_procedure("clock::advance", clock::advance::ClockAdvanceProcedure::new)
		.with_procedure("identity::inject", identity::inject::IdentityInject::new)
		.with_procedure("inspect_subscription", subscription::inspect::InspectSubscription::new);
	testing::register_testing_procedures(builder)
}