use std::sync::{Arc, OnceLock};
use reifydb_core::interface::catalog::{
column::{Column, ColumnIndex},
id::NamespaceId,
vtable::VTable,
};
use reifydb_type::value::{constraint::TypeConstraint, r#type::Type};
use super::ids::{columns::operator_retention_strategies::*, vtable::OPERATOR_RETENTION_STRATEGIES};
pub fn operator_retention_strategies() -> Arc<VTable> {
static INSTANCE: OnceLock<Arc<VTable>> = OnceLock::new();
INSTANCE.get_or_init(|| {
Arc::new(VTable {
id: OPERATOR_RETENTION_STRATEGIES,
namespace: NamespaceId::SYSTEM,
name: "operator_retention_strategies".to_string(),
columns: vec![
Column {
id: OPERATOR_ID,
name: "operator_id".to_string(),
constraint: TypeConstraint::unconstrained(Type::Uint8),
properties: vec![],
index: ColumnIndex(0),
auto_increment: false,
dictionary_id: None,
},
Column {
id: STRATEGY_TYPE,
name: "strategy_type".to_string(),
constraint: TypeConstraint::unconstrained(Type::Utf8),
properties: vec![],
index: ColumnIndex(1),
auto_increment: false,
dictionary_id: None,
},
Column {
id: CLEANUP_MODE,
name: "cleanup_mode".to_string(),
constraint: TypeConstraint::unconstrained(Type::Utf8),
properties: vec![],
index: ColumnIndex(2),
auto_increment: false,
dictionary_id: None,
},
Column {
id: VALUE,
name: "value".to_string(),
constraint: TypeConstraint::unconstrained(Type::Uint8),
properties: vec![],
index: ColumnIndex(3),
auto_increment: false,
dictionary_id: None,
},
],
})
})
.clone()
}