| /tonic/examples/src/load_balance/ |
| H A D | client.rs | 6 use tonic::transport::Channel;
12 .map(|a| Channel::from_static(a)); in main()
14 let channel = Channel::balance_list(endpoints); in main()
|
| /tonic/examples/src/tower/ |
| H A D | client.rs | 6 use tonic::{transport::Channel, Request, Status};
14 let channel = Channel::from_static("http://[::1]:50051").connect().await?; in main()
47 use tonic::transport::Channel;
51 inner: Channel,
55 pub fn new(inner: Channel) -> Self { in new()
|
| /tonic/examples/src/streaming/ |
| H A D | client.rs | 7 use tonic::transport::Channel;
17 async fn streaming_echo(client: &mut EchoClient<Channel>, num: usize) { in streaming_echo() argument
34 async fn bidirectional_streaming_echo(client: &mut EchoClient<Channel>, num: usize) { in bidirectional_streaming_echo() argument
50 async fn bidirectional_streaming_echo_throttle(client: &mut EchoClient<Channel>, dur: Duration) { in bidirectional_streaming_echo_throttle() argument
|
| /tonic/tonic/src/transport/channel/ |
| H A D | endpoint.rs | 4 use super::Channel;
350 pub async fn connect(&self) -> Result<Channel, Error> { in connect() argument
351 Channel::connect(self.http_connector(), self.clone()).await in connect()
358 pub fn connect_lazy(&self) -> Channel { in connect_lazy() argument
359 Channel::new(self.http_connector(), self.clone()) in connect_lazy()
369 pub async fn connect_with_connector<C>(&self, connector: C) -> Result<Channel, Error> in connect_with_connector() argument
381 Channel::connect(connector, self.clone()).await in connect_with_connector()
383 Channel::connect(connector, self.clone()).await in connect_with_connector()
394 pub fn connect_with_connector_lazy<C>(&self, connector: C) -> Channel in connect_with_connector_lazy()
405 Channel::new(connector, self.clone()) in connect_with_connector_lazy()
[all …]
|
| H A D | mod.rs | 66 pub struct Channel { struct
77 impl Channel { implementation
165 Channel { svc } in new()
187 Ok(Channel { svc }) in connect()
203 Channel { svc } in balance()
207 impl Service<http::Request<Body>> for Channel { implementation
233 impl fmt::Debug for Channel { implementation
|
| /tonic/examples/src/interceptor/ |
| H A D | client.rs | 6 transport::{Channel, Endpoint},
57 let client: GreeterClient<InterceptedService<Channel, MyInterceptor>> = in using_named_interceptor()
72 InterceptedService<Channel, fn(tonic::Request<()>) -> Result<tonic::Request<()>, Status>>, in using_function_pointer_interceptro()
|
| /tonic/examples/src/compression/ |
| H A D | client.rs | 4 use tonic::transport::Channel;
12 let channel = Channel::builder("http://[::1]:50051".parse().unwrap()) in main()
|
| /tonic/examples/src/authentication/ |
| H A D | client.rs | 6 use tonic::{metadata::MetadataValue, transport::Channel, Request};
10 let channel = Channel::from_static("http://[::1]:50051").connect().await?; in main()
|
| /tonic/examples/src/routeguide/ |
| H A D | client.rs | 7 use tonic::transport::Channel;
17 async fn print_features(client: &mut RouteGuideClient<Channel>) -> Result<(), Box<dyn Error>> { in print_features()
41 async fn run_record_route(client: &mut RouteGuideClient<Channel>) -> Result<(), Box<dyn Error>> { in run_record_route()
61 async fn run_route_chat(client: &mut RouteGuideClient<Channel>) -> Result<(), Box<dyn Error>> { in run_route_chat()
|
| /tonic/examples/src/tls/ |
| H A D | client.rs | 6 use tonic::transport::{Certificate, Channel, ClientTlsConfig};
18 let channel = Channel::from_static("https://[::1]:50051") in main()
|
| /tonic/examples/src/tls_client_auth/ |
| H A D | client.rs | 6 use tonic::transport::{Certificate, Channel, ClientTlsConfig, Identity};
22 let channel = Channel::from_static("https://[::1]:50051") in main()
|
| /tonic/examples/src/gcp/ |
| H A D | client.rs | 8 transport::{Certificate, Channel, ClientTlsConfig},
34 let channel = Channel::from_static(ENDPOINT) in main()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | http2_keep_alive.rs | 6 use tonic::transport::{server::TcpIncoming, Channel, Server};
68 let channel = Channel::from_shared(format!("http://{addr}")) in http2_keepalive_does_not_cause_panics_on_client_side()
|
| /tonic/tonic/src/transport/ |
| H A D | mod.rs | 103 pub use self::channel::{Channel, Endpoint};
|
| /tonic/examples/src/dynamic_load_balance/ |
| H A D | client.rs | 7 use tonic::transport::Channel;
20 let (channel, rx) = Channel::balance_channel(10); in main()
|
| /tonic/examples/src/blocking/ |
| H A D | client.rs | 17 client: GreeterClient<tonic::transport::Channel>,
|
| /tonic/tests/compression/src/ |
| H A D | util.rs | 18 use tonic::transport::{server::Connected, Channel};
136 pub async fn mock_io_channel(client: tokio::io::DuplexStream) -> Channel { in mock_io_channel() argument
|
| H A D | lib.rs | 15 transport::{Channel, Endpoint, Server, Uri},
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 9 use tonic::transport::{Channel, Error, Server};
126 type Client = TestClient<Channel>;
|
| /tonic/interop/src/ |
| H A D | client.rs | 7 use tonic::transport::Channel;
10 pub type TestClient = TestServiceClient<Channel>;
11 pub type UnimplementedClient = UnimplementedServiceClient<Channel>;
|
| /tonic/tonic/benches-disabled/benchmarks/compiled_protos/ |
| H A D | helloworld.rs | 21 impl GreeterClient<tonic::transport::Channel> {
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 142 impl #service_ident<tonic::transport::Channel> { in generate_connect()
|
| /tonic/examples/ |
| H A D | routeguide-tutorial.md | 648 use tonic::transport::Channel;
653 async fn print_features(client: &mut RouteGuideClient<Channel>) -> Result<(), Box<dyn Error>> {
695 async fn run_record_route(client: &mut RouteGuideClient<Channel>) -> Result<(), Box<dyn Error>> {
744 async fn run_route_chat(client: &mut RouteGuideClient<Channel>) -> Result<(), Box<dyn Error>> {
|
| /tonic/ |
| H A D | CHANGELOG.md | 299 * **transport:** support customizing `Channel`'s async executor ([#935](https://github.com/hyperium…
491 * **transport:** Return connection error on `Channel::connect` ([#413](https://github.com/hyperium/…
|