-
Notifications
You must be signed in to change notification settings - Fork 272
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
9 changed files
with
94 additions
and
262 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,113 +1,39 @@ | ||
| use crate::apollo_router::{ApolloPreparedQuery, ApolloRouter}; | ||
| use crate::configuration::Configuration; | ||
| use crate::http_service_registry::HttpServiceRegistry; | ||
| use apollo_router_core::prelude::{graphql::*, *}; | ||
| use futures::prelude::*; | ||
| use apollo_router_core::prelude::*; | ||
| use std::sync::Arc; | ||
|
|
||
| /// Factory for creating graphs. | ||
| /// | ||
| /// This trait enables us to test that `StateMachine` correctly recreates the ApolloRouter when | ||
| /// necessary e.g. when schema changes. | ||
| //#[cfg_attr(test, automock)] | ||
| #[async_trait::async_trait] | ||
| pub(crate) trait RouterFactory<Router, PreparedQuery> | ||
| where | ||
| Router: graphql::Router<PreparedQuery>, | ||
| PreparedQuery: graphql::PreparedQuery, | ||
| { | ||
| fn create( | ||
| async fn create( | ||
| &self, | ||
| configuration: &Configuration, | ||
| schema: Arc<graphql::Schema>, | ||
| plan_cache_limit: usize, | ||
| query_cache_limit: usize, | ||
| ) -> future::BoxFuture<'static, Router>; | ||
| fn recreate( | ||
| &self, | ||
| router: Arc<Router>, | ||
| configuration: &Configuration, | ||
| schema: Arc<graphql::Schema>, | ||
| plan_cache_limit: usize, | ||
| query_cache_limit: usize, | ||
| ) -> future::BoxFuture<'static, Router>; | ||
| fn get_plan_cache_limit(&self) -> usize; | ||
| fn get_query_cache_limit(&self) -> usize; | ||
| previous_router: Option<Arc<Router>>, | ||
| ) -> Router; | ||
| } | ||
|
|
||
| #[derive(Default)] | ||
| pub(crate) struct ApolloRouterFactory { | ||
| plan_cache_limit: usize, | ||
| query_cache_limit: usize, | ||
| } | ||
| impl ApolloRouterFactory { | ||
| pub fn new(plan_cache_limit: usize, query_cache_limit: usize) -> Self { | ||
| Self { | ||
| plan_cache_limit, | ||
| query_cache_limit, | ||
| } | ||
| } | ||
| } | ||
| pub(crate) struct ApolloRouterFactory {} | ||
|
|
||
| #[async_trait::async_trait] | ||
| impl RouterFactory<ApolloRouter, ApolloPreparedQuery> for ApolloRouterFactory { | ||
| fn create( | ||
| async fn create( | ||
| &self, | ||
| configuration: &Configuration, | ||
| schema: Arc<graphql::Schema>, | ||
| plan_cache_limit: usize, | ||
| query_cache_limit: usize, | ||
| ) -> future::BoxFuture<'static, ApolloRouter> { | ||
| previous_router: Option<Arc<ApolloRouter>>, | ||
| ) -> ApolloRouter { | ||
| let service_registry = HttpServiceRegistry::new(configuration); | ||
| tokio::task::spawn_blocking(move || { | ||
| ApolloRouter::new( | ||
| Arc::new( | ||
| graphql::RouterBridgeQueryPlanner::new(Arc::clone(&schema)) | ||
| .with_caching(plan_cache_limit), | ||
| ), | ||
| Arc::new(service_registry), | ||
| schema, | ||
| query_cache_limit, | ||
| ) | ||
| }) | ||
| .map(|res| res.expect("ApolloRouter::new() is infallible; qed")) | ||
| .boxed() | ||
| } | ||
|
|
||
| fn recreate( | ||
| &self, | ||
| router: Arc<ApolloRouter>, | ||
| configuration: &Configuration, | ||
| schema: Arc<graphql::Schema>, | ||
| plan_cache_limit: usize, | ||
| query_cache_limit: usize, | ||
| ) -> future::BoxFuture<'static, ApolloRouter> { | ||
| let factory = self.create(configuration, schema, plan_cache_limit, query_cache_limit); | ||
|
|
||
| Box::pin(async move { | ||
| // Use the "hot" entries in the supplied router to pre-populate | ||
| // our new router | ||
| let new_router = factory.await; | ||
| let hot_keys = router.get_query_planner().get_hot_keys().await; | ||
| // It would be nice to get these keys concurrently by spawning | ||
| // futures in our loop. However, these calls to get call the | ||
| // v8 based query planner and running too many of these | ||
| // concurrently is a bad idea. One for the future... | ||
| for key in hot_keys { | ||
| // We can ignore errors, since we are just warming up the | ||
| // cache | ||
| let _ = new_router | ||
| .get_query_planner() | ||
| .get(key.0, key.1, key.2) | ||
| .await; | ||
| } | ||
| new_router | ||
| }) | ||
| } | ||
|
|
||
| fn get_plan_cache_limit(&self) -> usize { | ||
| self.plan_cache_limit | ||
| } | ||
|
|
||
| fn get_query_cache_limit(&self) -> usize { | ||
| self.query_cache_limit | ||
| ApolloRouter::new(Arc::new(service_registry), schema, previous_router).await | ||
| } | ||
| } |
Oops, something went wrong.