Struct GrpcMessage 

pub struct GrpcMessage {
    pub service: String,
    pub method: String,
    pub payload: Vec<u8>,
}

gRPC message: 1-byte compressed flag + 4-byte length + payload.

Fields

service: String

Service name (e.g., “runtime.v1.RuntimeService”).

method: String

Method name (e.g., “RunPodSandbox”).

payload: Vec<u8>

Raw protobuf-encoded payload.

Implementations

impl GrpcMessage

pub fn new(service: String, method: String, payload: Vec<u8>) -> Self

Create a new gRPC message.

pub fn encode_payload(&self) -> Vec<u8>

Encode the payload into gRPC wire format (length-prefixed message).

Format: [compressed(1)] [length(4)] [message(N)]

pub fn decode_payload(data: &[u8]) -> Option<(Vec<u8>, usize)>

Decode a gRPC length-prefixed message from raw bytes.

Returns the decompressed payload and the number of bytes consumed, or None if the buffer is too small.

pub fn path(&self) -> String

Build the HTTP/2 path for this gRPC call.

Format: /{service}/{method}

Trait Implementations

impl Clone for GrpcMessage

fn clone(&self) -> GrpcMessage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for GrpcMessage

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

Formats the value using the given formatter.