wrapper props

aws · Feb 7, 2025 · 0411cf2 · 0411cf2
1 parent 00ad731
commit 0411cf2
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 4 deletions.
diff --git a/common/lib/plugins/efm/monitor.ts b/common/lib/plugins/efm/monitor.ts
@@ -25,6 +25,7 @@ import { TelemetryFactory } from "../../utils/telemetry/telemetry_factory";
 import { TelemetryCounter } from "../../utils/telemetry/telemetry_counter";
 import { TelemetryTraceLevel } from "../../utils/telemetry/telemetry_trace_level";
 import { HostResponseTimeMonitor } from "../strategy/fastest_response/host_response_time_monitor";
+import { WrapperProperties } from "../../wrapper_property";
 
 export interface Monitor {
   startMonitoring(context: MonitorConnectionContext): void;
@@ -241,7 +242,7 @@ export class MonitorImpl implements Monitor {
         // Open a new connection.
         const monitoringConnProperties: Map<string, any> = new Map(this.properties);
         for (const key of monitoringConnProperties.keys()) {
-          if (!key.startsWith(HostResponseTimeMonitor.MONITORING_PROPERTY_PREFIX)) {
+          if (!key.startsWith(WrapperProperties.MONITORING_PROPERTY_PREFIX)) {
             continue;
           }
           monitoringConnProperties.set(key.substring(HostResponseTimeMonitor.MONITORING_PROPERTY_PREFIX.length), this.properties.get(key));

diff --git a/common/lib/plugins/efm2/monitor.ts b/common/lib/plugins/efm2/monitor.ts
@@ -27,6 +27,7 @@ import { TelemetryTraceLevel } from "../../utils/telemetry/telemetry_trace_level
 import { HostAvailability } from "../../host_availability/host_availability";
 import { MapUtils } from "../../utils/map_utils";
 import { HostResponseTimeMonitor } from "../strategy/fastest_response/host_response_time_monitor";
+import { WrapperProperties } from "../../wrapper_property";
 
 export interface Monitor {
   startMonitoring(context: MonitorConnectionContext): void;
@@ -237,10 +238,10 @@ export class MonitorImpl implements Monitor {
         // Open a new connection.
         const monitoringConnProperties: Map<string, any> = new Map(this.properties);
         for (const key of monitoringConnProperties.keys()) {
-          if (!key.startsWith(HostResponseTimeMonitor.MONITORING_PROPERTY_PREFIX)) {
+          if (!key.startsWith(WrapperProperties.MONITORING_PROPERTY_PREFIX)) {
             continue;
           }
-          monitoringConnProperties.set(key.substring(HostResponseTimeMonitor.MONITORING_PROPERTY_PREFIX.length), this.properties.get(key));
+          monitoringConnProperties.set(key.substring(WrapperProperties.MONITORING_PROPERTY_PREFIX.length), this.properties.get(key));
           monitoringConnProperties.delete(key);
         }
 

diff --git a/common/lib/plugins/strategy/fastest_response/host_response_time_monitor.ts b/common/lib/plugins/strategy/fastest_response/host_response_time_monitor.ts
@@ -23,6 +23,7 @@ import { Messages } from "../../../utils/messages";
 import { TelemetryTraceLevel } from "../../../utils/telemetry/telemetry_trace_level";
 import { ClientWrapper } from "../../../client_wrapper";
 import { TelemetryContext } from "../../../utils/telemetry/telemetry_context";
+import { WrapperProperties } from "../../../wrapper_property";
 
 export class HostResponseTimeMonitor {
   static readonly MONITORING_PROPERTY_PREFIX = "frt_";
@@ -125,7 +126,7 @@ export class HostResponseTimeMonitor {
       }
       const monitoringConnProperties: Map<string, any> = new Map(this.properties);
       for (const key of monitoringConnProperties.keys()) {
-        if (!key.startsWith(HostResponseTimeMonitor.MONITORING_PROPERTY_PREFIX)) {
+        if (!key.startsWith(WrapperProperties.MONITORING_PROPERTY_PREFIX)) {
           continue;
         }
         monitoringConnProperties.set(key.substring(HostResponseTimeMonitor.MONITORING_PROPERTY_PREFIX.length), this.properties.get(key));