Method decode

gateway/src/kv/mod.rs:391–400

(&self, key: &str)

impl GetPutCodec for NodeState {
    fn decode<T: for<'de> serde::Deserialize<'de>>(&self, key: &str) -> Option<T> {
        self.get(key)
            .and_then(|entry| match decode(entry.value.as_ref()?) {
                Ok(value) => Some(value),
                Err(e) => {
                    warn!("failed to decode value for key {key}: {e:?}");
                    None
                }
            })
    }

    fn put_encoded<T: serde::Serialize>(&mut self, key: String, value: &T) -> Result<()> {
        self.put(key.clone(), encode(value)?)