Home
last modified time | relevance | path

Searched refs:endpoint (Results 1 – 7 of 7) sorted by relevance

/tonic/tonic/src/transport/channel/service/
H A Dconnection.rs28 fn new<C>(connector: C, endpoint: Endpoint, is_lazy: bool) -> Self in new()
38 .keep_alive_interval(endpoint.http2_keep_alive_interval) in new()
42 if let Some(val) = endpoint.http2_keep_alive_timeout { in new()
46 if let Some(val) = endpoint.http2_keep_alive_while_idle { in new()
50 if let Some(val) = endpoint.http2_adaptive_window { in new()
54 if let Some(val) = endpoint.http2_max_header_list_size { in new()
60 let origin = endpoint.origin.as_ref().unwrap_or(&endpoint.uri).clone(); in new()
65 .layer_fn(|s| GrpcTimeout::new(s, endpoint.timeout)) in new()
82 endpoint: Endpoint, in connect()
90 Self::new(connector, endpoint, false).ready_oneshot().await in connect()
[all …]
H A Ddiscover.rs38 Change::Insert(k, endpoint) => { in poll_next()
39 let connection = Connection::lazy(endpoint.http_connector(), endpoint); in poll_next()
/tonic/tonic/src/transport/channel/
H A Dmod.rs3 mod endpoint; module
9 pub use endpoint::Endpoint;
111 list.for_each(|endpoint| { in balance_list()
112 tx.try_send(Change::Insert(endpoint.uri.clone(), endpoint)) in balance_list()
150 pub fn new<C>(connector: C, endpoint: Endpoint) -> Self in new()
157 let buffer_size = endpoint.buffer_size.unwrap_or(DEFAULT_BUFFER_SIZE); in new()
158 let executor = endpoint.executor.clone(); in new()
160 let svc = Connection::lazy(connector, endpoint); in new()
178 let buffer_size = endpoint.buffer_size.unwrap_or(DEFAULT_BUFFER_SIZE); in connect()
179 let executor = endpoint.executor.clone(); in connect()
[all …]
/tonic/interop/src/bin/
H A Dclient.rs35 let mut endpoint = Endpoint::try_from(format!("{}://localhost:10000", scheme))? in main() localVariable
42 endpoint = endpoint.tls_config( in main()
49 let channel = endpoint.connect().await?; in main()
/tonic/tonic-types/
H A DREADME.md33 // Inside a gRPC server endpoint that returns `Result<Response<T>, Status>`
79 // Where `req_result` was returned by a gRPC client endpoint method
/tonic/examples/proto/googleapis/google/pubsub/v1/
H A Dpubsub.proto128 // subscription, pushes to the endpoint will stop.
525 // an empty `PushConfig`) or vice versa, or change the endpoint URL and other
673 // the call to the push endpoint.
742 // the endpoint will not be made.
812 // Configuration for a push delivery endpoint.
830 // Note: if not specified, the Push endpoint URL will be used.
834 // A URL locating the endpoint to which messages should be pushed.
835 // For example, a Webhook endpoint might use `https://example.com/push`.
843 // indicates the version of the data expected by the endpoint. This
/tonic/examples/proto/googleapis/google/api/
H A Dhttp.proto272 // `HttpRule` that maps the gRPC method to a REST endpoint, achieving the same