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

Remove elastic hosted service for alias/rollover

Browse source
This commit is contained in:
Sipke Schoorstra 2023-01-13 19:53:37 +01:00
parent 096206d392
commit 8ec2aa5b36
2 changed files with 0 additions and 73 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/modules/Elsa.Elasticsearch/Features/ElasticsearchFeature.cs
View file

@ -1,14 +1,9 @@
using Elastic.Clients.Elasticsearch;
using Elsa.Elasticsearch.Extensions;
using Elsa.Elasticsearch.HostedServices;
using Elsa.Elasticsearch.Modules.Management;
using Elsa.Elasticsearch.Modules.Runtime;
using Elsa.Elasticsearch.Options;
using Elsa.Elasticsearch.Services;
using Elsa.Features.Abstractions;
using Elsa.Features.Services;
using Elsa.Workflows.Management.Entities;
using Elsa.Workflows.Runtime.Entities;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Options;
@ -30,12 +25,6 @@ public class ElasticsearchFeature : FeatureBase
/// </summary>
public Action<ElasticsearchOptions> Options { get; set; } = _ => { };
/// <inheritdoc />
public override void ConfigureHostedServices()
{
Module.ConfigureHostedService<ConfigureAliasesHostedService>(-2);
}
/// <inheritdoc />
public override void Apply()
{

62
src/modules/Elsa.Elasticsearch/HostedServices/ConfigureAliasesHostedService.cs
View file

@ -1,62 +0,0 @@
using Elastic.Clients.Elasticsearch;
using Elastic.Clients.Elasticsearch.IndexManagement;
using Elsa.Elasticsearch.Options;
using Elsa.Elasticsearch.Services;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Options;
namespace Elsa.Elasticsearch.HostedServices;
/// <summary>
/// Configures aliases.
/// </summary>
public class ConfigureAliasesHostedService : IHostedService
{
private readonly ElasticsearchClient _client;
private readonly ElasticsearchOptions _options;
private readonly IEnumerable<IIndexConfiguration> _configurations;
/// <summary>
/// Constructor.
/// </summary>
public ConfigureAliasesHostedService(ElasticsearchClient client, IOptions<ElasticsearchOptions> options, IEnumerable<IIndexConfiguration> configurations)
{
_client = client;
_options = options.Value;
_configurations = configurations;
}
/// <inheritdoc />
public async Task StartAsync(CancellationToken cancellationToken)
{
await ConfigureClientAsync(cancellationToken);
}
/// <inheritdoc />
public Task StopAsync(CancellationToken cancellationToken) => Task.CompletedTask;
private async Task ConfigureClientAsync(CancellationToken cancellationToken)
{
foreach (var configuration in _configurations)
await configuration.ConfigureClientAsync(_client, cancellationToken);
foreach (var configuration in _configurations)
{
var alias = _options.GetIndexNameFor(configuration.DocumentType);
var indexName = configuration.IndexNamingStrategy.GenerateName(alias);
var indexExists = (await _client.Indices.ExistsAsync(indexName, cancellationToken)).Exists;
if (indexExists)
continue;
var response = await _client.Indices.CreateAsync(indexName, c => c
.Aliases(a => a.Add(alias, new Alias { IsWriteIndex = true })), cancellationToken);
if (response.IsValidResponse)
continue;
if (response.TryGetOriginalException(out var exception))
throw exception!;
}
}
}