| /tonic/tonic/src/transport/channel/ |
| H A D | endpoint.rs | 19 pub struct Endpoint { struct
43 impl Endpoint { argument
124 Endpoint { in origin()
147 Endpoint { in timeout()
164 Endpoint { in connect_timeout()
179 Endpoint { in tcp_keepalive()
193 Endpoint { in concurrency_limit()
208 Endpoint { in rate_limit()
221 Endpoint { in initial_stream_window_size()
231 Endpoint { in initial_connection_window_size()
[all …]
|
| H A D | mod.rs | 9 pub use endpoint::Endpoint;
79 pub fn builder(uri: Uri) -> Endpoint { in builder() argument
80 Endpoint::from(uri) in builder()
89 pub fn from_static(s: &'static str) -> Endpoint { in from_static() argument
100 pub fn from_shared(s: impl Into<Bytes>) -> Result<Endpoint, InvalidUri> { in from_shared() argument
109 pub fn balance_list(list: impl Iterator<Item = Endpoint>) -> Self { in balance_list()
122 pub fn balance_channel<K>(capacity: usize) -> (Self, Sender<Change<K, Endpoint>>) in balance_channel()
137 ) -> (Self, Sender<Change<K, Endpoint>>) in balance_channel_with_executor()
150 pub fn new<C>(connector: C, endpoint: Endpoint) -> Self in new()
171 pub async fn connect<C>(connector: C, endpoint: Endpoint) -> Result<Self, super::Error> in connect()
|
| /tonic/examples/src/interceptor/ |
| H A D | client.rs | 6 transport::{Channel, Endpoint},
16 let channel = Endpoint::from_static("http://[::1]:50051") in main()
53 let channel = Endpoint::from_static("http://[::1]:50051") in using_named_interceptor()
67 let channel = Endpoint::from_static("http://[::1]:50051") in using_function_pointer_interceptro()
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | discover.rs | 1 use super::super::{Connection, Endpoint};
22 changes: Receiver<Change<K, Endpoint>>,
26 pub(crate) fn new(changes: Receiver<Change<K, Endpoint>>) -> Self { in new()
|
| H A D | connection.rs | 4 transport::{channel::BoxFuture, service::GrpcTimeout, Endpoint},
28 fn new<C>(connector: C, endpoint: Endpoint, is_lazy: bool) -> Self in new() argument
82 endpoint: Endpoint, in connect() argument
93 pub(crate) fn lazy<C>(connector: C, endpoint: Endpoint) -> Self in lazy()
|
| /tonic/examples/src/dynamic_load_balance/ |
| H A D | client.rs | 8 use tonic::transport::Endpoint;
17 let e1 = Endpoint::from_static("http://[::1]:50051"); in main()
18 let e2 = Endpoint::from_static("http://[::1]:50052"); in main()
50 let e3 = Endpoint::from_static("http://[::1]:50051"); in main()
|
| /tonic/examples/src/multiplex/ |
| H A D | client.rs | 11 use tonic::transport::Endpoint;
15 let channel = Endpoint::from_static("http://[::1]:50051") in main()
|
| /tonic/examples/src/uds/ |
| H A D | client.rs | 11 use tonic::transport::{Endpoint, Uri};
21 let channel = Endpoint::try_from("http://[::]:50051")? in main()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | connect_info.rs | 7 Endpoint, Server,
45 let channel = Endpoint::from_shared(format!("http://{addr}")) in getting_connect_info()
71 transport::{server::UdsConnectInfo, Endpoint, Server, Uri},
118 let channel = Endpoint::try_from("http://[::]:50051") in getting_connect_info()
|
| H A D | user_agent.rs | 5 transport::{server::TcpIncoming, Endpoint, Server},
41 let channel = Endpoint::from_shared(format!("http://{addr}")) in writes_user_agent_header()
|
| H A D | interceptor.rs | 5 transport::{server::TcpIncoming, Endpoint, Server},
39 let channel = Endpoint::from_shared(format!("http://{addr}")) in interceptor_retrieves_grpc_method()
|
| H A D | http2_max_header_list_size.rs | 6 transport::{Endpoint, Server},
51 let channel = Endpoint::from_shared(addr) in test_http_max_header_list_size_and_long_errors()
|
| H A D | client_layer.rs | 6 transport::{server::TcpIncoming, Endpoint, Server},
42 let channel = Endpoint::from_shared(format!("http://{addr}")) in connect_supports_standard_tower_layers()
|
| H A D | connection.rs | 6 transport::{server::TcpIncoming, Endpoint, Server},
79 let channel = Endpoint::from_static("http://127.0.0.1:0").connect_lazy(); in connect_lazy_reconnects_after_first_failure()
99 let channel = Endpoint::from_shared(format!("http://{addr}")) in connect_lazy_reconnects_after_first_failure()
|
| H A D | extensions.rs | 13 transport::{server::TcpIncoming, Endpoint, Server},
56 let channel = Endpoint::from_shared(format!("http://{addr}")) in setting_extension_from_interceptor()
105 let channel = Endpoint::from_shared(format!("http://{addr}")) in setting_extension_from_tower()
|
| H A D | origin.rs | 10 transport::{server::TcpIncoming, Endpoint, Server},
49 let channel = Endpoint::from_shared(format!("http://{addr}")) in writes_origin_header()
|
| H A D | routes_builder.rs | 13 transport::{Endpoint, Server},
74 let channel = Endpoint::from_shared(format!("http://{addr}")) in multiple_service_using_routes_builder()
|
| H A D | max_message_size.rs | 10 transport::{Endpoint, Server},
160 let channel = Endpoint::try_from("http://[::]:50051") in response_stream_limit()
326 let channel = Endpoint::try_from("http://[::]:50051") in max_message_run()
|
| /tonic/examples/src/mock/ |
| H A D | mock.rs | 3 transport::{Endpoint, Server, Uri},
34 let channel = Endpoint::try_from("http://[::]:50051")? in main()
|
| /tonic/tonic/src/transport/ |
| H A D | mod.rs | 103 pub use self::channel::{Channel, Endpoint};
|
| /tonic/interop/src/bin/ |
| H A D | client.rs | 3 use tonic::transport::Endpoint;
35 let mut endpoint = Endpoint::try_from(format!("{}://localhost:10000", scheme))? in main()
|
| /tonic/tonic-reflection/tests/ |
| H A D | versions.rs | 85 let conn = tonic::transport::Endpoint::new(local_addr) in make_v1_request()
142 let conn = tonic::transport::Endpoint::new(local_addr) in make_v1alpha_request()
|
| /tonic/tonic-health/ |
| H A D | README.md | 12 let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
|
| /tonic/examples/src/blocking/ |
| H A D | client.rs | 24 D: TryInto<tonic::transport::Endpoint>, in connect() argument
|
| /tonic/tonic/benches-disabled/benchmarks/compiled_protos/ |
| H A D | helloworld.rs | 25 D: TryInto<tonic::transport::Endpoint>, in connect() argument
28 let conn = tonic::transport::Endpoint::new(dst)?.connect().await?; in connect()
|