| /tonic/tonic/src/ |
| H A D | extensions.rs | 4 service: &'a str, 5 method: &'a str, 11 pub fn new(service: &'a str, method: &'a str) -> Self { in new() argument 16 pub fn service(&self) -> &str { in service() argument 20 pub fn method(&self) -> &str { in method() argument
|
| /tonic/tonic-build/src/ |
| H A D | prost.rs | 106 fn name(&self) -> &str { in name() argument 110 fn package(&self) -> &str { in package() argument 114 fn identifier(&self) -> &str { in identifier() argument 130 fn name(&self) -> &str { in name() argument 169 proto_path: &str, in request_response_name() argument 172 let convert_type = |proto_type: &str, rust_type: &str| -> TokenStream { in request_response_name() 398 pub fn message_attribute<P: AsRef<str>, A: AsRef<str>>( in message_attribute() argument 434 S: AsRef<str>, in btree_map() argument 454 S: AsRef<str>, in bytes() argument 466 pub fn server_mod_attribute<P: AsRef<str>, A: AsRef<str>>( in server_mod_attribute() argument [all …]
|
| H A D | lib.rs | 105 type Comment: AsRef<str>; 111 fn name(&self) -> &str; in name() argument 113 fn package(&self) -> &str; in package() argument 115 fn identifier(&self) -> &str; in identifier() argument 130 type Comment: AsRef<str>; 133 fn name(&self) -> &str; in name() argument 135 fn identifier(&self) -> &str; in identifier() argument 137 fn codec_path(&self) -> &str; in codec_path() argument 151 proto_path: &str, in request_response_name() argument 229 name: &str, in generate_attributes() argument [all …]
|
| H A D | manual.rs | 74 pub fn name(mut self, name: impl AsRef<str>) -> Self { in name() 83 pub fn package(mut self, package: impl AsRef<str>) -> Self { in package() 89 pub fn comment(mut self, comment: impl AsRef<str>) -> Self { in comment() 138 fn name(&self) -> &str { in name() argument 142 fn package(&self) -> &str { in package() argument 146 fn identifier(&self) -> &str { in identifier() argument 192 fn name(&self) -> &str { in name() argument 196 fn identifier(&self) -> &str { in identifier() argument 200 fn codec_path(&self) -> &str { in codec_path() argument 222 _proto_path: &str, in request_response_name() argument [all …]
|
| H A D | code_gen.rs | 78 pub fn generate_client(&self, service: &impl Service, proto_path: &str) -> TokenStream { in generate_client() 94 pub fn generate_server(&self, service: &impl Service, proto_path: &str) -> TokenStream { in generate_server()
|
| H A D | server.rs | 16 proto_path: &str, in generate_internal() argument 200 proto_path: &str, in generate_trait() argument 233 proto_path: &str, in generate_trait_methods() argument 355 fn generate_named(server_service: &syn::Ident, service_name: &str) -> TokenStream { in generate_named() 361 pub const SERVICE_NAME: &str = #service_name; in generate_named() 364 const NAME: &'static str = SERVICE_NAME; in generate_named() 372 proto_path: &str, in generate_methods() argument 437 proto_path: &str, in generate_unary() argument 495 proto_path: &str, in generate_server_streaming() argument 562 proto_path: &str, in generate_client_streaming() argument [all …]
|
| H A D | client.rs | 14 proto_path: &str, in generate_internal() argument 170 proto_path: &str, in generate_methods() argument 225 proto_path: &str, in generate_unary() argument 256 proto_path: &str, in generate_server_streaming() argument 287 proto_path: &str, in generate_client_streaming() argument 318 proto_path: &str, in generate_streaming() argument
|
| /tonic/tonic/src/metadata/ |
| H A D | key.rs | 7 use std::str::FromStr; 102 pub fn from_static(src: &'static str) -> Self { in from_static() 118 pub fn as_str(&self) -> &str { in as_str() argument 150 impl<VE: ValueEncoding> AsRef<str> for MetadataKey<VE> { 151 fn as_ref(&self) -> &str { in as_ref() argument 162 impl<VE: ValueEncoding> Borrow<str> for MetadataKey<VE> { 163 fn borrow(&self) -> &str { in borrow() argument 214 impl<VE: ValueEncoding> PartialEq<str> for MetadataKey<VE> { 229 fn eq(&self, other: &str) -> bool { in eq() 234 impl<VE: ValueEncoding> PartialEq<MetadataKey<VE>> for str { implementation [all …]
|
| H A D | encoding.rs | 32 fn from_static(value: &'static str) -> HeaderValue; in from_static() 52 fn is_valid_key(key: &str) -> bool; in is_valid_key() 93 fn from_static(value: &'static str) -> HeaderValue { in from_static() 115 fn is_valid_key(key: &str) -> bool { in is_valid_key() 140 fn from_static(value: &'static str) -> HeaderValue { in from_static() 184 fn is_valid_key(key: &str) -> bool { in is_valid_key()
|
| H A D | value.rs | 11 use std::str::FromStr; 71 pub fn from_static(src: &'static str) -> Self { in from_static() 343 impl<'a> TryFrom<&'a str> for MetadataValue<Ascii> { 347 fn try_from(s: &'a str) -> Result<Self, Self::Error> { in try_from() 432 pub fn to_str(&self) -> Result<&str, ToStrError> { in to_str() argument 656 impl<VE: ValueEncoding> PartialEq<str> for MetadataValue<VE> { 658 fn eq(&self, other: &str) -> bool { in eq() 670 impl<VE: ValueEncoding> PartialOrd<str> for MetadataValue<VE> { 684 impl<VE: ValueEncoding> PartialEq<MetadataValue<VE>> for str { implementation 698 impl<VE: ValueEncoding> PartialOrd<MetadataValue<VE>> for str { implementation [all …]
|
| /tonic/tonic/src/service/ |
| H A D | layered.rs | 19 const NAME: &'static str = T::NAME; variable 71 const TEST_SERVICE_NAME: &str = "test-service-name"; 74 const NAME: &'static str = TEST_SERVICE_NAME; variable 78 fn get_name_of_named_service<S: NamedService>(_s: &S) -> &'static str { in get_name_of_named_service() argument
|
| /tonic/tonic-reflection/src/server/ |
| H A D | mod.rs | 194 prefix: &str, in process_message() argument 223 prefix: &str, in process_enum() argument 240 prefix: &str, in process_field() argument 252 fn symbol_by_name(&self, symbol: &str) -> Result<Vec<u8>, Status> { in symbol_by_name() 266 fn file_by_filename(&self, filename: &str) -> Result<Vec<u8>, Status> { in file_by_filename() 282 prefix: &str, in extract_name() argument 283 name_type: &str, in extract_name() argument
|
| /tonic/codegen/src/ |
| H A D | main.rs | 69 iface_files: &[&str], in codegen() argument 70 include_dirs: &[&str], in codegen() argument 114 const GENERATED_COMMENT: &str = "// This file is @generated by codegen."; in write_fds()
|
| /tonic/interop/src/ |
| H A D | lib.rs | 55 description: &'static str, 58 description: &'static str, 59 expression: &'static str,
|
| /tonic/tonic/src/server/ |
| H A D | mod.rs | 25 const NAME: &'static str; variable
|
| /tonic/tonic/src/codec/ |
| H A D | compression.rs | 11 pub(crate) const ENCODING_HEADER: &str = "grpc-encoding"; 12 pub(crate) const ACCEPT_ENCODING_HEADER: &str = "grpc-accept-encoding"; 160 match std::str::from_utf8(other) { in from_encoding_header() 182 pub(crate) fn as_str(self) -> &'static str { in as_str() argument 205 fn split_by_comma(s: &str) -> impl Iterator<Item = &str> { in split_by_comma()
|
| /tonic/tonic/src/transport/channel/ |
| H A D | endpoint.rs | 12 use std::{fmt, future::Future, net::IpAddr, pin::Pin, str::FromStr, time::Duration}; 71 pub fn from_static(s: &'static str) -> Self { in from_static() 488 impl TryFrom<&'static str> for Endpoint { 491 fn try_from(t: &'static str) -> Result<Self, Self::Error> { in try_from() 505 fn from_str(s: &str) -> Result<Self, Self::Err> { in from_str()
|
| /tonic/tests/web/tests/ |
| H A D | grpc_web.rs | 111 fn build_request(base_uri: String, content_type: &str, accept: &str) -> Request<Body> { in build_request() argument 138 async fn decode_body(body: Incoming, content_type: &str) -> (Output, Bytes) { in decode_body()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | status.rs | 70 const MESSAGE: &str = "Internal error, see metadata for details"; in status_with_metadata() 72 const ASCII_NAME: &str = "x-host-ip"; in status_with_metadata() 73 const ASCII_VALUE: &str = "127.0.0.1"; in status_with_metadata() 75 const BINARY_NAME: &str = "x-host-name-bin"; in status_with_metadata()
|
| /tonic/examples/src/gcp/ |
| H A D | client.rs | 12 const ENDPOINT: &str = "https://pubsub.googleapis.com";
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 38 pub fn as_str_name(&self) -> &'static str { in as_str_name() argument 47 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> { in from_str_name() 455 pub const SERVICE_NAME: &str = "grpc.health.v1.Health"; 457 const NAME: &'static str = SERVICE_NAME; variable
|
| /tonic/tonic-web/src/ |
| H A D | call.rs | 21 pub(crate) const GRPC_WEB: &str = "application/grpc-web"; 22 pub(crate) const GRPC_WEB_PROTO: &str = "application/grpc-web+proto"; 23 pub(crate) const GRPC_WEB_TEXT: &str = "application/grpc-web-text"; 24 pub(crate) const GRPC_WEB_TEXT_PROTO: &str = "application/grpc-web-text+proto"; 33 fn content_type(headers: &HeaderMap) -> Option<&str> { in content_type() argument 360 pub(crate) fn to_content_type(self) -> &'static str { in to_content_type() argument
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | user_agent.rs | 5 const TONIC_USER_AGENT: &str = concat!("tonic/", env!("CARGO_PKG_VERSION"));
|
| /tonic/tonic/src/transport/ |
| H A D | error.rs | 50 fn description(&self) -> &str { in description() argument
|
| /tonic/tonic-health/src/ |
| H A D | server.rs | 75 S: AsRef<str>, in set_service_status() 94 pub async fn clear_service_status(&mut self, service_name: &str) { in clear_service_status() argument 111 async fn service_health(&self, service_name: &str) -> Option<ServingStatus> { in service_health()
|