Skip to content

Commit

Permalink
Remove obsolete methods that only applied to V1
Browse files Browse the repository at this point in the history
  • Loading branch information
andrewlock committed Oct 24, 2023
1 parent 7a59b2a commit 6564ceb
Show file tree
Hide file tree
Showing 6 changed files with 6 additions and 75 deletions.
16 changes: 0 additions & 16 deletions tracer/src/Datadog.Trace/Telemetry/ITelemetryController.cs
Original file line number Diff line number Diff line change
Expand Up @@ -35,27 +35,11 @@ internal interface ITelemetryController
/// </summary>
void RecordTracerSettings(ImmutableTracerSettings settings, string defaultServiceName);

/// <summary>
/// Called when app sec security is enabled to record the security settings
/// </summary>
public void RecordSecuritySettings(SecuritySettings settings);

/// <summary>
/// Called when IAST security is enabled to record the IAST settings
/// </summary>
public void RecordIastSettings(IastSettings settings);

/// <summary>
/// Called to record profiler-related telemetry
/// </summary>
public void RecordProfilerSettings(Profiler profiler);

/// <summary>
/// Dispose resources for sending telemetry
/// </summary>
/// <param name="sendAppClosingTelemetry">True if the controller should send "app closing" telemetry before disposing</param>
public Task DisposeAsync(bool sendAppClosingTelemetry);

/// <summary>
/// Dispose resources for sending telemetry
/// </summary>
Expand Down
13 changes: 0 additions & 13 deletions tracer/src/Datadog.Trace/Telemetry/NullTelemetryController.cs
Original file line number Diff line number Diff line change
Expand Up @@ -32,19 +32,10 @@ public void RecordTracerSettings(ImmutableTracerSettings settings, string defaul
{
}

public void RecordSecuritySettings(SecuritySettings settings)
{
}

public void RecordProfilerSettings(Profiler profiler)
{
}

public Task DisposeAsync(bool sendAppClosingTelemetry)
{
return Task.CompletedTask;
}

public void Start()
{
}
Expand All @@ -57,9 +48,5 @@ public Task DisposeAsync()
{
return Task.CompletedTask;
}

public void RecordIastSettings(IastSettings settings)
{
}
}
}
17 changes: 0 additions & 17 deletions tracer/src/Datadog.Trace/Telemetry/TelemetryControllerV2.cs
Original file line number Diff line number Diff line change
Expand Up @@ -9,11 +9,9 @@
using System.Reflection;
using System.Threading;
using System.Threading.Tasks;
using Datadog.Trace.AppSec;
using Datadog.Trace.Configuration;
using Datadog.Trace.Configuration.Telemetry;
using Datadog.Trace.ContinuousProfiler;
using Datadog.Trace.Iast.Settings;
using Datadog.Trace.Logging;
using Datadog.Trace.Telemetry.Collectors;
using Datadog.Trace.Telemetry.Metrics;
Expand Down Expand Up @@ -95,16 +93,6 @@ public void Start()
public void ProductChanged(TelemetryProductType product, bool enabled, ErrorData? error)
=> _products.ProductChanged(product, enabled, error);

public void RecordSecuritySettings(SecuritySettings settings)
{
// Nothing to record, remove this method when telemetry V1 is removed
}

public void RecordIastSettings(IastSettings settings)
{
// Nothing to record, remove this method when telemetry V1 is removed
}

