pub struct ServerHandler<Cx> { /* private fields */ }Implementations§
Source§impl<Cx: Send + Sync + 'static> ServerHandler<Cx>
impl<Cx: Send + Sync + 'static> ServerHandler<Cx>
pub fn try_new_tokio( policy: Arc<dyn Policy<Cx>>, store: Arc<dyn ResourceStore>, ) -> Result<Self>
Sourcepub fn try_new_tokio_with_coordinator(
policy: Arc<dyn Policy<Cx>>,
store: Arc<dyn ResourceStore>,
commit_coordinator: Arc<dyn CommitCoordinator>,
) -> Result<Self>
pub fn try_new_tokio_with_coordinator( policy: Arc<dyn Policy<Cx>>, store: Arc<dyn ResourceStore>, commit_coordinator: Arc<dyn CommitCoordinator>, ) -> Result<Self>
Construct a handler backed by a specific CommitCoordinator.
Use this to wire a persistent coordinator (e.g. the Postgres-backed
GraphStore) instead of the default in-memory one.
Source§impl<Cx: Send + Sync + 'static> ServerHandler<Cx>
impl<Cx: Send + Sync + 'static> ServerHandler<Cx>
Sourcepub fn with_local_storage_policy(
self,
policy: impl Into<Arc<LocalStoragePolicy>>,
) -> Self
pub fn with_local_storage_policy( self, policy: impl Into<Arc<LocalStoragePolicy>>, ) -> Self
Set the allowlist governing file:// storage locations.
Rebuilds the inner handler with the policy attached. Call at construction time, before the handler is cloned/shared. When unset, all local storage is denied.
Sourcepub fn with_managed_storage_root(
self,
root: Option<impl Into<Arc<str>>>,
) -> Self
pub fn with_managed_storage_root( self, root: Option<impl Into<Arc<str>>>, ) -> Self
Set the metastore-level managed storage root.
Rebuilds the inner handler with the root attached. Call at construction
time, before the handler is cloned/shared. When unset, managed catalogs
must each supply their own storage_root.
Trait Implementations§
Source§impl<Cx: Clone> Clone for ServerHandler<Cx>
impl<Cx: Clone> Clone for ServerHandler<Cx>
Source§fn clone(&self) -> ServerHandler<Cx>
fn clone(&self) -> ServerHandler<Cx>
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl DeltaBackend<RequestContext> for ServerHandler<RequestContext>
impl DeltaBackend<RequestContext> for ServerHandler<RequestContext>
Source§fn capabilities(&self) -> DeltaCapabilities
fn capabilities(&self) -> DeltaCapabilities
The optional operations this backend serves, used by
getConfig to advertise
a capability-accurate endpoint list. Defaults to DeltaCapabilities::default
(all off), so a backend advertises an optional operation only by opting in.Source§fn catalog_exists<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
catalog: &'life1 str,
_cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn catalog_exists<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
catalog: &'life1 str,
_cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Confirm the catalog exists (for
getConfig). Missing → DeltaBackendError::NotFound.Source§fn resolve_table<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
table: &'life1 TableRef,
cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<ResolvedTable>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn resolve_table<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
table: &'life1 TableRef,
cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<ResolvedTable>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Resolve a table by 3-part name. Missing →
DeltaBackendError::NotFound.Authorize an action before the handler performs it. Read more
Source§fn validate_external_location<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
location: &'life1 str,
_cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn validate_external_location<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
location: &'life1 str,
_cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Validate that an EXTERNAL table location lies within a registered external
location.
Source§fn create_table_row<'life0, 'life1, 'async_trait>(
&'life0 self,
spec: CreateTableSpec,
_cx: &'life1 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<ResolvedTable>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn create_table_row<'life0, 'life1, 'async_trait>(
&'life0 self,
spec: CreateTableSpec,
_cx: &'life1 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<ResolvedTable>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Persist a new Delta table row and return it resolved. Read more
Source§fn update_table_row<'life0, 'life1, 'async_trait>(
&'life0 self,
spec: UpdateTableSpec,
_cx: &'life1 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<ResolvedTable>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn update_table_row<'life0, 'life1, 'async_trait>(
&'life0 self,
spec: UpdateTableSpec,
_cx: &'life1 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<ResolvedTable>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Persist metadata changes to an existing table and return it resolved. Read more
Source§fn delete_table<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
table: &'life1 TableRef,
cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn delete_table<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
table: &'life1 TableRef,
cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Delete a table.
Source§fn rename_table<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
from: &'life1 TableRef,
to_name: &'life2 str,
_cx: &'life3 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn rename_table<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
from: &'life1 TableRef,
to_name: &'life2 str,
_cx: &'life3 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
Rename a table within the same catalog + schema. Backends without rename
support return
DeltaBackendError::NotImplemented.Source§fn allocate_staging<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
at: &'life1 SchemaRef,
name: &'life2 str,
cx: &'life3 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<StagingReservation>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn allocate_staging<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
at: &'life1 SchemaRef,
name: &'life2 str,
cx: &'life3 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<StagingReservation>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
Allocate a staging reservation (uuid + managed location) under a schema.
Source§fn resolve_staging_by_location<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
location: &'life1 str,
_cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<StagingReservation>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn resolve_staging_by_location<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
location: &'life1 str,
_cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<StagingReservation>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Resolve a staging reservation by its managed location.
Source§fn resolve_staging_by_id<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
table_id: &'life1 str,
_cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<StagingReservation>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn resolve_staging_by_id<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
table_id: &'life1 str,
_cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<StagingReservation>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Resolve a staging reservation by its uuid.
Source§fn vend_table_credential<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
table_id: &'life1 str,
access: CredentialAccess,
cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<VendedCredential>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn vend_table_credential<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
table_id: &'life1 str,
access: CredentialAccess,
cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<VendedCredential>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Vend a credential for a table’s location at the given access level.
Source§fn vend_path_credential<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
location: &'life1 str,
access: CredentialAccess,
cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<VendedCredential>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn vend_path_credential<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
location: &'life1 str,
access: CredentialAccess,
cx: &'life2 RequestContext,
) -> Pin<Box<dyn Future<Output = BackendResult<VendedCredential>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Vend a credential for an arbitrary path at the given access level.
Source§fn commit_coordinator(&self) -> &dyn CommitCoordinator
fn commit_coordinator(&self) -> &dyn CommitCoordinator
The commit coordinator backing this backend’s Delta commit log.
Source§impl<Cx: Send + Sync + 'static> Policy<Cx> for ServerHandler<Cx>
impl<Cx: Send + Sync + 'static> Policy<Cx> for ServerHandler<Cx>
Check if the policy allows the action. Read more
fn check<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
obj: &'life1 dyn SecuredAction,
context: &'life2 Cx,
) -> Pin<Box<dyn Future<Output = Result<Decision>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn check_required<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
obj: &'life1 dyn SecuredAction,
context: &'life2 Cx,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Check if the policy allows the action, and return an error if denied.
Source§impl<Cx: Send + Sync + 'static> ProvidesCommitCoordinator for ServerHandler<Cx>
impl<Cx: Send + Sync + 'static> ProvidesCommitCoordinator for ServerHandler<Cx>
fn commit_coordinator(&self) -> &dyn CommitCoordinator
Source§impl<Cx: Send + Sync + 'static> ProvidesLocalStoragePolicy for ServerHandler<Cx>
impl<Cx: Send + Sync + 'static> ProvidesLocalStoragePolicy for ServerHandler<Cx>
fn local_storage_policy(&self) -> &LocalStoragePolicy
Source§impl<Cx: Send + Sync + 'static> ProvidesManagedStorageRoot for ServerHandler<Cx>
impl<Cx: Send + Sync + 'static> ProvidesManagedStorageRoot for ServerHandler<Cx>
fn managed_storage_root(&self) -> Option<&str>
Source§impl<Cx: Send + Sync + 'static> ProvidesPolicy<Cx> for ServerHandler<Cx>
impl<Cx: Send + Sync + 'static> ProvidesPolicy<Cx> for ServerHandler<Cx>
Source§impl<Cx: Send + Sync + 'static> ProvidesResourceStore for ServerHandler<Cx>
impl<Cx: Send + Sync + 'static> ProvidesResourceStore for ServerHandler<Cx>
fn store(&self) -> &dyn ResourceStore
Auto Trait Implementations§
impl<Cx> !RefUnwindSafe for ServerHandler<Cx>
impl<Cx> !UnwindSafe for ServerHandler<Cx>
impl<Cx> Freeze for ServerHandler<Cx>
impl<Cx> Send for ServerHandler<Cx>
impl<Cx> Sync for ServerHandler<Cx>
impl<Cx> Unpin for ServerHandler<Cx>
impl<Cx> UnsafeUnpin for ServerHandler<Cx>
Blanket Implementations§
Source§impl<T> AgentHandler for T
impl<T> AgentHandler for T
fn create_agent<'life0, 'async_trait>(
&'life0 self,
request: CreateAgentRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Agent, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Source§fn list_agents<'life0, 'async_trait>(
&'life0 self,
request: ListAgentsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListAgentsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_agents<'life0, 'async_trait>(
&'life0 self,
request: ListAgentsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListAgentsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Lists agents.
fn get_agent<'life0, 'async_trait>(
&'life0 self,
request: GetAgentRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Agent, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_agent<'life0, 'async_trait>(
&'life0 self,
request: UpdateAgentRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Agent, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_agent<'life0, 'async_trait>(
&'life0 self,
request: DeleteAgentRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Source§impl<T> AgentSkillHandler for T
impl<T> AgentSkillHandler for T
fn create_agent_skill<'life0, 'async_trait>(
&'life0 self,
request: CreateAgentSkillRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<AgentSkill, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Source§fn list_agent_skills<'life0, 'async_trait>(
&'life0 self,
request: ListAgentSkillsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListAgentSkillsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_agent_skills<'life0, 'async_trait>(
&'life0 self,
request: ListAgentSkillsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListAgentSkillsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Lists agent skills.
fn get_agent_skill<'life0, 'async_trait>(
&'life0 self,
request: GetAgentSkillRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<AgentSkill, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_agent_skill<'life0, 'async_trait>(
&'life0 self,
request: UpdateAgentSkillRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<AgentSkill, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_agent_skill<'life0, 'async_trait>(
&'life0 self,
request: DeleteAgentSkillRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CatalogHandler for T
impl<T> CatalogHandler for T
Source§fn create_catalog<'life0, 'async_trait>(
&'life0 self,
request: CreateCatalogRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Catalog, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_catalog<'life0, 'async_trait>(
&'life0 self,
request: CreateCatalogRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Catalog, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Create a new catalog Read more
Source§fn delete_catalog<'life0, 'async_trait>(
&'life0 self,
request: DeleteCatalogRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_catalog<'life0, 'async_trait>(
&'life0 self,
request: DeleteCatalogRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Delete a catalog Read more
Source§fn get_catalog<'life0, 'async_trait>(
&'life0 self,
request: GetCatalogRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Catalog, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_catalog<'life0, 'async_trait>(
&'life0 self,
request: GetCatalogRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Catalog, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Get a catalog Read more
Source§fn list_catalogs<'life0, 'async_trait>(
&'life0 self,
request: ListCatalogsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListCatalogsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_catalogs<'life0, 'async_trait>(
&'life0 self,
request: ListCatalogsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListCatalogsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
List catalogs Read more
Source§fn update_catalog<'life0, 'async_trait>(
&'life0 self,
request: UpdateCatalogRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Catalog, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_catalog<'life0, 'async_trait>(
&'life0 self,
request: UpdateCatalogRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Catalog, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Update a catalog Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> CredentialHandler for T
impl<T> CredentialHandler for T
fn list_credentials<'life0, 'async_trait>(
&'life0 self,
request: ListCredentialsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListCredentialsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_credential<'life0, 'async_trait>(
&'life0 self,
request: CreateCredentialRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Credential, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_credential<'life0, 'async_trait>(
&'life0 self,
request: GetCredentialRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Credential, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_credential<'life0, 'async_trait>(
&'life0 self,
request: UpdateCredentialRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Credential, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_credential<'life0, 'async_trait>(
&'life0 self,
request: DeleteCredentialRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Source§impl<T> CredentialHandlerExt for T
impl<T> CredentialHandlerExt for T
Source§fn get_credential_internal<'life0, 'async_trait>(
&'life0 self,
request: GetCredentialRequest,
) -> Pin<Box<dyn Future<Output = Result<Credential, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_credential_internal<'life0, 'async_trait>(
&'life0 self,
request: GetCredentialRequest,
) -> Pin<Box<dyn Future<Output = Result<Credential, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Get a credential without checking permissions. Read more
Source§impl<B, Cx> DeltaApiHandler<Cx> for Bwhere
B: DeltaBackend<Cx>,
Cx: Send + 'static,
impl<B, Cx> DeltaApiHandler<Cx> for Bwhere
B: DeltaBackend<Cx>,
Cx: Send + 'static,
Source§fn get_config<'life0, 'async_trait>(
&'life0 self,
query: GetConfigQuery,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaCatalogConfig, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
fn get_config<'life0, 'async_trait>(
&'life0 self,
query: GetConfigQuery,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaCatalogConfig, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
GET /delta/v1/configSource§fn create_staging_table<'life0, 'async_trait>(
&'life0 self,
path: SchemaRef,
request: DeltaCreateStagingTableRequest,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaStagingTableResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
fn create_staging_table<'life0, 'async_trait>(
&'life0 self,
path: SchemaRef,
request: DeltaCreateStagingTableRequest,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaStagingTableResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
POST /delta/v1/catalogs/{catalog}/schemas/{schema}/staging-tablesSource§fn create_table<'life0, 'async_trait>(
&'life0 self,
path: SchemaRef,
request: DeltaCreateTableRequest,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaLoadTableResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
fn create_table<'life0, 'async_trait>(
&'life0 self,
path: SchemaRef,
request: DeltaCreateTableRequest,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaLoadTableResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
POST /delta/v1/catalogs/{catalog}/schemas/{schema}/tablesSource§fn load_table<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaLoadTableResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
fn load_table<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaLoadTableResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
GET /delta/v1/catalogs/{catalog}/schemas/{schema}/tables/{table}Source§fn update_table<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
request: DeltaUpdateTableRequest,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaLoadTableResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
fn update_table<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
request: DeltaUpdateTableRequest,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaLoadTableResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
POST /delta/v1/catalogs/{catalog}/schemas/{schema}/tables/{table}Source§fn delete_table<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<(), DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
fn delete_table<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<(), DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
DELETE /delta/v1/catalogs/{catalog}/schemas/{schema}/tables/{table}Source§fn table_exists<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<(), DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
fn table_exists<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<(), DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
HEAD /delta/v1/catalogs/{catalog}/schemas/{schema}/tables/{table}Source§fn rename_table<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
request: DeltaRenameTableRequest,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<(), DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
fn rename_table<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
request: DeltaRenameTableRequest,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<(), DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
POST /delta/v1/catalogs/{catalog}/schemas/{schema}/tables/{table}/renameSource§fn get_table_credentials<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
operation: DeltaCredentialOperation,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaCredentialsResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
fn get_table_credentials<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
operation: DeltaCredentialOperation,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaCredentialsResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
GET /delta/v1/catalogs/{catalog}/schemas/{schema}/tables/{table}/credentialsSource§fn report_metrics<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
request: DeltaReportMetricsRequest,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<(), DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
fn report_metrics<'life0, 'async_trait>(
&'life0 self,
path: TableRef,
request: DeltaReportMetricsRequest,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<(), DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
POST /delta/v1/catalogs/{catalog}/schemas/{schema}/tables/{table}/metricsSource§fn get_staging_table_credentials<'life0, 'async_trait>(
&'life0 self,
table_id: String,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaCredentialsResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
fn get_staging_table_credentials<'life0, 'async_trait>(
&'life0 self,
table_id: String,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaCredentialsResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
GET /delta/v1/staging-tables/{table_id}/credentialsSource§fn get_temporary_path_credentials<'life0, 'async_trait>(
&'life0 self,
location: String,
operation: DeltaCredentialOperation,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaCredentialsResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
fn get_temporary_path_credentials<'life0, 'async_trait>(
&'life0 self,
location: String,
operation: DeltaCredentialOperation,
context: Cx,
) -> Pin<Box<dyn Future<Output = Result<DeltaCredentialsResponse, DeltaApiError>> + Send + 'async_trait>>where
'life0: 'async_trait,
B: 'async_trait,
GET /delta/v1/temporary-path-credentialsSource§impl<T> EntityTagAssignmentHandler for T
impl<T> EntityTagAssignmentHandler for T
Source§fn create_entity_tag_assignment<'life0, 'async_trait>(
&'life0 self,
request: CreateEntityTagAssignmentRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<EntityTagAssignment, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_entity_tag_assignment<'life0, 'async_trait>(
&'life0 self,
request: CreateEntityTagAssignmentRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<EntityTagAssignment, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Create an entity tag assignment Read more
Source§fn delete_entity_tag_assignment<'life0, 'async_trait>(
&'life0 self,
request: DeleteEntityTagAssignmentRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_entity_tag_assignment<'life0, 'async_trait>(
&'life0 self,
request: DeleteEntityTagAssignmentRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Delete an entity tag assignment Read more
Source§fn get_entity_tag_assignment<'life0, 'async_trait>(
&'life0 self,
request: GetEntityTagAssignmentRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<EntityTagAssignment, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_entity_tag_assignment<'life0, 'async_trait>(
&'life0 self,
request: GetEntityTagAssignmentRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<EntityTagAssignment, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Get an entity tag assignment Read more
Source§fn list_entity_tag_assignments<'life0, 'async_trait>(
&'life0 self,
request: ListEntityTagAssignmentsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListEntityTagAssignmentsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_entity_tag_assignments<'life0, 'async_trait>(
&'life0 self,
request: ListEntityTagAssignmentsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListEntityTagAssignmentsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
List entity tag assignments Read more
Source§fn update_entity_tag_assignment<'life0, 'async_trait>(
&'life0 self,
request: UpdateEntityTagAssignmentRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<EntityTagAssignment, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_entity_tag_assignment<'life0, 'async_trait>(
&'life0 self,
request: UpdateEntityTagAssignmentRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<EntityTagAssignment, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Update an entity tag assignment Read more
Source§impl<T> ExternalLocationHandler for T
impl<T> ExternalLocationHandler for T
Source§fn create_external_location<'life0, 'async_trait>(
&'life0 self,
request: CreateExternalLocationRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ExternalLocation, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_external_location<'life0, 'async_trait>(
&'life0 self,
request: CreateExternalLocationRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ExternalLocation, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Create a new external location
Source§fn delete_external_location<'life0, 'async_trait>(
&'life0 self,
request: DeleteExternalLocationRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_external_location<'life0, 'async_trait>(
&'life0 self,
request: DeleteExternalLocationRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Delete an external location
Source§fn get_external_location<'life0, 'async_trait>(
&'life0 self,
request: GetExternalLocationRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ExternalLocation, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_external_location<'life0, 'async_trait>(
&'life0 self,
request: GetExternalLocationRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ExternalLocation, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Get an external location
Source§fn list_external_locations<'life0, 'async_trait>(
&'life0 self,
request: ListExternalLocationsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListExternalLocationsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_external_locations<'life0, 'async_trait>(
&'life0 self,
request: ListExternalLocationsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListExternalLocationsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
List external locations
Source§fn update_external_location<'life0, 'async_trait>(
&'life0 self,
request: UpdateExternalLocationRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ExternalLocation, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_external_location<'life0, 'async_trait>(
&'life0 self,
request: UpdateExternalLocationRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ExternalLocation, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Update an external location
Source§impl<T> FunctionHandler for T
impl<T> FunctionHandler for T
Source§fn list_functions<'life0, 'async_trait>(
&'life0 self,
request: ListFunctionsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListFunctionsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_functions<'life0, 'async_trait>(
&'life0 self,
request: ListFunctionsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListFunctionsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
List functions Read more
Source§fn create_function<'life0, 'async_trait>(
&'life0 self,
request: CreateFunctionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Function, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_function<'life0, 'async_trait>(
&'life0 self,
request: CreateFunctionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Function, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Create a function Read more
Source§fn get_function<'life0, 'async_trait>(
&'life0 self,
request: GetFunctionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Function, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_function<'life0, 'async_trait>(
&'life0 self,
request: GetFunctionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Function, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Get a function Read more
Source§fn update_function<'life0, 'async_trait>(
&'life0 self,
request: UpdateFunctionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Function, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_function<'life0, 'async_trait>(
&'life0 self,
request: UpdateFunctionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Function, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Update a function Read more
Source§fn delete_function<'life0, 'async_trait>(
&'life0 self,
request: DeleteFunctionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_function<'life0, 'async_trait>(
&'life0 self,
request: DeleteFunctionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Delete a function Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::RequestSource§impl<T> ModelVersionHandler for T
impl<T> ModelVersionHandler for T
Source§fn list_model_versions<'life0, 'async_trait>(
&'life0 self,
request: ListModelVersionsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListModelVersionsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_model_versions<'life0, 'async_trait>(
&'life0 self,
request: ListModelVersionsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListModelVersionsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
List model versions Read more
Source§fn create_model_version<'life0, 'async_trait>(
&'life0 self,
request: CreateModelVersionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ModelVersion, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_model_version<'life0, 'async_trait>(
&'life0 self,
request: CreateModelVersionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ModelVersion, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Create a model version Read more
Source§fn get_model_version<'life0, 'async_trait>(
&'life0 self,
request: GetModelVersionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ModelVersion, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_model_version<'life0, 'async_trait>(
&'life0 self,
request: GetModelVersionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ModelVersion, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Get a model version Read more
Source§fn update_model_version<'life0, 'async_trait>(
&'life0 self,
request: UpdateModelVersionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ModelVersion, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_model_version<'life0, 'async_trait>(
&'life0 self,
request: UpdateModelVersionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ModelVersion, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Update a model version Read more
Source§fn delete_model_version<'life0, 'async_trait>(
&'life0 self,
request: DeleteModelVersionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_model_version<'life0, 'async_trait>(
&'life0 self,
request: DeleteModelVersionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Delete a model version Read more
Source§fn finalize_model_version<'life0, 'async_trait>(
&'life0 self,
request: FinalizeModelVersionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ModelVersion, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn finalize_model_version<'life0, 'async_trait>(
&'life0 self,
request: FinalizeModelVersionRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ModelVersion, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Finalize a model version Read more
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> PolicyHandler for T
impl<T> PolicyHandler for T
Source§fn create_policy<'life0, 'async_trait>(
&'life0 self,
request: CreatePolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<PolicyInfo, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_policy<'life0, 'async_trait>(
&'life0 self,
request: CreatePolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<PolicyInfo, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Create a new policy Read more
Source§fn delete_policy<'life0, 'async_trait>(
&'life0 self,
request: DeletePolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_policy<'life0, 'async_trait>(
&'life0 self,
request: DeletePolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Delete a policy Read more
Source§fn get_policy<'life0, 'async_trait>(
&'life0 self,
request: GetPolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<PolicyInfo, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_policy<'life0, 'async_trait>(
&'life0 self,
request: GetPolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<PolicyInfo, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Get a policy Read more
Source§fn list_policies<'life0, 'async_trait>(
&'life0 self,
request: ListPoliciesRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListPoliciesResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_policies<'life0, 'async_trait>(
&'life0 self,
request: ListPoliciesRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListPoliciesResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
List policies Read more
Source§fn update_policy<'life0, 'async_trait>(
&'life0 self,
request: UpdatePolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<PolicyInfo, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_policy<'life0, 'async_trait>(
&'life0 self,
request: UpdatePolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<PolicyInfo, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Update a policy Read more
Source§impl<T> ProviderHandler for T
impl<T> ProviderHandler for T
Source§fn create_provider<'life0, 'async_trait>(
&'life0 self,
request: CreateProviderRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Provider, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_provider<'life0, 'async_trait>(
&'life0 self,
request: CreateProviderRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Provider, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Create a new provider.
Source§fn delete_provider<'life0, 'async_trait>(
&'life0 self,
request: DeleteProviderRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_provider<'life0, 'async_trait>(
&'life0 self,
request: DeleteProviderRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Delete a provider.
Source§fn get_provider<'life0, 'async_trait>(
&'life0 self,
request: GetProviderRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Provider, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_provider<'life0, 'async_trait>(
&'life0 self,
request: GetProviderRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Provider, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Get a provider by name.
Source§fn list_providers<'life0, 'async_trait>(
&'life0 self,
request: ListProvidersRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListProvidersResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_providers<'life0, 'async_trait>(
&'life0 self,
request: ListProvidersRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListProvidersResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
List providers.
Source§fn update_provider<'life0, 'async_trait>(
&'life0 self,
request: UpdateProviderRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Provider, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_provider<'life0, 'async_trait>(
&'life0 self,
request: UpdateProviderRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Provider, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Update a provider.
impl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
Source§impl<T> RecipientHandler for T
impl<T> RecipientHandler for T
Source§fn create_recipient<'life0, 'async_trait>(
&'life0 self,
request: CreateRecipientRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Recipient, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_recipient<'life0, 'async_trait>(
&'life0 self,
request: CreateRecipientRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Recipient, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Create a new recipient.
Source§fn delete_recipient<'life0, 'async_trait>(
&'life0 self,
request: DeleteRecipientRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_recipient<'life0, 'async_trait>(
&'life0 self,
request: DeleteRecipientRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Delete a recipient.
Source§fn get_recipient<'life0, 'async_trait>(
&'life0 self,
request: GetRecipientRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Recipient, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_recipient<'life0, 'async_trait>(
&'life0 self,
request: GetRecipientRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Recipient, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Get a recipient by name.
Source§fn list_recipients<'life0, 'async_trait>(
&'life0 self,
request: ListRecipientsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListRecipientsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_recipients<'life0, 'async_trait>(
&'life0 self,
request: ListRecipientsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListRecipientsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
List recipients.
Source§fn update_recipient<'life0, 'async_trait>(
&'life0 self,
request: UpdateRecipientRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Recipient, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_recipient<'life0, 'async_trait>(
&'life0 self,
request: UpdateRecipientRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Recipient, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Update a recipient.
Source§impl<T> RegisteredModelHandler for T
impl<T> RegisteredModelHandler for T
Source§fn list_registered_models<'life0, 'async_trait>(
&'life0 self,
request: ListRegisteredModelsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListRegisteredModelsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_registered_models<'life0, 'async_trait>(
&'life0 self,
request: ListRegisteredModelsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListRegisteredModelsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
List registered models Read more
Source§fn create_registered_model<'life0, 'async_trait>(
&'life0 self,
request: CreateRegisteredModelRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<RegisteredModel, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_registered_model<'life0, 'async_trait>(
&'life0 self,
request: CreateRegisteredModelRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<RegisteredModel, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Create a registered model Read more
Source§fn get_registered_model<'life0, 'async_trait>(
&'life0 self,
request: GetRegisteredModelRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<RegisteredModel, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_registered_model<'life0, 'async_trait>(
&'life0 self,
request: GetRegisteredModelRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<RegisteredModel, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Get a registered model Read more
Source§fn update_registered_model<'life0, 'async_trait>(
&'life0 self,
request: UpdateRegisteredModelRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<RegisteredModel, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_registered_model<'life0, 'async_trait>(
&'life0 self,
request: UpdateRegisteredModelRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<RegisteredModel, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Update a registered model Read more
Source§fn delete_registered_model<'life0, 'async_trait>(
&'life0 self,
request: DeleteRegisteredModelRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_registered_model<'life0, 'async_trait>(
&'life0 self,
request: DeleteRegisteredModelRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Delete a registered model Read more
Source§impl<T> ResourceStore for Twhere
T: ProvidesResourceStore,
impl<T> ResourceStore for Twhere
T: ProvidesResourceStore,
Source§fn create_versioned<'life0, 'async_trait>(
&'life0 self,
resource: Resource,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef, u64), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_versioned<'life0, 'async_trait>(
&'life0 self,
resource: Resource,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef, u64), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Create a resource, returning its initial store version alongside it. Read more
Source§fn delete<'life0, 'life1, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
fn delete<'life0, 'life1, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
Delete a resource and all connected associations by its identifier. Read more
Source§fn replace_atomically_versioned<'life0, 'life1, 'async_trait>(
&'life0 self,
delete: &'life1 ResourceIdent,
create: Resource,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef, u64), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
fn replace_atomically_versioned<'life0, 'life1, 'async_trait>(
&'life0 self,
delete: &'life1 ResourceIdent,
create: Resource,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef, u64), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
replace_atomically, returning the created
object’s store version alongside it (see create_versioned). Read moreSource§fn update_checked<'life0, 'life1, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
resource: Resource,
precondition: Precondition,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef, u64), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
fn update_checked<'life0, 'life1, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
resource: Resource,
precondition: Precondition,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef, u64), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
Update a resource under an optimistic-concurrency precondition. Read more
Source§fn rename<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
new_name: &'life2 ResourceName,
precondition: Precondition,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef, u64), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
T: 'async_trait,
fn rename<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
new_name: &'life2 ResourceName,
precondition: Precondition,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef, u64), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
T: 'async_trait,
Rename a resource to a new (possibly namespaced) name. Read more
Source§fn add_association<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
from: &'life1 ResourceIdent,
to: &'life2 ResourceIdent,
label: &'life3 AssociationLabel,
properties: Option<HashMap<String, Value>>,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
T: 'async_trait,
fn add_association<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
from: &'life1 ResourceIdent,
to: &'life2 ResourceIdent,
label: &'life3 AssociationLabel,
properties: Option<HashMap<String, Value>>,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
T: 'async_trait,
Add an association between two resources. Read more
Source§fn remove_association<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
from: &'life1 ResourceIdent,
to: &'life2 ResourceIdent,
label: &'life3 AssociationLabel,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
T: 'async_trait,
fn remove_association<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
from: &'life1 ResourceIdent,
to: &'life2 ResourceIdent,
label: &'life3 AssociationLabel,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
T: 'async_trait,
Remove an association between two resources. Read more
Source§fn list_associations<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
resource: &'life1 ResourceIdent,
label: &'life2 AssociationLabel,
target_label: Option<&'life3 ResourceIdent>,
max_results: Option<usize>,
page_token: Option<String>,
) -> Pin<Box<dyn Future<Output = Result<(Vec<ResourceIdent>, Option<String>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
T: 'async_trait,
fn list_associations<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
resource: &'life1 ResourceIdent,
label: &'life2 AssociationLabel,
target_label: Option<&'life3 ResourceIdent>,
max_results: Option<usize>,
page_token: Option<String>,
) -> Pin<Box<dyn Future<Output = Result<(Vec<ResourceIdent>, Option<String>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
T: 'async_trait,
List associations of a resource. Read more
Source§fn list_associations_with_properties<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
resource: &'life1 ResourceIdent,
label: &'life2 AssociationLabel,
target_label: Option<&'life3 ResourceIdent>,
max_results: Option<usize>,
page_token: Option<String>,
) -> Pin<Box<dyn Future<Output = Result<(Vec<(ResourceIdent, Option<HashMap<String, Value>>)>, Option<String>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
T: 'async_trait,
fn list_associations_with_properties<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
resource: &'life1 ResourceIdent,
label: &'life2 AssociationLabel,
target_label: Option<&'life3 ResourceIdent>,
max_results: Option<usize>,
page_token: Option<String>,
) -> Pin<Box<dyn Future<Output = Result<(Vec<(ResourceIdent, Option<HashMap<String, Value>>)>, Option<String>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
T: 'async_trait,
List associations of a resource together with each association’s properties. Read more
Source§fn create<'life0, 'async_trait>(
&'life0 self,
resource: Resource,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
fn create<'life0, 'async_trait>(
&'life0 self,
resource: Resource,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
Create a new resource. Read more
Source§fn replace_atomically<'life0, 'life1, 'async_trait>(
&'life0 self,
delete: &'life1 ResourceIdent,
create: Resource,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn replace_atomically<'life0, 'life1, 'async_trait>(
&'life0 self,
delete: &'life1 ResourceIdent,
create: Resource,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Atomically delete one resource and create another in one transaction. Read more
Source§fn update<'life0, 'life1, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
resource: Resource,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn update<'life0, 'life1, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
resource: Resource,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Update a resource unconditionally. Read more
Source§impl<T> ResourceStoreReader for Twhere
T: ProvidesResourceStore,
impl<T> ResourceStoreReader for Twhere
T: ProvidesResourceStore,
Source§fn get<'life0, 'life1, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
fn get<'life0, 'life1, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
Get a resource by its identifier. Read more
Source§fn get_many<'life0, 'life1, 'async_trait>(
&'life0 self,
ids: &'life1 [ResourceIdent],
) -> Pin<Box<dyn Future<Output = Result<Vec<(Resource, ResourceRef)>, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
fn get_many<'life0, 'life1, 'async_trait>(
&'life0 self,
ids: &'life1 [ResourceIdent],
) -> Pin<Box<dyn Future<Output = Result<Vec<(Resource, ResourceRef)>, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
Get multiple resources by their identifiers. Read more
Source§fn get_with_secrets<'life0, 'life1, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
fn get_with_secrets<'life0, 'life1, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
Get a resource with its sensitive fields decrypted and merged into the typed model. Read more
Source§fn get_versioned<'life0, 'life1, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef, u64), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
fn get_versioned<'life0, 'life1, 'async_trait>(
&'life0 self,
id: &'life1 ResourceIdent,
) -> Pin<Box<dyn Future<Output = Result<(Resource, ResourceRef, u64), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
Get a resource together with its current version (etag). Read more
Source§fn list<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
label: &'life1 ObjectLabel,
namespace: Option<&'life2 ResourceName>,
max_results: Option<usize>,
page_token: Option<String>,
) -> Pin<Box<dyn Future<Output = Result<(Vec<Resource>, Option<String>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
T: 'async_trait,
fn list<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
label: &'life1 ObjectLabel,
namespace: Option<&'life2 ResourceName>,
max_results: Option<usize>,
page_token: Option<String>,
) -> Pin<Box<dyn Future<Output = Result<(Vec<Resource>, Option<String>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
T: 'async_trait,
List resources. Read more
Source§impl<T> SchemaHandler for T
impl<T> SchemaHandler for T
Source§fn create_schema<'life0, 'async_trait>(
&'life0 self,
request: CreateSchemaRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Schema, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_schema<'life0, 'async_trait>(
&'life0 self,
request: CreateSchemaRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Schema, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Creates a new schema for catalog in the Metatastore. The caller must be a metastore admin,
or have the CREATE_SCHEMA privilege in the parent catalog.
Source§fn delete_schema<'life0, 'async_trait>(
&'life0 self,
request: DeleteSchemaRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_schema<'life0, 'async_trait>(
&'life0 self,
request: DeleteSchemaRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Deletes the specified schema from the parent catalog. The caller must be the owner
of the schema or an owner of the parent catalog.
Source§fn list_schemas<'life0, 'async_trait>(
&'life0 self,
request: ListSchemasRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListSchemasResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_schemas<'life0, 'async_trait>(
&'life0 self,
request: ListSchemasRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListSchemasResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Gets an array of schemas for a catalog in the metastore. If the caller is the metastore
admin or the owner of the parent catalog, all schemas for the catalog will be retrieved.
Otherwise, only schemas owned by the caller (or for which the caller has the USE_SCHEMA privilege)
will be retrieved. There is no guarantee of a specific ordering of the elements in the array.
Source§fn get_schema<'life0, 'async_trait>(
&'life0 self,
request: GetSchemaRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Schema, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_schema<'life0, 'async_trait>(
&'life0 self,
request: GetSchemaRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Schema, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Gets the specified schema within the metastore.
The caller must be a metastore admin, the owner of the schema,
or a user that has the USE_SCHEMA privilege on the schema.
Source§fn update_schema<'life0, 'async_trait>(
&'life0 self,
request: UpdateSchemaRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Schema, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_schema<'life0, 'async_trait>(
&'life0 self,
request: UpdateSchemaRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Schema, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Updates a schema for a catalog. The caller must be the owner of the schema or a metastore admin.
If the caller is a metastore admin, only the owner field can be changed in the update.
If the name field must be updated, the caller must be a metastore admin or have the CREATE_SCHEMA
privilege on the parent catalog.
Create a new share.
Deletes a share.
List shares.
Get a share by name.
Update a share.
Source§fn get_permissions<'life0, 'async_trait>(
&'life0 self,
request: GetPermissionsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<GetPermissionsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_permissions<'life0, 'async_trait>(
&'life0 self,
request: GetPermissionsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<GetPermissionsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Gets the permissions for a data share from the metastore.
Source§fn update_permissions<'life0, 'async_trait>(
&'life0 self,
request: UpdatePermissionsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<UpdatePermissionsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_permissions<'life0, 'async_trait>(
&'life0 self,
request: UpdatePermissionsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<UpdatePermissionsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Updates the permissions for a data share in the metastore.
Source§impl<T> StagingTableHandler for T
impl<T> StagingTableHandler for T
Source§fn create_staging_table<'life0, 'async_trait>(
&'life0 self,
request: CreateStagingTableRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<StagingTable, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_staging_table<'life0, 'async_trait>(
&'life0 self,
request: CreateStagingTableRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<StagingTable, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Creates a new staging table, allocating an immutable table id and a storage
location under the parent schema/catalog managed storage root. The caller
must have the CREATE privilege on the parent schema.
Source§impl<T> TableHandler for T
impl<T> TableHandler for T
Source§fn list_table_summaries<'life0, 'async_trait>(
&'life0 self,
request: ListTableSummariesRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListTableSummariesResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_table_summaries<'life0, 'async_trait>(
&'life0 self,
request: ListTableSummariesRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListTableSummariesResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Gets an array of summaries for tables for a schema and catalog within the metastore. The table summaries returned are either: Read more
Source§fn list_tables<'life0, 'async_trait>(
&'life0 self,
request: ListTablesRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListTablesResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_tables<'life0, 'async_trait>(
&'life0 self,
request: ListTablesRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListTablesResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Gets an array of all tables for the current metastore under the parent catalog and schema. Read more
Source§fn create_table<'life0, 'async_trait>(
&'life0 self,
request: CreateTableRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Table, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_table<'life0, 'async_trait>(
&'life0 self,
request: CreateTableRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Table, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Create a table
Source§fn get_table<'life0, 'async_trait>(
&'life0 self,
request: GetTableRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Table, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_table<'life0, 'async_trait>(
&'life0 self,
request: GetTableRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Table, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Get a table
Source§fn get_table_exists<'life0, 'async_trait>(
&'life0 self,
request: GetTableExistsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<GetTableExistsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_table_exists<'life0, 'async_trait>(
&'life0 self,
request: GetTableExistsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<GetTableExistsResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Get boolean reflecting if table exists
Source§fn delete_table<'life0, 'async_trait>(
&'life0 self,
request: DeleteTableRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_table<'life0, 'async_trait>(
&'life0 self,
request: DeleteTableRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Delete a table
Source§impl<T> TagPolicyHandler for T
impl<T> TagPolicyHandler for T
Source§fn create_tag_policy<'life0, 'async_trait>(
&'life0 self,
request: CreateTagPolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TagPolicy, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn create_tag_policy<'life0, 'async_trait>(
&'life0 self,
request: CreateTagPolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TagPolicy, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Create a new tag policy Read more
Source§fn delete_tag_policy<'life0, 'async_trait>(
&'life0 self,
request: DeleteTagPolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn delete_tag_policy<'life0, 'async_trait>(
&'life0 self,
request: DeleteTagPolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Delete a tag policy Read more
Source§fn get_tag_policy<'life0, 'async_trait>(
&'life0 self,
request: GetTagPolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TagPolicy, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn get_tag_policy<'life0, 'async_trait>(
&'life0 self,
request: GetTagPolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TagPolicy, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Get a tag policy Read more
Source§fn list_tag_policies<'life0, 'async_trait>(
&'life0 self,
request: ListTagPoliciesRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListTagPoliciesResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_tag_policies<'life0, 'async_trait>(
&'life0 self,
request: ListTagPoliciesRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListTagPoliciesResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
List tag policies Read more
Source§fn update_tag_policy<'life0, 'async_trait>(
&'life0 self,
request: UpdateTagPolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TagPolicy, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn update_tag_policy<'life0, 'async_trait>(
&'life0 self,
request: UpdateTagPolicyRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TagPolicy, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Update a tag policy Read more
Source§impl<T> TemporaryCredentialHandler for T
impl<T> TemporaryCredentialHandler for T
Source§fn generate_temporary_volume_credentials<'life0, 'async_trait>(
&'life0 self,
request: GenerateTemporaryVolumeCredentialsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TemporaryCredential, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn generate_temporary_volume_credentials<'life0, 'async_trait>(
&'life0 self,
request: GenerateTemporaryVolumeCredentialsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TemporaryCredential, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Generate temporary credentials for a volume.
Resolves the volume by its UUID, authorizes the requested operation
against the concrete volume, then vends credentials scoped to the
volume’s storage location — mirroring
generate_temporary_table_credentials.
Source§fn generate_temporary_model_version_credentials<'life0, 'async_trait>(
&'life0 self,
request: GenerateTemporaryModelVersionCredentialsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TemporaryCredential, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn generate_temporary_model_version_credentials<'life0, 'async_trait>(
&'life0 self,
request: GenerateTemporaryModelVersionCredentialsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TemporaryCredential, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Generate temporary credentials for a model version.
Resolves the model version by its (catalog, schema, model, version)
composite name, authorizes the requested operation against the concrete
version, then vends credentials scoped to the version’s storage location —
mirroring
generate_temporary_volume_credentials.
Source§fn generate_temporary_path_credentials<'life0, 'async_trait>(
&'life0 self,
request: GenerateTemporaryPathCredentialsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TemporaryCredential, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn generate_temporary_path_credentials<'life0, 'async_trait>(
&'life0 self,
request: GenerateTemporaryPathCredentialsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TemporaryCredential, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Generate a new set of credentials for a path.
Source§fn generate_temporary_table_credentials<'life0, 'async_trait>(
&'life0 self,
request: GenerateTemporaryTableCredentialsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TemporaryCredential, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn generate_temporary_table_credentials<'life0, 'async_trait>(
&'life0 self,
request: GenerateTemporaryTableCredentialsRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<TemporaryCredential, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Generate a new set of credentials for a table.
Source§impl<T> VolumeHandler for T
impl<T> VolumeHandler for T
fn create_volume<'life0, 'async_trait>(
&'life0 self,
request: CreateVolumeRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<Volume, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Source§fn list_volumes<'life0, 'async_trait>(
&'life0 self,
request: ListVolumesRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListVolumesResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn list_volumes<'life0, 'async_trait>(
&'life0 self,
request: ListVolumesRequest,
context: RequestContext,
) -> Pin<Box<dyn Future<Output = Result<ListVolumesResponse, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Lists volumes.