Ez4.DbLeader 6.0.0

DI

    services.AddDbLeaderConfiguration(options =>
    {
        //Config Key
        options.KeyOptions = opt =>
        {
            opt.ServiceName = "data247-wk";
            //opt.IdentityName = "";
        };

        //Config Duration
        options.LockConfigOptions = opt =>
        {
            opt.Duration = TimeSpan.FromSeconds(5);
            opt.Retry = TimeSpan.FromSeconds(2);
        };

        //Store DbContext
        options.StoreOptions = opt =>
        {
            opt.ConfigureDbContext =
                builder => builder
                        .UseSqlServer("ConnectionString");
        };
    });

Usage

    var dbLeaderElector = scope.ServiceProvider.GetRequiredService<IDbLeaderElector>();
    dbLeaderElector.OnGetLock += async (string name) =>
    {
        Console.WriteLine($"{DateTime.Now.ToLongTimeString()} {name}: start");
    };

    dbLeaderElector.OnReleaseLock += async (string newIndentity) =>
    {
        Console.WriteLine($"{DateTime.Now.ToLongTimeString()} {newIndentity}: Take lock");
    };

    dbLeaderElector.OnError += (Exception ex) =>
    {
        Console.WriteLine(ex.GetBaseException().ToString());
    };
    await dbLeaderElector.RunAsync(token);