pub struct RegistryManager { /* private fields */ }Expand description
Registry manager for DDL operations.
Implementations§
Source§impl RegistryManager
impl RegistryManager
Sourcepub fn new(storage: Arc<dyn StorageBackend>) -> Self
pub fn new(storage: Arc<dyn StorageBackend>) -> Self
Create a new registry manager.
Sourcepub async fn load_or_create(&self) -> Result<Registry>
pub async fn load_or_create(&self) -> Result<Registry>
Load the latest registry from storage, or create a new one if none exists.
Sourcepub async fn load_version(&self, version: u64) -> Result<Registry>
pub async fn load_version(&self, version: u64) -> Result<Registry>
Load a specific version of the registry.
Sourcepub async fn create_hive(&self, hive_name: &str) -> Result<Registry>
pub async fn create_hive(&self, hive_name: &str) -> Result<Registry>
Create a hive in the registry.
Sourcepub async fn create_box(
&self,
hive_name: &str,
box_name: &str,
) -> Result<Registry>
pub async fn create_box( &self, hive_name: &str, box_name: &str, ) -> Result<Registry>
Create a box within a hive.
Sourcepub async fn create_frame(
&self,
hive_name: &str,
box_name: &str,
frame_name: &str,
schema: Value,
partition_by: Vec<String>,
) -> Result<Registry>
pub async fn create_frame( &self, hive_name: &str, box_name: &str, frame_name: &str, schema: Value, partition_by: Vec<String>, ) -> Result<Registry>
Create a frame within a box.
Sourcepub async fn list_hives(&self) -> Result<Vec<String>>
pub async fn list_hives(&self) -> Result<Vec<String>>
List all hives.
Sourcepub async fn list_boxes(&self, hive_name: &str) -> Result<Vec<String>>
pub async fn list_boxes(&self, hive_name: &str) -> Result<Vec<String>>
List all boxes in a hive.
Auto Trait Implementations§
impl Freeze for RegistryManager
impl !RefUnwindSafe for RegistryManager
impl Send for RegistryManager
impl Sync for RegistryManager
impl Unpin for RegistryManager
impl UnsafeUnpin for RegistryManager
impl !UnwindSafe for RegistryManager
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more