Home
last modified time | relevance | path

Searched refs:new (Results 1 – 25 of 183) sorted by relevance

12345678

/tonic/tonic-types/src/richer_error/error_details/
H A Dmod.rs59 pub fn new() -> Self { in new() method
77 ..ErrorDetails::new() in with_retry_info()
99 ..ErrorDetails::new() in with_debug_info()
119 ..ErrorDetails::new() in with_quota_failure()
139 ..ErrorDetails::new() in with_quota_failure_violation()
164 ..ErrorDetails::new() in with_error_info()
192 ..ErrorDetails::new() in with_precondition_failure()
222 ..ErrorDetails::new() in with_precondition_failure_violation()
242 ..ErrorDetails::new() in with_bad_request()
265 ..ErrorDetails::new() in with_bad_request_violation()
[all …]
/tonic/tests/compression/src/
H A Dcompressing_response.rs57 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled()
64 ServiceBuilder::new() in client_enabled_server_enabled()
115 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_disabled()
123 ServiceBuilder::new() in client_enabled_server_disabled()
156 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_disabled_multi_encoding()
164 ServiceBuilder::new() in client_enabled_server_disabled_multi_encoding()
230 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_disabled()
287 ServiceBuilder::new() in server_replying_with_unsupported_encoding()
324 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in disabling_compression_on_single_response()
382 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in disabling_compression_on_response_but_keeping_compression_on_stream()
[all …]
H A Dserver_stream.rs16 let svc = test_server::TestServer::new(Svc::default()).send_compressed(encoding); in client_enabled_server_enabled()
18 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled()
25 ServiceBuilder::new() in client_enabled_server_enabled()
26 .layer(MapResponseBodyLayer::new(move |body| { in client_enabled_server_enabled()
83 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_disabled_server_enabled()
90 ServiceBuilder::new() in client_disabled_server_enabled()
91 .layer(MapResponseBodyLayer::new(move |body| { in client_disabled_server_enabled()
133 let svc = test_server::TestServer::new(Svc::default()); in client_enabled_server_disabled()
135 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_disabled()
142 ServiceBuilder::new() in client_enabled_server_disabled()
[all …]
H A Dclient_stream.rs18 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled()
27 pub fn new(encoding: CompressionEncoding) -> Self { in client_enabled_server_enabled() method
49 ServiceBuilder::new() in client_enabled_server_enabled()
70 let req = Request::new(Box::pin(stream)); in client_enabled_server_enabled()
91 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_disabled_server_enabled()
103 ServiceBuilder::new() in client_disabled_server_enabled()
121 let req = Request::new(Box::pin(stream)); in client_disabled_server_enabled()
140 let svc = test_server::TestServer::new(Svc::default()); in client_enabled_server_disabled()
155 let req = Request::new(Box::pin(stream)); in client_enabled_server_disabled()
188 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in compressing_response_from_client_stream()
[all …]
H A Dbidirectional_stream.rs16 let svc = test_server::TestServer::new(Svc::default()) in client_enabled_server_enabled()
20 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled()
21 let response_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled()
30 pub fn new(encoding: CompressionEncoding) -> Self { in client_enabled_server_enabled() method
53 ServiceBuilder::new() in client_enabled_server_enabled()
55 AssertRightEncoding::new(encoding).clone().call(req) in client_enabled_server_enabled()
60 .layer(MapResponseBodyLayer::new(move |body| { in client_enabled_server_enabled()
75 let mut client = test_client::TestClient::new(mock_io_channel(client).await) in client_enabled_server_enabled()
81 let req = Request::new(stream); in client_enabled_server_enabled()
H A Dcompressing_request.rs16 let svc = test_server::TestServer::new(Svc::default()).accept_compressed(encoding); in client_enabled_server_enabled()
18 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled()
27 pub fn new(encoding: CompressionEncoding) -> Self { in client_enabled_server_enabled() method
49 ServiceBuilder::new() in client_enabled_server_enabled()
51 ServiceBuilder::new() in client_enabled_server_enabled()
53 AssertRightEncoding::new(encoding).clone().call(req) in client_enabled_server_enabled()
93 let svc = test_server::TestServer::new(Svc::default()) in client_enabled_server_enabled_multi_encoding()
98 let request_bytes_counter = Arc::new(AtomicUsize::new(0)); in client_enabled_server_enabled_multi_encoding()
113 ServiceBuilder::new() in client_enabled_server_enabled_multi_encoding()
115 ServiceBuilder::new() in client_enabled_server_enabled_multi_encoding()
[all …]
/tonic/examples/src/tls_rustls/
H A Dserver.rs29 let mut buf = std::io::BufReader::new(&fd); in main()
34 let mut buf = std::io::BufReader::new(&fd); in main()
45 let svc = Routes::new(pb::echo_server::EchoServer::new(server)).prepare(); in main()
47 let http = Builder::new(TokioExecutor::new()); in main()
50 let tls_acceptor = TlsAcceptor::from(Arc::new(tls)); in main()
66 let mut certificates = Vec::new(); in main()
79 let svc = tower::ServiceBuilder::new() in main()
80 .add_extension(Arc::new(ConnInfo { addr, certificates })) in main()
84 TokioIo::new(conn), in main()
85 TowerToHyperService::new( in main()
[all …]
H A Dclient.rs23 let mut buf = std::io::BufReader::new(&fd); in main()
31 let mut http = HttpConnector::new(); in main()
37 let connector = tower::ServiceBuilder::new() in main()
41 hyper_rustls::HttpsConnectorBuilder::new() in main()
53 let client = hyper_util::client::legacy::Client::builder(TokioExecutor::new()).build(connector); in main()
60 let request = tonic::Request::new(EchoRequest { in main()
/tonic/tests/integration_tests/tests/
H A Dconnection.rs18 Ok(Response::new(Output {})) in unary_call()
40 let sender = Arc::new(Mutex::new(Some(tx))); in connect_returns_err_via_call_after_connected()
41 let svc = test_server::TestServer::new(Svc(sender)); in connect_returns_err_via_call_after_connected()
60 client.unary_call(Request::new(Input {})).await.unwrap(); in connect_returns_err_via_call_after_connected()
64 let res = client.unary_call(Request::new(Input {})).await; in connect_returns_err_via_call_after_connected()
75 let sender = Arc::new(Mutex::new(Some(tx))); in connect_lazy_reconnects_after_first_failure()
76 let svc = test_server::TestServer::new(Svc(sender)); in connect_lazy_reconnects_after_first_failure()
80 let mut client = TestClient::new(channel); in connect_lazy_reconnects_after_first_failure()
83 client.unary_call(Request::new(Input {})).await.unwrap_err(); in connect_lazy_reconnects_after_first_failure()
103 let mut client = TestClient::new(channel); in connect_lazy_reconnects_after_first_failure()
[all …]
/tonic/tonic-health/src/
H A Dserver.rs22 let reporter = HealthReporter::new(); in health_reporter()
24 let server = HealthServer::new(service); in health_reporter()
40 fn new() -> Self { in new() method
44 let statuses = Arc::new(RwLock::new(HashMap::from([server_status]))); in new()
128 Ok(Response::new(HealthCheckResponse::new(status))) in check()
143 Ok(Response::new(WatchStream::new(status_rx))) in watch()
166 std::pin::Pin::new(&mut self.inner) in poll_next()
179 fn new(status: ServingStatus) -> Self { in new() method
206 let health_reporter = HealthReporter::new(); in make_test_service()
227 .check(Request::new(HealthCheckRequest { in test_service_check()
[all …]
/tonic/examples/src/h2c/
H A Dserver.rs30 Ok(Response::new(reply)) in say_hello()
42 let svc = Routes::new(GreeterServer::new(greeter)).prepare(); in main()
51 let builder = Builder::new(TokioExecutor::new()); in main()
53 TokioIo::new(io), in main()
54 TowerToHyperService::new(router), in main()
101 let mut req = req.map(Body::new); in call()
105 .map_request(|req: Request<_>| req.map(Body::new)); in call()
110 hyper::server::conn::http2::Builder::new(TokioExecutor::new()) in call()
111 .serve_connection(upgraded_io, TowerToHyperService::new(svc)) in call()
116 let mut res = hyper::Response::new(Body::default()); in call()
/tonic/tonic/src/transport/channel/service/
H A Dio.rs18 pub(in crate::transport) fn new<I: Io>(io: I) -> Self { in new() method
25 HyperConnected::new() in connected()
35 Pin::new(&mut self.0).poll_read(cx, buf) in poll_read()
45 Pin::new(&mut self.0).poll_write(cx, buf) in poll_write()
49 Pin::new(&mut self.0).poll_flush(cx) in poll_flush()
53 Pin::new(&mut self.0).poll_shutdown(cx) in poll_shutdown()
61 Pin::new(&mut self.0).poll_write_vectored(cx, bufs) in poll_write_vectored()
H A Dconnection.rs28 fn new<C>(connector: C, endpoint: Endpoint, is_lazy: bool) -> Self in new() method
35 let mut settings: Builder<SharedExec> = Builder::new(endpoint.executor.clone()) in new()
39 .timer(TokioTimer::new()) in new()
58 let stack = ServiceBuilder::new() in new()
62 AddOrigin::new(s, origin) in new()
64 .layer_fn(|s| UserAgent::new(s, endpoint.user_agent.clone())) in new()
65 .layer_fn(|s| GrpcTimeout::new(s, endpoint.timeout)) in new()
73 let conn = Reconnect::new(make_service, endpoint.uri.clone(), is_lazy); in new()
76 inner: BoxService::new(stack.layer(conn)), in new()
90 Self::new(connector, endpoint, false).ready_oneshot().await in connect()
[all …]
H A Dexecutor.rs13 pub(crate) fn new<E>(exec: E) -> Self in new() method
18 inner: Arc::new(exec), in new()
23 Self::new(TokioExecutor::new()) in tokio()
H A Dtls.rs30 pub(crate) fn new( in new() method
52 None => with_provider(Arc::new(crypto::ring::default_provider())), in new()
54 None => with_provider(Arc::new(crypto::aws_lc_rs::default_provider())), in new()
93 config.key_log = Arc::new(tokio_rustls::rustls::KeyLogFile::new()); in new()
98 config: Arc::new(config), in new()
99 domain: Arc::new(ServerName::try_from(domain)?.to_owned()), in new()
119 Ok(BoxedIo::new(TokioIo::new(io))) in connect()
/tonic/tonic/src/
H A Dutil.rs15 pub(crate) const STANDARD: GeneralPurpose = GeneralPurpose::new(
17 GeneralPurposeConfig::new()
22 pub(crate) const STANDARD_NO_PAD: GeneralPurpose = GeneralPurpose::new(
24 GeneralPurposeConfig::new()
H A Dresponse.rs26 pub fn new(message: T) -> Self { in new() method
28 metadata: MetadataMap::new(), in new()
30 extensions: Extensions::new(), in new()
83 let mut res = http::Response::new(self.message); in into_http()
132 Response::new(inner) in from()
143 let mut r = Response::new(1); in reserved_headers_are_excluded()
/tonic/tonic/src/transport/server/service/
H A Dio.rs18 pub(crate) fn new(connect_info: T) -> Self { in new() method
30 ConnectInfo::new(inner, self.connect_info.clone()) in layer()
41 fn new(inner: S, connect_info: T) -> Self { in new() method
106 Self::TlsIo(Box::new(io)) in new_tls_io()
131 Self::Io(io) => Pin::new(io).poll_read(cx, buf), in poll_read()
133 Self::TlsIo(io) => Pin::new(io).poll_read(cx, buf), in poll_read()
148 Self::Io(io) => Pin::new(io).poll_write(cx, buf), in poll_write()
156 Self::Io(io) => Pin::new(io).poll_flush(cx), in poll_flush()
158 Self::TlsIo(io) => Pin::new(io).poll_flush(cx), in poll_flush()
164 Self::Io(io) => Pin::new(io).poll_shutdown(cx), in poll_shutdown()
[all …]
/tonic/tonic-reflection/tests/
H A Dversions.rs17 String::new(), in test_v1()
41 v1alpha::server_reflection_request::MessageRequest::ListServices(String::new()), in test_v1alpha()
74 .serve_with_incoming_shutdown(TcpListenerStream::new(listener), async { in make_v1_request()
85 let conn = tonic::transport::Endpoint::new(local_addr) in make_v1_request()
90 let mut client = v1::server_reflection_client::ServerReflectionClient::new(conn); in make_v1_request()
92 let request = Request::new(tokio_stream::once(request)); in make_v1_request()
131 .serve_with_incoming_shutdown(TcpListenerStream::new(listener), async { in make_v1alpha_request()
142 let conn = tonic::transport::Endpoint::new(local_addr) in make_v1alpha_request()
147 let mut client = v1alpha::server_reflection_client::ServerReflectionClient::new(conn); in make_v1alpha_request()
149 let request = Request::new(tokio_stream::once(request)); in make_v1alpha_request()
/tonic/examples/src/grpc-web/
H A Dserver.rs24 Ok(Response::new(reply)) in say_hello()
35 let greeter = tower::ServiceBuilder::new() in main()
36 .layer(tower_http::cors::CorsLayer::new()) in main()
37 .layer(tonic_web::GrpcWebLayer::new()) in main()
39 .named_layer(GreeterServer::new(greeter)); in main()
H A Dclient.rs12 let client = hyper_util::client::legacy::Client::builder(TokioExecutor::new()).build_http(); in main()
14 let svc = tower::ServiceBuilder::new() in main()
15 .layer(GrpcWebClientLayer::new()) in main()
20 let request = tonic::Request::new(HelloRequest { in main()
/tonic/examples/src/multiplex/
H A Dclient.rs19 let mut greeter_client = GreeterClient::new(channel.clone()); in main()
20 let mut echo_client = EchoClient::new(channel); in main()
22 let request = tonic::Request::new(HelloRequest { in main()
30 let request = tonic::Request::new(EchoRequest { in main()
/tonic/tonic-build/src/
H A Dlib.rs245 let mut deprecated_stream = TokenStream::new(); in generate_deprecated()
250 let mut stream = TokenStream::new(); in generate_deprecated()
251 stream.append(Punct::new('#', Spacing::Alone)); in generate_deprecated()
267 let mut doc_stream = TokenStream::new(); in generate_doc_comment()
269 doc_stream.append(Ident::new("doc", Span::call_site())); in generate_doc_comment()
270 doc_stream.append(Punct::new('=', Spacing::Alone)); in generate_doc_comment()
273 let group = Group::new(Delimiter::Bracket, doc_stream); in generate_doc_comment()
275 let mut stream = TokenStream::new(); in generate_doc_comment()
276 stream.append(Punct::new('#', Spacing::Alone)); in generate_doc_comment()
283 let mut stream = TokenStream::new(); in generate_doc_comments()
[all …]
/tonic/examples/src/tower/
H A Dclient.rs16 let channel = ServiceBuilder::new() in main()
18 .layer(tonic::service::InterceptorLayer::new(intercept)) in main()
19 .layer_fn(AuthSvc::new) in main()
22 let mut client = GreeterClient::new(channel); in main()
24 let request = tonic::Request::new(HelloRequest { in main()
55 pub fn new(inner: Channel) -> Self { in new() method
/tonic/tests/integration_tests/src/
H A Dlib.rs32 Pin::new(&mut self.0).poll_read(cx, buf) in poll_read()
42 Pin::new(&mut self.0).poll_write(cx, buf) in poll_write()
46 Pin::new(&mut self.0).poll_flush(cx) in poll_flush()
53 Pin::new(&mut self.0).poll_shutdown(cx) in poll_shutdown()
61 Pin::new(&mut self.0).poll_write_vectored(cx, bufs) in poll_write_vectored()

12345678