feat: failover2 (#363)

Author: sophia-bq

common/lib/connection_plugin_chain_builder.ts

@@ -26,6 +26,7 @@ import { ExecuteTimePluginFactory } from "./plugins/execute_time_plugin_factory"
 import { ConnectTimePluginFactory } from "./plugins/connect_time_plugin_factory";
 import { AwsSecretsManagerPluginFactory } from "./authentication/aws_secrets_manager_plugin_factory";
 import { FailoverPluginFactory } from "./plugins/failover/failover_plugin_factory";
+import { Failover2PluginFactory } from "./plugins/failover2/failover2_plugin_factory";
 import { StaleDnsPluginFactory } from "./plugins/stale_dns/stale_dns_plugin_factory";
 import { FederatedAuthPluginFactory } from "./plugins/federated_auth/federated_auth_plugin_factory";
 import { ReadWriteSplittingPluginFactory } from "./plugins/read_write_splitting_plugin_factory";
@@ -58,6 +59,7 @@ export class ConnectionPluginChainBuilder {
     ["staleDns", { factory: StaleDnsPluginFactory, weight: 500 }],
     ["readWriteSplitting", { factory: ReadWriteSplittingPluginFactory, weight: 600 }],
     ["failover", { factory: FailoverPluginFactory, weight: 700 }],
+    ["failover2", { factory: Failover2PluginFactory, weight: 710 }],
     ["efm", { factory: HostMonitoringPluginFactory, weight: 800 }],
     ["fastestResponseStrategy", { factory: FastestResponseStrategyPluginFactory, weight: 900 }],
     ["limitless", { factory: LimitlessConnectionPluginFactory, weight: 950 }],
@@ -76,6 +78,7 @@ export class ConnectionPluginChainBuilder {
     [StaleDnsPluginFactory, 500],
     [ReadWriteSplittingPluginFactory, 600],
     [FailoverPluginFactory, 700],
+    [Failover2PluginFactory, 710],
     [HostMonitoringPluginFactory, 800],
     [LimitlessConnectionPluginFactory, 950],
     [IamAuthenticationPluginFactory, 1000],

common/lib/host_list_provider/connection_string_host_list_provider.ts

@@ -14,7 +14,6 @@
   limitations under the License.
 */
 
-import { AwsClient } from "../aws_client";
 import { HostAvailability } from "../host_availability/host_availability";
 import { HostInfo } from "../host_info";
 import { HostListProviderService } from "../host_list_provider_service";

common/lib/host_list_provider/host_list_provider.ts

@@ -23,6 +23,10 @@ export type DynamicHostListProvider = HostListProvider;
 
 export type StaticHostListProvider = HostListProvider;
 
+export interface BlockingHostListProvider extends HostListProvider {
+  forceMonitoringRefresh(shouldVerifyWriter: boolean, timeoutMs: number): Promise<HostInfo[]>;
+}
+
 export interface HostListProvider {
   refresh(): Promise<HostInfo[]>;