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; }