SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Refactor

Browse source
This commit is contained in:
Gürkan Güran 2023-01-11 01:47:49 +01:00
parent 7ebec21125
commit 3fd73bd2d0
2 changed files with 1 additions and 32 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/modules/Elsa.Elasticsearch/HostedServices/ConfigureIndexRolloverHostedService.cs
View file

@ -20,8 +20,7 @@ public class ConfigureIndexRolloverHostedService : IHostedService
var schedule = new CronSchedule
{
// At the beginning of every month
//CronExpression = "0 0 1 * *"
CronExpression = "*/5 * * * *"
CronExpression = "0 0 1 * *"
};
await _jobScheduler.ScheduleAsync(job, GetType().Name, schedule, cancellationToken: cancellationToken);

30
src/modules/Elsa.Elasticsearch/Implementations/RolloverStrategies/RolloverOnMonthlyBasis.cs
View file

@ -19,47 +19,17 @@ public class RolloverOnMonthlyBasis : IIndexRolloverStrategy
var getAliasResponse = await _client.Indices.GetAliasAsync(cancellationToken);
var aliases = getAliasResponse.Aliases.Values.SelectMany(s => s.Aliases.Select(a => a.Key));
//foreach (var (currentIndexName, aliasPointingCurrentIndex) in await GetAliasesWithTargetIndices(cancellationToken))
foreach (var alias in aliases)
{
var newIndexName = _indexNamingStrategy.GenerateName(alias);
var indexExists = (await _client.Indices.ExistsAsync(newIndexName, cancellationToken)).Exists;
if (indexExists) continue;
//await _client.Indices.CreateAsync(newIndexName, cancellationToken);
await _client.Indices.RolloverAsync(
alias,
cfg => cfg.NewIndex(newIndexName),
cancellationToken);
// // Update alias to recognize current index as read-only
// await _client.Indices.DeleteAliasAsync(currentIndexName, aliasPointingCurrentIndex, cancellationToken);
// await _client.Indices.PutAliasAsync(currentIndexName, aliasPointingCurrentIndex,
// cfg => cfg.IsWriteIndex(false), cancellationToken);
//
// // Point the alias to the new index
// await _client.Indices.PutAliasAsync(newIndexName, aliasPointingCurrentIndex,
// cfg => cfg.IsWriteIndex(), cancellationToken);
}
}
private async Task<IReadOnlyDictionary<string, string>> GetAliasesWithTargetIndices(CancellationToken cancellationToken)
{
var aliasesWithIndices = new Dictionary<string, string>();
var indicesResponse = await _client.Indices.GetAsync(Indices.All, cancellationToken);
var groupOfIndexWithAliases = indicesResponse.Indices.Values.Select(s => s
.Aliases!.Where(a => a.Value.IsWriteIndex != null && (bool)a.Value.IsWriteIndex));
foreach (var indexWithAliasList in groupOfIndexWithAliases)
{
// Only 1 alias exists per index in Elsa Elasticsearch configuration
var alias = indexWithAliasList.Single();
aliasesWithIndices.TryAdd(alias.Key.ToString(), alias.Value.ToString()!);
}
return aliasesWithIndices;
}
}