Struct DynamicGrpcService 

pub struct DynamicGrpcService { /* private fields */ }

A dynamically generated gRPC service

Implementations

impl DynamicGrpcService

pub fn new( service: ProtoService, latency_injector: Option<LatencyInjector>, ) -> Self

Create a new dynamic gRPC service

pub fn new_enhanced( service: ProtoService, latency_injector: Option<LatencyInjector>, proto_parser: Option<ProtoParser>, smart_config: SmartMockConfig, ) -> Self

Create a new enhanced dynamic gRPC service with proto parser and smart generator

pub fn descriptor_pool(&self) -> Option<&DescriptorPool>

Get the descriptor pool if available

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

Get the smart generator for external use

pub fn service(&self) -> &ProtoService

Get the service definition

pub async fn handle_unary( &self, method_name: &str, _request: Request<Any>, ) -> Result<Response<Any>, Status>

Handle a unary request

pub async fn handle_server_streaming( &self, method_name: &str, request: Request<Any>, ) -> Result<Response<ReceiverStream<Result<Any, Status>>>, Status>

Handle a server streaming request

pub async fn handle_client_streaming( &self, method_name: &str, request: Request<Streaming<Any>>, ) -> Result<Response<Any>, Status>

Handle a client streaming request

pub async fn handle_bidirectional_streaming( &self, method_name: &str, request: Request<Streaming<Any>>, ) -> Result<Response<ReceiverStream<Result<Any, Status>>>, Status>

Handle a bidirectional streaming request

pub fn service_name(&self) -> &str

Get the service name

pub fn set_mock_response(&mut self, method_name: &str, response: MockResponse)

Set a custom mock response for a method

pub fn set_error_simulation( &mut self, method_name: &str, error_message: &str, error_code: i32, )

Set error simulation for a method

pub fn methods(&self) -> &Vec<ProtoMethod>

Get the service methods

pub fn package(&self) -> &str

Get the service package