Home
last modified time | relevance | path

Searched refs:service_name (Results 1 – 5 of 5) sorted by relevance

/tonic/tonic-health/src/
H A Dserver.rs55 let service_name = <S as NamedService>::NAME; in set_serving() localVariable
56 self.set_service_status(service_name, ServingStatus::Serving) in set_serving()
66 let service_name = <S as NamedService>::NAME; in set_not_serving() localVariable
67 self.set_service_status(service_name, ServingStatus::NotServing) in set_not_serving()
77 let service_name = service_name.as_ref(); in set_service_status() localVariable
79 match writer.get(service_name) { in set_service_status()
94 pub async fn clear_service_status(&mut self, service_name: &str) { in clear_service_status()
96 let _ = writer.remove(service_name); in clear_service_status()
113 reader.get(service_name).map(|p| *p.1.borrow()) in service_health()
123 let service_name = request.get_ref().service.as_str(); in check() localVariable
[all …]
/tonic/tonic-build/src/
H A Dclient.rs33 let service_name = format_service_name(service, emit_package); in generate_internal() localVariable
35 let service_doc = if disable_comments.contains(&service_name) { in generate_internal()
42 let struct_attributes = attributes.for_struct(&service_name); in generate_internal()
231 let service_name = format_service_name(service, emit_package); in generate_unary() localVariable
246 req.extensions_mut().insert(GrpcMethod::new(#service_name, #method_name)); in generate_unary()
262 let service_name = format_service_name(service, emit_package); in generate_server_streaming() localVariable
277 req.extensions_mut().insert(GrpcMethod::new(#service_name, #method_name)); in generate_server_streaming()
293 let service_name = format_service_name(service, emit_package); in generate_client_streaming() localVariable
308 req.extensions_mut().insert(GrpcMethod::new(#service_name, #method_name)); in generate_client_streaming()
324 let service_name = format_service_name(service, emit_package); in generate_streaming() localVariable
[all …]
H A Dserver.rs47 let service_name = format_service_name(service, emit_package); in generate_internal() localVariable
49 let service_doc = if disable_comments.contains(&service_name) { in generate_internal()
55 let named = generate_named(&server_service, &service_name); in generate_internal()
57 let struct_attributes = attributes.for_struct(&service_name); in generate_internal()
355 fn generate_named(server_service: &syn::Ident, service_name: &str) -> TokenStream { in generate_named()
356 let service_name = syn::LitStr::new(service_name, proc_macro2::Span::call_site()); in generate_named() localVariable
361 pub const SERVICE_NAME: &str = #service_name; in generate_named()
/tonic/tonic-reflection/src/server/
H A Dmod.rs176 let service_name = extract_name(prefix, "service", service.name.as_ref())?; in process_file() localVariable
178 self.service_names.push(service_name.clone()); in process_file()
180 self.symbols.insert(service_name.clone(), fd.clone()); in process_file()
183 let method_name = extract_name(&service_name, "method", method.name.as_ref())?; in process_file()
/tonic/examples/proto/googleapis/google/api/
H A Dresource.proto188 // {service_name}/{resource_type_kind}. The `resource_type_kind` must be