Struct DatanodeTableManager

pub struct DatanodeTableManager {
    kv_backend: KvBackendRef,
}

Fields

kv_backend: KvBackendRef

Implementations

impl DatanodeTableManager

pub fn new(kv_backend: KvBackendRef) -> Self

pub async fn get( &self, key: &DatanodeTableKey, ) -> Result<Option<DatanodeTableValue>>

pub fn tables( &self, datanode_id: DatanodeId, ) -> BoxStream<'static, Result<DatanodeTableValue>>

pub async fn regions( &self, table_id: TableId, table_routes: &PhysicalTableRouteValue, ) -> Result<Vec<DatanodeTableValue>>

Find the DatanodeTableValues for the given [TableId] and PhysicalTableRouteValue.

pub fn build_create_txn( &self, table_id: TableId, engine: &str, region_storage_path: &str, region_options: HashMap<String, String>, region_wal_options: HashMap<RegionNumber, String>, distribution: RegionDistribution, ) -> Result<Txn>

Builds the create datanode table transactions. It only executes while the primary keys comparing successes.

pub(crate) async fn build_update_table_options_txn( &self, table_id: TableId, region_distribution: RegionDistribution, new_region_options: HashMap<String, String>, ) -> Result<Txn>

Builds a transaction to updates the redundant table options (including WAL options) for given table id, if provided.

Note that the provided new_region_options must be a complete set of all options rather than incremental changes.

pub(crate) fn build_update_txn( &self, table_id: TableId, region_info: RegionInfo, current_region_distribution: RegionDistribution, new_region_distribution: RegionDistribution, new_region_options: &HashMap<String, String>, new_region_wal_options: &HashMap<RegionNumber, String>, ) -> Result<Txn>

Builds the update datanode table transactions. It only executes while the primary keys comparing successes.

pub fn build_delete_txn( &self, table_id: TableId, distribution: RegionDistribution, ) -> Result<Txn>

Builds the delete datanode table transactions. It only executes while the primary keys comparing successes.