MCPcopy Create free account
hub / github.com/Dstack-TEE/dstack / iter_decoded

Method iter_decoded

gateway/src/kv/mod.rs:408–422  ·  view source on GitHub ↗
(
        &self,
        prefix: &str,
    )

Source from the content-addressed store, hash-verified

406 }
407
408 fn iter_decoded<T: for<'de> serde::Deserialize<'de>>(
409 &self,
410 prefix: &str,
411 ) -> impl Iterator<Item = (String, T)> {
412 self.iter_by_prefix(prefix).filter_map(|(key, entry)| {
413 let value = match decode(entry.value.as_ref()?) {
414 Ok(value) => value,
415 Err(e) => {
416 warn!("failed to decode value for key {key}: {e:?}");
417 return None;
418 }
419 };
420 Some((key.to_string(), value))
421 })
422 }
423
424 fn iter_decoded_values<T: for<'de> serde::Deserialize<'de>>(
425 &self,

Callers 6

load_all_instancesMethod · 0.80
load_all_nodesMethod · 0.80
get_all_peer_addrsMethod · 0.80

Calls 2

decodeFunction · 0.85
as_refMethod · 0.45

Tested by

no test coverage detected