Struct ObjectStoreAdapter 

pub struct ObjectStoreAdapter<S> { /* private fields */ }

Adapter that implements ResourceStore for any store implementing the generic ObjectStore and AssociationStore traits.

This bridges the typed Resource/ResourceIdent API surface to the generic Object<ObjectLabel> layer, using the TryFrom conversions generated by object_conversions!.

Implementations

impl<S> ObjectStoreAdapter<S>

pub fn new(store: S) -> ObjectStoreAdapter<S>

pub fn into_inner(self) -> S

Trait Implementations

impl<S> ResourceStore for ObjectStoreAdapter<S>

where S: ObjectStore<ObjectLabel> + AssociationStore<ObjectLabel> + SecretObjectReader<ObjectLabel> + Transactional<ObjectLabel> + Send + Sync + 'static,

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, ObjectStoreAdapter<S>: 'async_trait,

Run the delete + create in one backend transaction so the two land atomically (see the trait method’s contract). The transaction closure operates on the raw StoreExec surface, so the delete ident is resolved to a uuid before the transaction begins and the create Resource is converted to an Object up front. Neither StagingTable nor Table (the sole in-tree caller’s resources) carries a sensitive field, so bypassing the managed sealing layer inside the tx is sound.

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, ObjectStoreAdapter<S>: 'async_trait,

Create a resource, returning its initial store version alongside it.

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, ObjectStoreAdapter<S>: 'async_trait,

Delete a resource and all connected associations by its identifier.

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, ObjectStoreAdapter<S>: 'async_trait,

Update a resource under an optimistic-concurrency precondition.

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, ObjectStoreAdapter<S>: 'async_trait,

Rename a resource to a new (possibly namespaced) name.

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, ObjectStoreAdapter<S>: 'async_trait,

Add an association between two resources.

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, ObjectStoreAdapter<S>: 'async_trait,

Remove an association between two resources.

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, ObjectStoreAdapter<S>: 'async_trait,

List associations of a resource.

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, ObjectStoreAdapter<S>: 'async_trait,

List associations of a resource together with each association’s properties.

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.

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.

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.

impl<S> ResourceStoreReader for ObjectStoreAdapter<S>

where S: SecretObjectReader<ObjectLabel> + Send + Sync + 'static,

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, ObjectStoreAdapter<S>: 'async_trait,

Surface the stored object’s version alongside the resource, so a caller can pin a later CAS write to it (see ResourceStoreReader::get_versioned).

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, ObjectStoreAdapter<S>: 'async_trait,

Override the redacting default: read the object with its sensitive fields decrypted (via the inner store’s SecretObjectReader) so the typed model is fully hydrated.

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, ObjectStoreAdapter<S>: 'async_trait,

Get a resource by its identifier.

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, ObjectStoreAdapter<S>: 'async_trait,

List resources.

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, Self: 'async_trait,

Get multiple resources by their identifiers.