WormDb.Extensions 1.0.4

WormDb.Extensions

WormDb 的 ASP.NET Core 扩展包，提供 AddWormDb() 和 MapWormDbHttpApi() 两条扩展方法，一行代码将 WormDb 集成到现有 Web 应用中。

支持 Standalone / Leader / Follower 三种模式，自动处理生命周期（启动、停止、优雅退出）。

功能

核心 API

DI 注册

// 从 appsettings.json 配置
services.AddWormDb(configuration.GetSection("WormDb"));

// 或代码配置
services.AddWormDb(opts =>
{
    opts.Mode = WormDbMode.Standalone;
    opts.DataDir = "./data";
    opts.SegMaxBytes = 256 * 1024 * 1024;
    opts.TagIndexKeys = new[] { "level", "service" };
});

端点映射

// WebApplication 上
app.MapWormDbHttpApi();

// 或 IEndpointRouteBuilder 上
endpoints.MapWormDbHttpApi();

DI 可获取的服务

HTTP REST API

配置

appsettings.json

{
  "WormDb": {
    "Mode": "standalone",
    "DataDir": "./data",
    "SegMaxBytes": 268435456,
    "WriteQueueCapacity": 65536,
    "TagIndexKeys": ["level", "service"],
    "NodeId": 0,
    "LeaderAddress": null,
    "GrpcPort": 5100
  }
}

配置选项

public class WormDbOptions
{
    public WormDbMode Mode { get; set; }              // Standalone | Leader | Follower
    public string DataDir { get; set; } = "./data";
    public long SegMaxBytes { get; set; } = 256 * 1024 * 1024;
    public int WriteQueueCapacity { get; set; } = 65536;
    public string[] TagIndexKeys { get; set; } = Array.Empty<string>();
    public uint NodeId { get; set; } = 0;
    public string? LeaderAddress { get; set; }         // Follower 模式必填
    public int GrpcPort { get; set; } = 5100;          // Leader 模式必填
}

依赖

<ProjectReference Include="..\WormDb.Core\WormDb.Core.csproj" />
<ProjectReference Include="..\WormDb.Cluster\WormDb.Cluster.csproj" />


<FrameworkReference Include="Microsoft.AspNetCore.App" />


<PackageReference Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="10.0.8" />
<PackageReference Include="Microsoft.Extensions.Options.DataAnnotations" Version="10.0.8" />

使用

using WormDb.Extensions;

var builder = WebApplication.CreateBuilder(args);

// 1. 注册 WormDb 服务
builder.Services.AddWormDb(builder.Configuration.GetSection("WormDb"));

var app = builder.Build();

// 2. 映射 HTTP API 端点
app.MapWormDbHttpApi();

// 3. 启动
app.Run();