Home
last modified time | relevance | path

Searched refs:server (Results 1 – 25 of 88) sorted by relevance

1234

/tonic/examples/
H A DCargo.toml8 name = "helloworld-server"
16 name = "blocking-server"
24 name = "routeguide-server"
63 name = "tls-server"
64 path = "src/tls/server.rs"
88 name = "tower-server"
116 name = "tracing-server"
126 name = "uds-server"
139 name = "health-server"
219 name = "dynamic-server"
[all …]
H A DREADME.md40 $ cargo run --bin helloworld-server
54 $ cargo run --bin routeguide-server
68 $ cargo run --bin authentication-server
82 $ cargo run --bin load-balance-server
96 $ cargo run --bin dynamic-load-balance-server
110 $ cargo run --bin tls-server
118 $ cargo run --bin health-server
125 $ cargo run --bin reflection-server
133 $ cargo run --bin tower-server
178 $ cargo run --bin richer-error-server
[all …]
H A Dhelloworld-tutorial.md106 [[bin]] # Bin to run the HelloWorld gRPC server
107 name = "helloworld-server"
108 path = "src/server.rs"
142 …import the things we will be using in our server, including the protobuf. Start by making a file c…
195 Altogether your server should look something like this once you are done:
240 …server using the command `cargo run --bin helloworld-server`. This uses the [[bin]] we defined ear…
242 If you have a gRPC GUI client such as [Bloom RPC] you should be able to send requests to the server…
260 …server, and that's great but how can our application communicate with it? This is where our client…
318 …server which implements our SayHello service, and a client which makes requests to our server. You…
320 To run the server, run `cargo run --bin helloworld-server`.
[all …]
H A Drouteguide-tutorial.md7 - Generate server and client code.
50 Run the server
52 $ cargo run --bin routeguide-server
115 - A *server-side streaming RPC* where the client sends a request to the server and gets a stream
215 ## Creating the server
227 [examples/src/routeguide/server.rs][routeguide-server].
528 ### Starting the server argument
576 name = "routeguide-server"
577 path = "src/server.rs"
587 $ mv src/main.rs src/server.rs
[all …]
/tonic/interop/src/bin/
H A Dserver.rs1 use interop::server;
37 let test_service = server::TestServiceServer::new(server::TestService::default()); in main()
39 server::UnimplementedServiceServer::new(server::UnimplementedService::default()); in main()
42 let test_service_svc = server::EchoHeadersSvc::new(test_service); in main()
/tonic/interop/data/cert-generator/
H A Dserver_certs.tf7 private_key_pem = tls_private_key.server.private_key_pem
19 cert_request_pem = tls_cert_request.server.cert_request_pem
32 content = tls_locally_signed_cert.server.cert_pem
37 content = tls_private_key.server.private_key_pem
/tonic/tonic/src/transport/
H A Dmod.rs94 pub mod server; module
107 pub use self::server::Server;
118 pub use self::server::ServerTlsConfig;
/tonic/interop/proto/grpc/testing/
H A Dmessages.proto46 // clients to specify a status that the server should attempt to return.
55 // Desired payload type in the response from the server.
59 // Desired payload size in the response from the server.
71 // Whether to request the server to compress the response. This field is
77 // Whether server should return a given status
80 // Whether the server should expect this request to be compressed.
117 // Desired payload sizes in responses from the server.
124 // Whether to request the server to compress the response. This field is
134 // Desired payload type in the response from the server.
146 // Whether server should return a given status
[all …]
H A Dtest.proto40 // The server returns the payload with client desired type and sizes.
45 // The server returns the aggregated size of client payload as the result.
49 // A sequence of requests with each request served by the server immediately.
56 // The server buffers all the client requests and then serves them in order. A
57 // stream of responses are returned to the client when the server starts with
62 // The test server will not implement this method. It will be used
70 // A call that no server should implement
74 // A service used to control reconnect server.
/tonic/examples/src/autoreload/
H A Dserver.rs35 let server = Server::builder().add_service(GreeterServer::new(greeter)); in main() localVariable
44 server.serve_with_incoming(listener).await?; in main()
47 server.serve(addr).await?; in main()
/tonic/tests/compression/src/
H A Dcompressing_response.rs13 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled()
78 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_enabled()
111 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled()
152 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled_multi_encoding()
174 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_disabled_multi_encoding()
202 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_disabled()
273 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in server_replying_with_unsupported_encoding()
292 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in server_replying_with_unsupported_encoding()
317 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in disabling_compression_on_single_response()
375 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in disabling_compression_on_response_but_keeping_compression_on_stream()
[all …]
H A Dcompressing_request.rs14 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled()
61 .serve_with_incoming(tokio_stream::iter(vec![Ok::<_, std::io::Error>(server)])) in client_enabled_server_enabled()
91 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled_multi_encoding()
123 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_enabled_multi_encoding()
153 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled()
160 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_disabled()
204 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_mark_compressed_without_header_server_enabled()
212 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_mark_compressed_without_header_server_enabled()
H A Dserver_stream.rs14 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled()
35 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_enabled()
79 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_disabled_server_enabled()
100 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_disabled_server_enabled()
131 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled()
152 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_disabled()
H A Dclient_stream.rs14 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled()
59 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_enabled()
87 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_disabled_server_enabled()
111 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_disabled_server_enabled()
138 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled()
145 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_disabled()
184 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in compressing_response_from_client_stream()
205 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in compressing_response_from_client_stream()
/tonic/examples/src/tls/
H A Dserver.rs8 server::{TcpConnectInfo, TlsConnectInfo},
46 let server = EchoServer::default(); in main() localVariable
50 .add_service(pb::echo_server::EchoServer::new(server)) in main()
/tonic/tonic-reflection/proto/
H A Dreflection_v1.proto15 // Service exported by server reflection. A more complete description of how
16 // server reflection works can be found at
17 // https://github.com/grpc/grpc/blob/master/doc/server-reflection.md
33 // all related requests go to a single server.
42 // fields in message_request. The server distinguishes requests by their
81 // The message sent by the server to answer ServerReflectionInfo method.
85 // The server sets one of the following fields according to the message_request
107 // Serialized FileDescriptorProto messages sent by the server answering
117 // A list of extension numbers sent by the server answering
126 // A list of ServiceResponse sent by the server answering list_services request.
[all …]
H A Dreflection_v1alpha.proto15 // Service exported by server reflection
23 // all related requests go to a single server.
32 // fields in message_request. The server distinguishes requests by their
71 // The message sent by the server to answer ServerReflectionInfo method.
75 // The server sets one of the following fields according to the
97 // Serialized FileDescriptorProto messages sent by the server answering
107 // A list of extension numbers sent by the server answering
116 // A list of ServiceResponse sent by the server answering list_services request.
131 // The error code and error message sent by the server when an error occurs.
/tonic/interop/
H A DCargo.toml12 name = "server"
13 path = "src/bin/server.rs"
/tonic/examples/src/authentication/
H A Dserver.rs24 let server = EchoServer::default(); in main() localVariable
26 let svc = pb::echo_server::EchoServer::with_interceptor(server, check_auth); in main()
/tonic/examples/src/load_balance/
H A Dserver.rs37 let server = EchoServer { addr }; in main() localVariable
39 .add_service(pb::echo_server::EchoServer::new(server)) in main()
/tonic/tonic-web/
H A DREADME.md9 and allow the tonic server to accept HTTP/1.1 requests:
30 See [the examples folder][example] for a server and client example.
/tonic/examples/src/dynamic_load_balance/
H A Dserver.rs37 let server = EchoServer { addr }; in main() localVariable
39 .add_service(pb::echo_server::EchoServer::new(server)) in main()
/tonic/examples/src/tls_client_auth/
H A Dserver.rs39 let server = EchoServer::default(); in main() localVariable
47 .add_service(pb::echo_server::EchoServer::new(server)) in main()
/tonic/examples/src/health/
H A Dserver.rs6 use tonic_health::server::HealthReporter;
48 let (mut health_reporter, health_service) = tonic_health::server::health_reporter(); in main()
/tonic/examples/src/mock/
H A Dmock.rs20 let (client, server) = tokio::io::duplex(1024); in main()
27 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in main()

1234