Struct NnrpClientSession 

pub struct NnrpClientSession { /* private fields */ }

Implementations

impl NnrpClientSession

pub fn session_id(&self) -> u32

pub fn lifecycle(&self) -> &ConnectionLifecycle

pub fn pressure_state(&self) -> RuntimePressureState

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

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

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

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

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

pub async fn cancel_operation( &mut self, operation_id: u64, reason_code: u16, ) -> Result<(), RuntimeError>

pub async fn abort_operation( &mut self, operation_id: u64, reason_code: u16, ) -> Result<(), RuntimeError>

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

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

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

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

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

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

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

pub async fn update_priority( &mut self, operation_id: u64, priority_class: u16, priority_delta: i16, ) -> Result<(), RuntimeError>

pub async fn update_deadline( &mut self, operation_id: u64, deadline_unix_ms: u64, ) -> Result<(), RuntimeError>

pub async fn expire_at( &mut self, operation_id: u64, deadline_unix_ms: u64, ) -> Result<(), RuntimeError>

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

pub async fn send_credit_update( &mut self, metadata: PressureMetadata, ) -> 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_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_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, diagnostics: 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, diagnostics: Vec<u8>, ) -> Result<(), RuntimeError>

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

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

pub async fn patch_session( &mut self, patch: SessionPatchMetadata, ) -> Result<SessionPatchAckMetadata, RuntimeError>

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

pub fn build_migration_request( &self, new_transport_id: TransportId, last_result_frame_id: u64, client_migrate_ts_us: u64, ) -> SessionMigrateMetadata

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

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

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

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

Trait Implementations

impl Debug for NnrpClientSession

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

Formats the value using the given formatter.