Add IsRealTime Flag
This commit is contained in:
parent
964de973fb
commit
2e00e7bed9
|
|
@ -5,5 +5,10 @@ namespace BotSharp.Core.Crontab.Abstraction;
|
|||
/// </summary>
|
||||
public interface ICrontabSource
|
||||
{
|
||||
/// <summary>
|
||||
/// Set to true if the cron is real-time like Change Data Capture (CDC).
|
||||
/// </summary>
|
||||
bool IsRealTime => false;
|
||||
|
||||
CrontabItem GetCrontabItem();
|
||||
}
|
||||
|
|
|
|||
|
|
@ -51,6 +51,10 @@ public class CrontabService : ICrontabService, ITaskFeeder
|
|||
var cronsources = _services.GetServices<ICrontabSource>();
|
||||
foreach (var source in cronsources)
|
||||
{
|
||||
if (source.IsRealTime)
|
||||
{
|
||||
continue;
|
||||
}
|
||||
var item = source.GetCrontabItem();
|
||||
fixedCrantabItems.Add(source.GetCrontabItem());
|
||||
}
|
||||
|
|
|
|||
|
|
@ -45,7 +45,6 @@ public class CrontabWatcher : BackgroundService
|
|||
{
|
||||
var cron = services.GetRequiredService<ICrontabService>();
|
||||
var crons = await cron.GetCrontable();
|
||||
|
||||
var publisher = services.GetService<IEventPublisher>();
|
||||
|
||||
foreach (var item in crons)
|
||||
|
|
|
|||
Loading…
Reference in a new issue