EonaCat.Logger.Sentinel 1.0.0

EonaCat.Logger.Sentinel

Send logs to Redis for Sentinel using EonaCat.Logger.Sentinel.

builder.Logging.AddEonaCatSentinelLogger(options =>
{
    options.SentinelHosts = new() { "127.0.0.1:26379", "127.0.0.2:26379" };
    options.MasterName = "mymaster";
    options.RedisPassword = "redispass";
    options.RedisKey = "eonacat:logs";
    options.SinkMode = RedisSinkMode.Stream;
    options.ExpireAfter = TimeSpan.FromDays(1); // only for List mode
});

Consumer example:

using StackExchange.Redis;
using System;
using System.Threading.Tasks;

class StreamLogConsumer
{
    public static async Task StartAsync(string redisHost, string redisKey = "eonacat:logs")
    {
        var redis = await ConnectionMultiplexer.ConnectAsync(redisHost);
        var db = redis.GetDatabase();

        string lastId = "0-0";

        while (true)
        {
            var entries = db.StreamRead(redisKey, lastId, count: 10);
            foreach (var entry in entries)
            {
                foreach (var value in entry.Values)
                {
                    Console.WriteLine($"[{entry.Id}] {value.Name}: {value.Value}");
                }
                lastId = entry.Id;
            }

            await Task.Delay(500); // wait for more logs
        }
    }
}

Usage example:

await StreamLogConsumer.StartAsync("localhost:6379", "eonacat:logs");

Pub/Sub Subscriber example:

using StackExchange.Redis;
using System;
using System.Threading.Tasks;

class PubSubLogSubscriber
{
    public static async Task StartAsync(string redisHost, string channel = "eonacat:logs")
    {
        var redis = await ConnectionMultiplexer.ConnectAsync(redisHost);
        var sub = redis.GetSubscriber();

        await sub.SubscribeAsync(channel, (chan, msg) =>
        {
            Console.WriteLine($"[PubSub] {msg}");
        });

        Console.WriteLine($"Subscribed to channel: {channel}");
        await Task.Delay(-1); // keep alive
    }
}

Kibana Ready JSON example:

{
  "@timestamp": "2025-06-28T13:00:00Z",
  "level": "Information",
  "message": "Some log message",
  "exception": null,
  "application": "EonaCat",
  "context": { "CorrelationId": "abc123" }
}