Skip to content

Commit 47c3554

Browse files
committed
remove our custom instrumentation and add #nullable to listener
1 parent 6ebecb3 commit 47c3554

25 files changed

+395
-690
lines changed

nuget.config

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,5 @@
55
<clear />
66
<add key="Azure" value="https://pkgs.dev.azure.com/datadoghq/dd-trace-dotnet/_packaging/Public_Feed/nuget/v3/index.json" />
77
<add key="nuget" value="https://api.nuget.org/v3/index.json" />
8-
<add key="quartz" value="https://f.feedz.io/quartznet/quartznet/nuget/index.json" />
98
</packageSources>
109
</configuration>

tracer/missing-nullability-files.csv

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,6 @@ src/Datadog.Trace/DiagnosticListeners/DiagnosticManager.cs
108108
src/Datadog.Trace/DiagnosticListeners/DiagnosticObserver.cs
109109
src/Datadog.Trace/DiagnosticListeners/EndpointFeatureProxy.cs
110110
src/Datadog.Trace/DiagnosticListeners/IDiagnosticManager.cs
111-
src/Datadog.Trace/DiagnosticListeners/QuartzDiagnosticObserver.cs
112111
src/Datadog.Trace/DiagnosticListeners/RouteEndpoint.cs
113112
src/Datadog.Trace/DogStatsd/NoOpStatsd.cs
114113
src/Datadog.Trace/DogStatsd/StatsdExtensions.cs
@@ -496,8 +495,6 @@ src/Datadog.Trace/ClrProfiler/AutoInstrumentation/OpenTelemetry/TracerProviderBu
496495
src/Datadog.Trace/ClrProfiler/AutoInstrumentation/Process/EnvironmentVariablesScrubber.cs
497496
src/Datadog.Trace/ClrProfiler/AutoInstrumentation/Process/ProcessStartIntegration.cs
498497
src/Datadog.Trace/ClrProfiler/AutoInstrumentation/Process/ProcessStartTags.cs
499-
src/Datadog.Trace/ClrProfiler/AutoInstrumentation/Quartz/IJobDetailImplProxy.cs
500-
src/Datadog.Trace/ClrProfiler/AutoInstrumentation/Quartz/IJobDiagnosticDataProxy.cs
501498
src/Datadog.Trace/ClrProfiler/AutoInstrumentation/RabbitMQ/RabbitMQConstants.cs
502499
src/Datadog.Trace/Debugger/Configurations/Models/Capture.cs
503500
src/Datadog.Trace/Debugger/Configurations/Models/DebuggerExpression.cs

tracer/src/Datadog.Trace/ClrProfiler/AutoInstrumentation/Quartz/IJobDetailImplProxy.cs

Lines changed: 0 additions & 35 deletions
This file was deleted.

tracer/src/Datadog.Trace/ClrProfiler/AutoInstrumentation/Quartz/IJobDiagnosticDataProxy.cs

Lines changed: 0 additions & 103 deletions
This file was deleted.

tracer/src/Datadog.Trace/ClrProfiler/AutoInstrumentation/Quartz/QuartzCommon.cs

Lines changed: 0 additions & 72 deletions
This file was deleted.

tracer/src/Datadog.Trace/Configuration/IntegrationId.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,5 @@ internal enum IntegrationId
8787
DatadogTraceManual,
8888
EmailHtmlInjection,
8989
Protobuf,
90-
Quartz
9190
}
9291
}

tracer/src/Datadog.Trace/DiagnosticListeners/QuartzDiagnosticObserver.cs

Lines changed: 7 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -3,14 +3,14 @@
33
// This product includes software developed at Datadog (https://www.datadoghq.com/). Copyright 2017 Datadog, Inc.
44
// </copyright>
55

