Struct Context 

pub struct Context(/* private fields */);

Context is used to provide a local interface to fetch and subscribe to entities with a specific ContextData. Generally this means your auth token for a specific user, but ContextData is abstracted so you can use what you want.

Implementations

impl Context

pub fn begin(&self) -> Transaction

Begin a transaction.

impl Context

pub fn new<SE: StorageEngine + Send + Sync + 'static, PA: PolicyAgent + Send + Sync + 'static>( node: Node<SE, PA>, data: PA::ContextData, ) -> Self

pub fn node_id(&self) -> EntityId

pub async fn get<R: View>(&self, id: EntityId) -> Result<R, RetrievalError>

pub async fn get_cached<R: View>( &self, id: EntityId, ) -> Result<R, RetrievalError>

Get an entity, but its ok to return early if the entity is already in the local node storage

pub async fn fetch<R: View>( &self, args: impl TryInto<MatchArgs, Error = impl Into<RetrievalError>>, ) -> Result<Vec<R>, RetrievalError>

pub async fn fetch_one<R: View + Clone + 'static>( &self, args: impl TryInto<MatchArgs, Error = impl Into<RetrievalError>>, ) -> Result<Option<R>, RetrievalError>

pub fn query<R>( &self, args: impl TryInto<MatchArgs, Error = impl Into<RetrievalError>>, ) -> Result<LiveQuery<R>, RetrievalError>

where R: View,

Subscribe to changes in entities matching a selection

pub async fn query_wait<R>( &self, args: impl TryInto<MatchArgs, Error = impl Into<RetrievalError>>, ) -> Result<LiveQuery<R>, RetrievalError>

where R: View,

Subscribe to changes in entities matching a selection and wait for initialization

pub async fn collection( &self, id: &CollectionId, ) -> Result<StorageCollectionWrapper, RetrievalError>

Trait Implementations

impl Clone for Context

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.