Struct CatalogStore 

pub struct CatalogStore;

Implementations

impl CatalogStore

pub async fn find_column_by_name( rx: &mut impl QueryTransaction, source: impl Into<SourceId>, column_name: &str, ) -> Result<Option<ColumnDef>>

impl CatalogStore

pub async fn get_column( rx: &mut impl QueryTransaction, column: ColumnId, ) -> Result<ColumnDef>

impl CatalogStore

pub async fn list_columns( rx: &mut impl QueryTransaction, source: impl Into<SourceId>, ) -> Result<Vec<ColumnDef>>

pub async fn list_columns_all( rx: &mut impl QueryTransaction, ) -> Result<Vec<ColumnInfo>>

impl CatalogStore

pub async fn list_column_policies( rx: &mut impl QueryTransaction, column: ColumnId, ) -> Result<Vec<ColumnPolicy>>

pub async fn list_column_policies_all( rx: &mut impl QueryTransaction, ) -> Result<Vec<ColumnPolicy>>

impl CatalogStore

pub async fn create_dictionary( txn: &mut impl CommandTransaction, to_create: DictionaryToCreate, ) -> Result<DictionaryDef>

impl CatalogStore

pub async fn find_dictionary( rx: &mut impl QueryTransaction, dictionary_id: DictionaryId, ) -> Result<Option<DictionaryDef>>

pub async fn find_dictionary_by_name( rx: &mut impl QueryTransaction, namespace: NamespaceId, name: impl AsRef<str>, ) -> Result<Option<DictionaryDef>>

impl CatalogStore

pub async fn get_dictionary( rx: &mut impl QueryTransaction, dictionary: DictionaryId, ) -> Result<DictionaryDef>

impl CatalogStore

pub async fn list_dictionaries( rx: &mut impl QueryTransaction, namespace: NamespaceId, ) -> Result<Vec<DictionaryDef>>

List all dictionaries in a namespace

pub async fn list_all_dictionaries( rx: &mut impl QueryTransaction, ) -> Result<Vec<DictionaryDef>>

List all dictionaries in the database

impl CatalogStore

pub async fn create_flow( txn: &mut impl CommandTransaction, to_create: FlowToCreate, ) -> Result<FlowDef>

impl CatalogStore

pub async fn delete_flow( txn: &mut impl CommandTransaction, flow_id: FlowId, ) -> Result<()>

impl CatalogStore

pub async fn find_flow( rx: &mut impl QueryTransaction, id: FlowId, ) -> Result<Option<FlowDef>>

pub async fn find_flow_by_name( rx: &mut impl QueryTransaction, namespace: NamespaceId, name: impl AsRef<str>, ) -> Result<Option<FlowDef>>

impl CatalogStore

pub async fn get_flow( rx: &mut impl QueryTransaction, flow: FlowId, ) -> Result<FlowDef>

pub async fn get_flow_by_name( rx: &mut impl QueryTransaction, namespace: NamespaceId, name: impl AsRef<str>, ) -> Result<FlowDef>

impl CatalogStore

pub async fn list_flows_all( rx: &mut impl QueryTransaction, ) -> Result<Vec<FlowDef>>

impl CatalogStore

pub async fn update_flow_name( txn: &mut impl CommandTransaction, flow_id: FlowId, new_name: String, ) -> Result<()>

Update the name of a flow

pub async fn update_flow_status( txn: &mut impl CommandTransaction, flow_id: FlowId, status: FlowStatus, ) -> Result<()>

Update the status of a flow

impl CatalogStore

pub async fn create_flow_edge( txn: &mut impl CommandTransaction, edge_def: &FlowEdgeDef, ) -> Result<()>

impl CatalogStore

pub async fn delete_flow_edge( txn: &mut impl CommandTransaction, edge_id: FlowEdgeId, ) -> Result<()>

impl CatalogStore

pub async fn find_flow_edge( txn: &mut impl QueryTransaction, edge: FlowEdgeId, ) -> Result<Option<FlowEdgeDef>>

impl CatalogStore

pub async fn get_flow_edge( txn: &mut impl QueryTransaction, edge_id: FlowEdgeId, ) -> Result<FlowEdgeDef>

impl CatalogStore

pub async fn list_flow_edges_by_flow( txn: &mut impl QueryTransaction, flow_id: FlowId, ) -> Result<Vec<FlowEdgeDef>>

pub async fn list_flow_edges_all( txn: &mut impl QueryTransaction, ) -> Result<Vec<FlowEdgeDef>>

impl CatalogStore

pub async fn create_flow_node( txn: &mut impl CommandTransaction, node_def: &FlowNodeDef, ) -> Result<()>

impl CatalogStore

pub async fn delete_flow_node( txn: &mut impl CommandTransaction, node_id: FlowNodeId, ) -> Result<()>

