/
dsrelax
/
Tarantool.Queue.NetCore
Обзор
Документация
Войти
/
dsrelax
/
Tarantool.Queue.NetCore
Код
Запросы
0
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
master
src/ITube.cs
24 строки
906 B
Дмитрий
Support of the user queue tubes is added
31 янв 2024, 23:01
31 янв 2024, 23:01
8c2adc8
Код
Авторство
О чём код?
using Tarantool.Queues.Model; using Tarantool.Queues.Options; namespace Tarantool.Queues { public interface ITube { string Name { get; } TubeCreationOptions CreationOptions { get;} QueueType TubeType { get; } Task<QueueTubeStatistic> GetStatistics(); Task<TubeTask> Put(string data, TubeOptions opts); Task<TubeTask?> Take(int? timeout, CancellationToken cancellationToken); Task<TubeTask?> Take(int? timeout, TubeOptions opts, CancellationToken cancellationToken); Task<TubeTask> Ack(ulong taskId); Task<TubeTask> Delete(ulong taskId); Task<TubeTask> Release(ulong task_id, TubeOptions opts); Task<TubeTask> Bury(ulong taskId); Task<ulong> Kick(ulong count); Task<TubeTask> Peek(ulong taskId); Task<TubeTask> Touch(ulong taskId, TimeSpan delta); Task ReleaseAll(); } }