Struct WebSocketInput 

pub(crate) struct WebSocketInput {
    pub(crate) messages: SplitStream<WebSocketStream<ClientIo<TokioIo<Upgraded>>>>,
    pub(crate) framing: Framing,
    pub(crate) activity: Activity,
    pub(crate) written: Activity,
    pub(crate) discard: Discard,
}

The input of a WebSocket client.

Fields

messages: SplitStream<WebSocketStream<ClientIo<TokioIo<Upgraded>>>>

framing: Framing

activity: Activity

Touched by every message of the client except for pings and pongs, which a client like the WebSocket executor of client-go sends as a heartbeat. CRI-O does not count them either.

written: Activity

Touched whenever a part of what the server sends went out, see web::ClientIo::written.

discard: Discard

Drops the input of a client which sent a message larger than the server takes, see web::Discard.

Trait Implementations

impl ClientInput for WebSocketInput

async fn next(&mut self) -> Option<ClientEvent>

The next event, None once the client went away without a clean close.

async fn answer_close(&mut self)

Answer the clean close of the client, see web::answer_close.

async fn drain(self, output: Output)

End the connection once output closed it after ClientEvent::TooLarge, see web::drain.