From 97bbb34244e84051bf0dcab08ef5eba239dcd9f2 Mon Sep 17 00:00:00 2001
From: Martijn Laarman <Mpdreamz@gmail.com>
Date: Thu, 3 Aug 2023 13:35:33 +0200
Subject: [PATCH] Expose IlmPolicy as option to datashippers (#327)

---
 .../ElasticsearchLoggerProvider.cs                       | 2 +-
 .../Options/ElasticsearchLoggerOptions.cs                | 7 +++++++
 src/Elastic.Serilog.Sinks/ElasticsearchSink.cs           | 9 ++++++++-
 3 files changed, 16 insertions(+), 2 deletions(-)

diff --git a/src/Elastic.Extensions.Logging/ElasticsearchLoggerProvider.cs b/src/Elastic.Extensions.Logging/ElasticsearchLoggerProvider.cs
index 37f1377a..00fe5609 100644
--- a/src/Elastic.Extensions.Logging/ElasticsearchLoggerProvider.cs
+++ b/src/Elastic.Extensions.Logging/ElasticsearchLoggerProvider.cs
@@ -185,7 +185,7 @@ private IBufferedChannel<LogEvent> CreatIngestChannel(ElasticsearchLoggerOptions
 				};
 				SetupChannelOptions(_channelConfigurations, indexChannelOptions);
 				var channel = new EcsDataStreamChannel<LogEvent>(indexChannelOptions);
-				channel.BootstrapElasticsearch(loggerOptions.BootstrapMethod);
+				channel.BootstrapElasticsearch(loggerOptions.BootstrapMethod, loggerOptions.IlmPolicy);
 				return channel;
 			}
 		}
diff --git a/src/Elastic.Extensions.Logging/Options/ElasticsearchLoggerOptions.cs b/src/Elastic.Extensions.Logging/Options/ElasticsearchLoggerOptions.cs
index 69c5fdf6..9656912b 100644
--- a/src/Elastic.Extensions.Logging/Options/ElasticsearchLoggerOptions.cs
+++ b/src/Elastic.Extensions.Logging/Options/ElasticsearchLoggerOptions.cs
@@ -40,6 +40,13 @@ public class ElasticsearchLoggerOptions : IEcsDocumentCreationOptions
 		/// </summary>
 		public BootstrapMethod BootstrapMethod { get; set; } = BootstrapMethod.None;
 
+		/// <summary>
+		/// The ILM Policy to apply, see the following for more details:
+		/// <para>https://www.elastic.co/guide/en/elasticsearch/reference/current/index-lifecycle-management.html</para>
+		/// Defaults to `logs` which is shipped by default with Elasticsearch
+		/// </summary>
+		public string? IlmPolicy { get; set; }
+
 		/// <summary>
 		/// The index to log into, if this is not set the logger integration will assume it will write into datastreams <see cref="DataStream"/>.
 		/// <para>
diff --git a/src/Elastic.Serilog.Sinks/ElasticsearchSink.cs b/src/Elastic.Serilog.Sinks/ElasticsearchSink.cs
index 96d8902a..244d49ee 100644
--- a/src/Elastic.Serilog.Sinks/ElasticsearchSink.cs
+++ b/src/Elastic.Serilog.Sinks/ElasticsearchSink.cs
@@ -60,6 +60,13 @@ public ElasticsearchSinkOptions() : this(new DefaultHttpTransport(TransportHelpe
 		/// <inheritdoc cref="BootstrapMethod"/>
 		public BootstrapMethod BootstrapMethod { get; set; }
 
+		/// <summary>
+		/// The ILM Policy to apply, see the following for more details:
+		/// <para>https://www.elastic.co/guide/en/elasticsearch/reference/current/index-lifecycle-management.html</para>
+		/// Defaults to `logs` which is shipped by default with Elasticsearch
+		/// </summary>
+		public string? IlmPolicy { get; set; }
+
 	}
 
 	/// <summary>
@@ -90,7 +97,7 @@ public ElasticsearchSink(ElasticsearchSinkOptions<TEcsDocument> options)
 			_channel = new EcsDataStreamChannel<TEcsDocument>(channelOptions, new [] { new SelfLogCallbackListener<TEcsDocument>(options)});
 			if (_channel.DiagnosticsListener != null)
 				options.ChannelDiagnosticsCallback?.Invoke(_channel.DiagnosticsListener);
-			_channel.BootstrapElasticsearch(options.BootstrapMethod);
+			_channel.BootstrapElasticsearch(options.BootstrapMethod, options.IlmPolicy);
 		}
 
 		/// <inheritdoc cref="ILogEventSink.Emit"/>