Home
last modified time | relevance | path

Searched defs:Status (Results 1 – 25 of 64) sorted by relevance

123

/tonic/tonic/src/
H A Dstatus.rs38 pub struct Status { struct
47 /// or by `Status` fields above, they will be ignored. argument
53 /// gRPC status codes used by [`Status`]. argument
160 impl Status { implementation
310 ) -> Status { in from_error_generic()
561 ) -> Status { in with_details_and_metadata()
638 impl fmt::Debug for Status { implementation
672 impl From<h2::Error> for Status { implementation
712 impl fmt::Display for Status { implementation
725 impl Error for Status { implementation
[all …]
/tonic/tests/default_stubs/src/
H A Dlib.rs21 async fn unary(&self, _: Request<()>) -> Result<Response<()>, Status> { in unary() argument
28 ) -> Result<Response<Self::ServerStreamStream>, Status> { in server_stream() argument
32 async fn client_stream(&self, _: Request<Streaming<()>>) -> Result<Response<()>, Status> { in client_stream() argument
39 ) -> Result<Response<Self::BidirectionalStreamStream>, Status> { in bidirectional_stream() argument
/tonic/tests/compression/src/
H A Dlib.rs49 async fn compress_output_unary(&self, _req: Request<()>) -> Result<Response<SomeData>, Status> { in compress_output_unary() argument
57 async fn compress_input_unary(&self, req: Request<SomeData>) -> Result<Response<()>, Status> { in compress_input_unary() argument
68 ) -> Result<Response<Self::CompressOutputServerStreamStream>, Status> { in compress_output_server_stream() argument
79 ) -> Result<Response<()>, Status> { in compress_input_client_stream() argument
90 ) -> Result<Response<SomeData>, Status> { in compress_output_client_stream() argument
109 ) -> Result<Response<Self::CompressInputOutputBidirectionalStreamStream>, Status> { in compress_input_output_bidirectional_stream() argument
/tonic/tests/web/src/
H A Dlib.rs18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in unary_call() argument
36 ) -> Result<Response<Self::ServerStreamStream>, Status> { in server_stream() argument
52 ) -> Result<Response<Output>, Status> { in client_stream() argument
/tonic/tests/integration_tests/tests/
H A Dinterceptor.rs17 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in interceptor_retrieves_grpc_method() argument
43 fn client_intercept(req: Request<()>) -> Result<Request<()>, Status> { in interceptor_retrieves_grpc_method() argument
H A Droutes_builder.rs23 async fn unary_call(&self, _req: Request<Input>) -> Result<Response<Output>, Status> { in multiple_service_using_routes_builder() argument
32 async fn unary_call(&self, request: Request<Input1>) -> Result<Response<Output1>, Status> { in multiple_service_using_routes_builder() argument
43 ) -> Result<Response<Self::StreamCallStream>, Status> { in multiple_service_using_routes_builder() argument
H A Dmax_message_size.rs127 async fn unary_call(&self, _req: Request<Input1>) -> Result<Response<Output1>, Status> { in response_stream_limit() argument
137 ) -> Result<Response<Self::StreamCallStream>, Status> { in response_stream_limit() argument
274 async fn max_message_run(case: &TestCase) -> Result<(), Status> { in max_message_run() argument
284 async fn unary_call(&self, _req: Request<Input1>) -> Result<Response<Output1>, Status> { in max_message_run() argument
296 ) -> Result<Response<Self::StreamCallStream>, Status> { in max_message_run() argument
H A Dstatus.rs24 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in status_with_details() argument
82 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in status_with_metadata() argument
155 ) -> Result<Response<Self::StreamCallStream>, Status> { in status_from_server_stream() argument
225 ) -> Result<Response<Self::StreamCallStream>, Status> { in message_and_then_status_from_server_stream() argument
H A Dconnect_info.rs18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in getting_connect_info() argument
82 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in unary_call() argument
H A Duser_agent.rs15 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in writes_user_agent_header() argument
/tonic/examples/src/interceptor/
H A Dserver.rs18 ) -> Result<Response<HelloReply>, Status> { in say_hello() argument
49 fn intercept(mut req: Request<()>) -> Result<Request<()>, Status> { in intercept() argument
H A Dclient.rs36 fn intercept(req: Request<()>) -> Result<Request<()>, Status> { in intercept() argument
46 fn call(&mut self, request: tonic::Request<()>) -> Result<tonic::Request<()>, Status> { in call() argument
/tonic/tonic-types/proto/
H A Dstatus.proto35 message Status { message
/tonic/examples/src/multiplex/
H A Dserver.rs45 ) -> Result<Response<HelloReply>, Status> { in say_hello() argument
61 ) -> Result<Response<EchoResponse>, Status> { in unary_echo() argument
/tonic/tonic/src/codec/
H A Ddecode.rs150 ) -> Result<Option<DecodeBuf<'_>>, Status> { in decode_chunk() argument
248 fn poll_frame(&mut self, cx: &mut Context<'_>) -> Poll<Result<Option<()>, Status>> { in poll_frame() argument
287 fn response(&mut self) -> Result<(), Status> { in response() argument
329 pub async fn message(&mut self) -> Result<Option<T>, Status> { in message() argument
352 pub async fn trailers(&mut self) -> Result<Option<MetadataMap>, Status> { in trailers() argument
372 fn decode_chunk(&mut self) -> Result<Option<T>, Status> { in decode_chunk() argument
/tonic/examples/src/routeguide/
H A Dserver.rs27 async fn get_feature(&self, request: Request<Point>) -> Result<Response<Feature>, Status> { in get_feature() argument
44 ) -> Result<Response<Self::ListFeaturesStream>, Status> { in list_features() argument
67 ) -> Result<Response<RouteSummary>, Status> { in record_route() argument
109 ) -> Result<Response<Self::RouteChatStream>, Status> { in route_chat() argument
/tonic/tests/use_arc_self/src/
H A Dlib.rs17 ) -> Result<Response<SomeData>, Status> { in test_request() argument
/tonic/tonic-types/src/generated/
H A Dgoogle_rpc.rs10 pub struct Status { struct
16 … /// \[google.rpc.Status.details\]\[google.rpc.Status.details\] field, or localized by the client. argument
18 pub message: ::prost::alloc::string::String,
22 pub details: ::prost::alloc::vec::Vec<::prost_types::Any>,
/tonic/examples/src/helloworld/
H A Dserver.rs18 ) -> Result<Response<HelloReply>, Status> { in say_hello() argument
/tonic/examples/src/tracing/
H A Dserver.rs21 ) -> Result<Response<HelloReply>, Status> { in say_hello() argument
/tonic/examples/src/codec_buffers/
H A Dserver.rs28 ) -> Result<Response<HelloReply>, Status> { in say_hello() argument
/tonic/examples/src/compression/
H A Dserver.rs19 ) -> Result<Response<HelloReply>, Status> { in say_hello() argument
/tonic/examples/src/json-codec/
H A Dserver.rs25 ) -> Result<Response<HelloResponse>, Status> { in say_hello() argument
/tonic/examples/src/grpc-web/
H A Dserver.rs18 ) -> Result<Response<HelloReply>, Status> { in say_hello() argument
/tonic/tonic-types/src/richer_error/
H A Dmod.rs77 ) -> tonic::Status; in with_error_details_and_metadata()
98 ) -> tonic::Status; in with_error_details()
123 ) -> tonic::Status; in with_error_details_vec_and_metadata()
146 ) -> tonic::Status; in with_error_details_vec()
481 impl crate::sealed::Sealed for tonic::Status {} implementation
483 impl StatusExt for tonic::Status { implementation
687 impl crate::sealed::Sealed for pb::Status {} implementation
759 impl RpcStatusExt for pb::Status { implementation

123