in TasksTracker.Processor.Backend.Svc/Controllers/HealthController.cs [22:46]
public async Task<IActionResult> Readiness()
{
try
{
string? _instanceId = Environment.GetEnvironmentVariable("HOSTNAME");
_logger.LogInformation("Readiness::Invoked readiness endpoint by instance {0}", _instanceId);
_logger.LogInformation("Readiness::Testing state store (blob) availability by creating new dummy file by instance {0}", _instanceId);
await _daprClient.SaveStateAsync(BLOB_STORE_NAME, BLOB_KEY_NAME, DateTime.UtcNow);
_logger.LogInformation("Readiness::Deleting dummy file from state store (blob) by instance {0}", _instanceId);
await _daprClient.DeleteStateAsync(BLOB_STORE_NAME, BLOB_KEY_NAME);
}
catch (Exception e)
{
_logger.LogCritical(e, "Exception while invoking Readiness prob");
return new StatusCodeResult(StatusCodes.Status503ServiceUnavailable);
}
return Ok();
}