Struct GrpcAdapter 

pub struct GrpcAdapter { /* private fields */ }

gRPC adapter for gRPC services and RPCs

Handles gRPC protocol-specific request/response transformation.

Implementations

impl GrpcAdapter

pub fn new() -> Self

Create a new gRPC adapter

pub fn unary(&mut self, service: &str, method: &str, handler: &str) -> &mut Self

Register a unary RPC method

pub fn client_streaming( &mut self, service: &str, method: &str, handler: &str, ) -> &mut Self

Register a client streaming RPC method

pub fn server_streaming( &mut self, service: &str, method: &str, handler: &str, ) -> &mut Self

Register a server streaming RPC method

pub fn bidirectional_streaming( &mut self, service: &str, method: &str, handler: &str, ) -> &mut Self

Register a bidirectional streaming RPC method

pub fn match_method(&self, full_name: &str) -> Option<&GrpcMethod>

Find a matching method by fully qualified name

Format: “ServiceName.MethodName”

pub fn parse_request(&self, request: &str) -> Result<(String, String), String>

Parse a gRPC request string

Format: “ServiceName.MethodName:payload” Example: “UserService.GetUser:{"id":42}”

pub fn generate_proto(&self) -> String

Generate .proto file for registered methods

Generates Protocol Buffer definition from registered methods.

pub fn build_request(&self, method: &str, payload: &str) -> GrpcRequest

Build a gRPC request

pub fn format_response(&self, status: GrpcStatus, message: &str) -> String

Format a gRPC response

Trait Implementations

impl Default for GrpcAdapter

fn default() -> Self

Returns the “default value” for a type.

impl ProtocolAdapter for GrpcAdapter

fn name(&self) -> &str

Get the name of this protocol adapter

fn handle( &self, request: &str, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send + '_>>

Handle a protocol-specific request