Struct QueryGroup 

pub struct QueryGroup {
    pub id: QueryGroupId,
    pub query_name: String,
    pub args: Arc<Value>,
    pub auth_scope: AuthScope,
    pub auth_context: AuthContext,
    pub table_deps: &'static [&'static str],
    pub selected_cols: &'static [&'static str],
    pub read_set: ReadSet,
    pub last_result_hash: Option<String>,
    pub subscribers: Vec<SubscriberId>,
    pub created_at: DateTime<Utc>,
    pub execution_count: u64,
}

A query group is the primary unit of execution. Multiple subscribers watching the same query+args+auth_scope share a single group. On invalidation, the query executes once per group (not per subscriber).

Fields

id: QueryGroupId

query_name: String

args: Arc<Value>

auth_scope: AuthScope

auth_context: AuthContext

table_deps: &'static [&'static str]

Compile-time table dependencies from FunctionInfo.

selected_cols: &'static [&'static str]

Compile-time selected columns from FunctionInfo.

read_set: ReadSet

last_result_hash: Option<String>

Result hash for delta detection. Shared across all subscribers.

subscribers: Vec<SubscriberId>

All subscribers in this group.

created_at: DateTime<Utc>

execution_count: u64

Implementations

impl QueryGroup

pub fn compute_lookup_key( query_name: &str, args: &Value, auth_scope: &AuthScope, ) -> u64

Compute the lookup key for dedup: hash of (query_name, args, auth_scope).

pub fn record_execution(&mut self, read_set: ReadSet, result_hash: String)

Record a query execution result.

pub fn should_invalidate(&self, change: &Change) -> bool

Check if a change should invalidate this group.