Struct Repository 

pub struct Repository<M = ()> { /* private fields */ }

Full CRUD access to one model over a store; usable as an axum extractor.

Implementations

impl<M: Model> Repository<M>

pub fn new(store: Arc<dyn Store>) -> Self

Repository over the given store.

pub async fn save(&self, model: &mut M) -> Result<(), StoreError>

Insert the model and store its generated key.

pub async fn save_many(&self, models: &mut [M]) -> Result<(), StoreError>

Insert a batch of models in one call.

pub async fn get(&self, id: &Value) -> Result<Option<M>, StoreError>

Load one model by key value.

pub async fn all(&self) -> Result<Vec<M>, StoreError>

All models ordered by key.

pub async fn filter( &self, field: Name, value: &Value, ) -> Result<Vec<M>, StoreError>

Models whose given field equals the value.

pub async fn ordered(&self, sort: Sort) -> Result<Vec<M>, StoreError>

All models with the given sort applied.

pub async fn scan_query(&self, query: &Query) -> Result<Vec<M>, StoreError>

Models matched by the query, refusing projected rows.

pub async fn rows(&self, query: &Query) -> Result<Vec<Row>, StoreError>

Raw rows matched by the query.

pub async fn total_query(&self, query: &Query) -> Result<usize, StoreError>

Count of rows matched by the query.

pub async fn mass(&self, query: &Query) -> Result<Value, StoreError>

Aggregate value computed by the query’s mass action.

pub async fn update(&self, model: &M) -> Result<(), StoreError>

Replace the row for this model’s key.

pub async fn delete(&self, id: &Value) -> Result<(), StoreError>

Delete the row with the given key value.

Trait Implementations

impl<M: Model> FromRequestParts<()> for Repository<M>

type Rejection = Error

If the extractor fails it’ll use this “rejection” type. A rejection is a kind of error that can be converted into a response.

async fn from_request_parts( parts: &mut Parts, _state: &(), ) -> Result<Self, Self::Rejection>

Perform the extraction.