Struct SubscriptionResponse 

pub struct SubscriptionResponse {
    pub query_id: String,
    pub source_id: String,
    pub receiver: Box<dyn ChangeReceiver<SourceEventWrapper>>,
    pub bootstrap_receiver: Option<BootstrapEventReceiver>,
    pub position_handle: Option<Arc<AtomicU64>>,
}

Subscription response for source subscriptions Subscription response from Source to Query

Fields

query_id: String

source_id: String

receiver: Box<dyn ChangeReceiver<SourceEventWrapper>>

bootstrap_receiver: Option<BootstrapEventReceiver>

position_handle: Option<Arc<AtomicU64>>

Shared handle for the query to report its last durably-processed sequence position. Created by replay-capable sources when request_position_handle is true. The query writes to this atomically after each commit; the source reads the minimum across all subscribers to advance its upstream cursor. Sources should initialize this to u64::MAX (meaning “no position confirmed yet”).