pub struct ServerHandlerInner<Cx> { /* private fields */ }Implementations§
Source§impl<Cx: Send + Sync + 'static> ServerHandlerInner<Cx>
impl<Cx: Send + Sync + 'static> ServerHandlerInner<Cx>
pub fn new(policy: Arc<dyn Policy<Cx>>, store: Arc<dyn ResourceStore>) -> Self
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.
When unset, the handler denies every local storage path.
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.
When unset, managed catalogs must each supply their own storage_root.
Sourcepub fn with_commit_coordinator(
self,
coordinator: Arc<dyn CommitCoordinator>,
) -> Self
pub fn with_commit_coordinator( self, coordinator: Arc<dyn CommitCoordinator>, ) -> Self
Override the Delta commit coordinator (e.g. a Postgres-backed one, or a custom unbackfilled cap).
Trait Implementations§
Source§impl<Cx: Clone> Clone for ServerHandlerInner<Cx>
impl<Cx: Clone> Clone for ServerHandlerInner<Cx>
Source§fn clone(&self) -> ServerHandlerInner<Cx>
fn clone(&self) -> ServerHandlerInner<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<Cx: Send + Sync + 'static> Policy<Cx> for ServerHandlerInner<Cx>
impl<Cx: Send + Sync + 'static> Policy<Cx> for ServerHandlerInner<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 ServerHandlerInner<Cx>
impl<Cx: Send + Sync + 'static> ProvidesCommitCoordinator for ServerHandlerInner<Cx>
fn commit_coordinator(&self) -> &dyn CommitCoordinator
Source§impl<Cx: Send + Sync + 'static> ProvidesLocalStoragePolicy for ServerHandlerInner<Cx>
impl<Cx: Send + Sync + 'static> ProvidesLocalStoragePolicy for ServerHandlerInner<Cx>
fn local_storage_policy(&self) -> &LocalStoragePolicy
Source§impl<Cx: Send + Sync + 'static> ProvidesManagedStorageRoot for ServerHandlerInner<Cx>
impl<Cx: Send + Sync + 'static> ProvidesManagedStorageRoot for ServerHandlerInner<Cx>
fn managed_storage_root(&self) -> Option<&str>
Source§impl<Cx: Send + Sync + 'static> ProvidesPolicy<Cx> for ServerHandlerInner<Cx>
impl<Cx: Send + Sync + 'static> ProvidesPolicy<Cx> for ServerHandlerInner<Cx>
Source§impl<Cx: Send + Sync + 'static> ProvidesResourceStore for ServerHandlerInner<Cx>
impl<Cx: Send + Sync + 'static> ProvidesResourceStore for ServerHandlerInner<Cx>
fn store(&self) -> &dyn ResourceStore
Auto Trait Implementations§
impl<Cx> !RefUnwindSafe for ServerHandlerInner<Cx>
impl<Cx> !UnwindSafe for ServerHandlerInner<Cx>
impl<Cx> Freeze for ServerHandlerInner<Cx>
impl<Cx> Send for ServerHandlerInner<Cx>
impl<Cx> Sync for ServerHandlerInner<Cx>
impl<Cx> Unpin for ServerHandlerInner<Cx>
impl<Cx> UnsafeUnpin for ServerHandlerInner<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<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.