EonaCat.Logger.Pipe 1.0.0

EonaCat.Logger.Pipe

Send logs via Named Pipes (Windows) or Unix Domain Sockets (Unix) using EonaCat.Logger.Pipe.

var serviceProvider = new ServiceCollection()
    .AddLogging(builder =>
    {
        builder.ClearProviders();
        builder.AddPipeLogger(options =>
        {
            options.PipeName = RuntimeInformation.IsOSPlatform(OSPlatform.Windows) ? "MyNamedPipe" : "/tmp/mysocket.sock";
            options.MinimumLogLevel = LogLevel.Information;
        });
    })
    .BuildServiceProvider();

var logger = serviceProvider.GetRequiredService<ILogger<Program>>();
logger.LogInformation("This message goes over Named Pipe or Unix Domain Socket!");

Example on how to subscribe to events from the PipeLogger:

var options = new PipeLoggerOptions { PipeName = pipeName };
var provider = new PipeLoggerProvider(options);
var logger = (PipeLogger)provider.CreateLogger("DemoCategory");

// Subscribe to events
logger.OnLogSent += (sender, message) =>
{
    Console.WriteLine($"Event: Log sent - {message}");
};

logger.OnLogError += (sender, ex) =>
{
    Console.WriteLine($"Event: Logging error - {ex}");
};

// Use the logger directly to log
logger.Log(LogLevel.Information, new EventId(0), "Hello from event demo!", null, (state, ex) => state.ToString());

Example on how subscribe to events from the PipeLoggerProvider:

var provider = new PipeLoggerProvider(options);

provider.OnLogSent += (s, msg) => Console.WriteLine($"Provider event: Log sent - {msg}");
provider.OnLogError += (s, ex) => Console.WriteLine($"Provider event: Log error - {ex}");

// Create a logger and log
var logger = provider.CreateLogger("Demo");
logger.Log(LogLevel.Information, new EventId(0), "Testing provider events", null, (state, ex) => state.ToString());

Example for running your own Named Pipe server:

var pipeName = RuntimeInformation.IsOSPlatform(OSPlatform.Windows) ? "demopipe" : "/tmp/demopipe.sock";

            // Start server in background task
            var server = new PipeLogServer(pipeName);
            var serverTask = server.StartAsync();

            // Setup logging with PipeLogger
            var services = new ServiceCollection()
                .AddLogging(builder =>
                {
                    builder.ClearProviders();
                    builder.AddPipeLogger(options =>
                    {
                        options.PipeName = pipeName;
                        options.MinimumLogLevel = LogLevel.Information;
                    });
                })
                .BuildServiceProvider();

            var logger = services.GetRequiredService<ILogger<Program>>();

            // Log some messages
            for (int i = 0; i < 5; i++)
            {
                logger.LogInformation($"Test log message #{i + 1}");
                await Task.Delay(500);
            }

            Console.WriteLine("Press any key to exit...");
            Console.ReadKey();
        }