Interface Read

libs/@local/graph/store/src/query/mod.rs:95–123

Read access to a store.

/// Read access to a store.
pub trait Read<R: QueryRecord>: Sync {
    type ReadStream: Stream<Item = Result<R, Report<QueryError>>> + Send + Sync;

    fn read(
        &self,
        filters: &[Filter<'_, R>],
        temporal_axes: Option<&QueryTemporalAxes>,
        include_drafts: bool,
    ) -> impl Future<Output = Result<Self::ReadStream, Report<QueryError>>> + Send;

    #[tracing::instrument(level = "info", skip(self, filters))]
    fn read_vec(
        &self,
        filters: &[Filter<'_, R>],
        temporal_axes: Option<&QueryTemporalAxes>,
        include_drafts: bool,
    ) -> impl Future<Output = Result<Vec<R>, Report<QueryError>>> + Send {
        self.read(filters, temporal_axes, include_drafts)
            .and_then(TryStreamExt::try_collect)
            .in_current_span()
    }

    fn read_one(
        &self,
        filters: &[Filter<'_, R>],
        temporal_axes: Option<&QueryTemporalAxes>,
        include_drafts: bool,
    ) -> impl Future<Output = Result<R, Report<QueryError>>> + Send;
}

// TODO: Add remaining CRUD traits