Struct delta_sharing_server::manager::postgres::PostgresShareReader

pub struct PostgresShareReader { /* private fields */ }

ShareReader implementation leveraging Postgres as backing store.

Implementations

impl PostgresShareReader

pub async fn new(connection_url: &str) -> Self

Create a new PostgresShareReader.

pub fn from_pool(pool: PgPool) -> Self

Create a new PostgresShareReader from an existing PgPool.

pub fn pool(&self) -> &PgPool

Return a reference to the underlying PgPool.

pub async fn insert_share(&self, share_name: &str) -> Result<Share, Error>

Insert a new share into the database.

pub async fn delete_share_by_name(&self, share_name: &str) -> Result<(), Error>

Delete a share from the database.

pub async fn delete_shares(&self) -> Result<(), Error>

Delete all shares from the database.

pub async fn insert_schema( &self, share: &Share, schema_name: &str ) -> Result<Schema, Error>

Insert a new schema into the database.

pub async fn delete_schema_by_name( &self, schema_name: &str ) -> Result<(), Error>

Delete a schema from the database.

pub async fn delete_schemas(&self) -> Result<(), Error>

Delete all schemas from the database.

pub async fn insert_table( &self, schema: &Schema, table_name: &str, storage_path: &str, storage_format: Option<&String> ) -> Result<Table, Error>

Insert a new table into the database.

pub async fn delete_table_by_name( &self, share_name: &str, schema_name: &str, table_name: &str ) -> Result<(), Error>

Delete a table from the database.

pub async fn delete_tables(&self) -> Result<(), Error>

Delete all tables from the database.

Trait Implementations

impl Debug for PostgresShareReader

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ShareReader for PostgresShareReader

fn list_shares<'life0, 'life1, 'async_trait>( &'life0 self, cursor: &'life1 ListCursor ) -> Pin<Box<dyn Future<Output = Result<List<Share>, ShareIoError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetch a list of shares stored on the sharing server store. The list cursor is used to limit the amount of returned shares and to resume listing from a specified point in the collection.

fn get_share<'life0, 'life1, 'async_trait>( &'life0 self, share_name: &'life1 str ) -> Pin<Box<dyn Future<Output = Result<Share, ShareIoError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get share details by name

fn list_schemas<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, share_name: &'life1 str, cursor: &'life2 ListCursor ) -> Pin<Box<dyn Future<Output = Result<List<Schema>, ShareIoError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Fetch a list of schemas stored on the sharing server store under a spcific share. The list cursor is used to limit the amount of returned schemas and to resume listing from a specified point in the collection.

fn list_tables_in_share<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, share_name: &'life1 str, cursor: &'life2 ListCursor ) -> Pin<Box<dyn Future<Output = Result<List<Table>, ShareIoError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Fetch a list of tables stored on the sharing server store under a spcific share combination. The list cursor is used to limit the amount of returned tables and to resume listing from a specified point in the collection.

fn list_tables_in_schema<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, share_name: &'life1 str, schema_name: &'life2 str, cursor: &'life3 ListCursor ) -> Pin<Box<dyn Future<Output = Result<List<Table>, ShareIoError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Fetch a list of tables stored on the sharing server store under a spcific share + schema combination. The list cursor is used to limit the amount of returned tables and to resume listing from a specified point in the collection.

fn get_table<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, share_name: &'life1 str, schema_name: &'life2 str, table_name: &'life3 str ) -> Pin<Box<dyn Future<Output = Result<Table, ShareIoError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Get table specifics for a combination of share + schema + name.