/
dsrelax
/
Tarantool.Queue.NetCore
Обзор
Документация
Войти
/
dsrelax
/
Tarantool.Queue.NetCore
Код
Запросы
0
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
master
src/IConsumer.cs
21 строка
731 B
Дмитрий
Добавьте файлы проекта.
27 янв 2024, 11:19
27 янв 2024, 11:19
331f11f
Код
Авторство
О чём код?
using Tarantool.Queues.Model; using Tarantool.Queues.Options; namespace Tarantool.Queues { public interface IConsumer<TQueueTubeOption> : ITubeClient where TQueueTubeOption : TubeOptions { Task<TubeTask> Release(TubeTask tubeTask, TQueueTubeOption? opts = null); Task<ConsumeResult> Consume(int? timeout, CancellationToken cancellationToken, TQueueTubeOption? opts = null); Task<TubeTask> Delete(TubeTask tubeTask); Task<TubeTask> Bury(TubeTask tubeTask); Task<TubeTask> Touch(TubeTask tubeTask, TimeSpan delta); Task<TubeTask> Peek(TubeTask tubeTask); } internal interface IConsumerCommitter { Task<TubeTask> Ack(TubeTask tubeTask); } }