public void RecordProfilerSettings(Profiler profiler)
{
_configuration.Record(ConfigTelemetryData.ProfilerLoaded, profiler.Status.IsProfilerReady, ConfigurationOrigins.Default);
Expand All @@ -123,11 +111,6 @@ public void IntegrationGeneratedSpan(IntegrationId integrationId)
public void IntegrationDisabledDueToError(IntegrationId integrationId, string error)
=> _integrations.IntegrationDisabledDueToError(integrationId, error);

public Task DisposeAsync(bool sendAppClosingTelemetry)
{
return Task.CompletedTask;
}

public async Task DisposeAsync()
{
TerminateLoop();
Expand Down
11 changes: 2 additions & 9 deletions tracer/src/Datadog.Trace/TracerManager.cs
Original file line number Diff line number Diff line change
Expand Up @@ -246,13 +246,6 @@ private static async Task CleanUpOldTracerManager(TracerManager oldManager, Trac
oldManager.Statsd?.Dispose();
}

var telemetryReplaced = false;
if (oldManager.Telemetry != newManager.Telemetry && oldManager.Telemetry is not null)
{
telemetryReplaced = true;
await oldManager.Telemetry.DisposeAsync(sendAppClosingTelemetry: false).ConfigureAwait(false);
}

var discoveryReplaced = false;
if (oldManager.DiscoveryService != newManager.DiscoveryService && oldManager.DiscoveryService is not null)
{
Expand Down Expand Up @@ -283,8 +276,8 @@ private static async Task CleanUpOldTracerManager(TracerManager oldManager, Trac

Log.Information(
exception: null,
"Replaced global instances. AgentWriter: {AgentWriterReplaced}, StatsD: {StatsDReplaced}, RuntimeMetricsWriter: {RuntimeMetricsWriterReplaced}, Telemetry: {TelemetryReplaced}, Discovery: {DiscoveryReplaced}, DataStreamsManager: {DataStreamsManagerReplaced}, RemoteConfigurationManager: {ConfigurationManagerReplaced}, DynamicConfigurationManager: {DynamicConfigurationManagerReplaced}",
new object[] { agentWriterReplaced, statsdReplaced, runtimeMetricsWriterReplaced, telemetryReplaced, discoveryReplaced, dataStreamsReplaced, configurationManagerReplaced, dynamicConfigurationManagerReplaced });
"Replaced global instances. AgentWriter: {AgentWriterReplaced}, StatsD: {StatsDReplaced}, RuntimeMetricsWriter: {RuntimeMetricsWriterReplaced}, Discovery: {DiscoveryReplaced}, DataStreamsManager: {DataStreamsManagerReplaced}, RemoteConfigurationManager: {ConfigurationManagerReplaced}, DynamicConfigurationManager: {DynamicConfigurationManagerReplaced}",
new object[] { agentWriterReplaced, statsdReplaced, runtimeMetricsWriterReplaced, discoveryReplaced, dataStreamsReplaced, configurationManagerReplaced, dynamicConfigurationManagerReplaced });
}
catch (Exception ex)
{
Expand Down
11 changes: 4 additions & 7 deletions tracer/src/Datadog.Trace/TracerManagerFactory.cs
Original file line number Diff line number Diff line change
Expand Up @@ -137,14 +137,11 @@ internal TracerManager CreateTracerManager(
telemetry ??= CreateTelemetryController(settings, discoveryService);
telemetry.RecordTracerSettings(settings, defaultServiceName);

var security = Security.Instance;
telemetry.RecordSecuritySettings(security.Settings);
TelemetryFactory.Metrics.SetWafVersion(security.DdlibWafVersion);
telemetry.RecordIastSettings(Datadog.Trace.Iast.Iast.Instance.Settings);
ErrorData? initError = !string.IsNullOrEmpty(security.InitializationError)
? new ErrorData(TelemetryErrorCode.AppsecConfigurationError, security.InitializationError)
TelemetryFactory.Metrics.SetWafVersion(Security.Instance.DdlibWafVersion);
ErrorData? initError = !string.IsNullOrEmpty(Security.Instance.InitializationError)
? new ErrorData(TelemetryErrorCode.AppsecConfigurationError, Security.Instance.InitializationError)
: null;
telemetry.ProductChanged(TelemetryProductType.AppSec, enabled: security.Enabled, initError);
telemetry.ProductChanged(TelemetryProductType.AppSec, enabled: Security.Instance.Enabled, initError);

var profiler = Profiler.Instance;
telemetry.RecordProfilerSettings(profiler);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -124,19 +124,10 @@ public void RecordTracerSettings(ImmutableTracerSettings settings, string defaul
{
}

public void RecordSecuritySettings(SecuritySettings settings)
{
}

public void RecordProfilerSettings(Profiler profiler)
{
}

public Task DisposeAsync(bool sendAppClosingTelemetry)
{
return Task.CompletedTask;
}

public Task DisposeAsync()
{
return Task.CompletedTask;
Expand All @@ -149,10 +140,6 @@ public void Start()
public void ProductChanged(TelemetryProductType product, bool enabled, ErrorData? error)
{
}

public void RecordIastSettings(IastSettings settings)
{
}
}
}
}

0 comments on commit 6564ceb

Please sign in to comment.