diff --git a/build/Build.cs b/build/Build.cs index 6fbbc8dc..98b046e8 100644 --- a/build/Build.cs +++ b/build/Build.cs @@ -206,7 +206,8 @@ Copyright The OpenTelemetry Authors under Apache License Version 2.0 DotNetBuild(s => s .SetProjectFile(project) .SetNoRestore(true) - .SetConfiguration(this.configuration)); + .SetConfiguration(this.configuration) + .SetProperty("TreatWarningsAsErrors", "true")); } }); diff --git a/sample-applications/integration-test-app/integration-test-app/integration-test-app.csproj b/sample-applications/integration-test-app/integration-test-app/integration-test-app.csproj index 57556212..93e292a2 100644 --- a/sample-applications/integration-test-app/integration-test-app/integration-test-app.csproj +++ b/sample-applications/integration-test-app/integration-test-app/integration-test-app.csproj @@ -3,11 +3,15 @@ netcoreapp8.0 integration_test_app + + $(NoWarn);SA0001;SA1300 - + runtime; build; native; contentfiles; analyzers; buildtransitive all diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWS.Distro.OpenTelemetry.AutoInstrumentation.csproj b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWS.Distro.OpenTelemetry.AutoInstrumentation.csproj index 4e8e7053..c11c31f4 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWS.Distro.OpenTelemetry.AutoInstrumentation.csproj +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWS.Distro.OpenTelemetry.AutoInstrumentation.csproj @@ -8,6 +8,7 @@ enable true ../../buildtools/awsoteldotnet.snk + true @@ -33,7 +34,7 @@ - + runtime; build; native; contentfiles; analyzers; buildtransitive all diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWSDistroOpenTelemetryEventSource.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWSDistroOpenTelemetryEventSource.cs deleted file mode 100644 index e69de29b..00000000 diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWSOpenTelemetryOptions.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWSOpenTelemetryOptions.cs index c1376a25..4d1c3108 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWSOpenTelemetryOptions.cs +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWSOpenTelemetryOptions.cs @@ -22,4 +22,4 @@ internal AWSOpenTelemetryOptions(IConfiguration configuration) { // custom implementation of initializing exporter settings / instrumentations / Service Name etc. } -} \ No newline at end of file +} diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWSXRayEventSource.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWSXRayEventSource.cs index 78fbbe05..7431bbbf 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWSXRayEventSource.cs +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AWSXRayEventSource.cs @@ -9,7 +9,7 @@ namespace AWS.Distro.OpenTelemetry.AutoInstrumentation; [EventSource(Name = "OpenTelemetry-AWS-XRay")] internal class AWSXRayEventSource : EventSource { - internal static readonly AWSXRayEventSource Log = new (); + internal static readonly AWSXRayEventSource Log = new(); [NonEvent] public void ActivityContextExtractException(string format, Exception ex) diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AlwaysRecordSampler.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AlwaysRecordSampler.cs index 48b3a4a0..c52ea348 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AlwaysRecordSampler.cs +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AlwaysRecordSampler.cs @@ -6,13 +6,13 @@ namespace AWS.Distro.OpenTelemetry.AutoInstrumentation; /// -/// This sampler will return the sampling result of the provided {@link #rootSampler}, unless the +/// This sampler will return the sampling result of the provided rootSampler, unless the /// sampling result contains the sampling decision , in which case, a /// new sampling result will be returned that is functionally equivalent to the original, except that /// it contains the sampling decision . This ensures that all /// spans are recorded, with no change to sampling. /// -///

The intended use case of this sampler is to provide a means of sending all spans to a +/// The intended use case of this sampler is to provide a means of sending all spans to a /// processor without having an impact on the sampling rate. This may be desirable if a user wishes /// to count or otherwise measure all spans produced in a service, without incurring the cost of 100% /// sampling. diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AttributePropagatingSpanProcessorBuilder.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AttributePropagatingSpanProcessorBuilder.cs index 66159b6e..f6815970 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AttributePropagatingSpanProcessorBuilder.cs +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AttributePropagatingSpanProcessorBuilder.cs @@ -25,11 +25,20 @@ private AttributePropagatingSpanProcessorBuilder() { } + ///

+ /// Creates a new AttributePropagatingSpanProcessorBuilder instance. + /// + /// A new builder instance. public static AttributePropagatingSpanProcessorBuilder Create() { return new AttributePropagatingSpanProcessorBuilder(); } + /// + /// Sets the propagation data extractor function. + /// + /// Function to extract propagation data from activity. + /// This builder instance. public AttributePropagatingSpanProcessorBuilder SetPropagationDataExtractor(Func propagationDataExtractor) { if (propagationDataExtractor == null) @@ -41,6 +50,11 @@ public AttributePropagatingSpanProcessorBuilder SetPropagationDataExtractor(Func return this; } + /// + /// Sets the propagation data key. + /// + /// The key for propagation data. + /// This builder instance. public AttributePropagatingSpanProcessorBuilder SetPropagationDataKey(string propagationDataKey) { if (propagationDataKey == null) @@ -52,6 +66,11 @@ public AttributePropagatingSpanProcessorBuilder SetPropagationDataKey(string pro return this; } + /// + /// Sets the attribute keys to propagate. + /// + /// List of attribute keys to propagate. + /// This builder instance. public AttributePropagatingSpanProcessorBuilder SetAttributesKeysToPropagate(List attributesKeysToPropagate) { if (attributesKeysToPropagate == null) @@ -64,6 +83,10 @@ public AttributePropagatingSpanProcessorBuilder SetAttributesKeysToPropagate(Lis return this; } + /// + /// Builds the AttributePropagatingSpanProcessor. + /// + /// The configured processor. public AttributePropagatingSpanProcessor Build() { return AttributePropagatingSpanProcessor diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsBatchUnsampledSpanExportProcessor.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsBatchUnsampledSpanExportProcessor.cs index 08bdd192..1b72b5a8 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsBatchUnsampledSpanExportProcessor.cs +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsBatchUnsampledSpanExportProcessor.cs @@ -42,4 +42,4 @@ public override void OnEnd(Activity data) this.OnExport(data); } } -} \ No newline at end of file +} diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsMetricAttributeGenerator.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsMetricAttributeGenerator.cs index 683933dd..31a0dcc6 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsMetricAttributeGenerator.cs +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsMetricAttributeGenerator.cs @@ -18,9 +18,9 @@ namespace AWS.Distro.OpenTelemetry.AutoInstrumentation; /// /// AwsMetricAttributeGenerator generates very specific metric attributes based on low-cardinality /// span and resource attributes. If such attributes are not present, we fallback to default values. -///

The goal of these particular metric attributes is to get metrics for incoming and outgoing +/// The goal of these particular metric attributes is to get metrics for incoming and outgoing /// traffic for a service. Namely, and spans -/// represent "incoming" traffic, { and spans +/// represent "incoming" traffic, and spans /// represent "outgoing" traffic, and spans are ignored. ///

internal class AwsMetricAttributeGenerator : IMetricAttributeGenerator @@ -169,28 +169,28 @@ private static void SetEgressOperation(Activity span, ActivityTagsCollection att /// instrumented span attributes, and are clear indications of customer intent. If AWS Remote /// attributes are not present, the next highest priority span attribute is Peer Service, which is /// also a reliable indicator of customer intent. If this is set, it will override - /// AWS_REMOTE_SERVICE identified from any other span attribute, other than AWS Remote attributes. + /// AWS_REMOTE_SERVICE identified from any other span attribute, other than AWS Remote attributes.

/// ///

After this, we look for the following low-cardinality span attributes that can be used to - /// determine the remote metric attributes: + /// determine the remote metric attributes:

/// ///
    - ///
  • RPC - ///
  • DB - ///
  • FAAS - ///
  • Messaging + ///
  • RPC
    • + ///
  • DB
    • + ///
  • FAAS
    • + ///
  • Messaging
    • ///
  • GraphQL - Special case, if is present, - /// we use it for RemoteOperation and set RemoteService to . + /// we use it for RemoteOperation and set RemoteService to .
    • ///
/// ///

In each case, these span attributes were selected from the OpenTelemetry trace semantic - /// convention specifications as they adhere to the three following criteria: + /// convention specifications as they adhere to the three following criteria:

/// ///
    - ///
  • Attributes are meaningfully indicative of remote service/operation names. + ///
  • Attributes are meaningfully indicative of remote service/operation names.
    • ///
  • Attributes are defined in the specification to be low cardinality, usually with a low- - /// cardinality list of values. - ///
  • Attributes are confirmed to have low-cardinality values, based on code analysis. + /// cardinality list of values.
    • + ///
  • Attributes are confirmed to have low-cardinality values, based on code analysis.
    • ///
/// /// if the selected attributes are still producing the UnknownRemoteService or diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsMetricAttributesSpanProcessor.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsMetricAttributesSpanProcessor.cs index fff56337..e9cc7817 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsMetricAttributesSpanProcessor.cs +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsMetricAttributesSpanProcessor.cs @@ -78,16 +78,18 @@ private static Activity WrapSpanWithAttributes(Activity span, ActivityTagsCollec return span; } + /// + /// If the map has no items, no modifications are required. If there is one item, it means the + /// span either produces Service or Dependency metric attributes, and in either case we want to + /// modify the span with them. If there are two items, the span produces both Service and + /// Dependency metric attributes indicating the span is a local dependency root. The Service + /// Attributes must be a subset of the Dependency, with the exception of AttributeAWSSpanKind. The + /// knowledge that the span is a local root is more important that knowing that it is a + /// Dependency metric, so we take all the Dependency metrics but replace AttributeAWSSpanKind with + /// . + /// private Activity AddMetricAttributes(Activity span) { - /// If the map has no items, no modifications are required. If there is one item, it means the - /// span either produces Service or Dependency metric attributes, and in either case we want to - /// modify the span with them. If there are two items, the span produces both Service and - /// Dependency metric attributes indicating the span is a local dependency root. The Service - /// Attributes must be a subset of the Dependency, with the exception of AttributeAWSSpanKind. The - /// knowledge that the span is a local root is more important that knowing that it is a - /// Dependency metric, so we take all the Dependency metrics but replace AttributeAWSSpanKind with - /// . Dictionary attributeMap = this.generator.GenerateMetricAttributeMapFromSpan(span, this.resource); ActivityTagsCollection attributes = new ActivityTagsCollection(); diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsSpanProcessingUtil.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsSpanProcessingUtil.cs index bbe8523e..fc01a9dc 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsSpanProcessingUtil.cs +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsSpanProcessingUtil.cs @@ -316,7 +316,7 @@ private static bool IsSqsReceiveMessageConsumerSpan(Activity span) string? serviceName = (string?)span.GetTagItem(AttributeAWSServiceName); return !string.IsNullOrEmpty(serviceName) - && serviceName.Equals(SQSService) + && SQSService.Equals(serviceName) && ActivityKind.Consumer.Equals(spanKind) && spanActivitySource != null && spanActivitySource.Name.StartsWith(ActivitySourceName) diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/MetricAttributeGenerator.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/IMetricAttributeGenerator.cs similarity index 94% rename from src/AWS.Distro.OpenTelemetry.AutoInstrumentation/MetricAttributeGenerator.cs rename to src/AWS.Distro.OpenTelemetry.AutoInstrumentation/IMetricAttributeGenerator.cs index 9d8c543c..7f00ca2c 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/MetricAttributeGenerator.cs +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/IMetricAttributeGenerator.cs @@ -10,7 +10,7 @@ namespace AWS.Distro.OpenTelemetry.AutoInstrumentation; /// /// Metric attribute generator defines an interface for classes that can generate specific attributes /// to be used by an to produce metrics and by -/// to wrap the original span. +/// AwsMetricAttributesSpanExporter to wrap the original span. /// public interface IMetricAttributeGenerator { diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/LambdaWrapper.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/LambdaWrapper.cs index 252d93c0..e639ff20 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/LambdaWrapper.cs +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/LambdaWrapper.cs @@ -63,11 +63,11 @@ static LambdaWrapper() /// The following are assumptions made about the lambda handler function parameters. /// * Maximum Parameters: A .NET Lambda handler function can have up to two parameters. /// * Parameter Order: If both parameters are used, the event input parameter must come first, followed by the ILambdaContext. - /// * Return Types: The handler can return void, a specific type, or a Task/Task for asynchronous methods. + /// * Return Types: The handler can return void, a specific type, or a Task/Task[T] for asynchronous methods. /// - /// - /// - /// + /// Input JObject to be converted to the correct object type. + /// Lambda context for the function execution. + /// Task containing the result object from the original handler. /// Multiple exceptions that act as safe gaurds in case any of the /// assumptions are wrong or if for any reason reflection is failing to get the original function and it's info. private async Task FunctionHandler(JObject input, ILambdaContext context) @@ -154,7 +154,7 @@ static LambdaWrapper() } } - private (MethodInfo, object) ExtractOriginalHandler() + private (MethodInfo HandlerMethod, object HandlerInstance) ExtractOriginalHandler() { string? originalHandler = Environment.GetEnvironmentVariable("OTEL_INSTRUMENTATION_AWS_LAMBDA_HANDLER"); if (string.IsNullOrEmpty(originalHandler)) @@ -188,4 +188,4 @@ static LambdaWrapper() return (handlerMethod, handlerInstance); } } -#endif \ No newline at end of file +#endif diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/Plugin.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/Plugin.cs index 68d57407..9eb2c8d5 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/Plugin.cs +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/Plugin.cs @@ -359,11 +359,11 @@ public void ConfigureTracesOptions(HttpClientTraceInstrumentationOptions options #endif } +#if !NETFRAMEWORK /// /// Used to call ShouldSampleParent function /// /// options to configure -#if !NETFRAMEWORK public void ConfigureTracesOptions(AspNetCoreTraceInstrumentationOptions options) { options.EnrichWithHttpRequest = (activity, request) => diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/RegionalResourceArnParser.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/RegionalResourceArnParser.cs index bcc9146c..e94a3215 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/RegionalResourceArnParser.cs +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/RegionalResourceArnParser.cs @@ -3,18 +3,46 @@ namespace AWS.Distro.OpenTelemetry.AutoInstrumentation; +/// +/// Parser for AWS regional resource ARNs. +/// public class RegionalResourceArnParser { + /// + /// Gets the account ID from an AWS ARN. + /// + /// The ARN to parse. + /// The account ID or null if not found. public static string? GetAccountId(string? arn) => ParseArn(arn)?[4]; + /// + /// Gets the region from an AWS ARN. + /// + /// The ARN to parse. + /// The region or null if not found. public static string? GetRegion(string? arn) => ParseArn(arn)?[3]; + /// + /// Extracts the Kinesis stream name from an ARN. + /// + /// The Kinesis stream ARN. + /// The stream name or null if not found. public static string? ExtractKinesisStreamNameFromArn(string? arn) => ExtractResourceNameFromArn(arn)?.Replace("stream/", string.Empty); + /// + /// Extracts the DynamoDB table name from an ARN. + /// + /// The DynamoDB table ARN. + /// The table name or null if not found. public static string? ExtractDynamoDbTableNameFromArn(string? arn) => ExtractResourceNameFromArn(arn)?.Replace("table/", string.Empty); + /// + /// Extracts the resource name from an AWS ARN. + /// + /// The ARN to parse. + /// The resource name or null if not found. public static string? ExtractResourceNameFromArn(string? arn) => ParseArn(arn) is var parts && parts != null ? parts[parts.Length - 1] : null; @@ -23,7 +51,7 @@ public class RegionalResourceArnParser /// arn:partition:service:region:account-id:resource-type/resource-id or /// arn:partition:service:region:account-id:resource-type:resource-id /// - private static string[] ? ParseArn(string? arn) + private static string[]? ParseArn(string? arn) { if (arn == null || !arn.StartsWith("arn:")) { diff --git a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/SqlUrlParser.cs b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/SqsUrlParser.cs similarity index 86% rename from src/AWS.Distro.OpenTelemetry.AutoInstrumentation/SqlUrlParser.cs rename to src/AWS.Distro.OpenTelemetry.AutoInstrumentation/SqsUrlParser.cs index fdecb6fb..b35bf972 100644 --- a/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/SqlUrlParser.cs +++ b/src/AWS.Distro.OpenTelemetry.AutoInstrumentation/SqsUrlParser.cs @@ -40,16 +40,26 @@ public class SqsUrlParser return null; } - public static string? GetAccountId(string? url) => ParseUrl(url).accountId; + /// + /// Gets the account ID from an SQS URL. + /// + /// The SQS URL to parse. + /// The account ID or null if not found. + public static string? GetAccountId(string? url) => ParseUrl(url).AccountId; - public static string? GetRegion(string? url) => ParseUrl(url).region; + /// + /// Gets the region from an SQS URL. + /// + /// The SQS URL to parse. + /// The region or null if not found. + public static string? GetRegion(string? url) => ParseUrl(url).Region; /// /// Parses new SQS URLs https://sqs.region.amazonaws.com/accountI/queueName; /// /// SQS URL to parse /// Tuple containing queue name, account ID, and region - public static (string? QueueName, string? accountId, string? region) ParseUrl(string? url) + public static (string? QueueName, string? AccountId, string? Region) ParseUrl(string? url) { if (url == null) { diff --git a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests.csproj b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests.csproj index 8df3283e..19b2cfd0 100644 --- a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests.csproj +++ b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests.csproj @@ -8,6 +8,13 @@ ../../buildtools/awsoteldotnet.snk false true + + $(NoWarn);CS8002;SA0001;SA1204;SA1300;SA1402 @@ -27,7 +34,7 @@ - + runtime; build; native; contentfiles; analyzers; buildtransitive all diff --git a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsBatchUnsampledSpanExportProcessorTest.cs b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsBatchUnsampledSpanExportProcessorTest.cs index 06635133..d3d61bf9 100644 --- a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsBatchUnsampledSpanExportProcessorTest.cs +++ b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsBatchUnsampledSpanExportProcessorTest.cs @@ -103,4 +103,4 @@ public void CheckThatUnSampledActivityIsProcessed() Assert.Equal(0, (long)droppedCount); } } -} \ No newline at end of file +} diff --git a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsLambdaSpanProcessorTest.cs b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsLambdaSpanProcessorTest.cs index 6349ceaf..22beb2ac 100644 --- a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsLambdaSpanProcessorTest.cs +++ b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsLambdaSpanProcessorTest.cs @@ -86,4 +86,4 @@ public void CheckThatMultipleServerSpanFlagNotAdded() Assert.Null(lambdaActivity.GetTagItem(AttributeAWSTraceLambdaFlagMultipleServer)); } -} \ No newline at end of file +} diff --git a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsMetricAttributesGeneratorTest.cs b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsMetricAttributesGeneratorTest.cs index 77edef6e..8ab2e2f1 100644 --- a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsMetricAttributesGeneratorTest.cs +++ b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsMetricAttributesGeneratorTest.cs @@ -55,9 +55,9 @@ public void TestServerSpanWithoutAttributes() { List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Server.ToString().ToUpper()), - new (AttributeAWSLocalService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownService), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), + new(AttributeAWSSpanKind, ActivityKind.Server.ToString().ToUpper()), + new(AttributeAWSLocalService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownService), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); Activity? spanDataMock = this.testSource.StartActivity(string.Empty, ActivityKind.Server); @@ -70,11 +70,11 @@ public void TestConsumerSpanWithoutAttributes() { List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Consumer.ToString().ToUpper()), - new (AttributeAWSLocalService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownService), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), - new (AttributeAWSRemoteService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteService), - new (AttributeAWSRemoteOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteOperation), + new(AttributeAWSSpanKind, ActivityKind.Consumer.ToString().ToUpper()), + new(AttributeAWSLocalService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownService), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), + new(AttributeAWSRemoteService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteService), + new(AttributeAWSRemoteOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteOperation), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); Activity? spanDataMock = this.testSource.StartActivity(string.Empty, ActivityKind.Consumer); @@ -88,9 +88,9 @@ public void TestSpanAttributesForEmptyResource() this.resource = Resource.Empty; List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Server.ToString().ToUpper()), - new (AttributeAWSLocalService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownService), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), + new(AttributeAWSSpanKind, ActivityKind.Server.ToString().ToUpper()), + new(AttributeAWSLocalService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownService), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); Activity? spanDataMock = this.testSource.StartActivity(string.Empty, ActivityKind.Server); @@ -103,11 +103,11 @@ public void TestProducerSpanWithoutAttributes() { List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Producer.ToString().ToUpper()), - new (AttributeAWSLocalService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownService), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), - new (AttributeAWSRemoteService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteService), - new (AttributeAWSRemoteOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteOperation), + new(AttributeAWSSpanKind, ActivityKind.Producer.ToString().ToUpper()), + new(AttributeAWSLocalService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownService), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), + new(AttributeAWSRemoteService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteService), + new(AttributeAWSRemoteOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteOperation), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); Activity? spanDataMock = this.testSource.StartActivity(string.Empty, ActivityKind.Producer); @@ -120,11 +120,11 @@ public void TestClientSpanWithoutAttributes() { List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Client.ToString().ToUpper()), - new (AttributeAWSLocalService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownService), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), - new (AttributeAWSRemoteService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteService), - new (AttributeAWSRemoteOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteOperation), + new(AttributeAWSSpanKind, ActivityKind.Client.ToString().ToUpper()), + new(AttributeAWSLocalService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownService), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), + new(AttributeAWSRemoteService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteService), + new(AttributeAWSRemoteOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteOperation), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); Activity? spanDataMock = this.testSource.StartActivity(string.Empty, ActivityKind.Client); @@ -149,9 +149,9 @@ public void TestLocalRootServerSpan() Activity? spanDataMock = this.testSource.StartActivity(this.spanNameValue, ActivityKind.Server); List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, AutoInstrumentation.AwsSpanProcessingUtil.LocalRoot), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, this.spanNameValue), + new(AttributeAWSSpanKind, AutoInstrumentation.AwsSpanProcessingUtil.LocalRoot), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, this.spanNameValue), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); this.ValidateAttributesProducedForNonLocalRootSpanOfKind(expectedAttributes, spanDataMock); @@ -165,9 +165,9 @@ public void TestLocalRootInternalSpan() Activity? spanDataMock = this.testSource.StartActivity(this.spanNameValue, ActivityKind.Internal); List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, AutoInstrumentation.AwsSpanProcessingUtil.LocalRoot), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), + new(AttributeAWSSpanKind, AutoInstrumentation.AwsSpanProcessingUtil.LocalRoot), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); this.ValidateAttributesProducedForNonLocalRootSpanOfKind(expectedAttributes, spanDataMock); @@ -184,18 +184,18 @@ public void TestLocalRootClientSpan() List> expectServiceAttiributesList = new List> { - new (AttributeAWSSpanKind, AutoInstrumentation.AwsSpanProcessingUtil.LocalRoot), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), + new(AttributeAWSSpanKind, AutoInstrumentation.AwsSpanProcessingUtil.LocalRoot), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), }; List> expectDependencyAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Client.ToString().ToUpper()), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), - new (AttributeAWSRemoteService, this.awsRemoteServiceValue), - new (AttributeAWSRemoteOperation, this.awsRemoteOperationValue), + new(AttributeAWSSpanKind, ActivityKind.Client.ToString().ToUpper()), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), + new(AttributeAWSRemoteService, this.awsRemoteServiceValue), + new(AttributeAWSRemoteOperation, this.awsRemoteOperationValue), }; ActivityTagsCollection expectServiceAttiributes = new ActivityTagsCollection(expectServiceAttiributesList); @@ -215,18 +215,18 @@ public void TestLocalRootConsumerSpan() List> expectServiceAttiributesList = new List> { - new (AttributeAWSSpanKind, AutoInstrumentation.AwsSpanProcessingUtil.LocalRoot), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), + new(AttributeAWSSpanKind, AutoInstrumentation.AwsSpanProcessingUtil.LocalRoot), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), }; List> expectDependencyAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Consumer.ToString().ToUpper()), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), - new (AttributeAWSRemoteService, this.awsRemoteServiceValue), - new (AttributeAWSRemoteOperation, this.awsRemoteOperationValue), + new(AttributeAWSSpanKind, ActivityKind.Consumer.ToString().ToUpper()), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), + new(AttributeAWSRemoteService, this.awsRemoteServiceValue), + new(AttributeAWSRemoteOperation, this.awsRemoteOperationValue), }; ActivityTagsCollection expectServiceAttiributes = new ActivityTagsCollection(expectServiceAttiributesList); @@ -246,18 +246,18 @@ public void TestLocalRootProducerSpan() List> expectServiceAttiributesList = new List> { - new (AttributeAWSSpanKind, AutoInstrumentation.AwsSpanProcessingUtil.LocalRoot), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), + new(AttributeAWSSpanKind, AutoInstrumentation.AwsSpanProcessingUtil.LocalRoot), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), }; List> expectDependencyAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Producer.ToString().ToUpper()), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), - new (AttributeAWSRemoteService, this.awsRemoteServiceValue), - new (AttributeAWSRemoteOperation, this.awsRemoteOperationValue), + new(AttributeAWSSpanKind, ActivityKind.Producer.ToString().ToUpper()), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.InternalOperation), + new(AttributeAWSRemoteService, this.awsRemoteServiceValue), + new(AttributeAWSRemoteOperation, this.awsRemoteOperationValue), }; ActivityTagsCollection expectServiceAttiributes = new ActivityTagsCollection(expectServiceAttiributesList); @@ -272,11 +272,11 @@ public void TestConsumerSpanWithAttributes() this.UpdateResourceWithServiceName(); List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Consumer.ToString().ToUpper()), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), - new (AttributeAWSRemoteService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteService), - new (AttributeAWSRemoteOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteOperation), + new(AttributeAWSSpanKind, ActivityKind.Consumer.ToString().ToUpper()), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), + new(AttributeAWSRemoteService, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteService), + new(AttributeAWSRemoteOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownRemoteOperation), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); Activity? spanDataMock = this.testSource.StartActivity(string.Empty, ActivityKind.Consumer); @@ -290,9 +290,9 @@ public void TestServerSpanWithAttributes() this.UpdateResourceWithServiceName(); List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Server.ToString().ToUpper()), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, this.spanNameValue), + new(AttributeAWSSpanKind, ActivityKind.Server.ToString().ToUpper()), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, this.spanNameValue), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); Activity? spanDataMock = this.testSource.StartActivity(this.spanNameValue, ActivityKind.Server); @@ -307,9 +307,9 @@ public void TestServerSpanWithEmptySpanName() this.UpdateResourceWithServiceName(); List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Server.ToString().ToUpper()), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), + new(AttributeAWSSpanKind, ActivityKind.Server.ToString().ToUpper()), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); Activity? spanDataMock = this.testSource.StartActivity(string.Empty, ActivityKind.Server); @@ -323,9 +323,9 @@ public void TestServerSpanWithSpanNameAsHttpMethod() this.UpdateResourceWithServiceName(); List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Server.ToString().ToUpper()), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), + new(AttributeAWSSpanKind, ActivityKind.Server.ToString().ToUpper()), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, AutoInstrumentation.AwsSpanProcessingUtil.UnknownOperation), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); Activity? spanDataMock = this.testSource.StartActivity("GET", ActivityKind.Server); @@ -341,9 +341,9 @@ public void TestServerSpanWithSpanNameWithHttpTarget() this.UpdateResourceWithServiceName(); List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Server.ToString().ToUpper()), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, "POST /payment"), + new(AttributeAWSSpanKind, ActivityKind.Server.ToString().ToUpper()), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, "POST /payment"), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); Activity? spanDataMock = this.testSource.StartActivity("POST", ActivityKind.Server); @@ -359,11 +359,11 @@ public void TestProducerSpanWithAttributes() this.UpdateResourceWithServiceName(); List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Producer.ToString().ToUpper()), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, this.awsLocalOperationValue), - new (AttributeAWSRemoteService, this.awsRemoteServiceValue), - new (AttributeAWSRemoteOperation, this.awsRemoteOperationValue), + new(AttributeAWSSpanKind, ActivityKind.Producer.ToString().ToUpper()), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, this.awsLocalOperationValue), + new(AttributeAWSRemoteService, this.awsRemoteServiceValue), + new(AttributeAWSRemoteOperation, this.awsRemoteOperationValue), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); Activity? spanDataMock = this.testSource.StartActivity(string.Empty, ActivityKind.Producer); @@ -381,11 +381,11 @@ public void TestClientSpanWithAttributes() this.UpdateResourceWithServiceName(); List> expectAttributesList = new List> { - new (AttributeAWSSpanKind, ActivityKind.Client.ToString().ToUpper()), - new (AttributeAWSLocalService, this.serviceNameValue), - new (AttributeAWSLocalOperation, this.awsLocalOperationValue), - new (AttributeAWSRemoteService, this.awsRemoteServiceValue), - new (AttributeAWSRemoteOperation, this.awsRemoteOperationValue), + new(AttributeAWSSpanKind, ActivityKind.Client.ToString().ToUpper()), + new(AttributeAWSLocalService, this.serviceNameValue), + new(AttributeAWSLocalOperation, this.awsLocalOperationValue), + new(AttributeAWSRemoteService, this.awsRemoteServiceValue), + new(AttributeAWSRemoteOperation, this.awsRemoteOperationValue), }; ActivityTagsCollection expectedAttributes = new ActivityTagsCollection(expectAttributesList); Activity? spanDataMock = this.testSource.StartActivity(string.Empty, ActivityKind.Client); @@ -1147,7 +1147,7 @@ public void TestSdkClientSpanWithRemoteResourceAttributes() { { AttributeAWSSNSTopicArn, "arn:aws:sns:us-west-2:invalid_account_id:aws_topic_arn" }, }; - this.ValidateRemoteResourceAttributes(attributesCombination, null, null, null); + this.ValidateRemoteResourceAttributes(attributesCombination, null!, null!, null!); // Arn with invalid region attributesCombination = new Dictionary @@ -1161,7 +1161,7 @@ public void TestSdkClientSpanWithRemoteResourceAttributes() { { AttributeAWSSNSTopicArn, "invalid_arn" }, }; - this.ValidateRemoteResourceAttributes(attributesCombination, null, null, null); + this.ValidateRemoteResourceAttributes(attributesCombination, null!, null!, null!); // Invalid arn but account access key is available attributesCombination = new Dictionary @@ -1170,7 +1170,7 @@ public void TestSdkClientSpanWithRemoteResourceAttributes() { AttributeAWSAuthAccessKey, this.awsRemoteResourceAccessKey }, { AttributeAWSAuthRegion, this.awsRemoteResourceRegion }, }; - this.ValidateRemoteResourceAttributes(attributesCombination, null, null, null); + this.ValidateRemoteResourceAttributes(attributesCombination, null!, null!, null!); } [Fact] @@ -1500,8 +1500,8 @@ private void UpdateResourceWithServiceName() { List> resourceAttributes = new List> { - new (AutoInstrumentation.AwsMetricAttributeGenerator.AttributeServiceName, this.serviceNameValue), - new (AwsAttributeKeys.AttributeAWSLocalService, this.serviceNameValue), + new(AutoInstrumentation.AwsMetricAttributeGenerator.AttributeServiceName, this.serviceNameValue), + new(AwsAttributeKeys.AttributeAWSLocalService, this.serviceNameValue), }; this.resource = new Resource(resourceAttributes); } diff --git a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsSpanMetricsProcessorTest.cs b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsSpanMetricsProcessorTest.cs index 6e4fd1cc..25c2e89a 100644 --- a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsSpanMetricsProcessorTest.cs +++ b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsSpanMetricsProcessorTest.cs @@ -571,6 +571,7 @@ public static void Clear() [System.Diagnostics.CodeAnalysis.SuppressMessage("StyleCop.CSharp.DocumentationRules", "SA1600:Elements should be documented", Justification = "Tests")] [System.Diagnostics.CodeAnalysis.SuppressMessage("StyleCop.CSharp.DocumentationRules", "SA1602:Enumeration items should be documented", Justification = "Tests")] +[System.Diagnostics.CodeAnalysis.SuppressMessage("StyleCop.CSharp.OrderingRules", "SA1201:Elements should appear in the correct order", Justification = "Test helper enum")] public enum ExpectedStatusMetric { ERROR = 0, diff --git a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsSpanProcessingUtilTest.cs b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsSpanProcessingUtilTest.cs index 91c0e874..16568c60 100644 --- a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsSpanProcessingUtilTest.cs +++ b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/AwsSpanProcessingUtilTest.cs @@ -3,12 +3,6 @@ using System.Diagnostics; using System.Reflection; -using static AWS.Distro.OpenTelemetry.AutoInstrumentation.AwsAttributeKeys; -using static AWS.Distro.OpenTelemetry.AutoInstrumentation.AwsSpanProcessingUtil; -using static OpenTelemetry.Trace.TraceSemanticConventions; - -namespace AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests; - using Microsoft.AspNetCore.Diagnostics; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Http.Features; @@ -16,6 +10,11 @@ namespace AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests; using Microsoft.AspNetCore.Routing.Patterns; using Moq; using Xunit; +using static AWS.Distro.OpenTelemetry.AutoInstrumentation.AwsAttributeKeys; +using static AWS.Distro.OpenTelemetry.AutoInstrumentation.AwsSpanProcessingUtil; +using static OpenTelemetry.Trace.TraceSemanticConventions; + +namespace AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests; [System.Diagnostics.CodeAnalysis.SuppressMessage("StyleCop.CSharp.DocumentationRules", "SA1600:Elements should be documented", Justification = "Tests")] #pragma warning disable CS8602 // Possible null reference argument. diff --git a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/OtlpAwsSpanExporterTest.cs b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/OtlpAwsSpanExporterTest.cs index 1260bc64..03df5c31 100644 --- a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/OtlpAwsSpanExporterTest.cs +++ b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/OtlpAwsSpanExporterTest.cs @@ -68,14 +68,14 @@ public void TestAwsSpanExporterInjectSigV4Headers() Content = new StringContent(string.Empty), }; - (ExportResult result, HttpRequestMessage? capturedRequest) execute = SetupMockExporterAndCaptureRequest(exporter, response); + (ExportResult Result, HttpRequestMessage? CapturedRequest) execute = SetupMockExporterAndCaptureRequest(exporter, response); int callCount = mockAuth.CallCount; // Verify the result - Assert.Equal(ExportResult.Success, execute.result); + Assert.Equal(ExportResult.Success, execute.Result); Assert.Equal(1, callCount); - Assert.NotNull(execute.capturedRequest); - ValidateSigV4Headers(execute.capturedRequest, ExpectedAuth + callCount, ExpectedAmzDate + callCount, ExpectedAmzContentSha256 + callCount); + Assert.NotNull(execute.CapturedRequest); + ValidateSigV4Headers(execute.CapturedRequest, ExpectedAuth + callCount, ExpectedAmzDate + callCount, ExpectedAmzContentSha256 + callCount); } // Verifies that the exporter can successfully export multiple span requests with different sigv4 headers. @@ -96,14 +96,14 @@ public void TestAwsSpanExporterInjectsSigV4HeadersMultipleExports() for (int i = 1; i < 11; i += 1) { - (ExportResult result, HttpRequestMessage? capturedRequest) execute = SetupMockExporterAndCaptureRequest(exporter, response); + (ExportResult Result, HttpRequestMessage? CapturedRequest) execute = SetupMockExporterAndCaptureRequest(exporter, response); var callCount = mockAuth.CallCount; - Assert.Equal(ExportResult.Success, execute.result); + Assert.Equal(ExportResult.Success, execute.Result); Assert.Equal(i, callCount); - Assert.NotNull(execute.capturedRequest); - ValidateSigV4Headers(execute.capturedRequest, ExpectedAuth + callCount, ExpectedAmzDate + callCount, ExpectedAmzContentSha256 + callCount); + Assert.NotNull(execute.CapturedRequest); + ValidateSigV4Headers(execute.CapturedRequest, ExpectedAuth + callCount, ExpectedAmzDate + callCount, ExpectedAmzContentSha256 + callCount); } } @@ -129,13 +129,13 @@ public void TestAwsSpanExporterShouldNotRetryWithUnRetryableStatusCode() }; BaseExporter exporter = new OtlpAwsSpanExporter(this.options, this.tracerProvider.GetDefaultResource(), mockAuth); - (ExportResult result, HttpRequestMessage? capturedRequest) execute = SetupMockExporterAndCaptureRequest(exporter, response); + (ExportResult Result, HttpRequestMessage? CapturedRequest) execute = SetupMockExporterAndCaptureRequest(exporter, response); int callCount = mockAuth.CallCount; - Assert.Equal(ExportResult.Failure, execute.result); + Assert.Equal(ExportResult.Failure, execute.Result); Assert.Equal(1, callCount); - Assert.NotNull(execute.capturedRequest); - ValidateSigV4Headers(execute.capturedRequest, ExpectedAuth + callCount, ExpectedAmzDate + callCount, ExpectedAmzContentSha256 + callCount); + Assert.NotNull(execute.CapturedRequest); + ValidateSigV4Headers(execute.CapturedRequest, ExpectedAuth + callCount, ExpectedAmzDate + callCount, ExpectedAmzContentSha256 + callCount); } } @@ -164,13 +164,13 @@ public void TestAwsSpanExporterShouldRetryWithRetryableStatusCode() response.Headers.RetryAfter = new RetryConditionHeaderValue(TimeSpan.FromMilliseconds(500)); BaseExporter exporter = new OtlpAwsSpanExporter(this.options, this.tracerProvider.GetDefaultResource(), mockAuth); - (ExportResult result, HttpRequestMessage? capturedRequest) execute = SetupMockExporterAndCaptureRequest(exporter, response); + (ExportResult Result, HttpRequestMessage? CapturedRequest) execute = SetupMockExporterAndCaptureRequest(exporter, response); int callCount = mockAuth.CallCount; - Assert.Equal(ExportResult.Failure, execute.result); + Assert.Equal(ExportResult.Failure, execute.Result); Assert.Equal(2, callCount); - Assert.NotNull(execute.capturedRequest); - ValidateSigV4Headers(execute.capturedRequest, ExpectedAuth + callCount, ExpectedAmzDate + callCount, ExpectedAmzContentSha256 + callCount); + Assert.NotNull(execute.CapturedRequest); + ValidateSigV4Headers(execute.CapturedRequest, ExpectedAuth + callCount, ExpectedAmzDate + callCount, ExpectedAmzContentSha256 + callCount); } } @@ -189,10 +189,10 @@ public void TestAwsSpanExporterShouldRetryIfFailureToSignSigV4() }; this.options.TimeoutMilliseconds = 5000; BaseExporter exporter = new OtlpAwsSpanExporter(this.options, this.tracerProvider.GetDefaultResource(), mockAuth); - (ExportResult result, HttpRequestMessage? capturedRequest) execute = SetupMockExporterAndCaptureRequest(exporter, response); - Assert.Equal(ExportResult.Failure, execute.result); + (ExportResult Result, HttpRequestMessage? CapturedRequest) execute = SetupMockExporterAndCaptureRequest(exporter, response); + Assert.Equal(ExportResult.Failure, execute.Result); Assert.True(mockAuth.CallCount > 1); // The delay is random for exceptions. Hard to tell how times it retries. - Assert.Null(execute.capturedRequest); + Assert.Null(execute.CapturedRequest); } this.options.TimeoutMilliseconds = 1000; @@ -210,7 +210,7 @@ private static void ValidateSigV4Headers(HttpRequestMessage? capturedRequest, st Assert.Equal(expectedAmzContentSha256, capturedRequest.Headers.GetValues(XAmzContentSha256Header).First()); } - private static (ExportResult, HttpRequestMessage?) SetupMockExporterAndCaptureRequest(BaseExporter exporter, HttpResponseMessage response) + private static (ExportResult Result, HttpRequestMessage? CapturedRequest) SetupMockExporterAndCaptureRequest(BaseExporter exporter, HttpResponseMessage response) { HttpRequestMessage? capturedRequest = null; diff --git a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/RegionalResourceArnParserTest.cs b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/RegionalResourceArnParserTest.cs index aa2f6b69..1a3edf9b 100644 --- a/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/RegionalResourceArnParserTest.cs +++ b/test/AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests/RegionalResourceArnParserTest.cs @@ -7,7 +7,7 @@ namespace AWS.Distro.OpenTelemetry.AutoInstrumentation.Tests; [System.Diagnostics.CodeAnalysis.SuppressMessage("StyleCop.CSharp.DocumentationRules", "SA1600:Elements should be documented", Justification = "Tests")] -public class RegionalResourceArnParserTests +public class RegionalResourceArnParserTest { [Theory] [InlineData(null, null)]