Configure more

Author: alexeyzimarev

src/Experimental/src/Eventuous.Connectors.EsdbElastic/Index/IndexConfig.cs

@@ -3,13 +3,9 @@
 namespace Eventuous.Connectors.EsdbElastic.Index;
 
 public record IndexConfig {
+    public string                    IndexName { get; init; } = null!;
     public DataStreamTemplateConfig? Template  { get; init; }
     public LifecycleConfig?          Lifecycle { get; init; }
-
-    public void Deconstruct(out DataStreamTemplateConfig? templateConfig, out LifecycleConfig? lifecycleConfig) {
-        templateConfig  = Template;
-        lifecycleConfig = Lifecycle;
-    }
 }
 
 public record DataStreamTemplateConfig {

src/Experimental/src/Eventuous.Connectors.EsdbElastic/Program.cs

@@ -1,4 +1,3 @@
-using Elasticsearch.Net;
 using Eventuous.Connectors.Base;
 using Eventuous.Connectors.EsdbElastic.Conversions;
 using Eventuous.Connectors.EsdbElastic.Index;
@@ -27,9 +26,10 @@
     .AddElasticClient(config.ConnectionString!, config.ApiKey);
 
 var concurrencyLimit = builder.Configuration.GetValue<uint>("connector:concurrencyLimit", 1);
+var subscriptionId = builder.Configuration.GetValue<string>("connector:subscriptionId", "default");
 
 new ConnectorBuilder()
-    .SubscribeWith<AllStreamSubscription, AllStreamSubscriptionOptions>("esdb-elastic-connector")
+    .SubscribeWith<AllStreamSubscription, AllStreamSubscriptionOptions>(subscriptionId)
     .ConfigureSubscriptionOptions(
         cfg => {
             cfg.EventSerializer  = serializer;
@@ -43,7 +43,7 @@
         }
     )
     .ProduceWith<ElasticProducer, ElasticProduceOptions>()
-    .TransformWith(_ => new EventTransform("eventlog"))
+    .TransformWith(_ => new EventTransform(config.DataStream.IndexName))
     .Register(builder.Services);
 
 builder.AddStartupJob<IElasticClient, IndexConfig>(SetupIndex.CreateIfNecessary);

src/Experimental/src/Eventuous.Connectors.EsdbElastic/config.yaml

@@ -1,8 +1,10 @@
 connector:
   concurrencyLimit: 1
+  subscriptionId: "esdb-elastic-connector"
 eventstoredb:
   connectionString: "esdb://localhost:2113?tls=false"
 elastic:
+  indexName: "eventlog"
   connectionString: "http://localhost:9200"
   apiKey: ""
   dataStream: