Struct ControlPlaneKernelPort 

pub struct ControlPlaneKernelPort { /* private fields */ }

Implementations

impl ControlPlaneKernelPort

pub fn drain_ingress(&self, limit: usize) -> Vec<BackendIngress>

pub fn provider_authority(&self) -> ProviderRuntimeAuthorityHandle

pub fn publish_events( &self, events: impl IntoIterator<Item = ControlEvent>, ) -> PublishReport

pub fn publish_step(&self, step: &KernelStep) -> ControlPlanePublishReport

Publishes one already-reduced kernel step in a fixed edge order.

Provider outcomes and effects first reconcile the private executor boundary. The immutable combined snapshot is then replaced before request/authority outcomes, control events, exact scoped completions, and their trailing source-gap marker. A successfully closed client’s subscriptions are disconnected only after its ClientClosed completions have been offered.