| /tonic/tonic-build/src/ |
| H A D | client.rs | 180 if method.deprecated() { in generate_methods() 184 let method = match (method.client_streaming(), method.server_streaming()) { in generate_methods() localVariable 187 method, in generate_methods() 194 method, in generate_methods() 201 method, in generate_methods() 208 method, in generate_methods() 215 stream.extend(method); in generate_methods() 223 method: &T::Method, in generate_unary() 254 method: &T::Method, in generate_server_streaming() 285 method: &T::Method, in generate_client_streaming() [all …]
|
| H A D | server.rs | 260 let method = match ( in generate_trait_methods() localVariable 349 stream.extend(method); in generate_trait_methods() 387 method, in generate_methods() 396 method, in generate_methods() 405 method, in generate_methods() 414 method, in generate_methods() 424 let method = quote! { in generate_methods() localVariable 436 method: &T, in generate_unary() 494 method: &T, in generate_server_streaming() 561 method: &T, in generate_client_streaming() [all …]
|
| H A D | lib.rs | 211 fn format_method_path<T: Service>(service: &T, method: &T::Method, emit_package: bool) -> String { in format_method_path() 215 method.identifier() in format_method_path() 219 fn format_method_name<T: Service>(service: &T, method: &T::Method, emit_package: bool) -> String { in format_method_name() 223 method.identifier() in format_method_name()
|
| H A D | manual.rs | 95 pub fn method(mut self, method: Method) -> Self { in method() method 96 self.methods.push(method); in method()
|
| /tonic/tonic/src/ |
| H A D | extensions.rs | 5 method: &'a str, field 11 pub fn new(service: &'a str, method: &'a str) -> Self { in new() 12 Self { service, method } in new() 20 pub fn method(&self) -> &str { in method() method 21 self.method in method()
|
| H A D | request.rs | 177 method: http::Method, in into_http() 184 *request.method_mut() = method; in into_http()
|
| /tonic/examples/proto/googleapis/google/api/ |
| H A D | client.proto | 28 // A definition of a client library method signature. 32 // Normally, this method receives a single argument (a struct or instance 34 // add one or more overloads providing flattened or simpler method signatures 37 // The fields on the method signature are provided as a comma-separated 47 // Would add the following Java overload (in addition to the method accepting 54 // * Adding this annotation to an unannotated method is backwards 56 // * Adding this annotation to a method which already has existing 57 // method signature annotations is backwards compatible if and only if 58 // the new method signature annotation is last in the sequence. 59 // * Modifying or removing an existing method signature annotation is [all …]
|
| H A D | http.proto | 27 // [HttpRule][google.api.HttpRule], each specifying the mapping of an RPC method 46 // gRPC Transcoding is a feature for mapping between a gRPC method and one or 59 // typically specified as an `google.api.http` annotation on the gRPC method. 61 // Each mapping specifies a URL path template and an HTTP method. The path 125 // specifies the mapping. Consider a REST update method on the 153 // the update method: 272 // `HttpRule` that maps the gRPC method to a REST endpoint, achieving the same 282 // # Selects a gRPC method and applies HttpRule to it. 314 // Selects a method to which this rule applies. 339 // The custom pattern is used for specifying an HTTP method that is not [all …]
|
| /tonic/tonic-web/src/ |
| H A D | service.rs | 32 method: &'a Method, 61 match RequestKind::new(req.headers(), req.method(), req.version()) { in call() 72 method: &Method::POST, in call() 90 debug!(kind = "simple", error="method not allowed", method = ?req.method()); in call() 190 fn new(headers: &'a HeaderMap, method: &'a Method, version: Version) -> Self { in new() 193 method, in new() 293 .method(Method::POST) in request() 332 for method in &[ in only_post_and_options_allowed() 340 *req.method_mut() = method.clone(); in only_post_and_options_allowed() 348 method in only_post_and_options_allowed() [all …]
|
| /tonic/tonic-reflection/proto/ |
| H A D | reflection_v1alpha.proto | 28 // The message sent by the client when calling ServerReflectionInfo method. 40 // (e.g. <package>.<service>[.<method>] or <package>.<type>). 49 // Its corresponding method is best-effort: it's not guaranteed that the 50 // reflection service will implement this method, and it's not guaranteed 51 // that this method will provide all extensions. Returns 71 // The message sent by the server to answer ServerReflectionInfo method.
|
| H A D | reflection_v1.proto | 38 // The message sent by the client when calling ServerReflectionInfo method. 50 // (e.g. <package>.<service>[.<method>] or <package>.<type>). 59 // Its corresponding method is best-effort: it's not guaranteed that the 60 // reflection service will implement this method, and it's not guaranteed 61 // that this method will provide all extensions. Returns 81 // The message sent by the server to answer ServerReflectionInfo method.
|
| /tonic/examples/proto/googleapis/google/pubsub/v1/ |
| H A D | schema.proto | 128 // Request for the CreateSchema method. 167 // Request for the GetSchema method. 182 // Request for the `ListSchemas` method. 207 // Response for the `ListSchemas` method. 217 // Request for the `DeleteSchema` method. 227 // Request for the `ValidateSchema` method. 242 // Response for the `ValidateSchema` method. 245 // Request for the `ValidateMessage` method. 275 // Response for the `ValidateMessage` method.
|
| H A D | pubsub.proto | 241 // Request for the GetTopic method. 251 // Request for the UpdateTopic method. 265 // Request for the Publish method. 278 // Response for the `Publish` method. 286 // Request for the `ListTopics` method. 306 // Response for the `ListTopics` method. 986 // Request for the `Pull` method. 1013 // Response for the `Pull` method. 1047 // Request for the Acknowledge method. 1232 // Request for the GetSnapshot method. [all …]
|
| /tonic/tonic/src/service/ |
| H A D | interceptor.rs | 136 let method = req.method().clone(); in call() localVariable 148 let req = req.into_http(uri, method, version, SanitizeHeaders::No); in call() 332 assert_eq!(request.method(), http::Method::OPTIONS); in doesnt_change_http_method() 340 .method(http::Method::OPTIONS) in doesnt_change_http_method()
|
| /tonic/tests/ambiguous_methods/proto/ |
| H A D | ambiguous_methods.proto | 9 // with the same method names from Arc,
|
| /tonic/examples/ |
| H A D | build.rs | 56 .method( in build_json_codec_service()
|
| H A D | routeguide-tutorial.md | 84 Our first step is to define the gRPC *service* and the method *request* and *response* types using 105 types. gRPC lets you define four kinds of service method, all of which are used in the `RouteGuide` 117 no more messages. As you can see in our example, you specify a server-side streaming method by 129 all and return its response. You specify a client-side streaming method by placing the `stream` 142 this type of method by placing the `stream` keyword before both the request and the response. 428 Now let's look at something a little more complicated: the client-side streaming method 430 with information about their trip. As you can see, this time the method receives a 624 Calling the simple RPC `get_feature` is as straightforward as calling a local method: 640 We call the `get_feature` client method, passing a single `Point` value wrapped in a 681 We use the `message()` method from the `tonic::Streaming` struct to repeatedly read in the [all …]
|
| /tonic/tonic-reflection/src/server/ |
| H A D | mod.rs | 182 for method in &service.method { in process_file() 183 let method_name = extract_name(&service_name, "method", method.name.as_ref())?; in process_file()
|
| /tonic/tonic-health/proto/ |
| H A D | health.proto | 37 SERVICE_UNKNOWN = 3; // Used only by the Watch method. 59 // should assume this method is not supported and should not retry the
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 358 let method = CheckSvc(inner); in call() localVariable 369 let res = grpc.unary(method, req).await; in call() 404 let method = WatchSvc(inner); in call() localVariable 415 let res = grpc.server_streaming(method, req).await; in call()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | interceptor.rs | 48 assert_eq!(gm.method(), "UnaryCall"); in interceptor_retrieves_grpc_method()
|
| /tonic/tonic/benches-disabled/benchmarks/compiled_protos/ |
| H A D | helloworld.rs | 149 let method = SayHello(inner); in call() localVariable 152 let res = grpc.unary(method, req).await; in call()
|
| /tonic/interop/proto/grpc/testing/ |
| H A D | test.proto | 15 // An integration test service that covers all the method signature permutations 62 // The test server will not implement this method. It will be used
|
| /tonic/tests/web/tests/ |
| H A D | grpc_web.rs | 127 .method(Method::POST) in build_request()
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 406 let method = ServerReflectionInfoSvc(inner); in call() localVariable 417 let res = grpc.streaming(method, req).await; in call()
|