diff --git a/common/lib/pg_client_wrapper.ts b/common/lib/pg_client_wrapper.ts index 2f1169ab..8989315e 100644 --- a/common/lib/pg_client_wrapper.ts +++ b/common/lib/pg_client_wrapper.ts @@ -17,7 +17,6 @@ import { ClientWrapper } from "./client_wrapper"; import { HostInfo } from "./host_info"; import { uniqueId } from "../logutils"; -import { logTopology } from "./utils/utils"; /* This an internal wrapper class for a target community driver client created by the NodePostgresPgDriverDialect. diff --git a/common/lib/plugins/connection_tracker/aurora_connection_tracker_plugin.ts b/common/lib/plugins/connection_tracker/aurora_connection_tracker_plugin.ts index b2abacb2..85c42d94 100644 --- a/common/lib/plugins/connection_tracker/aurora_connection_tracker_plugin.ts +++ b/common/lib/plugins/connection_tracker/aurora_connection_tracker_plugin.ts @@ -26,8 +26,6 @@ import { FailoverError } from "../../utils/errors"; import { HostChangeOptions } from "../../host_change_options"; import { HostRole } from "../../host_role"; import { OpenedConnectionTracker } from "./opened_connection_tracker"; -import { logger } from "../../../logutils"; -import { logTopology } from "../../utils/utils"; export class AuroraConnectionTrackerPlugin extends AbstractConnectionPlugin implements CanReleaseResources { private static readonly subscribedMethods = new Set(["notifyHostListChanged"].concat(SubscribedMethodHelper.NETWORK_BOUND_METHODS)); diff --git a/common/lib/plugins/connection_tracker/opened_connection_tracker.ts b/common/lib/plugins/connection_tracker/opened_connection_tracker.ts index cb3594b8..7e9ac9c8 100644 --- a/common/lib/plugins/connection_tracker/opened_connection_tracker.ts +++ b/common/lib/plugins/connection_tracker/opened_connection_tracker.ts @@ -21,7 +21,6 @@ import { logger } from "../../../logutils"; import { MapUtils } from "../../utils/map_utils"; import { Messages } from "../../utils/messages"; import { PluginService } from "../../plugin_service"; -import { logTopology } from "../../utils/utils"; export class OpenedConnectionTracker { static readonly openedConnections: Map>> = new Map>>(); diff --git a/common/lib/plugins/failover/reader_failover_handler.ts b/common/lib/plugins/failover/reader_failover_handler.ts index 5a27d10d..7fb10c29 100644 --- a/common/lib/plugins/failover/reader_failover_handler.ts +++ b/common/lib/plugins/failover/reader_failover_handler.ts @@ -316,7 +316,7 @@ class ConnectionAttemptTask { try { this.targetClient = await this.pluginService.forceConnect(this.newHost, copy); - // ensure that new connection is a connection to a reader node + // Ensure that new connection is a connection to a reader host try { if ((await this.pluginService.getHostRole(this.targetClient)) === HostRole.READER) { return this.targetClient; diff --git a/pg/lib/client.ts b/pg/lib/client.ts index 77d0eb5f..4ba7e53a 100644 --- a/pg/lib/client.ts +++ b/pg/lib/client.ts @@ -29,7 +29,6 @@ import { RdsMultiAZPgDatabaseDialect } from "./dialect/rds_multi_az_pg_database_ import { HostInfo } from "../../common/lib/host_info"; import { TelemetryTraceLevel } from "../../common/lib/utils/telemetry/telemetry_trace_level"; import { NodePostgresDriverDialect } from "./dialect/node_postgres_driver_dialect"; -import { logTopology } from "../../common/lib/utils/utils"; import { TransactionIsolationLevel } from "../../common/lib/utils/transaction_isolation_level"; export class AwsPGClient extends AwsClient {