reifydb_core/key/
kind.rs

1// Copyright (c) reifydb.com 2025
2// This file is licensed under the AGPL-3.0-or-later, see license.md file
3
4use reifydb_type::Error;
5use serde::{Deserialize, Serialize};
6
7#[repr(u8)]
8#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
9#[serde(try_from = "u8", into = "u8")]
10pub enum KeyKind {
11	Namespace = 0x01,
12	Table = 0x02,
13	Row = 0x03,
14	NamespaceTable = 0x04,
15	SystemSequence = 0x05,
16	Columns = 0x06,
17	Column = 0x07,
18	RowSequence = 0x08,
19	ColumnPolicy = 0x09,
20	SystemVersion = 0x0A,
21	TransactionVersion = 0x0B,
22	Index = 0x0C,
23	IndexEntry = 0x0D,
24	ColumnSequence = 0x0E,
25	CdcConsumer = 0x0F,
26	View = 0x10,
27	NamespaceView = 0x11,
28	PrimaryKey = 0x12,
29	FlowNodeState = 0x13,
30	RingBuffer = 0x14,
31	NamespaceRingBuffer = 0x15,
32	RingBufferMetadata = 0x16,
33	SourceRetentionPolicy = 0x17,
34	OperatorRetentionPolicy = 0x18,
35	Flow = 0x19,
36	NamespaceFlow = 0x1A,
37}
38
39impl From<KeyKind> for u8 {
40	fn from(kind: KeyKind) -> Self {
41		kind as u8
42	}
43}
44impl TryFrom<u8> for KeyKind {
45	type Error = Error;
46
47	fn try_from(value: u8) -> std::result::Result<Self, Self::Error> {
48		match value {
49			0x01 => Ok(Self::Namespace),
50			0x02 => Ok(Self::Table),
51			0x03 => Ok(Self::Row),
52			0x04 => Ok(Self::NamespaceTable),
53			0x05 => Ok(Self::SystemSequence),
54			0x06 => Ok(Self::Columns),
55			0x07 => Ok(Self::Column),
56			0x08 => Ok(Self::RowSequence),
57			0x09 => Ok(Self::ColumnPolicy),
58			0x0A => Ok(Self::SystemVersion),
59			0x0B => Ok(Self::TransactionVersion),
60			0x0C => Ok(Self::Index),
61			0x0D => Ok(Self::IndexEntry),
62			0x0E => Ok(Self::ColumnSequence),
63			0x0F => Ok(Self::CdcConsumer),
64			0x10 => Ok(Self::View),
65			0x11 => Ok(Self::NamespaceView),
66			0x12 => Ok(Self::PrimaryKey),
67			0x13 => Ok(Self::FlowNodeState),
68			0x14 => Ok(Self::RingBuffer),
69			0x15 => Ok(Self::NamespaceRingBuffer),
70			0x16 => Ok(Self::RingBufferMetadata),
71			0x17 => Ok(Self::SourceRetentionPolicy),
72			0x18 => Ok(Self::OperatorRetentionPolicy),
73			0x19 => Ok(Self::Flow),
74			0x1A => Ok(Self::NamespaceFlow),
75			_ => Err(serde::de::Error::custom(format!("Invalid KeyKind value: {value:#04x}"))),
76		}
77	}
78}