Merge branch 'main' into dluna-ci-pr-speed-and-coverage

Author: david-luna

.github/ISSUE_TEMPLATE/bug_report.md

@@ -31,3 +31,4 @@ If possible, provide a recipe for reproducing the error.
 Add any other context about the problem here.
 -->
 
+<sub>**Tip**: [React](https://github.blog/news-insights/product-news/add-reactions-to-pull-requests-issues-and-comments/) with 👍 to help prioritize this issue. Please use comments to provide useful context, avoiding `+1` or `me too`, to help us triage it. Learn more [here](https://opentelemetry.io/community/end-user/issue-participation/).</sub>

.github/ISSUE_TEMPLATE/discussion.md

@@ -11,3 +11,5 @@ labels: discussion
 - [ ] This only affects the JavaScript OpenTelemetry library
 - [ ] This may affect other libraries, but I would like to get opinions here first
 
+<sub>**Tip**: [React](https://github.blog/news-insights/product-news/add-reactions-to-pull-requests-issues-and-comments/) with 👍 to help prioritize this issue. Please use comments to provide useful context, avoiding `+1` or `me too`, to help us triage it. Learn more [here](https://opentelemetry.io/community/end-user/issue-participation/).</sub>
+

.github/ISSUE_TEMPLATE/feature_request.md

@@ -31,3 +31,5 @@ A clear and concise description of any alternative solutions or features you've
 Add any other context or screenshots about the feature request here.
 -->
 
+<sub>**Tip**: [React](https://github.blog/news-insights/product-news/add-reactions-to-pull-requests-issues-and-comments/) with 👍 to help prioritize this issue. Please use comments to provide useful context, avoiding `+1` or `me too`, to help us triage it. Learn more [here](https://opentelemetry.io/community/end-user/issue-participation/).</sub>
+

.github/ISSUE_TEMPLATE/instrumentation_request.md

@@ -34,3 +34,5 @@ Any code-owners listed MUST fulfill all criteria laid out in the checklist below
 <!--
 Add any other context or screenshots about the instrumentation request here. Is there a reference you could point for the well-defined lifecycle methods?
 -->
+
+<sub>**Tip**: [React](https://github.blog/news-insights/product-news/add-reactions-to-pull-requests-issues-and-comments/) with 👍 to help prioritize this issue. Please use comments to provide useful context, avoiding `+1` or `me too`, to help us triage it. Learn more [here](https://opentelemetry.io/community/end-user/issue-participation/).</sub>

.github/ISSUE_TEMPLATE/ownership_request.md

@@ -38,3 +38,5 @@ Examples:
 <!--
 Add any other context that does not fit any of the above sections
 -->
+
+<sub>**Tip**: [React](https://github.blog/news-insights/product-news/add-reactions-to-pull-requests-issues-and-comments/) with 👍 to help prioritize this issue. Please use comments to provide useful context, avoiding `+1` or `me too`, to help us triage it. Learn more [here](https://opentelemetry.io/community/end-user/issue-participation/).</sub>

.release-please-manifest.json

@@ -7,7 +7,7 @@
   "packages/resource-detector-github": "0.31.0",
   "packages/resource-detector-instana": "0.22.0",
   "packages/auto-configuration-propagators": "0.4.1",
-  "packages/auto-instrumentations-node": "0.62.0",
+  "packages/auto-instrumentations-node": "0.62.1",
   "packages/auto-instrumentations-web": "0.49.0",
   "packages/baggage-span-processor": "0.4.0",
   "packages/baggage-log-record-processor": "0.4.0",
@@ -17,21 +17,21 @@
   "packages/redis-common": "0.38.0",
   "packages/sql-common": "0.41.0",
   "packages/contrib-test-utils": "0.49.0",
-  "packages/winston-transport": "0.14.0",
+  "packages/winston-transport": "0.14.1",
   "packages/instrumentation-amqplib": "0.50.0",
-  "packages/instrumentation-cucumber": "0.18.0",
-  "packages/instrumentation-dataloader": "0.21.0",
+  "packages/instrumentation-cucumber": "0.18.1",
+  "packages/instrumentation-dataloader": "0.21.1",
   "packages/instrumentation-fs": "0.23.0",
-  "packages/instrumentation-kafkajs": "0.12.0",
+  "packages/instrumentation-kafkajs": "0.13.0",
   "packages/instrumentation-lru-memoizer": "0.48.0",
   "packages/instrumentation-mongoose": "0.50.0",
-  "packages/instrumentation-runtime-node": "0.17.0",
+  "packages/instrumentation-runtime-node": "0.17.1",
   "packages/instrumentation-socket.io": "0.50.0",
   "packages/instrumentation-tedious": "0.22.0",
   "packages/instrumentation-typeorm": "0.4.0",
   "packages/instrumentation-undici": "0.14.0",
   "packages/instrumentation-aws-lambda": "0.54.0",
-  "packages/instrumentation-aws-sdk": "0.56.0",
+  "packages/instrumentation-aws-sdk": "0.57.0",
   "packages/instrumentation-bunyan": "0.49.0",
   "packages/instrumentation-cassandra-driver": "0.49.0",
   "packages/instrumentation-connect": "0.47.0",
@@ -47,16 +47,16 @@
   "packages/instrumentation-memcached": "0.47.0",
   "packages/instrumentation-mongodb": "0.56.0",
   "packages/instrumentation-mysql": "0.49.0",
-  "packages/instrumentation-mysql2": "0.49.0",
+  "packages/instrumentation-mysql2": "0.50.0",
   "packages/instrumentation-nestjs-core": "0.49.0",
   "packages/instrumentation-net": "0.47.0",
   "packages/instrumentation-oracledb": "0.29.0",
-  "packages/instrumentation-pg": "0.55.0",
+  "packages/instrumentation-pg": "0.56.0",
   "packages/instrumentation-pino": "0.50.0",
   "packages/instrumentation-redis": "0.51.0",
   "packages/instrumentation-restify": "0.49.0",
   "packages/instrumentation-router": "0.48.0",
-  "packages/instrumentation-winston": "0.48.0",
+  "packages/instrumentation-winston": "0.48.1",
   "packages/instrumentation-document-load": "0.48.0",
   "packages/instrumentation-long-task": "0.48.0",
   "packages/instrumentation-user-interaction": "0.48.0",

incubator/opentelemetry-sampler-aws-xray/src/aws-xray-sampling-client.ts

@@ -45,7 +45,7 @@ export class AWSXRaySamplingClient {
     this.makeSamplingRequest<GetSamplingTargetsResponse>(
       this.samplingTargetsEndpoint,
       callback,
-      this.samplerDiag.debug,
+      (message: string) => this.samplerDiag.debug(message),
       JSON.stringify(requestBody)
     );
   }
@@ -56,7 +56,7 @@ export class AWSXRaySamplingClient {
     this.makeSamplingRequest<GetSamplingRulesResponse>(
       this.getSamplingRulesEndpoint,
       callback,
-      this.samplerDiag.error
+      (message: string) => this.samplerDiag.error(message)
     );
   }
 

incubator/opentelemetry-sampler-aws-xray/src/fallback-sampler.ts

@@ -21,16 +21,20 @@
 import { Attributes, Context, Link, SpanKind } from '@opentelemetry/api';
 import {
   Sampler,
+  SamplingDecision,
   SamplingResult,
   TraceIdRatioBasedSampler,
 } from '@opentelemetry/sdk-trace-base';
+import { RateLimitingSampler } from './rate-limiting-sampler';
 
 // FallbackSampler samples 1 req/sec and additional 5% of requests using TraceIdRatioBasedSampler.
 export class FallbackSampler implements Sampler {
   private fixedRateSampler: TraceIdRatioBasedSampler;
+  private rateLimitingSampler: RateLimitingSampler;
 
-  constructor() {
-    this.fixedRateSampler = new TraceIdRatioBasedSampler(0.05);
+  constructor(ratio = 0.05, quota = 1) {
+    this.fixedRateSampler = new TraceIdRatioBasedSampler(ratio);
+    this.rateLimitingSampler = new RateLimitingSampler(quota);
   }
 
   shouldSample(
@@ -41,7 +45,19 @@ export class FallbackSampler implements Sampler {
     attributes: Attributes,
     links: Link[]
   ): SamplingResult {
-    // TODO: implement and use Rate Limiting Sampler
+    const samplingResult: SamplingResult =
+      this.rateLimitingSampler.shouldSample(
+        context,
+        traceId,
+        spanName,
+        spanKind,
+        attributes,
+        links
+      );
+
+    if (samplingResult.decision !== SamplingDecision.NOT_RECORD) {
+      return samplingResult;
+    }
 
     return this.fixedRateSampler.shouldSample(context, traceId);
   }

incubator/opentelemetry-sampler-aws-xray/src/rate-limiter.ts

@@ -0,0 +1,65 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+// Includes work from:
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+/*
+ * The RateLimiter keeps track of the current reservoir quota balance available (measured via available time)
+ * If enough time has elapsed, the RateLimiter will allow quota balance to be consumed/taken (decrease available time)
+ * A RateLimitingSampler uses this RateLimiter to determine if it should sample or not based on the quota balance available.
+ */
+export class RateLimiter {
+  // Quota assigned to client to dictate maximum quota balance that can be consumed per second.
+  private quota: number;
+  private MAX_BALANCE_MILLIS: number;
+  // Used to measure current quota balance.
+  private walletFloorMillis: number;
+
+  constructor(quota: number, maxBalanceInSeconds = 1) {
+    this.MAX_BALANCE_MILLIS = maxBalanceInSeconds * 1000.0;
+    this.quota = quota;
+    this.walletFloorMillis = Date.now();
+    // current "balance" would be `ceiling - floor`
+  }
+
+  public take(cost = 1): boolean {
+    if (this.quota === 0) {
+      return false;
+    }
+
+    // assume divide by zero not possible
+    const costInMillis: number = (cost * 1000.0) / this.quota;
+
+    const walletCeilingMillis: number = Date.now();
+    let currentBalanceMillis: number =
+      walletCeilingMillis - this.walletFloorMillis;
+    currentBalanceMillis = Math.min(
+      currentBalanceMillis,
+      this.MAX_BALANCE_MILLIS
+    );
+    const pendingRemainingBalanceMillis: number =
+      currentBalanceMillis - costInMillis;
+    if (pendingRemainingBalanceMillis >= 0) {
+      this.walletFloorMillis =
+        walletCeilingMillis - pendingRemainingBalanceMillis;
+      return true;
+    }
+    // No changes to the wallet state
+    return false;
+  }
+}

incubator/opentelemetry-sampler-aws-xray/src/rate-limiting-sampler.ts

@@ -0,0 +1,58 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+// Includes work from:
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+import { Attributes, Context, Link, SpanKind } from '@opentelemetry/api';
+import {
+  Sampler,
+  SamplingDecision,
+  SamplingResult,
+} from '@opentelemetry/sdk-trace-base';
+import { RateLimiter } from './rate-limiter';
+
+export class RateLimitingSampler implements Sampler {
+  private quota: number;
+  private reservoir: RateLimiter;
+
+  constructor(quota: number) {
+    this.quota = quota;
+    this.reservoir = new RateLimiter(quota);
+  }
+
+  shouldSample(
+    context: Context,
+    traceId: string,
+    spanName: string,
+    spanKind: SpanKind,
+    attributes: Attributes,
+    links: Link[]
+  ): SamplingResult {
+    if (this.reservoir.take(1)) {
+      return {
+        decision: SamplingDecision.RECORD_AND_SAMPLED,
+        attributes: attributes,
+      };
+    }
+    return { decision: SamplingDecision.NOT_RECORD, attributes: attributes };
+  }
+
+  public toString(): string {
+    return `RateLimitingSampler{rate limiting sampling with sampling config of ${this.quota} req/sec and 0% of additional requests}`;
+  }
+}