Struct NnrpServerSession 

pub struct NnrpServerSession { /* private fields */ }

Implementations

impl NnrpServerSession

pub fn session_id(&self) -> u32

pub fn client_open(&self) -> &SessionOpenMetadata

pub fn lifecycle(&self) -> &ConnectionLifecycle

pub fn operations(&self) -> &OperationRegistry

pub fn pressure_state(&self) -> RuntimePressureState

pub fn cache_object_count(&self) -> usize

pub async fn receive_submit(&mut self) -> Result<NnrpSubmit, RuntimeError>

pub async fn await_event(&mut self) -> Result<NnrpServerEvent, RuntimeError>

pub async fn send_result( &mut self, frame_id: u32, metadata: ResultPushMetadata, body: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_result_drop( &mut self, frame_id: u32, ) -> Result<(), RuntimeError>

pub async fn send_partial_result( &mut self, metadata: PartialResultMetadata, body: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_progress( &mut self, metadata: ProgressMetadata, body: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_result_drop_reason( &mut self, metadata: ResultDropReasonMetadata, ) -> Result<(), RuntimeError>

pub async fn send_result_drop_reason_with_diagnostics( &mut self, metadata: ResultDropReasonMetadata, diagnostics: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_control_request( &mut self, message_type: MessageType, metadata: ControlRequestMetadata, diagnostics: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_scheduling_update( &mut self, message_type: MessageType, metadata: SchedulingMetadata, ) -> Result<(), RuntimeError>

pub async fn supersede_operation( &mut self, metadata: SupersedeMetadata, diagnostics: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn update_budget( &mut self, metadata: BudgetMetadata, ) -> Result<(), RuntimeError>

pub async fn send_capability( &mut self, message_type: MessageType, metadata: CapabilityMetadata, body: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_route_hint( &mut self, message_type: MessageType, metadata: RouteHintMetadata, body: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_object_declare( &mut self, metadata: ObjectDescriptorMetadata, body: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_object_ref( &mut self, metadata: ObjectReferenceMetadata, body: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_object_release( &mut self, metadata: ObjectReleaseMetadata, body: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_object_delta( &mut self, message_type: MessageType, metadata: ObjectDeltaMetadata, body: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_cache_reference( &mut self, metadata: CacheReferenceMetadata, body: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_cache_miss( &mut self, metadata: CacheMissMetadata, body: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_cache_invalidate( &mut self, metadata: CacheInvalidateMetadata, ) -> Result<(), RuntimeError>

pub async fn receive_cancel(&mut self) -> Result<NnrpCancel, RuntimeError>

pub async fn receive_runtime_control( &mut self, ) -> Result<NnrpRuntimeControl, RuntimeError>

pub async fn receive_scheduling_update( &mut self, ) -> Result<NnrpSchedulingUpdate, RuntimeError>

pub async fn receive_pressure_update( &mut self, ) -> Result<NnrpPressureUpdate, RuntimeError>

pub async fn send_backpressure( &mut self, metadata: PressureMetadata, ) -> Result<(), RuntimeError>

pub async fn send_credit_update( &mut self, metadata: PressureMetadata, ) -> Result<(), RuntimeError>

pub async fn send_trace_context( &mut self, frame_id: u32, metadata: TraceContextMetadata, body: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_recoverable_error( &mut self, metadata: RecoverableErrorMetadata, diagnostics: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_retry_after( &mut self, metadata: RetryAfterMetadata, diagnostics: Vec<u8>, ) -> Result<(), RuntimeError>

pub async fn send_result_hint( &mut self, metadata: ResultHintMetadata, ) -> Result<(), RuntimeError>

pub fn track_cache_object( &mut self, object_id: CacheObjectId, ) -> Result<(), RuntimeError>

pub async fn receive_patch( &mut self, ) -> Result<SessionPatchMetadata, RuntimeError>

pub async fn send_patch_ack( &mut self, ack: SessionPatchAckMetadata, ) -> Result<(), RuntimeError>

pub async fn send_flow_update( &mut self, metadata: FlowUpdateMetadata, ) -> Result<(), RuntimeError>

pub async fn receive_migrate(&mut self) -> Result<NnrpMigration, RuntimeError>

pub async fn send_migrate_ack( &mut self, request: &SessionMigrateMetadata, ack: SessionMigrateAckMetadata, ) -> Result<(), RuntimeError>

pub async fn receive_close( &mut self, ) -> Result<SessionCloseMetadata, RuntimeError>

pub async fn ack_close( &mut self, close: &SessionCloseMetadata, ) -> Result<(), RuntimeError>

pub async fn close(self) -> Result<(), RuntimeError>

pub async fn close_in_place(&mut self) -> Result<(), RuntimeError>

Trait Implementations

impl Debug for NnrpServerSession

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

Formats the value using the given formatter.