Iskra.Clients.SequenceGenerator 1.0.30

Iskra.Clients.SequenceGenerator

Описание

Пакет Iskra.Clients.SequenceGenerator предоставляет клиентскую библиотеку для работы с генератором последовательностей. Он позволяет создавать, обновлять, удалять и получать счетчики последовательностей, а также получать следующие значения этих счетчиков.

Установка

Установите пакет через NuGet:

dotnet add package Iskra.Clients.SequenceGenerator

Использование

1. Конфигурация

Добавьте пакет в ваш проект и настройте его в Startup.cs или Program.cs вашего приложения.

В Startup.cs:

public void ConfigureServices(IServiceCollection services)
{
 // Добавление генератора последовательностей с фоновым сервисом для проверки существования необходимых счетчиков
 services.AddReoSequenceGeneratorWithCounterNameExistsChecking(Configuration);
}

В Program.cs (для .NET 6 и выше):

public static IHostBuilder CreateHostBuilder(string[] args) =>
 Host.CreateDefaultBuilder(args)
 .ConfigureServices((context, services) =>
 {
 // Добавление генератора последовательностей с фоновым сервисом для проверки существования необходимых счетчиков
 services.AddReoSequenceGeneratorWithCounterNameExistsChecking(context.Configuration);
 });

2. Использование клиента

Внедрите ISequenceGeneratorClient в ваш класс и используйте его методы для работы с счетчиками последовательностей.

public class SequenceService
{
 private readonly ISequenceGeneratorClient _sequenceGeneratorClient;

 public SequenceService(ISequenceGeneratorClient sequenceGeneratorClient)
 {
 _sequenceGeneratorClient = sequenceGeneratorClient;
 }

 public async Task<int> GetNextSequenceValue(string name, CancellationToken token = default)
 {
 var sequence = await _sequenceGeneratorClient.GetNextAsync(name, token);
 return sequence.Value;
 }
}

3. Методы клиента

Получение счетчика последовательности

Task<Sequence> GetAsync(string name, CancellationToken token);

Обновление счетчика последовательности

Task<Sequence> UpdateAsync(string name, int value, CancellationToken token);

Создание счетчика последовательности

Task<Sequence> CreateAsync(string name, CancellationToken token);

Удаление счетчика последовательности

Task<bool> DeleteAsync(string name, CancellationToken token);

Получение списка всех счетчиков последовательностей

Task<IReadOnlyCollection<Sequence>> GetAllAsync(CancellationToken token);

Получение следующего значения счетчика последовательности

Task<Sequence> GetNextAsync(string name, CancellationToken token);

Получение нескольких значений счетчика последовательности

Task<BulkSequence> GetNextBulkAsync(string name, int chunkSize, CancellationToken token);

Примеры

Создание и получение следующего значения счетчика

public async Task<int> CreateAndGetNextValue(string sequenceName)
{
 // Создаем счетчик последовательности
 await _sequenceGeneratorClient.CreateAsync(sequenceName);

 // Получаем следующее значение счетчика
 var nextSequence = await _sequenceGeneratorClient.GetNextAsync(sequenceName);
 return nextSequence.Value;
}

Обновление и получение следующего значения счетчика

public async Task<int> UpdateAndGetNextValue(string sequenceName, int newValue)
{
 // Обновляем значение счетчика
 await _sequenceGeneratorClient.UpdateAsync(sequenceName, newValue);

 // Получаем следующее значение счетчика
 var nextSequence = await _sequenceGeneratorClient.GetNextAsync(sequenceName);
 return nextSequence.Value;
}