Struct delta_sharing_server::state::SharingServerState

pub struct SharingServerState { /* private fields */ }

State of the sharing server.

Implementations

impl SharingServerState

pub fn new(manager: Arc<dyn ShareReader>) -> Self

Create a new sharing server state.

pub fn add_table_reader( &mut self, format: impl Into<String>, reader: Arc<dyn TableReader> )

Add a table reader to the state.

pub fn add_url_signer( &mut self, storage: impl Into<String>, signer: Arc<dyn UrlSigner> )

Add a url signer to the state.

pub fn set_table_readers( &mut self, readers: HashMap<String, Arc<dyn TableReader>> )

Set the table readers.

pub fn set_url_signers(&mut self, signers: HashMap<String, Arc<dyn UrlSigner>>)

Set the url signers.

pub fn table_manager(&self) -> Arc<dyn ShareReader>

Get the share rearder.

pub fn table_reader(&self, format: &str) -> Option<Arc<dyn TableReader>>

Get the table reader for a specific format.

pub fn url_signer(&self, storage: &str) -> Option<Arc<dyn UrlSigner>>

Get the url signer for a specific object store.

pub async fn list_shares( &self, cursor: &ListCursor ) -> Result<ListSharesResponse, ServerError>

Get a list of shares in the share store.

pub async fn get_share( &self, share_name: &str ) -> Result<GetShareResponse, ServerError>

Get a share from the share store.

pub async fn list_schemas( &self, share_name: &str, cursor: &ListCursor ) -> Result<ListSchemasResponse, ServerError>

Get a list of schemas in a share.

pub async fn list_tables_in_share( &self, share_name: &str, cursor: &ListCursor ) -> Result<ListTablesResponse, ServerError>

Get a list of tables in a share.

pub async fn list_tables_in_schema( &self, share_name: &str, schema_name: &str, cursor: &ListCursor ) -> Result<ListTablesResponse, ServerError>

Get a list of tables in a schema.

pub async fn get_table_version( &self, share_name: &str, schema_name: &str, table_name: &str, version: Version ) -> Result<TableVersionResponse, ServerError>

Get the version of a table.

pub async fn get_table_metadata( &self, share_name: &str, schema_name: &str, table_name: &str ) -> Result<TableActionsResponse, ServerError>

Get the metadata of a table.

pub async fn get_table_data( &self, share_name: &str, schema_name: &str, table_name: &str, _version: Version ) -> Result<TableActionsResponse, ServerError>

Get the data files of a table version.

Trait Implementations

impl Clone for SharingServerState

fn clone(&self) -> SharingServerState

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.