Skip to content

Commit

Permalink
File scoped namespaces
Browse files Browse the repository at this point in the history
  • Loading branch information
niemyjski committed Jan 5, 2024
1 parent 1ba4a4f commit 56b7d7f
Show file tree
Hide file tree
Showing 238 changed files with 21,949 additions and 22,190 deletions.
29 changes: 14 additions & 15 deletions samples/Foundatio.HostingSample/Jobs/EvenMinutesJob.cs
Original file line number Diff line number Diff line change
Expand Up @@ -4,25 +4,24 @@
using Foundatio.Jobs;
using Microsoft.Extensions.Logging;

namespace Foundatio.HostingSample
namespace Foundatio.HostingSample;

public class EvenMinutesJob : IJob
{
public class EvenMinutesJob : IJob
{
private readonly ILogger _logger;
private readonly ILogger _logger;

public EvenMinutesJob(ILoggerFactory loggerFactory)
{
_logger = loggerFactory.CreateLogger<EvenMinutesJob>();
}
public EvenMinutesJob(ILoggerFactory loggerFactory)
{
_logger = loggerFactory.CreateLogger<EvenMinutesJob>();
}

public async Task<JobResult> RunAsync(CancellationToken cancellationToken = default)
{
if (_logger.IsEnabled(LogLevel.Information))
_logger.LogInformation("EvenMinuteJob Run Thread={ManagedThreadId}", Thread.CurrentThread.ManagedThreadId);
public async Task<JobResult> RunAsync(CancellationToken cancellationToken = default)
{
if (_logger.IsEnabled(LogLevel.Information))
_logger.LogInformation("EvenMinuteJob Run Thread={ManagedThreadId}", Thread.CurrentThread.ManagedThreadId);

await Task.Delay(TimeSpan.FromSeconds(5));
await Task.Delay(TimeSpan.FromSeconds(5));

return JobResult.Success;
}
return JobResult.Success;
}
}
29 changes: 14 additions & 15 deletions samples/Foundatio.HostingSample/Jobs/EveryMinuteJob.cs
Original file line number Diff line number Diff line change
Expand Up @@ -4,25 +4,24 @@
using Foundatio.Jobs;
using Microsoft.Extensions.Logging;

namespace Foundatio.HostingSample
namespace Foundatio.HostingSample;

public class EveryMinuteJob : IJob
{
public class EveryMinuteJob : IJob
{
private readonly ILogger _logger;
private readonly ILogger _logger;

public EveryMinuteJob(ILoggerFactory loggerFactory)
{
_logger = loggerFactory.CreateLogger<EveryMinuteJob>();
}
public EveryMinuteJob(ILoggerFactory loggerFactory)
{
_logger = loggerFactory.CreateLogger<EveryMinuteJob>();
}

public async Task<JobResult> RunAsync(CancellationToken cancellationToken = default)
{
if (_logger.IsEnabled(LogLevel.Information))
_logger.LogInformation("EveryMinuteJob Run Thread={ManagedThreadId}", Thread.CurrentThread.ManagedThreadId);
public async Task<JobResult> RunAsync(CancellationToken cancellationToken = default)
{
if (_logger.IsEnabled(LogLevel.Information))
_logger.LogInformation("EveryMinuteJob Run Thread={ManagedThreadId}", Thread.CurrentThread.ManagedThreadId);

await Task.Delay(TimeSpan.FromSeconds(4));
await Task.Delay(TimeSpan.FromSeconds(4));

return JobResult.Success;
}
return JobResult.Success;
}
}
33 changes: 16 additions & 17 deletions samples/Foundatio.HostingSample/Jobs/Sample1Job.cs
Original file line number Diff line number Diff line change
Expand Up @@ -3,26 +3,25 @@
using Foundatio.Jobs;
using Microsoft.Extensions.Logging;

namespace Foundatio.HostingSample
namespace Foundatio.HostingSample;

[Job(Description = "Sample 1 job", Interval = "5s", IterationLimit = 5)]
public class Sample1Job : IJob
{
[Job(Description = "Sample 1 job", Interval = "5s", IterationLimit = 5)]
public class Sample1Job : IJob
{
private readonly ILogger _logger;
private int _iterationCount = 0;
private readonly ILogger _logger;
private int _iterationCount = 0;

public Sample1Job(ILoggerFactory loggerFactory)
{
_logger = loggerFactory.CreateLogger<Sample1Job>();
}
public Sample1Job(ILoggerFactory loggerFactory)
{
_logger = loggerFactory.CreateLogger<Sample1Job>();
}

public Task<JobResult> RunAsync(CancellationToken cancellationToken = default)
{
Interlocked.Increment(ref _iterationCount);
if (_logger.IsEnabled(LogLevel.Information))
_logger.LogTrace("Sample1Job Run #{IterationCount} Thread={ManagedThreadId}", _iterationCount, Thread.CurrentThread.ManagedThreadId);
public Task<JobResult> RunAsync(CancellationToken cancellationToken = default)
{
Interlocked.Increment(ref _iterationCount);
if (_logger.IsEnabled(LogLevel.Information))
_logger.LogTrace("Sample1Job Run #{IterationCount} Thread={ManagedThreadId}", _iterationCount, Thread.CurrentThread.ManagedThreadId);

return Task.FromResult(JobResult.Success);
}
return Task.FromResult(JobResult.Success);
}
}
63 changes: 31 additions & 32 deletions samples/Foundatio.HostingSample/Jobs/Sample2Job.cs
Original file line number Diff line number Diff line change
Expand Up @@ -6,39 +6,38 @@
using Microsoft.Extensions.Diagnostics.HealthChecks;
using Microsoft.Extensions.Logging;

namespace Foundatio.HostingSample
namespace Foundatio.HostingSample;

[Job(Description = "Sample 2 job", Interval = "2s", IterationLimit = 10)]
public class Sample2Job : IJob, IHealthCheck
{
[Job(Description = "Sample 2 job", Interval = "2s", IterationLimit = 10)]
public class Sample2Job : IJob, IHealthCheck
private readonly ILogger _logger;
private int _iterationCount = 0;
private DateTime? _lastRun = null;

public Sample2Job(ILoggerFactory loggerFactory)
{
_logger = loggerFactory.CreateLogger<Sample2Job>();
}

public Task<JobResult> RunAsync(CancellationToken cancellationToken = default)
{
private readonly ILogger _logger;
private int _iterationCount = 0;
private DateTime? _lastRun = null;

public Sample2Job(ILoggerFactory loggerFactory)
{
_logger = loggerFactory.CreateLogger<Sample2Job>();
}

public Task<JobResult> RunAsync(CancellationToken cancellationToken = default)
{
_lastRun = SystemClock.UtcNow;
Interlocked.Increment(ref _iterationCount);
if (_logger.IsEnabled(LogLevel.Information))
_logger.LogTrace("Sample2Job Run #{IterationCount} Thread={ManagedThreadId}", _iterationCount, Thread.CurrentThread.ManagedThreadId);

return Task.FromResult(JobResult.Success);
}

public Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default)
{
if (!_lastRun.HasValue)
return Task.FromResult(HealthCheckResult.Healthy("Job has not been run yet."));

if (SystemClock.UtcNow.Subtract(_lastRun.Value) > TimeSpan.FromSeconds(5))
return Task.FromResult(HealthCheckResult.Unhealthy("Job has not run in the last 5 seconds."));

return Task.FromResult(HealthCheckResult.Healthy("Job has run in the last 5 seconds."));
}
_lastRun = SystemClock.UtcNow;
Interlocked.Increment(ref _iterationCount);
if (_logger.IsEnabled(LogLevel.Information))
_logger.LogTrace("Sample2Job Run #{IterationCount} Thread={ManagedThreadId}", _iterationCount, Thread.CurrentThread.ManagedThreadId);

return Task.FromResult(JobResult.Success);
}

public Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default)
{
if (!_lastRun.HasValue)
return Task.FromResult(HealthCheckResult.Healthy("Job has not been run yet."));

if (SystemClock.UtcNow.Subtract(_lastRun.Value) > TimeSpan.FromSeconds(5))
return Task.FromResult(HealthCheckResult.Unhealthy("Job has not run in the last 5 seconds."));

return Task.FromResult(HealthCheckResult.Healthy("Job has run in the last 5 seconds."));
}
}
19 changes: 9 additions & 10 deletions samples/Foundatio.HostingSample/MyCriticalHealthCheck.cs
Original file line number Diff line number Diff line change
Expand Up @@ -3,17 +3,16 @@
using System.Threading.Tasks;
using Microsoft.Extensions.Diagnostics.HealthChecks;

namespace Foundatio.HostingSample
namespace Foundatio.HostingSample;

public class MyCriticalHealthCheck : IHealthCheck
{
public class MyCriticalHealthCheck : IHealthCheck
{
private static DateTime _startTime = DateTime.Now;
private static DateTime _startTime = DateTime.Now;

public Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = new CancellationToken())
{
return DateTime.Now.Subtract(_startTime) > TimeSpan.FromSeconds(3) ?
Task.FromResult(HealthCheckResult.Healthy("Critical resource is available."))
: Task.FromResult(HealthCheckResult.Unhealthy("Critical resource not available."));
}
public Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = new CancellationToken())
{
return DateTime.Now.Subtract(_startTime) > TimeSpan.FromSeconds(3) ?
Task.FromResult(HealthCheckResult.Healthy("Critical resource is available."))
: Task.FromResult(HealthCheckResult.Unhealthy("Critical resource not available."));
}
}
Loading

0 comments on commit 56b7d7f

Please sign in to comment.