reifydb-catalog 0.4.13

Database catalog and metadata management 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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92

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

use reifydb_core::interface::catalog::{
	id::{ColumnId, RingBufferId, SequenceId, TableId},
	shape::ShapeId,
};
use reifydb_transaction::transaction::Transaction;
use reifydb_type::value::{Value, row_number::RowNumber};
use tracing::instrument;

use crate::{
	CatalogStore, Result,
	catalog::Catalog,
	store::sequence::{Sequence, column::ColumnSequence, generator::SequenceTransaction, row::RowSequence},
};

impl Catalog {
	#[instrument(name = "catalog::sequence::find", level = "trace", skip(self, txn))]
	pub fn find_sequence(&self, txn: &mut Transaction<'_>, id: SequenceId) -> Result<Option<Sequence>> {
		CatalogStore::find_sequence(txn, id)
	}

	#[instrument(name = "catalog::sequence::get", level = "trace", skip(self, txn))]
	pub fn get_sequence(&self, txn: &mut Transaction<'_>, id: SequenceId) -> Result<Sequence> {
		CatalogStore::get_sequence(txn, id)
	}

	#[instrument(name = "catalog::sequence::list", level = "debug", skip(self, txn))]
	pub fn list_sequences(&self, txn: &mut Transaction<'_>) -> Result<Vec<Sequence>> {
		CatalogStore::list_sequences(txn)
	}

	#[instrument(name = "catalog::sequence::next_row_number", level = "trace", skip(self, txn))]
	pub fn next_row_number(&self, txn: &mut impl SequenceTransaction, table: TableId) -> Result<RowNumber> {
		RowSequence::next_row_number(txn, table)
	}

	#[instrument(name = "catalog::sequence::next_row_number_batch", level = "trace", skip(self, txn))]
	pub fn next_row_number_batch(
		&self,
		txn: &mut impl SequenceTransaction,
		table: TableId,
		count: u64,
	) -> Result<Vec<RowNumber>> {
		RowSequence::next_row_number_batch(txn, table, count)
	}

	#[instrument(name = "catalog::sequence::next_row_number_for_ringbuffer", level = "trace", skip(self, txn))]
	pub fn next_row_number_for_ringbuffer(
		&self,
		txn: &mut impl SequenceTransaction,
		ringbuffer: RingBufferId,
	) -> Result<RowNumber> {
		RowSequence::next_row_number_for_ringbuffer(txn, ringbuffer)
	}

	#[instrument(
		name = "catalog::sequence::next_row_number_batch_for_ringbuffer",
		level = "trace",
		skip(self, txn)
	)]
	pub fn next_row_number_batch_for_ringbuffer(
		&self,
		txn: &mut impl SequenceTransaction,
		ringbuffer: RingBufferId,
		count: u64,
	) -> Result<Vec<RowNumber>> {
		RowSequence::next_row_number_batch_for_ringbuffer(txn, ringbuffer, count)
	}

	#[instrument(name = "catalog::sequence::column_sequence_next_value", level = "trace", skip(self, txn, shape))]
	pub fn column_sequence_next_value(
		&self,
		txn: &mut impl SequenceTransaction,
		shape: impl Into<ShapeId>,
		column: ColumnId,
	) -> Result<Value> {
		ColumnSequence::next_value(txn, shape, column)
	}

	#[instrument(name = "catalog::sequence::column_sequence_set_value", level = "trace", skip(self, txn, shape))]
	pub fn column_sequence_set_value(
		&self,
		txn: &mut impl SequenceTransaction,
		shape: impl Into<ShapeId>,
		column: ColumnId,
		value: Value,
	) -> Result<()> {
		ColumnSequence::set_value(txn, shape, column, value)
	}
}