Struct Query 

pub struct Query { /* private fields */ }

Query builder for Automerge documents

Provides a fluent API for building queries with filtering, sorting, and pagination.

Implementations

impl Query

pub fn new(store: Arc<AutomergeStore>, collection_name: &str) -> Query

Create a new query for a collection

Arguments

• store - AutomergeStore containing the documents
• collection_name - Name of the collection to query

pub fn where_eq(self, field: &str, value: Value) -> Query

Filter where field equals value

Example

query.where_eq("operational", Value::Bool(true))

pub fn where_gt(self, field: &str, value: Value) -> Query

Filter where field is greater than value

pub fn where_lt(self, field: &str, value: Value) -> Query

Filter where field is less than value

pub fn where_gte(self, field: &str, value: Value) -> Query

Filter where field is greater than or equal to value

pub fn where_lte(self, field: &str, value: Value) -> Query

Filter where field is less than or equal to value

pub fn where_contains(self, field: &str, value: Value) -> Query

Filter where array field contains value

Example

query.where_contains("capabilities", Value::String("sensor".into()))

pub fn filter_by_ids(self, ids: &[String]) -> Query

Filter to only documents with IDs in the given set

Used for integrating with spatial indices like GeohashIndex.

Example

let nearby_ids = geohash_index.find_near(lat, lon)?;
query.filter_by_ids(&nearby_ids)

pub fn order_by(self, field: &str, order: SortOrder) -> Query

Sort results by field

Example

query.order_by("timestamp", SortOrder::Desc)

pub fn limit(self, n: usize) -> Query

Limit number of results

pub fn offset(self, n: usize) -> Query

Skip first n results (for pagination)

pub fn execute(self) -> Result<Vec<(String, Automerge)>, Error>

Execute the query and return matching documents

Returns (doc_id, Automerge) tuples for all matching documents.

pub fn execute_ids(self) -> Result<Vec<String>, Error>

Execute and return only document IDs

pub fn execute_json(self) -> Result<Vec<(String, Value)>, Error>

Execute the query and return matching documents as JSON values.

pub fn count(self) -> Result<usize, Error>

Count matching documents (without loading full documents)