Struct GrpcTransport 

pub struct GrpcTransport { /* private fields */ }

Unix socket-based gRPC transport.

Implementations

impl GrpcTransport

pub const DEFAULT_MAX_FRAME_SIZE: u32 = 16_384u32

Default maximum HTTP/2 frame size (16 KiB).

pub const DEFAULT_WINDOW_SIZE: u32 = 65_535u32

Default window size (64 KiB).

pub fn new(socket_path: String) -> Self

Create a new gRPC transport targeting a Unix socket.

pub fn socket_path(&self) -> &str

Get the socket path.

pub fn next_stream(&mut self) -> u32

Allocate the next client stream ID (always odd).

pub fn build_request_frame(&mut self, msg: &GrpcMessage) -> Http2Frame

Build a DATA frame containing a gRPC-encoded message.

pub fn parse_response_frame(frame: &Http2Frame) -> Option<GrpcResponse>

Parse a gRPC response from an HTTP/2 DATA frame.

pub fn window_size(&self) -> u32

Get the current window size.

pub fn update_window(&mut self, delta: u32)

Update window size by a delta.

pub fn consume_window(&mut self, amount: u32) -> bool

Consume window for a send operation.

Trait Implementations

impl Debug for GrpcTransport

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

Formats the value using the given formatter.