Home
last modified time | relevance | path

Searched refs:Status (Results 1 – 25 of 93) sorted by relevance

1234

/tonic/tests/default_stubs/src/
H A Dlib.rs7 use tonic::{Request, Response, Status, Streaming};
17 type ServerStreamStream = Pin<Box<dyn Stream<Item = Result<(), Status>> + Send + 'static>>;
19 Pin<Box<dyn Stream<Item = Result<(), Status>> + Send + 'static>>;
21 async fn unary(&self, _: Request<()>) -> Result<Response<()>, Status> { in unary() argument
22 Err(Status::permission_denied("")) in unary()
28 ) -> Result<Response<Self::ServerStreamStream>, Status> { in server_stream() argument
29 Err(Status::permission_denied("")) in server_stream()
32 async fn client_stream(&self, _: Request<Streaming<()>>) -> Result<Response<()>, Status> { in client_stream() argument
33 Err(Status::permission_denied("")) in client_stream()
39 ) -> Result<Response<Self::BidirectionalStreamStream>, Status> { in bidirectional_stream() argument
[all …]
/tonic/tonic/src/
H A Dstatus.rs38 pub struct Status { struct
160 impl Status { implementation
163 Status { in new()
310 ) -> Status { in from_error_generic() argument
476 Some(Status { in from_header_map()
561 ) -> Status { in with_details_and_metadata() argument
562 Status { in with_details_and_metadata()
638 impl fmt::Debug for Status { implementation
665 Status::new( in invalid_header_value_byte()
712 impl fmt::Display for Status { implementation
[all …]
/tonic/tonic/src/server/
H A Dservice.rs1 use crate::{Request, Response, Status, Streaming};
15 type Future: Future<Output = Result<Response<Self::Response>, Status>>;
23 T: Service<Request<M1>, Response = Response<M2>, Error = crate::Status>,
42 type ResponseStream: Stream<Item = Result<Self::Response, Status>>;
45 type Future: Future<Output = Result<Response<Self::ResponseStream>, Status>>;
53 T: Service<Request<M1>, Response = Response<S>, Error = crate::Status>,
54 S: Stream<Item = Result<M2, crate::Status>>,
74 type Future: Future<Output = Result<Response<Self::Response>, Status>>;
101 type ResponseStream: Stream<Item = Result<Self::Response, Status>>;
104 type Future: Future<Output = Result<Response<Self::ResponseStream>, Status>>;
[all …]
/tonic/tests/compression/src/
H A Dlib.rs16 Request, Response, Status, Streaming,
49 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
63 Pin<Box<dyn Stream<Item = Result<SomeData, Status>> + Send + 'static>>;
68 ) -> Result<Response<Self::CompressOutputServerStreamStream>, Status> { in compress_output_server_stream() argument
72 .map(Ok::<_, Status>); in compress_output_server_stream()
79 ) -> Result<Response<()>, Status> { in compress_input_client_stream() argument
90 ) -> Result<Response<SomeData>, Status> { in compress_output_client_stream() argument
104 Pin<Box<dyn Stream<Item = Result<SomeData, Status>> + Send + 'static>>;
109 ) -> Result<Response<Self::CompressInputOutputBidirectionalStreamStream>, Status> { in compress_input_output_bidirectional_stream() argument
[all …]
/tonic/tonic/src/codec/
H A Dencode.rs5 use crate::Status;
31 error: Option<Status>,
72 T: Encoder<Error = Status>,
75 type Item = Result<Bytes, Status>;
141 ) -> Result<(), Status> in encode_item()
143 T: Encoder<Error = Status>, in encode_item()
185 ) -> Result<(), Status> { in finish_encoding() argument
226 error: Option<Status>,
295 Status::ok("") in trailers()
305 T: Encoder<Error = Status>,
[all …]
H A Ddecode.rs3 use crate::{body::Body, metadata::MetadataMap, Code, Status};
46 Error(Option<Status>),
69 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_response()
85 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_empty()
101 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_request()
150 ) -> Result<Option<DecodeBuf<'_>>, Status> { in decode_chunk() argument
181 return Err(Status::internal(message)); in decode_chunk()
190 return Err(Status::out_of_range( in decode_chunk()
233 return Err(Status::internal(message)); in decode_chunk()
287 fn response(&mut self) -> Result<(), Status> { in response() argument
[all …]
H A Dprost.rs3 use crate::Status;
96 type Error = Status;
129 type Error = Status;
147 Status::internal(error.to_string()) in from_decode_error()
156 use crate::Status;
270 .get(Status::GRPC_STATUS) in encode_max_message_size_exceeded()
307 .get(Status::GRPC_STATUS) in encode_too_big()
319 type Error = Status;
336 type Error = Status;
350 use crate::Status;
[all …]
/tonic/tonic-types/src/richer_error/
H A Dmod.rs38 let status = pb::Status { in gen_details_bytes()
77 ) -> tonic::Status; in with_error_details_and_metadata() argument
98 ) -> tonic::Status; in with_error_details() argument
123 ) -> tonic::Status; in with_error_details_vec_and_metadata() argument
146 ) -> tonic::Status; in with_error_details_vec() argument
481 impl crate::sealed::Sealed for tonic::Status {} implementation
483 impl StatusExt for tonic::Status { implementation
607 let status = pb::Status::decode(self.details())?; in check_error_details()
687 impl crate::sealed::Sealed for pb::Status {} implementation
759 impl RpcStatusExt for pb::Status { implementation
[all …]
/tonic/examples/src/cancellation/
H A Dserver.rs4 use tonic::{transport::Server, Request, Response, Status};
25 ) -> Result<Response<HelloReply>, Status> { in say_hello() argument
43 Err(Status::cancelled("Request cancelled by client")) in say_hello()
52 ) -> Result<Response<HelloReply>, Status> in with_cancellation_handler()
54 FRequest: Future<Output = Result<Response<HelloReply>, Status>> + Send + 'static, in with_cancellation_handler()
55 FCancellation: Future<Output = Result<Response<HelloReply>, Status>> + Send + 'static, in with_cancellation_handler()
/tonic/tests/web/src/
H A Dlib.rs4 use tonic::{Request, Response, Status, Streaming};
12 type BoxStream<T> = Pin<Box<dyn Stream<Item = Result<T, Status>> + Send + 'static>>;
18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in unary_call() argument
22 Err(Status::invalid_argument("invalid boom")) in unary_call()
36 ) -> Result<Response<Self::ServerStreamStream>, Status> { in server_stream() argument
52 ) -> Result<Response<Output>, Status> { in client_stream() argument
/tonic/tonic-reflection/src/server/
H A Dv1alpha.rs5 use tonic::{Request, Response, Status, Streaming};
29 ) -> Result<Response<Self::ServerReflectionInfoStream>, Status> { in server_reflection_info() argument
31 let (resp_tx, resp_rx) = mpsc::channel::<Result<ServerReflectionResponse, Status>>(1); in server_reflection_info()
42 None => Err(Status::invalid_argument("invalid MessageRequest")), in server_reflection_info()
57 Err(Status::not_found("extensions are not supported")) in server_reflection_info()
109 inner: tokio_stream::wrappers::ReceiverStream<Result<ServerReflectionResponse, Status>>,
113 fn new(resp_rx: mpsc::Receiver<Result<ServerReflectionResponse, Status>>) -> Self { in new()
120 type Item = Result<ServerReflectionResponse, Status>;
H A Dv1.rs5 use tonic::{Request, Response, Status, Streaming};
29 ) -> Result<Response<Self::ServerReflectionInfoStream>, Status> { in server_reflection_info() argument
31 let (resp_tx, resp_rx) = mpsc::channel::<Result<ServerReflectionResponse, Status>>(1); in server_reflection_info()
42 None => Err(Status::invalid_argument("invalid MessageRequest")), in server_reflection_info()
57 Err(Status::not_found("extensions are not supported")) in server_reflection_info()
109 inner: tokio_stream::wrappers::ReceiverStream<Result<ServerReflectionResponse, Status>>,
113 fn new(resp_rx: mpsc::Receiver<Result<ServerReflectionResponse, Status>>) -> Self { in new()
120 type Item = Result<ServerReflectionResponse, Status>;
/tonic/examples/src/authentication/
H A Dserver.rs6 use tonic::{metadata::MetadataValue, transport::Server, Request, Response, Status};
8 type EchoResult<T> = Result<Response<T>, Status>;
33 fn check_auth(req: Request<()>) -> Result<Request<()>, Status> { in check_auth() argument
38 _ => Err(Status::unauthenticated("No valid auth token")), in check_auth()
/tonic/examples/src/json-codec/
H A Dcommon.rs10 Status,
28 type Error = Status;
31 serde_json::to_writer(buf.writer(), &item).map_err(|e| Status::internal(e.to_string())) in encode()
40 type Error = Status;
48 serde_json::from_reader(buf.reader()).map_err(|e| Status::internal(e.to_string()))?; in decode()
/tonic/tonic-types/
H A DREADME.md6 [`tonic::Status`], allowing the implementation of the [gRPC Richer Error Model]
14 The [`StatusExt`] trait adds associated functions to [`tonic::Status`] that can
17 [`tonic::Status`] that can be used by a tonic client to extract error details,
29 use tonic::{Code, Status};
33 // Inside a gRPC server endpoint that returns `Result<Response<T>, Status>`
60 let status = Status::with_error_details(
75 use tonic::{Response, Status};
80 fn handle_request_result<T>(req_result: Result<Response<T>, Status>) {
107 ## Alternative `tonic::Status` associated functions and methods
122 [`tonic::Status`].
[all …]
/tonic/examples/src/streaming/
H A Dserver.rs8 use tonic::{transport::Server, Request, Response, Status, Streaming};
12 type EchoResult<T> = Result<Response<T>, Status>;
13 type ResponseStream = Pin<Box<dyn Stream<Item = Result<EchoResponse, Status>> + Send>>;
15 fn match_for_io_error(err_status: &Status) -> Option<&std::io::Error> { in match_for_io_error()
41 Err(Status::unimplemented("not implemented")) in unary_echo()
64 match tx.send(Result::<_, Status>::Ok(item)).await { in server_streaming_echo()
87 Err(Status::unimplemented("not implemented")) in client_streaming_echo()
/tonic/tonic/src/service/
H A Dinterceptor.rs5 use crate::{request::SanitizeHeaders, Status};
43 fn call(&mut self, request: crate::Request<()>) -> Result<crate::Request<()>, Status>; in call() argument
48 F: FnMut(crate::Request<()>) -> Result<crate::Request<()>, Status>,
179 fn status(status: Status) -> Self { in status()
181 kind: Kind::Status(Some(status)), in status()
190 Status(Option<Status>), enumerator
202 KindProj::Status(status) => { in poll()
285 Ok::<_, Status>(http::Response::new(())) in doesnt_remove_headers_from_requests()
311 let expected = Status::permission_denied(message).into_http::<()>(); in handles_intercepted_status_as_response()
314 Ok::<_, Status>(http::Response::new(())) in handles_intercepted_status_as_response()
[all …]
/tonic/tests/integration_tests/tests/
H A Dstreams.rs3 use tonic::{transport::Server, Request, Response, Status};
6 Box<dyn tokio_stream::Stream<Item = std::result::Result<T, Status>> + Send + 'static>,
20 ) -> Result<Response<Self::StreamCallStream>, Status> { in status_from_server_stream_with_source() argument
50 type Item = Result<OutputStream, Status>;
H A Dstatus.rs15 Code, Request, Response, Status,
24 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in status_with_details() argument
25 Err(Status::with_details( in status_with_details()
82 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in status_with_metadata() argument
87 Err(Status::with_metadata(Code::Internal, MESSAGE, metadata)) in status_with_metadata()
139 Box<dyn tokio_stream::Stream<Item = std::result::Result<T, Status>> + Send + 'static>,
155 ) -> Result<Response<Self::StreamCallStream>, Status> { in status_from_server_stream() argument
157 Err::<OutputStream, _>(Status::unavailable("foo")), in status_from_server_stream()
158 Err::<OutputStream, _>(Status::unavailable("bar")), in status_from_server_stream()
225 ) -> Result<Response<Self::StreamCallStream>, Status> { in message_and_then_status_from_server_stream() argument
[all …]
/tonic/tonic-web/src/
H A Dcall.rs11 use tonic::Status;
173 ) -> Poll<Option<Result<Frame<Bytes>, Status>>> { in poll_decode() argument
219 ) -> Poll<Option<Result<Frame<Bytes>, Status>>> { in poll_encode() argument
256 type Error = Status;
344 type Item = Result<Frame<Bytes>, Status>;
375 fn internal_error(e: impl std::fmt::Display) -> Status { in internal_error() argument
376 Status::internal(format!("tonic-web: {}", e)) in internal_error()
463 fn find_trailers(buf: &[u8]) -> Result<FindTrailers, Status> { in find_trailers() argument
481 return Err(Status::internal(format!( in find_trailers()
538 headers.insert(Status::GRPC_STATUS, 0.into()); in decode_trailers()
[all …]
/tonic/examples/src/interceptor/
H A Dclient.rs7 Request, Status,
36 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
72 InterceptedService<Channel, fn(tonic::Request<()>) -> Result<tonic::Request<()>, Status>>, in using_function_pointer_interceptro()
/tonic/interop/src/
H A Dserver.rs11 use tonic::{body::Body, server::NamedService, Code, Request, Response, Status};
20 type Result<T> = StdResult<Response<T>, Status>;
22 type Stream<T> = Pin<Box<dyn tokio_stream::Stream<Item = StdResult<T, Status>> + Send + 'static>>;
35 let status = Status::new(Code::from_i32(echo_status.code), echo_status.message); in unary_call()
42 let status = Status::new(Code::InvalidArgument, "response_size cannot be negative"); in unary_call()
114 let status = Status::new(Code::from_i32(echo_status.code), echo_status.message); in full_duplex_call()
124 … let status = Status::new(Code::from_i32(echo_status.code), echo_status.message); in full_duplex_call()
150 Err(Status::unimplemented("TODO")) in half_duplex_call()
154 Err(Status::unimplemented("")) in unimplemented_call()
164 Err(Status::unimplemented("")) in unimplemented_call()
/tonic/tests/use_arc_self/src/
H A Dlib.rs5 use tonic::{Request, Response, Status};
17 ) -> Result<Response<SomeData>, Status> { in test_request() argument
/tonic/examples/src/multiplex/
H A Dserver.rs1 use tonic::{transport::Server, Request, Response, Status};
45 ) -> Result<Response<HelloReply>, Status> { in say_hello() argument
61 ) -> Result<Response<EchoResponse>, Status> { in unary_echo() argument
/tonic/examples/src/richer-error/
H A Dserver.rs1 use tonic::{transport::Server, Code, Request, Response, Status};
19 ) -> Result<Response<HelloReply>, Status> { in say_hello() argument
42 let status = Status::with_error_details( in say_hello()

1234