apollo_router/plugins/connectors/
mod.rs

1pub(crate) mod configuration;
2pub(crate) mod handle_responses;
3pub(crate) mod incompatible;
4pub(crate) mod make_requests;
5pub(crate) mod plugin;
6pub(crate) mod query_plans;
7pub(crate) mod request_limit;
8pub(crate) mod tracing;
9
10#[cfg(test)]
11pub(crate) mod tests;
12
13use apollo_federation::connectors::runtime::inputs::ContextReader;
14
15impl ContextReader for &crate::Context {
16    fn get_key(&self, key: &str) -> Option<serde_json_bytes::Value> {
17        match self.get::<&str, serde_json_bytes::Value>(key) {
18            Ok(Some(value)) => Some(value.clone()),
19            _ => None,
20        }
21    }
22}