6+
#nullable enable
67
#if !NETFRAMEWORK
78
using System;
89
using System.Collections.Generic;
910
using System.Diagnostics.CodeAnalysis;
1011
using System.Reflection;
1112
using System.Threading.Tasks;
1213
using Datadog.Trace.AppSec;
13-
using Datadog.Trace.ClrProfiler.AutoInstrumentation.Quartz;
1414
using Datadog.Trace.Configuration;
1515
using Datadog.Trace.Debugger;
1616
using Datadog.Trace.Debugger.SpanCodeOrigin;
@@ -29,22 +29,20 @@ namespace Datadog.Trace.DiagnosticListeners
2929
/// </summary>
3030
internal sealed class QuartzDiagnosticObserver : DiagnosticObserver
3131
{
32-
public const IntegrationId IntegrationId = Configuration.IntegrationId.Quartz;
33-
3432
private const string DiagnosticListenerName = "Quartz";
3533

3634
private static readonly IDatadogLogger Log = DatadogLogging.GetLoggerFor<QuartzDiagnosticObserver>();
37-
private readonly Tracer _tracer;
38-
private readonly Security _security;
39-
private readonly Iast.Iast _iast;
40-
private readonly SpanCodeOrigin _spanCodeOrigin;
35+
private readonly Tracer? _tracer;
36+
private readonly Security? _security;
37+
private readonly Iast.Iast? _iast;
38+
private readonly SpanCodeOrigin? _spanCodeOrigin;
4139

4240
public QuartzDiagnosticObserver()
4341
: this(null, null, null, null)
4442
{
4543
}
4644

47-
public QuartzDiagnosticObserver(Tracer tracer, Security security, Iast.Iast iast, SpanCodeOrigin spanCodeOrigin)
45+
public QuartzDiagnosticObserver(Tracer? tracer, Security? security, Iast.Iast? iast, SpanCodeOrigin? spanCodeOrigin)
4846
{
4947
_tracer = tracer;
5048
_security = security;
@@ -60,7 +58,7 @@ public QuartzDiagnosticObserver(Tracer tracer, Security security, Iast.Iast iast
6058

6159
private Iast.Iast CurrentIast => _iast ?? Iast.Iast.Instance;
6260

63-
private SpanCodeOrigin CurrentCodeOrigin => _spanCodeOrigin ?? DebuggerManager.Instance.CodeOrigin;
61+
private SpanCodeOrigin? CurrentCodeOrigin => _spanCodeOrigin ?? DebuggerManager.Instance.CodeOrigin;
6462

6563
protected override void OnNext(string eventName, object arg)
6664
{
@@ -70,15 +68,12 @@ protected override void OnNext(string eventName, object arg)
7068
{
7169
case "Quartz.Job.Execute.Start":
7270
case "Quartz.Job.Veto.Start":
73-
// OnStartSpan(arg);
7471
break;
7572
case "Quartz.Job.Execute.Stop":
7673
case "Quartz.Job.Veto.Stop":
77-
// OnStopSpan(arg);
7874
break;
7975
case "Quartz.Job.Execute.Exception":
8076
case "Quartz.Job.Veto.Exception":
81-
// OnException(arg);
8277
break;
8378
}
8479
}
@@ -87,27 +82,6 @@ protected override void OnNext(string eventName, object arg)
8782
Log.Error(ex, "Error processing Quartz diagnostic event: {EventName}", eventName);
8883
}
8984
}
90-
91-
private void OnStartSpan(object arg)
92-
{
93-
Log.Information("Quartz JobExecution.Start event received");
94-
QuartzCommon.CreateScope(CurrentTracer, arg, QuartzCommon.OnJobExecuteOperation);
95-
}
96-
97-
private void OnStopSpan(object arg)
98-
{
99-
Log.Information("Quartz JobExecution.Stop event received");
100-
CurrentTracer.ActiveScope.Close();
101-
}
102-
103-
private void OnException(object arg)
104-
{
105-
Log.Information("Quartz JobExecution.Exception event received");
106-
if (arg is Exception exception)
107-
{
108-
CurrentTracer.ActiveScope.Span.SetException(exception);
109-
}
110-
}
11185
}
11286
}
11387
#endif

tracer/src/Datadog.Trace/Generated/net461/Datadog.Trace.SourceGenerators/EnumExtensionsGenerator/IntegrationIdExtensions_EnumExtensions.g.cs

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ internal static partial class IntegrationIdExtensions
1717
/// The number of members in the enum.
1818
/// This is a non-distinct count of defined names.
1919
/// </summary>
20-
public const int Length = 76;
20+
public const int Length = 75;
2121

2222
/// <summary>
2323
/// Returns the string representation of the <see cref="Datadog.Trace.Configuration.IntegrationId"/> value.
@@ -105,7 +105,6 @@ public static string ToStringFast(this Datadog.Trace.Configuration.IntegrationId
105105
Datadog.Trace.Configuration.IntegrationId.DatadogTraceManual => nameof(Datadog.Trace.Configuration.IntegrationId.DatadogTraceManual),
106106
Datadog.Trace.Configuration.IntegrationId.EmailHtmlInjection => nameof(Datadog.Trace.Configuration.IntegrationId.EmailHtmlInjection),
107107
Datadog.Trace.Configuration.IntegrationId.Protobuf => nameof(Datadog.Trace.Configuration.IntegrationId.Protobuf),
108-
Datadog.Trace.Configuration.IntegrationId.Quartz => nameof(Datadog.Trace.Configuration.IntegrationId.Quartz),
109108
_ => value.ToString(),
110109
};
111110

@@ -194,7 +193,6 @@ public static Datadog.Trace.Configuration.IntegrationId[] GetValues()
194193
Datadog.Trace.Configuration.IntegrationId.DatadogTraceManual,
195194
Datadog.Trace.Configuration.IntegrationId.EmailHtmlInjection,
196195
Datadog.Trace.Configuration.IntegrationId.Protobuf,
197-
Datadog.Trace.Configuration.IntegrationId.Quartz,
198196
};
199197

200198
/// <summary>
@@ -283,6 +281,5 @@ public static string[] GetNames()
283281
nameof(Datadog.Trace.Configuration.IntegrationId.DatadogTraceManual),
284282
nameof(Datadog.Trace.Configuration.IntegrationId.EmailHtmlInjection),
285283
nameof(Datadog.Trace.Configuration.IntegrationId.Protobuf),
286-
nameof(Datadog.Trace.Configuration.IntegrationId.Quartz),
287284
};
288285
}

0 commit comments

Comments
 (0)