Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@

using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.DependencyInjection.Extensions;
using Microsoft.Extensions.Logging;
using OpenTelemetry.Internal;
using OpenTelemetry.Resources;

Expand All @@ -28,6 +29,24 @@ namespace OpenTelemetry.Logs;
/// </summary>
internal static class LoggerProviderBuilderExtensions
{
/// <summary>
/// Registers a configuration action for the <see
/// cref="OpenTelemetryLoggerOptions"/> used by <see cref="ILogger"/>
/// integration (<see cref="OpenTelemetryLoggerProvider"/>).
/// </summary>
/// <param name="loggerProviderBuilder"><see cref="LoggerProviderBuilder"/>.</param>
/// <param name="configure">Configuration action.</param>
/// <returns>Returns <see cref="LoggerProviderBuilder"/> for chaining.</returns>
public static LoggerProviderBuilder ConfigureLoggerOptions(
this LoggerProviderBuilder loggerProviderBuilder,
Action<OpenTelemetryLoggerOptions> configure)
{
Guard.ThrowIfNull(configure);

return loggerProviderBuilder.ConfigureServices(
services => services.Configure(configure));
}

/// <summary>
/// Sets the <see cref="ResourceBuilder"/> from which the Resource associated with
/// this provider is built from. Overwrites currently set ResourceBuilder.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -89,6 +89,7 @@ public class OpenTelemetryLoggerOptions
/// </summary>
/// <param name="processor">Log processor to add.</param>
/// <returns>Returns <see cref="OpenTelemetryLoggerOptions"/> for chaining.</returns>
// todo: [Obsolete("Use the LoggerProviderBuilder class to manage processors. The AddProcessor method on OpenTelemetryLoggerOptions will be removed in a future version.")]
public OpenTelemetryLoggerOptions AddProcessor(BaseProcessor<LogRecord> processor)
{
Guard.ThrowIfNull(processor);
Expand All @@ -104,6 +105,7 @@ public OpenTelemetryLoggerOptions AddProcessor(BaseProcessor<LogRecord> processo
/// </summary>
/// <param name="resourceBuilder"><see cref="ResourceBuilder"/> from which Resource will be built.</param>
/// <returns>Returns <see cref="OpenTelemetryLoggerOptions"/> for chaining.</returns>
// todo: [Obsolete("Use the LoggerProviderBuilder class to manage resources. The AddProcessor method on OpenTelemetryLoggerOptions will be removed in a future version.")]
public OpenTelemetryLoggerOptions SetResourceBuilder(ResourceBuilder resourceBuilder)
{
Guard.ThrowIfNull(resourceBuilder);
Expand Down
115 changes: 77 additions & 38 deletions src/OpenTelemetry/Logs/ILogger/OpenTelemetryLoggingExtensions.cs
Original file line number Diff line number Diff line change
Expand Up @@ -41,45 +41,10 @@ public static class OpenTelemetryLoggingExtensions
/// </remarks>
/// <param name="builder">The <see cref="ILoggingBuilder"/> to use.</param>
/// <returns>The supplied <see cref="ILoggingBuilder"/> for call chaining.</returns>
// todo: [Obsolete("Call AddOpenTelemetryLogging instead the AddOpenTelemetry method will be removed in a future version.")]
public static ILoggingBuilder AddOpenTelemetry(
this ILoggingBuilder builder)
{
Guard.ThrowIfNull(builder);

builder.AddConfiguration();

// Note: This will bind logger options element (eg "Logging:OpenTelemetry") to OpenTelemetryLoggerOptions
LoggerProviderOptions.RegisterProviderOptions<OpenTelemetryLoggerOptions, OpenTelemetryLoggerProvider>(builder.Services);

new LoggerProviderServiceCollectionBuilder(builder.Services).ConfigureBuilder(
(sp, logging) =>
{
var options = sp.GetRequiredService<IOptionsMonitor<OpenTelemetryLoggerOptions>>().CurrentValue;

if (options.ResourceBuilder != null)
{
logging.SetResourceBuilder(options.ResourceBuilder);

options.ResourceBuilder = null;
}

foreach (var processor in options.Processors)
{
logging.AddProcessor(processor);
}

options.Processors.Clear();
});

builder.Services.TryAddEnumerable(
ServiceDescriptor.Singleton<ILoggerProvider, OpenTelemetryLoggerProvider>(
sp => new OpenTelemetryLoggerProvider(
sp.GetRequiredService<LoggerProvider>(),
sp.GetRequiredService<IOptionsMonitor<OpenTelemetryLoggerOptions>>().CurrentValue,
disposeProvider: false)));

return builder;
}
=> AddOpenTelemetryLogging(builder);

/// <summary>
/// Adds an OpenTelemetry logger named 'OpenTelemetry' to the <see cref="ILoggerFactory"/>.
Expand All @@ -88,15 +53,89 @@ public static ILoggingBuilder AddOpenTelemetry(
/// <param name="builder">The <see cref="ILoggingBuilder"/> to use.</param>
/// <param name="configure">Optional configuration action.</param>
/// <returns>The supplied <see cref="ILoggingBuilder"/> for call chaining.</returns>
// todo: [Obsolete("Call AddOpenTelemetryLogging and use LoggerProviderBuilder.ConfigureLoggerOptions instead. The AddOpenTelemetry method will be removed in a future version.")]
public static ILoggingBuilder AddOpenTelemetry(
this ILoggingBuilder builder,
Action<OpenTelemetryLoggerOptions>? configure)
{
AddOpenTelemetryLogging(builder);

if (configure != null)
{
builder.Services.Configure(configure);
}

return AddOpenTelemetry(builder);
return builder;
}

/// <summary>
/// Adds an OpenTelemetry logger named 'OpenTelemetry' to the <see cref="ILoggerFactory"/>.
/// </summary>
/// <remarks><inheritdoc cref="AddOpenTelemetry(ILoggingBuilder)" path="/remarks"/></remarks>
/// <param name="builder">The <see cref="ILoggingBuilder"/> to use.</param>
/// <returns>The supplied <see cref="ILoggingBuilder"/> for call chaining.</returns>
internal static ILoggingBuilder AddOpenTelemetryLogging(
this ILoggingBuilder builder)
=> AddOpenTelemetryLogging(builder, b => { });

/// <summary>
/// Adds an OpenTelemetry logger named 'OpenTelemetry' to the <see cref="ILoggerFactory"/>.
/// </summary>
/// <remarks><inheritdoc cref="AddOpenTelemetry(ILoggingBuilder)" path="/remarks"/></remarks>
/// <param name="builder">The <see cref="ILoggingBuilder"/> to use.</param>
/// <param name="configure">Configuration action.</param>
/// <returns>The supplied <see cref="ILoggingBuilder"/> for call chaining.</returns>
internal static ILoggingBuilder AddOpenTelemetryLogging(
this ILoggingBuilder builder,
Action<LoggerProviderBuilder> configure)
{
Guard.ThrowIfNull(configure);

AddOpenTelemetryLoggerIntegration(builder);

var loggerBuilder = new LoggerProviderServiceCollectionBuilder(builder.Services);

// Note: This code is to support legacy AddProcessor & SetResourceBuilder APIs on OpenTelemetryLoggerOptions.
loggerBuilder.ConfigureBuilder((sp, sdkLoggerBuilder) =>
{
var options = sp.GetRequiredService<IOptionsMonitor<OpenTelemetryLoggerOptions>>().CurrentValue;

if (options.ResourceBuilder != null)
{
sdkLoggerBuilder.SetResourceBuilder(options.ResourceBuilder);

options.ResourceBuilder = null;
}

foreach (var processor in options.Processors)
{
sdkLoggerBuilder.AddProcessor(processor);
}

options.Processors.Clear();
});

configure(loggerBuilder);

return builder;
}

private static void AddOpenTelemetryLoggerIntegration(ILoggingBuilder builder)
{
Guard.ThrowIfNull(builder);

builder.AddConfiguration();

// Note: This will bind logger options element (eg "Logging:OpenTelemetry") to OpenTelemetryLoggerOptions
LoggerProviderOptions.RegisterProviderOptions<OpenTelemetryLoggerOptions, OpenTelemetryLoggerProvider>(builder.Services);

builder.Services.AddOpenTelemetrySharedProviderBuilderServices();

builder.Services.TryAddEnumerable(
ServiceDescriptor.Singleton<ILoggerProvider, OpenTelemetryLoggerProvider>(
sp => new OpenTelemetryLoggerProvider(
sp.GetRequiredService<LoggerProvider>(),
sp.GetRequiredService<IOptionsMonitor<OpenTelemetryLoggerOptions>>().CurrentValue,
disposeProvider: false)));
}
}