Compare commits
6 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 8a8ed98a91 | |||
| 4b8aecc779 | |||
| f4a350b2e3 | |||
| e61f628804 | |||
| 56dbe85868 | |||
| 8fa3ac7546 |
@@ -104,6 +104,7 @@ steps:
|
||||
- mkdir -p $HOME/.kube
|
||||
- echo "$KUBE_CONFIG" > $HOME/.kube/config
|
||||
- kubectl apply -f litecharms-scheduler.yml
|
||||
- sleep 10
|
||||
- kubectl rollout restart statefulset/litecharms-scheduler -n litecharms-scheduler
|
||||
|
||||
depends_on:
|
||||
|
||||
@@ -8,8 +8,7 @@
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="LiteCharms.Abstractions" Version="1.20.0" />
|
||||
<PackageReference Include="Microsoft.Extensions.Hosting" Version="10.0.7" />
|
||||
<PackageReference Include="Microsoft.Extensions.Hosting" Version="10.0.8" />
|
||||
<PackageReference Include="Mediator.SourceGenerator" Version="3.0.2">
|
||||
<PrivateAssets>all</PrivateAssets>
|
||||
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
|
||||
@@ -18,9 +17,7 @@
|
||||
|
||||
<!-- Lite Charms Libraries -->
|
||||
<ItemGroup>
|
||||
<PackageReference Include="LiteCharms.Extensions" Version="1.20.0" />
|
||||
<PackageReference Include="LiteCharms.Features" Version="1.20.0" />
|
||||
<PackageReference Include="LiteCharms.Models" Version="1.20.0" />
|
||||
<PackageReference Include="LiteCharms.Features" Version="1.26.0" />
|
||||
</ItemGroup>
|
||||
|
||||
<!-- Shared Global Usings -->
|
||||
|
||||
@@ -1,17 +1,26 @@
|
||||
using LiteCharms.Extensions;
|
||||
using LiteCharms.Features.Extensions;
|
||||
using LiteCharms.Features.Mediator;
|
||||
using LiteCharmsScheduler.Workers;
|
||||
using static LiteCharms.Abstractions.Constants;
|
||||
using Mediator;
|
||||
using static LiteCharms.Features.Email.Extensions.Constants;
|
||||
|
||||
var builder = Host.CreateApplicationBuilder(args);
|
||||
|
||||
builder.Services.AddMediator();
|
||||
|
||||
builder.Services.AddScoped(typeof(IPipelineBehavior<,>), typeof(TelemetryPipelineBehavior<,>));
|
||||
builder.Services.AddScoped(typeof(IPipelineBehavior<,>), typeof(LoggingPipelineBehavior<,>));
|
||||
|
||||
builder.Services.AddEmailServices(builder.Configuration);
|
||||
builder.Services.AddEmailServiceBus();
|
||||
|
||||
builder.Services.AddSalesServiceBus();
|
||||
builder.Services.AddGeneralServiceBus();
|
||||
builder.Services.AddEmailServices(builder.Configuration);
|
||||
builder.Services.AddShopDatabase(builder.Configuration);
|
||||
builder.Services.AddQuartzSchedulerClient(ShopSchedulerName, builder.Configuration);
|
||||
|
||||
builder.Services.AddShopServices();
|
||||
builder.Services.AddShopDatabase(builder.Configuration);
|
||||
|
||||
builder.Services.AddHostedService<JobWorker>();
|
||||
|
||||
var host = builder.Build();
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
using LiteCharms.Abstractions;
|
||||
using LiteCharms.Features.Notifications.Events;
|
||||
using LiteCharms.Features.Quartz.Abstractions;
|
||||
using LiteCharms.Features.Shop.Notifications.Events;
|
||||
|
||||
namespace LiteCharmsScheduler.Workers
|
||||
{
|
||||
@@ -7,7 +7,7 @@ namespace LiteCharmsScheduler.Workers
|
||||
{
|
||||
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
||||
{
|
||||
await jobOrchestrator.ScheduleAsync(ProcessEmailNotificationsEvent.Create(), "0 1 * * * ?", stoppingToken);
|
||||
await jobOrchestrator.ScheduleAsync(ProcessEmailNotificationsEvent.Create(), "0 0/1 * * * ?", stoppingToken);
|
||||
|
||||
logger.LogInformation("Startup jobs scheduled");
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user