Struct GrpcMethodRequest

pub struct GrpcMethodRequest<D, S> {
    pub destination: Uri,
    pub service: ServiceDescriptor,
    pub method: MethodDescriptor,
    pub codec: MethodCodec<D, S>,
    pub message: D,
}

Fields

destination: Uri

service: ServiceDescriptor

method: MethodDescriptor

codec: MethodCodec<D, S>

message: D

Implementations

impl<D, S> GrpcMethodRequest<D, S>

pub fn format_method_path(&self) -> PathAndQuery

Trait Implementations

impl Assault<GrpcMethodRequest<Value, JsonSerializer>, Response<Value>> for GrpcAssault

type Request = GrpcRequest

type Response = GrpcResponse

type Recorder = GrpcIoRecorder

fn command(&self) -> &Relentless

fn recorder(&self) -> Self::Recorder

async fn execute<S>(&self, service: S) -> Result<ExitCode, RelentlessError>

where Self::Request: RequestFactory<Req, S>, <Self::Request as RequestFactory<Req, S>>::Error: Error + Send + Sync + 'static, <Self::Response as Evaluate<Res>>::Message: Display, S: Service<Req, Response = Res> + Clone + Send + 'static, <S as Service<Req>>::Error: Error + Send + Sync + 'static, <S as Service<Req>>::Future: Send + 'static,

fn configs( &self, ) -> (Vec<Config<Self::Request, Self::Response>>, Vec<RelentlessError>)

TODO document

fn all_destinations( &self, configs: &[Config<Self::Request, Self::Response>], ) -> Vec<Uri>

fn build_service<S>(&self, service: S) -> RecordService<S, Self::Recorder>

where Self::Recorder: IoRecord<Req> + CollectClone<Req> + RequestIoRecord<Req> + IoRecord<Res> + CollectClone<Res> + Clone + Send + 'static, S: Service<Req>,

TODO document

async fn assault_with<S>( &self, configs: Vec<Config<Self::Request, Self::Response>>, service: S, ) -> Result<Report<<Self::Response as Evaluate<Res>>::Message, Self::Request, Self::Response>, RelentlessError>

where Self::Request: RequestFactory<Req, S>, <Self::Request as RequestFactory<Req, S>>::Error: Error + Send + Sync + 'static, S: Service<Req, Response = Res> + Clone + Send + 'static, <S as Service<Req>>::Error: Error + Send + Sync + 'static, <S as Service<Req>>::Future: Send + 'static,

fn report_with<W>( &self, report: &Report<<Self::Response as Evaluate<Res>>::Message, Self::Request, Self::Response>, write: W, ) -> Result<bool, Error>

where <Self::Response as Evaluate<Res>>::Message: Display, W: Write,

fn pass( &self, report: &Report<<Self::Response as Evaluate<Res>>::Message, Self::Request, Self::Response>, ) -> bool

fn allow( &self, report: &Report<<Self::Response as Evaluate<Res>>::Message, Self::Request, Self::Response>, ) -> bool

fn exit_code( &self, report: &Report<<Self::Response as Evaluate<Res>>::Message, Self::Request, Self::Response>, ) -> ExitCode

impl<D: Clone, S: Clone> Clone for GrpcMethodRequest<D, S>

fn clone(&self) -> GrpcMethodRequest<D, S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<De, Se> CollectClone<GrpcMethodRequest<De, Se>> for GrpcIoRecorder

where De: for<'a> Deserializer<'a> + DeserializeOwned + Send + Sync + 'static, for<'a> <De as Deserializer<'a>>::Error: Error + Send + Sync + 'static, Se: Clone + Send,

type Error = Error

async fn collect_clone( &self, r: GrpcMethodRequest<De, Se>, ) -> Result<(GrpcMethodRequest<De, Se>, GrpcMethodRequest<De, Se>), Self::Error>

impl<D: Debug, S: Debug> Debug for GrpcMethodRequest<D, S>

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

Formats the value using the given formatter.

impl<De, Se> IoRecord<GrpcMethodRequest<De, Se>> for GrpcIoRecorder

where De: for<'a> Deserializer<'a> + Send + Sync + 'static, for<'a> <De as Deserializer<'a>>::Error: Error + Send + Sync + 'static, Se: Send,

type Error = Error

fn extension(&self, _r: &GrpcMethodRequest<De, Se>) -> &'static str

async fn record<W: Write>( &self, w: &mut W, r: GrpcMethodRequest<De, Se>, ) -> Result<(), Self::Error>

async fn record_raw<W: Write + Send>( &self, w: &mut W, r: GrpcMethodRequest<De, Se>, ) -> Result<(), Self::Error>

impl<D: PartialEq, S: PartialEq> PartialEq for GrpcMethodRequest<D, S>

fn eq(&self, other: &GrpcMethodRequest<D, S>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<S> RequestFactory<GrpcMethodRequest<Value, JsonSerializer>, S> for GrpcRequest

where S: Service<GrpcMethodRequest<Value, JsonSerializer>>,

type Error = RelentlessError

async fn produce( &self, service: S, destination: &Uri, target: &str, template: &Template, ) -> Result<GrpcMethodRequest<Value, JsonSerializer>, Self::Error>

impl<De, Se> RequestIoRecord<GrpcMethodRequest<De, Se>> for GrpcIoRecorder

fn record_dir(&self, r: &GrpcMethodRequest<De, Se>) -> PathBuf

impl<S, De, Se> Service<GrpcMethodRequest<De, Se>> for GrpcClient<S>

where S: GrpcService<BoxBody> + Clone + Send + 'static, S::ResponseBody: Send, <S::ResponseBody as Body>::Error: Into<Box<dyn Error + Send + Sync>>, S::Future: Send + 'static, De: for<'a> Deserializer<'a> + Send + Sync + 'static, for<'a> <De as Deserializer<'a>>::Error: Error + Send + Sync + 'static, Se: Serializer + Clone + Send + Sync + 'static, Se::Ok: Send + Sync + 'static, Se::Error: Error + Send + Sync + 'static,

type Response = Response<<Se as Serializer>::Ok>

Responses given by the service.

type Error = GrpcClientError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<GrpcClient<S> as Service<GrpcMethodRequest<De, Se>>>::Response, <GrpcClient<S> as Service<GrpcMethodRequest<De, Se>>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: GrpcMethodRequest<De, Se>) -> Self::Future

Process the request and return the response asynchronously.

impl<D, S> StructuralPartialEq for GrpcMethodRequest<D, S>