Searched refs:Change (Results 1 – 6 of 6) sorted by relevance
| /tonic/tonic/src/transport/channel/service/ |
| H A D | discover.rs | 10 use tower::discover::Change as TowerChange;
14 pub enum Change<K, V> { enum
22 changes: Receiver<Change<K, Endpoint>>,
26 pub(crate) fn new(changes: Receiver<Change<K, Endpoint>>) -> Self { in new()
38 Change::Insert(k, endpoint) => { in poll_next()
42 Change::Remove(k) => Poll::Ready(Some(Ok(TowerChange::Remove(k)))), in poll_next()
|
| H A D | mod.rs | 14 pub use self::discover::Change;
|
| /tonic/examples/src/dynamic_load_balance/ |
| H A D | client.rs | 6 use tonic::transport::channel::Change;
28 let change = Change::Insert("1", e1); in main()
33 let change = Change::Insert("2", e2); in main()
38 let change = Change::Remove("1"); in main()
44 let change = Change::Remove("2"); in main()
51 let change = Change::Insert("3", e3); in main()
57 let change = Change::Remove("3"); in main()
|
| /tonic/tonic/src/transport/channel/ |
| H A D | mod.rs | 8 pub use self::service::Change;
112 tx.try_send(Change::Insert(endpoint.uri.clone(), endpoint)) 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()
|
| /tonic/examples/ |
| H A D | routeguide-tutorial.md | 45 Change your current directory to Tonic's repository root:
|
| /tonic/ |
| H A D | CHANGELOG.md | 660 * **transport:** Change channel connect to be async ([#107](https://github.com/hyperium/tonic/issue…
|