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

Point alias to writable index

Browse source
This commit is contained in:
Gürkan Güran 2023-01-08 14:43:53 +01:00
parent 7ded6a1320
commit 00962a0b90
2 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/modules/Elsa.Elasticsearch/Extensions/ElasticExtensions.cs
View file

@ -45,11 +45,11 @@ public static class ElasticExtensions
if (indexExists) continue;
var response = client.Indices.Create(indexName, s => s
.Aliases(a => a.Alias(aliasName)));
.Aliases(a => a.Alias(aliasName))
.Map(m => m.AutoMap(type)));
if (response.IsValid) continue;
throw response.OriginalException;
}
}
}

5
src/modules/Elsa.Scheduling/Jobs/ConfigureElasticIndicesJob.cs
View file

@ -29,10 +29,11 @@ public class ConfigureElasticIndicesJob : Job
var indexExists = (await client.Indices.ExistsAsync(newIndexName)).Exists;
if (indexExists) continue;
// Point the alias to the new index
// Point the alias to the new writable index
await client.Indices.BulkAliasAsync(aliases => aliases
.Remove(a => a.Alias(aliasPointingCurrentIndex).Index(currentIndexName))
.Add(a => a.Alias(aliasPointingCurrentIndex).Index(newIndexName)));
.Add(a => a.Alias(aliasPointingCurrentIndex).Index(currentIndexName).IsWriteIndex(false))
.Add(a => a.Alias(aliasPointingCurrentIndex).Index(newIndexName).IsWriteIndex()));
}
}
}