Struct SubscriptionInfo 

pub struct SubscriptionInfo {
    pub id: SubscriptionId,
    pub session_id: SessionId,
    pub query_name: String,
    pub args: Value,
    pub query_hash: String,
    pub read_set: ReadSet,
    pub last_result_hash: Option<String>,
    pub created_at: DateTime<Utc>,
    pub last_executed_at: Option<DateTime<Utc>>,
    pub execution_count: u64,
    pub memory_bytes: usize,
}

Information about a server-side subscription.

Fields

id: SubscriptionId

Unique subscription ID.

session_id: SessionId

Session that owns this subscription.

query_name: String

Query function name.

args: Value

Query arguments (as JSON).

query_hash: String

Hash of query + args for deduplication.

read_set: ReadSet

Read set from last execution.

last_result_hash: Option<String>

Hash of last result for delta computation.

created_at: DateTime<Utc>

When the subscription was created.

last_executed_at: Option<DateTime<Utc>>

When the subscription was last executed.

execution_count: u64

Number of times the subscription has been re-executed.

memory_bytes: usize

Estimated memory usage in bytes.

Implementations

impl SubscriptionInfo

pub fn new( session_id: SessionId, query_name: impl Into<String>, args: Value, ) -> Self

Create a new subscription info.

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

Update after execution.

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

Check if a change should invalidate this subscription.

Trait Implementations

impl Clone for SubscriptionInfo

fn clone(&self) -> SubscriptionInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionInfo

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

Formats the value using the given formatter.