impl CatalogStore

pub async fn find_flow_node( txn: &mut impl QueryTransaction, node_id: FlowNodeId, ) -> Result<Option<FlowNodeDef>>

impl CatalogStore

pub async fn get_flow_node( txn: &mut impl QueryTransaction, node_id: FlowNodeId, ) -> Result<FlowNodeDef>

impl CatalogStore

pub async fn list_flow_nodes_by_flow( txn: &mut impl QueryTransaction, flow_id: FlowId, ) -> Result<Vec<FlowNodeDef>>

pub async fn list_flow_nodes_all( txn: &mut impl QueryTransaction, ) -> Result<Vec<FlowNodeDef>>

impl CatalogStore

pub async fn create_namespace( txn: &mut impl CommandTransaction, to_create: NamespaceToCreate, ) -> Result<NamespaceDef>

impl CatalogStore

pub async fn find_namespace_by_name( rx: &mut impl QueryTransaction, name: impl AsRef<str>, ) -> Result<Option<NamespaceDef>>

pub async fn find_namespace( rx: &mut impl QueryTransaction, id: NamespaceId, ) -> Result<Option<NamespaceDef>>

impl CatalogStore

pub async fn get_namespace( rx: &mut impl QueryTransaction, namespace: NamespaceId, ) -> Result<NamespaceDef>

impl CatalogStore

pub async fn list_namespaces_all( rx: &mut impl QueryTransaction, ) -> Result<Vec<NamespaceDef>>

impl CatalogStore

pub async fn create_primary_key( txn: &mut impl CommandTransaction, to_create: PrimaryKeyToCreate, ) -> Result<PrimaryKeyId>

impl CatalogStore

pub async fn find_primary_key( rx: &mut impl QueryTransaction, source: impl Into<SourceId>, ) -> Result<Option<PrimaryKeyDef>>

pub async fn find_table_primary_key( rx: &mut impl QueryTransaction, table_id: TableId, ) -> Result<Option<PrimaryKeyDef>>

pub async fn find_view_primary_key( rx: &mut impl QueryTransaction, view_id: ViewId, ) -> Result<Option<PrimaryKeyDef>>

impl CatalogStore

pub async fn list_primary_keys( rx: &mut impl QueryTransaction, ) -> Result<Vec<PrimaryKeyInfo>>

pub async fn list_primary_key_columns( rx: &mut impl QueryTransaction, ) -> Result<Vec<(u64, u64, usize)>>

impl CatalogStore

pub async fn find_source_retention_policy( txn: &mut impl QueryTransaction, source: SourceId, ) -> Result<Option<RetentionPolicy>>

Find a retention policy for a source (table, view, or ring buffer) Returns None if no retention policy is set

pub async fn find_operator_retention_policy( txn: &mut impl QueryTransaction, operator: FlowNodeId, ) -> Result<Option<RetentionPolicy>>

Find a retention policy for an operator Returns None if no retention policy is set

impl CatalogStore

pub async fn get_source_retention_policy( txn: &mut impl QueryTransaction, source: SourceId, ) -> Result<RetentionPolicy>

Get a retention policy for a source (table, view, or ring buffer) Returns an error if no retention policy is set

pub async fn get_operator_retention_policy( txn: &mut impl QueryTransaction, operator: FlowNodeId, ) -> Result<RetentionPolicy>

Get a retention policy for an operator (flow node) Returns an error if no retention policy is set

impl CatalogStore

pub async fn list_source_retention_policies( rx: &mut impl QueryTransaction, ) -> Result<Vec<SourceRetentionPolicyEntry>>

List all retention policies for sources (tables, views, ring buffers)

pub async fn list_operator_retention_policies( rx: &mut impl QueryTransaction, ) -> Result<Vec<OperatorRetentionPolicyEntry>>

List all retention policies for operators

impl CatalogStore

pub async fn create_ringbuffer( txn: &mut impl CommandTransaction, to_create: RingBufferToCreate, ) -> Result<RingBufferDef>

impl CatalogStore

pub async fn find_ringbuffer( rx: &mut impl QueryTransaction, ringbuffer: RingBufferId, ) -> Result<Option<RingBufferDef>>

pub async fn find_ringbuffer_metadata( rx: &mut impl QueryTransaction, ringbuffer: RingBufferId, ) -> Result<Option<RingBufferMetadata>>

pub async fn find_ringbuffer_by_name( rx: &mut impl QueryTransaction, namespace: NamespaceId, name: impl AsRef<str>, ) -> Result<Option<RingBufferDef>>

impl CatalogStore

pub async fn get_ringbuffer( rx: &mut impl QueryTransaction, ringbuffer: RingBufferId, ) -> Result<RingBufferDef>

