| /tonic/tonic/src/ |
| H A D | extensions.rs | 4 service: &'a str, field
11 pub fn new(service: &'a str, method: &'a str) -> Self { in new()
12 Self { service, method } in new()
16 pub fn service(&self) -> &str { in service() method
17 self.service in service()
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 12 service: &T, in generate_internal()
23 service, in generate_internal()
168 service: &T, in generate_methods()
186 service, in generate_methods()
193 service, in generate_methods()
200 service, in generate_methods()
207 service, in generate_methods()
222 service: &T, in generate_unary()
253 service: &T, in generate_server_streaming()
284 service: &T, in generate_client_streaming()
[all …]
|
| H A D | code_gen.rs | 78 pub fn generate_client(&self, service: &impl Service, proto_path: &str) -> TokenStream { in generate_client()
80 service, in generate_client()
94 pub fn generate_server(&self, service: &impl Service, proto_path: &str) -> TokenStream { in generate_server()
96 service, in generate_server()
|
| H A D | server.rs | 14 service: &T, in generate_internal()
24 service, in generate_internal()
36 service, in generate_internal()
52 generate_doc_comments(service.comment()) in generate_internal()
198 service: &T, in generate_trait()
208 service, in generate_trait()
218 service.name() in generate_trait()
231 service: &T, in generate_trait_methods()
241 for method in service.methods() { in generate_trait_methods()
370 service: &T, in generate_methods()
[all …]
|
| H A D | lib.rs | 201 fn format_service_name<T: Service>(service: &T, emit_package: bool) -> String { in format_service_name()
202 let package = if emit_package { service.package() } else { "" }; in format_service_name()
207 service.identifier(), in format_service_name()
211 fn format_method_path<T: Service>(service: &T, method: &T::Method, emit_package: bool) -> String { in format_method_path()
214 format_service_name(service, emit_package), in format_method_path()
219 fn format_method_name<T: Service>(service: &T, method: &T::Method, emit_package: bool) -> String { in format_method_name()
222 format_service_name(service, emit_package), in format_method_name()
|
| H A D | manual.rs | 362 fn generate(&mut self, service: &Service) { in generate()
367 .generate_server(service, ""); in generate()
377 .generate_client(service, ""); in generate()
491 for service in services { in compile()
492 generator.generate(service); in compile()
496 let out_file = out_dir.join(format!("{}.{}.rs", service.package, service.name)); in compile()
|
| /tonic/tonic-health/src/ |
| H A D | server.rs | 24 let server = HealthServer::new(service); in health_reporter()
226 let resp = service in test_service_check()
228 service: "".to_string(), in test_service_check()
236 let resp = service in test_service_check()
245 let resp = service in test_service_check()
247 service: "TestService".to_string(), in test_service_check()
258 let resp = service in test_service_check()
273 let resp = service in test_service_watch()
275 service: "".to_string(), in test_service_watch()
288 let resp = service in test_service_watch()
[all …]
|
| /tonic/tonic/src/client/ |
| H A D | mod.rs | 20 mod service; module
23 pub use self::service::GrpcService;
|
| /tonic/tonic-health/proto/ |
| H A D | health.proto | 29 string service = 1; field
42 service Health {
43 // If the requested service is unknown, the call will fail with status
47 // Performs a watch for the serving status of the requested service.
50 // the service's serving status changes.
52 // If the requested service is unknown when the call is received, the
55 // future point, the serving status of the service becomes known, the
56 // server will send a new message with the service's serving status.
|
| /tonic/tonic/src/server/ |
| H A D | mod.rs | 12 mod service; module
15 pub use self::service::{
|
| H A D | grpc.rs | 221 mut service: S, in unary()
246 let response = service in unary()
264 mut service: S, in server_streaming()
290 let response = service.call(request).await; in server_streaming()
305 mut service: S, in client_streaming()
320 let response = service in client_streaming()
338 mut service: S, in streaming()
354 let response = service.call(request).await; in streaming()
|
| /tonic/tonic-reflection/tests/ |
| H A D | versions.rs | 26 services.service, in test_v1()
50 services.service, in test_v1alpha()
70 let service = Builder::configure().build_v1().unwrap(); in make_v1_request() localVariable
73 .add_service(service) in make_v1_request()
127 let service = Builder::configure().build_v1alpha().unwrap(); in make_v1alpha_request() localVariable
130 .add_service(service) in make_v1alpha_request()
|
| /tonic/tonic-reflection/proto/ |
| H A D | reflection_v1alpha.proto | 21 service ServerReflection {
22 // The reflection service is structured as a bidirectional stream, ensuring
31 // To use reflection service, the client should set one of the following
40 // (e.g. <package>.<service>[.<method>] or <package>.<type>).
50 // reflection service will implement this method, and it's not guaranteed
82 // The reflection service is allowed to avoid sending FileDescriptorProtos
118 // The information of each service may be expanded in the future, so we use
120 repeated ServiceResponse service = 1; field
123 // The information of a single service used by ListServiceResponse to answer
126 // Full name of a registered service, including its package name. The format
[all …]
|
| H A D | reflection_v1.proto | 31 service ServerReflection {
32 // The reflection service is structured as a bidirectional stream, ensuring
41 // To use reflection service, the client should set one of the following
50 // (e.g. <package>.<service>[.<method>] or <package>.<type>).
60 // reflection service will implement this method, and it's not guaranteed
92 // The reflection service is allowed to avoid sending FileDescriptorProtos
128 // The information of each service may be expanded in the future, so we use
130 repeated ServiceResponse service = 1; field
133 // The information of a single service used by ListServiceResponse to answer
136 // Full name of a registered service, including its package name. The format
[all …]
|
| /tonic/tests/integration_tests/proto/ |
| H A D | test.proto | 5 service Test {
12 service Test1 {
|
| /tonic/examples/src/tower/ |
| H A D | client.rs | 3 use service::AuthSvc;
18 .layer(tonic::service::InterceptorLayer::new(intercept)) in main()
20 .service(channel); in main()
41 mod service { module
|
| /tonic/examples/proto/attrs/ |
| H A D | attrs.proto | 15 // Echo is the echo service.
16 service Echo {
|
| /tonic/examples/src/health/ |
| H A D | README.md | 5 …e crate to set up a HealthServer that will run alongside the application service. In order to test…
11 ./grpc_health_probe -addr=[::1]:50051 -service=helloworld.Greeter
16 will show the change in health status of the service over time.
|
| /tonic/tonic-web/src/ |
| H A D | lib.rs | 76 pub use service::{GrpcWebService, ResponseFuture};
81 mod service; module
|
| /tonic/interop/proto/grpc/testing/ |
| H A D | test.proto | 15 // An integration test service that covers all the method signature permutations
25 // A simple service to test the various types of RPCs and experiment with
27 service TestService {
67 // A simple service NOT implemented at servers so clients can test for
69 service UnimplementedService {
74 // A service used to control reconnect server.
75 service ReconnectService {
|
| /tonic/tests/ambiguous_methods/proto/ |
| H A D | ambiguous_methods.proto | 11 service HelloService {
16 service HelloStreamingService {
|
| /tonic/tonic/src/service/ |
| H A D | layered.rs | 42 fn named_layer<S>(&self, service: S) -> Layered<L::Service, S> in named_layer()
48 fn named_layer<S>(&self, service: S) -> Layered<<L>::Service, S> in named_layer()
53 inner: self.layer(service), in named_layer()
|
| /tonic/tests/disable_comments/proto/ |
| H A D | test.proto | 6 service Service1 {
14 service Service2 {
|
| /tonic/examples/src/compression/ |
| H A D | server.rs | 36 let service = GreeterServer::new(greeter) in main() localVariable
40 Server::builder().add_service(service).serve(addr).await?; in main()
|
| /tonic/tonic-types/proto/ |
| H A D | error_details.proto | 57 // a service could respond with a QuotaFailure detail containing the project
59 // calling project hasn't enabled the service in the developer console, then
60 // a service could respond with the project id and set `service_disabled`
75 // description to find more about the quota configuration in the service's
97 // "service": "pubsub.googleapis.com"
121 // is typically the registered service name of the tool or product that
142 // acknowledged, it could list the terms of service violation in the
147 // The type of PreconditionFailure. We recommend using a service-specific
154 // which terms of service is being referenced.
160 // For example: "Terms of service not accepted".
[all …]
|