Struct MongoAdapter 

pub struct MongoAdapter { /* private fields */ }

Implementations

impl MongoAdapter

pub async fn connect(uri: &str, database: &str) -> Result<Self, ParseError>

Trait Implementations

impl StorageAdapter for MongoAdapter

async fn all_schemas(&self) -> Result<Vec<ClassSchema>, ParseError>

Load every class schema. Upstream has no per-class fetch: a miss on any class triggers a full getAllClasses, and reproducing that shape keeps the caching behavior comparable.

async fn insert_schema(&self, schema: &ClassSchema) -> Result<(), ParseError>

Insert a class schema, failing if the class already exists.

async fn upsert_schema(&self, schema: &ClassSchema) -> Result<(), ParseError>

Persist a class schema, creating the class if it does not exist.

async fn reserve_field( &self, class_name: &str, field_name: &str, field_type: &FieldType, options: Option<&ParseMap>, ) -> Result<AddFieldOutcome, ParseError>

Reserve a field type atomically, before any row is written, together with its options.

async fn set_field_options( &self, class_name: &str, field_name: &str, options: &ParseMap, ) -> Result<(), ParseError>

Set one field’s options, for a field that already exists.

async fn set_indexes( &self, class_name: &str, indexes: &ParseMap, ) -> Result<(), ParseError>

Replace _metadata.indexes with the block the request produced.

async fn set_class_permissions( &self, class_name: &str, clp: Option<&ClassLevelPermissions>, ) -> Result<(), ParseError>

Replace _metadata.class_permissions. None removes the key, which is not the same as storing an empty block: see ClassSchema::clp.

async fn delete_class(&self, schema: &ClassSchema) -> Result<(), ParseError>

Drop a class: its rows, its schema entry and every join collection belonging to it.

async fn delete_fields( &self, schema: &ClassSchema, fields: &[String], ) -> Result<(), ParseError>

Remove fields from a class: the schema entry and the column on every row.

async fn create( &self, schema: &ClassSchema, row: &Row, ) -> Result<WriteResult, ParseError>

Insert one row. object_id is generated by the caller, not the adapter, because it is part of the Parse contract rather than a storage detail.

async fn upsert_one( &self, schema: &ClassSchema, query: &Query, row: &Row, ) -> Result<(), ParseError>

Insert a row, or do nothing if one already matches.

async fn find( &self, schema: &ClassSchema, query: &Query, options: &QueryOptions, ) -> Result<Vec<Row>, ParseError>

Find rows matching the query.

async fn count( &self, schema: &ClassSchema, query: &Query, ) -> Result<u64, ParseError>

Count rows matching the query.

async fn update( &self, schema: &ClassSchema, query: &Query, update: &Update, ) -> Result<u64, ParseError>

Update matching rows.

async fn update_one_returning( &self, schema: &ClassSchema, query: &Query, update: &Update, ) -> Result<Option<Row>, ParseError>

Update one row and return its post-image.

async fn delete( &self, schema: &ClassSchema, query: &Query, ) -> Result<u64, ParseError>

Delete matching rows. Returns how many, for the same reason as update.

async fn ensure_index( &self, class_name: &str, fields: &[&str], name: Option<&str>, unique: bool, case_insensitive: bool, ) -> Result<(), ParseError>

Create a unique index.

async fn create_indexes( &self, class_name: &str, indexes: &[SchemaIndex], ) -> Result<(), ParseError>

Create named indexes from the schema API’s indexes block.

async fn drop_index( &self, class_name: &str, name: &str, ) -> Result<(), ParseError>

Drop an index by name, for the {"__op":"Delete"} form.