Struct QueryRequest 

pub struct QueryRequest<Q> {
    pub tx: Arc<str>,
    pub created_at: Arc<str>,
    pub query: Q,
}

Fields

tx: Arc<str>

created_at: Arc<str>

query: Q

Implementations

impl<Q> QueryRequest<Q>

pub fn new(query: Q) -> Self

pub fn with_tx(query: Q, tx: Arc<str>) -> Self

Trait Implementations

impl<Q: QueryId + QueryItemType + Serialize + Debug + Send + Sync + 'static> AnyQuery for QueryRequest<Q>

fn query_item_type(&self) -> Arc<str>

Returns the item type this query targets (e.g., “Server”, “Client”).

fn to_value(&self) -> Value

Serialize this query to a JSON Value.

impl<Q: Clone> Clone for QueryRequest<Q>

fn clone(&self) -> QueryRequest<Q>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Q: Debug> Debug for QueryRequest<Q>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Q: Default> Default for QueryRequest<Q>

fn default() -> Self

Returns the “default value” for a type.

impl<'de, Q> Deserialize<'de> for QueryRequest<Q>

where Q: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<Q: Clone> From<&QueryRequest<Q>> for QueryRequest<Q>

fn from(request: &Self) -> Self

Converts to this type from the input type.

impl<Q: QueryParams> From<Q> for QueryRequest<Q>

fn from(query: Q) -> Self

Converts to this type from the input type.

impl<Q: QueryParams + Clone> Query for QueryRequest<Q>

where Q::Item: Eventable + WithId + DeserializeOwned + Clone + Debug + Send + Sync + 'static,

type Params = Q

The inner query params type

fn watch( &self, client: &MykoClient, ) -> Cell<Vec<Arc<<Self as QueryItemType>::Item>>, CellImmutable>

impl<Q: QueryHandler + Clone + Send + Sync + 'static> QueryHandler for QueryRequest<Q>

fn test_entity(ctx: QueryTestContext<Self>) -> bool

Per-entity membership predicate.

fn build_view( ctx: QueryBuildArgs<Self>, ) -> Option<impl MapQuery<Key = Arc<str>, Value = Arc<dyn AnyItem>>>

Optional set-wise reactive builder for complex many-to-many joins.

fn build_window( _ctx: QueryWindowBuildArgs<Self>, ) -> Result<Option<WindowedQuerySource>, String>

where Self: Send + Sync + 'static,

Optional pushed-down builder for a bounded query window.

impl<Q: QueryId> QueryId for QueryRequest<Q>

fn query_id(&self) -> Arc<str>

impl<Q: QueryIdStatic> QueryIdStatic for QueryRequest<Q>

fn query_id_static() -> Arc<str>

impl<Q: QueryItemType> QueryItemType for QueryRequest<Q>

type Item = <Q as QueryItemType>::Item

fn query_item_type(&self) -> Arc<str>

fn query_item_type_static() -> Arc<str>

impl<Q> Serialize for QueryRequest<Q>

where Q: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<Q: Send + Sync + 'static> WithTransaction for QueryRequest<Q>

fn tx_id(&self) -> Arc<str>