reifydb-core 0.4.5

Core database interfaces and data structures 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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

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

use reifydb_type::value::{constraint::TypeConstraint, sumtype::VariantRef};
use serde::{Deserialize, Serialize};

use crate::interface::catalog::id::{NamespaceId, ProcedureId};

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub enum ProcedureTrigger {
	/// Invoked explicitly via CALL
	Call,
	/// Triggered by DISPATCH on an event variant
	Event {
		variant: VariantRef,
	},
	/// Invoked via CALL but dispatched to a registered native (Rust) implementation
	NativeCall {
		native_name: String,
	},
}

impl Default for ProcedureTrigger {
	fn default() -> Self {
		ProcedureTrigger::Call
	}
}

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub struct Procedure {
	pub id: ProcedureId,
	pub namespace: NamespaceId,
	pub name: String,
	pub params: Vec<ProcedureParam>,
	pub return_type: Option<TypeConstraint>,
	/// RQL source text, compiled on load
	pub body: String,
	pub trigger: ProcedureTrigger,
	/// Test procedures can only be called from test context
	pub is_test: bool,
}

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub struct ProcedureParam {
	pub name: String,
	pub param_type: TypeConstraint,
}