| /tonic/examples/src/load_balance/ |
| H A D | server.rs | 15 addr: SocketAddr, field
21 let message = format!("{} (from {})", request.into_inner().message, self.addr); in unary_echo()
33 for addr in &addrs { in main()
34 let addr = addr.parse()?; in main() localVariable
37 let server = EchoServer { addr }; in main()
40 .serve(addr); in main()
|
| /tonic/examples/src/dynamic_load_balance/ |
| H A D | server.rs | 15 addr: SocketAddr, field
21 let message = format!("{} (from {})", request.into_inner().message, self.addr); in unary_echo()
33 for addr in &addrs { in main()
34 let addr = addr.parse()?; in main() localVariable
37 let server = EchoServer { addr }; in main()
40 .serve(addr); in main()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | timeout.rs | 8 let addr = run_service_in_background(Duration::from_secs(1), Duration::from_secs(100)).await; in cancelation_on_timeout() localVariable
10 let mut client = test_client::TestClient::connect(format!("http://{}", addr)) in cancelation_on_timeout()
28 let addr = run_service_in_background(Duration::from_secs(1), Duration::from_millis(100)).await; in picks_server_timeout_if_thats_sorter() localVariable
30 let mut client = test_client::TestClient::connect(format!("http://{}", addr)) in picks_server_timeout_if_thats_sorter()
47 let addr = run_service_in_background(Duration::from_secs(1), Duration::from_secs(100)).await; in picks_client_timeout_if_thats_sorter() localVariable
49 let mut client = test_client::TestClient::connect(format!("http://{}", addr)) in picks_client_timeout_if_thats_sorter()
80 let addr = listener.local_addr().unwrap(); in run_service_in_background() localVariable
91 addr in run_service_in_background()
|
| /tonic/tonic/src/transport/server/ |
| H A D | incoming.rs | 56 pub fn bind(addr: SocketAddr) -> std::io::Result<Self> { in bind()
57 let std_listener = StdTcpListener::bind(addr)?; in bind()
124 let addr = "127.0.0.1:1322".parse().unwrap(); in one_tcpincoming_at_a_time() localVariable
126 let _t1 = TcpIncoming::bind(addr).unwrap(); in one_tcpincoming_at_a_time()
127 let _t2 = TcpIncoming::bind(addr).unwrap_err(); in one_tcpincoming_at_a_time()
129 let _t3 = TcpIncoming::bind(addr).unwrap(); in one_tcpincoming_at_a_time()
|
| /tonic/examples/src/codec_buffers/ |
| H A D | server.rs | 40 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
43 println!("GreeterServer listening on {}", addr); in main()
47 .serve(addr) in main()
|
| /tonic/examples/src/helloworld/ |
| H A D | server.rs | 30 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
33 println!("GreeterServer listening on {}", addr); in main()
37 .serve(addr) in main()
|
| /tonic/examples/src/json-codec/ |
| H A D | server.rs | 37 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
40 println!("GreeterServer listening on {}", addr); in main()
44 .serve(addr) in main()
|
| /tonic/examples/src/compression/ |
| H A D | server.rs | 31 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
34 println!("GreeterServer listening on {}", addr); in main()
40 Server::builder().add_service(service).serve(addr).await?; in main()
|
| /tonic/examples/src/tracing/ |
| H A D | server.rs | 40 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
43 tracing::info!(message = "Starting server.", %addr); in main()
48 .serve(addr) in main()
|
| /tonic/examples/src/grpc-web/ |
| H A D | server.rs | 32 let addr = "127.0.0.1:3000".parse().unwrap(); in main() localVariable
41 println!("GreeterServer listening on {}", addr); in main()
47 .serve(addr) in main()
|
| /tonic/examples/src/autoreload/ |
| H A D | server.rs | 30 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
33 println!("GreeterServer listening on {}", addr); in main()
47 server.serve(addr).await?; in main()
|
| /tonic/examples/src/richer-error/ |
| H A D | server.rs | 60 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
63 println!("GreeterServer listening on {}", addr); in main()
67 .serve(addr) in main()
|
| H A D | server_vec.rs | 60 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
63 println!("GreeterServer listening on {}", addr); in main()
67 .serve(addr) in main()
|
| /tonic/examples/src/interceptor/ |
| H A D | server.rs | 31 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
39 println!("GreeterServer listening on {}", addr); in main()
41 Server::builder().add_service(svc).serve(addr).await?; in main()
|
| /tonic/examples/src/health/ |
| H A D | server.rs | 55 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
58 println!("HealthServer + GreeterServer listening on {}", addr); in main()
63 .serve(addr) in main()
|
| /tonic/tonic/src/ |
| H A D | request.rs | 216 let addr = self in local_addr() localVariable
222 let addr = addr.or_else(|| { in local_addr() localVariable
228 addr in local_addr()
238 let addr = self in remote_addr() localVariable
244 let addr = addr.or_else(|| { in remote_addr() localVariable
250 addr in remote_addr()
|
| /tonic/examples/src/cancellation/ |
| H A D | server.rs | 74 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
77 println!("GreeterServer listening on {}", addr); in main()
81 .serve(addr) in main()
|
| /tonic/examples/src/blocking/ |
| H A D | server.rs | 32 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
38 .serve(addr); in main()
|
| /tonic/examples/src/tls_rustls/ |
| H A D | server.rs | 53 let (conn, addr) = match listener.accept().await { in main()
80 .add_extension(Arc::new(ConnInfo { addr, certificates })) in main()
97 addr: std::net::SocketAddr, field
112 conn_info.addr, conn_info.certificates in unary_echo()
|
| /tonic/examples/src/dynamic/ |
| H A D | server.rs | 78 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
80 println!("Grpc server listening on {}", addr); in main()
84 .serve(addr) in main()
|
| /tonic/examples/src/reflection/ |
| H A D | server.rs | 36 let addr = "[::1]:50052".parse().unwrap(); in main() localVariable
42 .serve(addr) in main()
|
| /tonic/tonic-reflection/tests/ |
| H A D | versions.rs | 66 let addr: SocketAddr = "127.0.0.1:0".parse().expect("SocketAddr parse"); in make_v1_request() localVariable
67 let listener = tokio::net::TcpListener::bind(addr).await.expect("bind"); in make_v1_request()
123 let addr: SocketAddr = "127.0.0.1:0".parse().expect("SocketAddr parse"); in make_v1alpha_request() localVariable
124 let listener = tokio::net::TcpListener::bind(addr).await.expect("bind"); in make_v1alpha_request()
|
| /tonic/interop/src/bin/ |
| H A D | server.rs | 25 let addr = "127.0.0.1:10000".parse().unwrap(); in main() localVariable
47 .serve(addr) in main()
|
| /tonic/examples/src/authentication/ |
| H A D | server.rs | 23 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
28 Server::builder().add_service(svc).serve(addr).await?; in main()
|
| /tonic/examples/src/multiplex/ |
| H A D | server.rs | 23 let addr = "[::1]:50051".parse().unwrap(); in main() localVariable
31 .serve(addr) in main()
|