Struct MockReflectionProxy 

pub struct MockReflectionProxy { /* private fields */ }

A mock-enabled reflection proxy that serves mock responses

Implementations

impl MockReflectionProxy

pub async fn handle_unary_request( &self, request: Request<DynamicMessage>, ) -> Result<Response<DynamicMessage>, Status>

Handle a unary gRPC request

pub async fn handle_server_streaming_request( &self, request: Request<DynamicMessage>, ) -> Result<Response<ReceiverStream<Result<DynamicMessage, Status>>>, Status>

Handle a server streaming gRPC request

pub async fn handle_client_streaming_request( &self, request: Request<Streaming<DynamicMessage>>, ) -> Result<Response<DynamicMessage>, Status>

Handle a client streaming gRPC request

pub async fn handle_bidirectional_streaming_request( &self, request: Request<Streaming<DynamicMessage>>, ) -> Result<Response<ReceiverStream<Result<DynamicMessage, Status>>>, Status>

Handle a bidirectional streaming gRPC request

pub fn extract_service_method_from_request<T>( &self, request: &Request<T>, ) -> Result<(String, String), Status>

Extract service and method names from a request

impl MockReflectionProxy

pub async fn preprocess_request<T>( &self, request: &mut Request<T>, ) -> Result<(), Status>

where T: ReflectMessage,

Apply request preprocessing middleware

pub async fn log_request<T>( &self, request: &Request<T>, service_name: &str, method_name: &str, )

where T: ReflectMessage,

Apply request logging middleware

pub async fn postprocess_response<T>( &self, response: &mut Response<T>, service_name: &str, method_name: &str, ) -> Result<(), Status>

Apply response postprocessing middleware

pub async fn postprocess_dynamic_response( &self, response: &mut Response<DynamicMessage>, service_name: &str, method_name: &str, ) -> Result<(), Status>

Apply response postprocessing with body transformations for DynamicMessage responses

pub async fn postprocess_streaming_dynamic_response( &self, response: &mut Response<ReceiverStream<Result<DynamicMessage, Status>>>, service_name: &str, method_name: &str, ) -> Result<(), Status>

Apply response postprocessing for streaming DynamicMessage responses

pub async fn handle_error( &self, error: Status, service_name: &str, method_name: &str, ) -> Status

Apply error handling middleware

pub async fn collect_metrics( &self, service_name: &str, method_name: &str, duration: Duration, success: bool, )

Apply metrics collection middleware

impl MockReflectionProxy

pub async fn new( config: ProxyConfig, service_registry: Arc<ServiceRegistry>, ) -> Result<Self, Status>

Create a new mock reflection proxy

pub fn config(&self) -> &ProxyConfig

Get the proxy configuration

pub fn cache(&self) -> &DescriptorCache

Get the descriptor cache

pub fn service_registry(&self) -> &Arc<ServiceRegistry>

Get the service registry

pub fn service_names(&self) -> Vec<String>

Get the list of service names

pub fn smart_generator(&self) -> &Arc<Mutex<SmartMockGenerator>>

Get the smart mock generator

pub fn should_mock_service_method( &self, service_name: &str, _method_name: &str, ) -> bool

Check if a service method should be mocked

pub fn timeout_duration(&self) -> Duration

Get the timeout duration for requests

pub fn update_config(&mut self, config: ProxyConfig)

Update the proxy configuration

pub fn track_connection(&self) -> ConnectionGuard

Create a connection guard that tracks active connections

pub async fn get_stats(&self) -> ProxyStats

Get statistics about the proxy

impl MockReflectionProxy

pub async fn validate_request( &self, request: &Request<DynamicMessage>, service_name: &str, method_name: &str, ) -> Result<(), Status>

Validate a request against the service method schema

pub async fn validate_response( &self, response: &DynamicMessage, service_name: &str, method_name: &str, ) -> Result<(), Status>

Validate response data against the method’s response schema

pub async fn route_request<T>( &self, request: Request<T>, ) -> Result<(String, String, Request<T>), Status>

Route a request to the appropriate handler

pub async fn can_handle_service_method( &self, service_name: &str, method_name: &str, ) -> bool

Check if a service method should be processed by this proxy

pub async fn validate_service_method_signature( &self, service_name: &str, method_name: &str, input_descriptor: MessageDescriptor, output_descriptor: MessageDescriptor, ) -> Result<(), Status>

Validate service method signature compatibility

pub fn value_matches_kind(value: &Value, kind: Kind) -> bool

Check if a Value matches a Kind

pub async fn validate_request_size<T>( &self, request: &Request<T>, max_size: usize, ) -> Result<(), Status>

where T: Message,

Validate request size limits

pub async fn validate_response_size( &self, response: &DynamicMessage, max_size: usize, ) -> Result<(), Status>

Validate response size limits

pub fn should_skip_validation( &self, service_name: &str, method_name: &str, ) -> bool

Check if request should be skipped for validation (admin endpoints, etc.)

pub fn get_validation_mode_for_method( &self, service_name: &str, method_name: &str, ) -> ValidationMode

Apply validation mode for a service method

Trait Implementations

impl Clone for MockReflectionProxy

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.