Struct StreamingService 

pub struct StreamingService { /* private fields */ }

CRI Streaming Service implementation.

Implementations

impl StreamingService

pub fn new() -> Self

Create a new streaming service.

pub fn exec_sync( &self, request: &ExecRequest, ) -> Result<ExecResponse, StreamError>

Run a command synchronously in a container.

pub fn run_command( &mut self, request: &ExecRequest, current_tick: u64, ) -> Result<u64, StreamError>

Start an asynchronous command session.

pub fn attach( &mut self, request: &AttachRequest, current_tick: u64, ) -> Result<u64, StreamError>

Attach to a running container’s I/O streams.

pub fn port_forward( &mut self, request: &PortForwardRequest, current_tick: u64, ) -> Result<u64, StreamError>

Set up port forwarding for a pod sandbox.

pub fn close_session(&mut self, session_id: u64) -> Result<(), StreamError>

Close a streaming session.

pub fn session_status(&self, session_id: u64) -> Option<&StreamSession>

Get session status.

pub fn active_session_count(&self) -> usize

Count active sessions.

pub fn cleanup_closed(&mut self) -> usize

Remove closed sessions.

Trait Implementations

impl Debug for StreamingService

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

Formats the value using the given formatter.

impl Default for StreamingService

fn default() -> Self

Returns the “default value” for a type.