pub async fn get_ringbuffer_metadata( rx: &mut impl QueryTransaction, ringbuffer: RingBufferId, ) -> Result<RingBufferMetadata>

impl CatalogStore

pub async fn get_ringbuffer_pk_id( rx: &mut impl QueryTransaction, ringbuffer_id: RingBufferId, ) -> Result<Option<PrimaryKeyId>>

Get the primary key ID for a ring buffer Returns None if the ring buffer doesn’t exist or has no primary key

impl CatalogStore

pub async fn list_ringbuffers_all( rx: &mut impl QueryTransaction, ) -> Result<Vec<RingBufferDef>>

impl CatalogStore

pub async fn set_ringbuffer_primary_key( txn: &mut impl CommandTransaction, ringbuffer_id: RingBufferId, primary_key_id: PrimaryKeyId, ) -> Result<()>

Set the primary key ID for a ring buffer Returns an internal error if the ring buffer doesn’t exist

impl CatalogStore

pub async fn update_ringbuffer_metadata( txn: &mut impl CommandTransaction, metadata: RingBufferMetadata, ) -> Result<()>

impl CatalogStore

pub async fn find_sequence( rx: &mut impl QueryTransaction, sequence_id: SequenceId, ) -> Result<Option<Sequence>>

impl CatalogStore

pub async fn get_sequence( rx: &mut impl QueryTransaction, sequence_id: SequenceId, ) -> Result<Sequence>

impl CatalogStore

pub async fn list_sequences( rx: &mut impl QueryTransaction, ) -> Result<Vec<Sequence>>

impl CatalogStore

pub async fn find_source( rx: &mut impl QueryTransaction, source: impl Into<SourceId>, ) -> Result<Option<SourceDef>>

Find a source (table, store::view, or virtual table) by its SourceId Returns None if the source doesn’t exist

impl CatalogStore

pub async fn get_source( rx: &mut impl QueryTransaction, source: impl Into<SourceId>, ) -> Result<SourceDef>

Get a source (table or view) by its SourceId Returns an error if the source doesn’t exist

impl CatalogStore

pub async fn create_table( txn: &mut impl CommandTransaction, to_create: TableToCreate, ) -> Result<TableDef>

impl CatalogStore

pub async fn find_table( rx: &mut impl QueryTransaction, table: TableId, ) -> Result<Option<TableDef>>

pub async fn find_table_by_name( rx: &mut impl QueryTransaction, namespace: NamespaceId, name: impl AsRef<str>, ) -> Result<Option<TableDef>>

impl CatalogStore

pub async fn get_table( rx: &mut impl QueryTransaction, table: TableId, ) -> Result<TableDef>

impl CatalogStore

pub async fn get_table_pk_id( rx: &mut impl QueryTransaction, table_id: TableId, ) -> Result<Option<PrimaryKeyId>>

Get the primary key ID for a table Returns None if the table doesn’t exist or has no primary key

impl CatalogStore

pub async fn list_tables_all( rx: &mut impl QueryTransaction, ) -> Result<Vec<TableDef>>

impl CatalogStore

pub async fn set_table_primary_key( txn: &mut impl CommandTransaction, table_id: TableId, primary_key_id: PrimaryKeyId, ) -> Result<()>

Set the primary key ID for a table Returns an internal error if the table doesn’t exist

impl CatalogStore

pub async fn create_deferred_view( txn: &mut impl CommandTransaction, to_create: ViewToCreate, ) -> Result<ViewDef>

pub async fn create_transactional_view( txn: &mut impl CommandTransaction, to_create: ViewToCreate, ) -> Result<ViewDef>

impl CatalogStore

pub async fn find_view( rx: &mut impl QueryTransaction, id: ViewId, ) -> Result<Option<ViewDef>>

pub async fn find_view_by_name( rx: &mut impl QueryTransaction, namespace: NamespaceId, name: impl AsRef<str>, ) -> Result<Option<ViewDef>>

impl CatalogStore

pub async fn get_view( rx: &mut impl QueryTransaction, view: ViewId, ) -> Result<ViewDef>

impl CatalogStore

pub async fn get_view_pk_id( rx: &mut impl QueryTransaction, view_id: ViewId, ) -> Result<Option<PrimaryKeyId>>

Get the primary key ID for a view Returns None if the view doesn’t exist or has no primary key

impl CatalogStore

pub async fn list_views_all( rx: &mut impl QueryTransaction, ) -> Result<Vec<ViewDef>>

impl CatalogStore

pub async fn set_view_primary_key( txn: &mut impl CommandTransaction, view_id: ViewId, primary_key_id: PrimaryKeyId, ) -> Result<()>

Set the primary key ID for a view Returns an internal error if the view doesn’t exist