Home
last modified time | relevance | path

Searched refs:a (Results 1 – 25 of 79) sorted by relevance

1234

/tonic/tonic/src/
H A Dextensions.rs3 pub struct GrpcMethod<'a> {
4 service: &'a str,
5 method: &'a str,
8 impl<'a> GrpcMethod<'a> {
11 pub fn new(service: &'a str, method: &'a str) -> Self { in new()
/tonic/tonic/src/metadata/
H A Dmap.rs1235 impl<'a> Iterator for Iter<'a> {
1262 impl<'a> Iterator for IterMut<'a> {
1305 impl<'a> Iterator for Keys<'a> {
1327 impl<'a> Iterator for Values<'a> {
1348 impl<'a> Iterator for ValuesMut<'a> {
1434 impl<'a, VE: ValueEncoding> Entry<'a, VE> {
1539 impl<'a, VE: ValueEncoding> VacantEntry<'a, VE> {
1935 impl<'a, 'b: 'a, VE: ValueEncoding> IntoIterator for &'b OccupiedEntry<'a, VE> {
1944 impl<'a, 'b: 'a, VE: ValueEncoding> IntoIterator for &'b mut OccupiedEntry<'a, VE> {
1955 impl<'a, VE: ValueEncoding> GetAll<'a, VE> {
[all …]
H A Dencoding.rs38 fn equals(a: &HeaderValue, b: &[u8]) -> bool; in equals()
41 fn values_equal(a: &HeaderValue, b: &HeaderValue) -> bool; in values_equal()
101 fn equals(a: &HeaderValue, b: &[u8]) -> bool { in equals()
102 a.as_bytes() == b in equals()
105 fn values_equal(a: &HeaderValue, b: &HeaderValue) -> bool { in values_equal()
106 a == b in values_equal()
158 fn equals(a: &HeaderValue, b: &[u8]) -> bool { in equals()
162 a.as_bytes() == b in equals()
166 fn values_equal(a: &HeaderValue, b: &HeaderValue) -> bool { in values_equal()
167 match (Self::decode(a.as_bytes()), Self::decode(b.as_bytes())) { in values_equal()
[all …]
H A Dkey.rs187 impl<'a, VE: ValueEncoding> From<&'a MetadataKey<VE>> for MetadataKey<VE> {
188 fn from(src: &'a MetadataKey<VE>) -> MetadataKey<VE> { in from()
200 impl<'a, VE: ValueEncoding> PartialEq<&'a MetadataKey<VE>> for MetadataKey<VE> {
202 fn eq(&self, other: &&'a MetadataKey<VE>) -> bool { in eq()
254 impl<'a, VE: ValueEncoding> PartialEq<&'a str> for MetadataKey<VE> {
258 fn eq(&self, other: &&'a str) -> bool { in eq()
H A Dvalue.rs343 impl<'a> TryFrom<&'a str> for MetadataValue<Ascii> {
347 fn try_from(s: &'a str) -> Result<Self, Self::Error> { in try_from()
358 impl<'a> TryFrom<&'a String> for MetadataValue<Ascii> {
362 fn try_from(s: &'a String) -> Result<Self, Self::Error> { in try_from()
589 impl<'a, VE: ValueEncoding> From<&'a MetadataValue<VE>> for MetadataValue<VE> {
591 fn from(t: &'a MetadataValue<VE>) -> Self { in from()
754 impl<'a, VE: ValueEncoding, T: ?Sized> PartialEq<&'a T> for MetadataValue<VE>
759 fn eq(&self, other: &&'a T) -> bool { in eq()
764 impl<'a, VE: ValueEncoding, T: ?Sized> PartialOrd<&'a T> for MetadataValue<VE>
769 fn partial_cmp(&self, other: &&'a T) -> Option<cmp::Ordering> { in partial_cmp()
/tonic/tonic/src/codec/
H A Dbuffer.rs6 pub struct DecodeBuf<'a> {
7 buf: &'a mut BytesMut,
13 pub struct EncodeBuf<'a> {
14 buf: &'a mut BytesMut,
17 impl<'a> DecodeBuf<'a> {
18 pub(crate) fn new(buf: &'a mut BytesMut, len: usize) -> Self { in new()
55 impl<'a> EncodeBuf<'a> {
56 pub(crate) fn new(buf: &'a mut BytesMut) -> Self { in new()
/tonic/examples/proto/routeguide/
H A Droute_guide.proto5 // You may obtain a copy of the License at
27 // Obtains the feature at a given position.
36 // streamed rather than returned at once (e.g. in a response message with a
37 // repeated field), as the rectangle may cover a large area and contain a
43 // Accepts a stream of Points on a route being traversed, returning a
49 // Accepts a stream of RouteNotes sent while a route is being traversed,
73 // A feature names something at a given point.
75 // If a feature could not be named, the name is empty.
84 // A RouteNote is a message sent while at a given point.
93 // A RouteSummary is received in response to a RecordRoute rpc.
/tonic/examples/
H A Drouteguide-tutorial.md6 - Define a service in a `.proto` file.
96 To define a service, you specify a named `service` in your `.proto` file:
121 // streamed rather than returned at once (e.g. in a response message with a
122 // repeated field), as the rectangle may cover a large area and contain a
132 // Accepts a stream of Points on a route being traversed, returning a
144 // Accepts a stream of RouteNotes sent while a route is being traversed,
368 All our service methods receive a `tonic::Request<T>` and return a
421 We create a channel and spawn a new asynchronous task where we perform a lookup, sending
565 <a name="client"></a>
678 As in the simple RPC, we pass a single value request. However, instead of getting a
[all …]
H A Dhelloworld-tutorial.md11 [rustup] is a convenient tool to install it, if you haven't already.
17 For this tutorial, we will start by creating a new Rust project with Cargo:
34 [protocol buffers]. We will keep our `.proto` files in a directory in our project's root.
43 … supported by Tonic. For this tutorial we will only use a simple RPC, if you would like to see a T…
54 …l be using in our application. An RPC contains an Identifier, a Request type, and returns a Respon…
127 At the root of your project (not /src), create a `build.rs` file and add the following code:
167 println!("Got a request: {:?}", request);
216 println!("Got a request: {:?}", request);
242 If you have a gRPC GUI client such as [Bloom RPC] you should be able to send requests to the server…
260 …a running gRPC server, and that's great but how can our application communicate with it? This is w…
[all …]
/tonic/
H A DCONTRIBUTING.md39 have uncovered a bug in a `tonic` crate, creating a new issue in the
43 supporting details (a test case that demonstrates a bug), providing
65 ### Submitting a Bug Report
74 evaluate the report is a description of the behavior you are seeing and a simple
86 ### Triaging a Bug Report
90 including whether the behavior being seen is a bug or a feature. This discussion
152 The type level example for `tokio_timer::Timeout` provides a good example of a
187 easiest way to execute a future from a test.
283 From within GitHub, opening a new Pull Request will present you with a
335 ### Review a bit at a time.
[all …]
H A DREADME.md3 A rust implementation of [gRPC], a high performance, open source, general
6 …a gRPC over HTTP/2 implementation focused on high performance, interoperability, and flexibility. …
19 implementation and any encoding via a set of generic traits. The HTTP/2 implementation is based on …
20 a fast HTTP/1.1 and HTTP/2 client and server built on top of the robust [`tokio`] stack. The codegen
36 - The [`helloworld`][helloworld-tutorial] tutorial provides a basic example of using `tonic`, perfe…
37 - The [`routeguide`][routeguide-tutorial] tutorial provides a complete example of using `tonic` and…
40 may be a good resource as it shows examples of many of the gRPC features.
76 you! We have a [contributing guide][guide] to help you get involved in the Tonic
/tonic/tonic-types/proto/
H A Derror_details.proto5 // You may obtain a copy of the License at
54 // Describes how a quota check failed.
57 // a service could respond with a QuotaFailure detail containing the project
66 // A message type used to describe a single quota violation. For example, a
67 // daily quota or a custom quota that was exceeded.
104 // instance in a region that is out of stock:
135 // instances that can be created in a single (batch) request.
171 // A message type used to describe a single bad request field.
173 // A path leading to a field in the request body. The value will be a
182 // Describes all violations in a client request.
[all …]
/tonic/examples/proto/googleapis/google/api/
H A Dfield_behavior.proto5 // You may obtain a copy of the License at
43 // An indicator of the behavior of a given field (for example, that a field
53 // Specifically denotes a field as optional.
58 // Denotes a field as required.
63 // Denotes a field as output only.
65 // field in a request does nothing (the server *must* ignore it and
66 // *must not* throw an error as a result of the field's presence).
69 // Denotes a field as input only.
74 // Denotes a field as immutable.
75 // This indicates that the field may be set once in a request to create a
[all …]
H A Dhttp.proto5 // You may obtain a copy of the License at
46 // gRPC Transcoding is a feature for mapping between a gRPC method and one or
63 // as each field is a non-repeated field with a primitive (non-message) type.
109 // This enables a HTTP JSON to RPC mapping as below:
118 // primitive type or a repeated primitive type or a non-repeated message type.
121 // message is mapped to a separate parameter, such as
122 // `...?foo.a=A&foo.b=B&foo.c=C`.
247 // `"{var=*}"`, when such a variable is expanded into a URL path on the client
255 // or `"{var=**}"`, when such a variable is expanded into a URL path on the
266 // for configuring a gRPC service to become a user-facing product. The
[all …]
H A Dclient.proto5 // You may obtain a copy of the License at
28 // A definition of a client library method signature.
32 // Normally, this method receives a single argument (a struct or instance
37 // The fields on the method signature are provided as a comma-separated
56 // * Adding this annotation to a method which already has existing
60 // a breaking change.
61 // * Re-ordering existing method signature annotations is a breaking
88 // If there is more than one scope, use a comma-separated string:
H A Dresource.proto5 // You may obtain a copy of the License at
29 // An annotation that describes a resource reference, see
35 // An annotation that describes a resource definition without a corresponding
41 // An annotation that describes a resource definition, see
46 // A simple descriptor of a resource type.
48 // ResourceDescriptor annotates a resource message (either by means of a
55 // // Indicates this message defines a resource schema.
171 // A flag representing a specific style that a resource claims to conform to.
257 // These indicate that a resource is expected to conform to a given
262 // Defines a proto annotation that describes a string field that refers to
[all …]
/tonic/examples/proto/googleapis/google/pubsub/v1/
H A Dpubsub.proto39 // messages to a topic.
114 // does not exist. After a topic is deleted, a new topic may be created with
223 // subscriber that receives a `PubsubMessage` via a `Pull` call or a push
301 // a continuation of a prior `ListTopics` call, and that the system should
329 // that this is a continuation of a prior `ListTopicSubscriptions` call, and
360 // that this is a continuation of a prior `ListTopicSnapshots` call, and
411 // Creates a subscription to a given topic. See the [resource name rules]
538 // <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a>
586 // <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a>
604 // are immediately dropped. After a snapshot is deleted, a new one may be
[all …]
H A Dschema.proto5 // You may obtain a copy of the License at
44 // Creates a schema.
53 // Gets a schema.
61 // Lists schemas in a project.
69 // Deletes a schema.
77 // Validates a schema.
86 // Validates a message against a schema.
123 // the full definition of the schema that is a valid schema definition of
142 // by CreateSchema will have a `name` made using the given `parent` and
202 // this is a continuation of a prior `ListSchemas` call, and that the
[all …]
/tonic/examples/data/gcp/
H A Droots.pem177 # SHA1 Fingerprint: d1:cb:ca:5d:b2:d5:2a:7f:69:3b:67:4d:e5:f0:5a:1d:0c:95:7d:f0
276 # SHA256 Fingerprint: 96:0a:df:00:63:e9:63:56:75:0c:29:65:dd:0a:08:67:da:0b:9c:bd:6e:77:71:4a:ea:fb…
422 # MD5 Fingerprint: e4:a6:8a:c8:54:ac:52:42:46:0a:fd:72:48:1b:2a:44
424 …6 Fingerprint: cb:3c:cb:b7:60:31:e5:e0:13:8f:8d:d3:9a:23:f9:de:47:ff:c3:5e:43:c1:14:4c:ea:27:d4:6a…
642 # MD5 Fingerprint: 4b:e2:c9:91:96:65:0c:f4:0e:5a:93:92:a0:0a:fe:b2
739 # MD5 Fingerprint: 42:65:ca:be:01:9a:9a:4c:a9:8c:41:49:cd:c0:d5:7f
741 # SHA256 Fingerprint: 0a:81:ec:5a:92:97:77:f1:45:90:4a:f3:8d:5d:50:9f:66:b5:e2:c5:8f:cd:b5:31:05:8b…
915 # SHA256 Fingerprint: 2c:ab:ea:fe:37:d0:6c:a2:2a:ba:73:91:c0:03:3d:25:98:29:52:c4:53:64:73:49:76:3a…
957 # MD5 Fingerprint: 80:3a:bc:22:c1:e6:fb:8d:9b:3b:27:4a:32:1b:9a:01
1021 # MD5 Fingerprint: 32:4a:4b:bb:c8:63:69:9b:be:74:9a:c6:dd:1d:46:24
[all …]
/tonic/tonic-reflection/proto/
H A Dreflection_v1alpha.proto5 // You may obtain a copy of the License at
22 // The reflection service is structured as a bidirectional stream, ensuring
23 // all related requests go to a single server.
35 // Find a proto file by the file name.
39 // This field should be a fully-qualified symbol name
53 // This field should be a fully-qualified type name. The format is
80 // As the repeated label is not allowed in oneof fields, we use a
98 // a file_by_filename, file_containing_symbol, or file_containing_extension
101 // Serialized FileDescriptorProto messages. We avoid taking a dependency on
123 // The information of a single service used by ListServiceResponse to answer
[all …]
H A Dreflection_v1.proto5 // You may obtain a copy of the License at
32 // The reflection service is structured as a bidirectional stream, ensuring
33 // all related requests go to a single server.
45 // Find a proto file by the file name.
49 // This field should be a fully-qualified symbol name
63 // This field should be a fully-qualified type name. The format is
90 // As the repeated label is not allowed in oneof fields, we use a
108 // a file_by_filename, file_containing_symbol, or file_containing_extension
111 // Serialized FileDescriptorProto messages. We avoid taking a dependency on
133 // The information of a single service used by ListServiceResponse to answer
[all …]
/tonic/tonic-health/proto/
H A Dhealth.proto5 // You may obtain a copy of the License at
47 // Performs a watch for the serving status of the requested service.
48 // The server will immediately send back a message indicating the current
49 // serving status. It will then subsequently send a new message whenever
53 // server will send a message setting the serving status to
56 // server will send a new message with the service's serving status.
/tonic/examples/src/load_balance/
H A Dclient.rs12 .map(|a| Channel::from_static(a)); in main()
/tonic/tonic-types/
H A DREADME.md7 with [`tonic`] in a convenient way.
15 be used on the server side to create a status with error details, which can then
17 [`tonic::Status`] that can be used by a tonic client to extract error details,
22 The examples bellow cover a basic use case of the [gRPC Richer Error Model].
33 // Inside a gRPC server endpoint that returns `Result<Response<T>, Status>`
79 // Where `req_result` was returned by a gRPC client endpoint method
120 client. For example, using [`StatusExt::get_details_bad_request`] is a
121 more direct way of extracting a [`BadRequest`] error message from
/tonic/examples/src/health/
H A DREADME.md3 gRPC has a [health checking protocol](https://github.com/grpc/grpc/blob/master/doc/health-checking.…
5 This example uses the crate to set up a HealthServer that will run alongside the application servic…

1234