Searched refs:K (Results 1 – 4 of 4) sorted by relevance
| /tonic/tonic/src/transport/channel/service/ |
| H A D | discover.rs | 14 pub enum Change<K, V> {
16 Insert(K, V),
18 Remove(K),
21 pub(crate) struct DynamicServiceStream<K: Hash + Eq + Clone> {
22 changes: Receiver<Change<K, Endpoint>>,
25 impl<K: Hash + Eq + Clone> DynamicServiceStream<K> {
26 pub(crate) fn new(changes: Receiver<Change<K, Endpoint>>) -> Self { in new() argument
31 impl<K: Hash + Eq + Clone> Stream for DynamicServiceStream<K> {
32 type Item = Result<TowerChange<K, Connection>, crate::BoxError>;
48 impl<K: Hash + Eq + Clone> Unpin for DynamicServiceStream<K> {}
|
| /tonic/tonic/src/metadata/ |
| H A D | map.rs | 468 pub fn get<K>(&self, key: K) -> Option<&MetadataValue<Ascii>> in get()
504 pub fn get_bin<K>(&self, key: K) -> Option<&MetadataValue<Binary>> in get_bin()
542 pub fn get_mut<K>(&mut self, key: K) -> Option<&mut MetadataValue<Ascii>> in get_mut()
622 pub fn get_all<K>(&self, key: K) -> GetAll<'_, Ascii> in get_all()
665 pub fn get_all_bin<K>(&self, key: K) -> GetAll<'_, Binary> in get_all_bin()
695 pub fn contains_key<K>(&self, key: K) -> bool in contains_key()
951 key: K, in generic_entry() argument
1054 key: K, in insert_bin() argument
1106 pub fn append<K>(&mut self, key: K, value: MetadataValue<Ascii>) -> bool in append() argument
1187 pub fn remove<K>(&mut self, key: K) -> Option<MetadataValue<Ascii>> in remove()
[all …]
|
| /tonic/tonic/src/transport/channel/ |
| H A D | mod.rs | 122 pub fn balance_channel<K>(capacity: usize) -> (Self, Sender<Change<K, Endpoint>>) in balance_channel() argument
124 K: Hash + Eq + Send + Clone + 'static, in balance_channel()
134 pub fn balance_channel_with_executor<K, E>( in balance_channel_with_executor() argument
137 ) -> (Self, Sender<Change<K, Endpoint>>) in balance_channel_with_executor() argument
139 K: Hash + Eq + Send + Clone + 'static, in balance_channel_with_executor()
|
| /tonic/examples/data/gcp/ |
| H A D | roots.pem | 779 +jjeRFcV5fiMyNlI4g0WJx0eyIOFJbe6qlVBzAMiSy2RjYvmia9mx+n/K+k8rNrS
1011 8n/Uqgr/Qh037ZTlZFkSIHc40zI+OIF1lnP6aI+xy84fxez6nH7PfrHxBy22/L/K
|