Struct InMemoryProvider

pub struct InMemoryProvider { /* private fields */ }

Thread-safe in-memory resource provider supporting both single and multi-tenant operations.

This provider organizes data as: tenant_id -> resource_type -> resource_id -> resource For single-tenant operations, it uses “default” as the tenant_id.

Implementations

impl InMemoryProvider

pub fn new() -> Self

Create a new in-memory provider.

pub async fn clear(&self)

Clear all data (useful for testing).

pub async fn get_stats(&self) -> InMemoryStats

Get statistics about stored data.

pub async fn list_resources_in_tenant( &self, tenant_id: &str, resource_type: &str, ) -> Vec<Resource>

List all resources of a specific type in a tenant.

impl InMemoryProvider

pub async fn conditional_update( &self, resource_type: &str, id: &str, data: Value, expected_version: &ScimVersion, context: &RequestContext, ) -> Result<ConditionalResult<VersionedResource>, InMemoryError>

pub async fn conditional_delete( &self, resource_type: &str, id: &str, expected_version: &ScimVersion, context: &RequestContext, ) -> Result<ConditionalResult<()>, InMemoryError>

pub async fn conditional_patch_resource( &self, resource_type: &str, id: &str, patch_request: &Value, expected_version: &ScimVersion, context: &RequestContext, ) -> Result<ConditionalResult<VersionedResource>, InMemoryError>

pub async fn get_versioned_resource( &self, resource_type: &str, id: &str, context: &RequestContext, ) -> Result<Option<VersionedResource>, InMemoryError>

pub async fn create_versioned_resource( &self, resource_type: &str, data: Value, context: &RequestContext, ) -> Result<VersionedResource, InMemoryError>

Trait Implementations

impl Clone for InMemoryProvider

fn clone(&self) -> InMemoryProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryProvider

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

Formats the value using the given formatter.

impl Default for InMemoryProvider

fn default() -> Self

Returns the “default value” for a type.

impl ResourceProvider for InMemoryProvider

fn apply_patch_operation( &self, resource_data: &mut Value, operation: &Value, ) -> Result<(), Self::Error>

Override the default patch operation implementation

type Error = InMemoryError

async fn create_resource( &self, resource_type: &str, data: Value, context: &RequestContext, ) -> Result<Resource, Self::Error>

Create a resource for the tenant specified in the request context.

async fn get_resource( &self, resource_type: &str, id: &str, context: &RequestContext, ) -> Result<Option<Resource>, Self::Error>

Get a resource by ID from the tenant specified in the request context.

async fn update_resource( &self, resource_type: &str, id: &str, data: Value, context: &RequestContext, ) -> Result<Resource, Self::Error>

Update a resource in the tenant specified in the request context.

async fn delete_resource( &self, resource_type: &str, id: &str, context: &RequestContext, ) -> Result<(), Self::Error>

Delete a resource from the tenant specified in the request context.

async fn list_resources( &self, resource_type: &str, query: Option<&ListQuery>, context: &RequestContext, ) -> Result<Vec<Resource>, Self::Error>

List resources from the tenant specified in the request context.

async fn find_resource_by_attribute( &self, resource_type: &str, attribute: &str, value: &Value, context: &RequestContext, ) -> Result<Option<Resource>, Self::Error>

Find a resource by attribute value within the tenant specified in the request context.

async fn resource_exists( &self, resource_type: &str, id: &str, context: &RequestContext, ) -> Result<bool, Self::Error>

Check if a resource exists within the tenant specified in the request context.

async fn patch_resource( &self, resource_type: &str, id: &str, patch_request: &Value, context: &RequestContext, ) -> Result<Resource, Self::Error>

Apply PATCH operations to a resource within the tenant specified in the request context.

fn conditional_update( &self, resource_type: &str, id: &str, data: Value, expected_version: &ScimVersion, context: &RequestContext, ) -> impl Future<Output = Result<ConditionalResult<VersionedResource>, Self::Error>> + Send

where Self: Sync,

Conditionally update a resource if the version matches.

fn conditional_delete( &self, resource_type: &str, id: &str, expected_version: &ScimVersion, context: &RequestContext, ) -> impl Future<Output = Result<ConditionalResult<()>, Self::Error>> + Send

where Self: Sync,

Conditionally delete a resource if the version matches.

fn get_versioned_resource( &self, resource_type: &str, id: &str, context: &RequestContext, ) -> impl Future<Output = Result<Option<VersionedResource>, Self::Error>> + Send

where Self: Sync,

Get a resource with its version information.