Struct EventSubscription 

pub struct EventSubscription {
    pub namespace: String,
    pub filter: EventFilter,
    pub selector: SubscriptionSelector,
    pub workflow_target: Option<WorkflowId>,
    pub replay: Vec<Event>,
    pub events: BoxStream<'static, Result<Event, EventStreamLagged>>,
}

Authorized subscription returned by the adapter boundary.

Fields

namespace: String

Namespace authorized by the guard.

filter: EventFilter

Engine-side filter used for the subscription.

selector: SubscriptionSelector

Workflow-type/status selectors applied server-side before encoding.

workflow_target: Option<WorkflowId>

Per-workflow target, when the subscription is tied to one workflow.

replay: Vec<Event>

Recorded history slice replayed before the live tail. Empty unless the request carried a per-workflow resume cursor.

events: BoxStream<'static, Result<Event, EventStreamLagged>>

Live event stream obtained from Engine::subscribe after authorization. When a resume cursor is present this tail is already deduplicated against replay (seq > snapshot head).