Skip to content

Commit

Permalink
logging
Browse files Browse the repository at this point in the history
  • Loading branch information
joyc-bq committed Jan 6, 2025
1 parent 63a5924 commit 7b58ef1
Show file tree
Hide file tree
Showing 5 changed files with 1 addition and 6 deletions.
1 change: 0 additions & 1 deletion common/lib/pg_client_wrapper.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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<string>(["notifyHostListChanged"].concat(SubscribedMethodHelper.NETWORK_BOUND_METHODS));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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<string, Array<WeakRef<ClientWrapper>>> = new Map<string, Array<WeakRef<ClientWrapper>>>();
Expand Down
2 changes: 1 addition & 1 deletion common/lib/plugins/failover/reader_failover_handler.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
1 change: 0 additions & 1 deletion pg/lib/client.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit 7b58ef1

Please sign in to comment.