From c0ea9a2efb5d195be99e59e9cc2958db23d51643 Mon Sep 17 00:00:00 2001
From: Mahad Zaryab <mahadzaryab1@gmail.com>
Date: Tue, 7 Jan 2025 23:13:57 -0500
Subject: [PATCH] Propagate Arguments To Archive Constructor

Signed-off-by: Mahad Zaryab <mahadzaryab1@gmail.com>
---
 plugin/storage/es/factory.go | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/plugin/storage/es/factory.go b/plugin/storage/es/factory.go
index ee4a356cea1..808c6112864 100644
--- a/plugin/storage/es/factory.go
+++ b/plugin/storage/es/factory.go
@@ -205,7 +205,7 @@ func (f *Factory) CreateSpanReader() (spanstore.Reader, error) {
 
 // CreateSpanWriter implements storage.Factory
 func (f *Factory) CreateSpanWriter() (spanstore.Writer, error) {
-	return createSpanWriter(f.getPrimaryClient, f.primaryConfig, f.primaryMetricsFactory, f.logger)
+	return createSpanWriter(f.getPrimaryClient, f.primaryConfig, f.primaryMetricsFactory, f.logger, "", f.primaryConfig.UseReadWriteAliases)
 }
 
 // CreateDependencyReader implements storage.Factory
@@ -230,7 +230,7 @@ func (f *Factory) CreateArchiveSpanWriter() (spanstore.Writer, error) {
 	if !f.archiveConfig.Enabled {
 		return nil, nil
 	}
-	return createSpanWriter(f.getArchiveClient, f.archiveConfig, f.archiveMetricsFactory, f.logger)
+	return createSpanWriter(f.getArchiveClient, f.archiveConfig, f.archiveMetricsFactory, f.logger, "archive", true)
 }
 
 func createSpanReader(
@@ -265,6 +265,8 @@ func createSpanWriter(
 	cfg *config.Configuration,
 	mFactory metrics.Factory,
 	logger *zap.Logger,
+	indexSuffix string,
+	useReadWriteAliases bool,
 ) (spanstore.Writer, error) {
 	var tags []string
 	var err error
@@ -279,12 +281,13 @@ func createSpanWriter(
 	writer := esSpanStore.NewSpanWriter(esSpanStore.SpanWriterParams{
 		Client:              clientFn,
 		IndexPrefix:         cfg.Indices.IndexPrefix,
+		IndexSuffix:         indexSuffix,
 		SpanIndex:           cfg.Indices.Spans,
 		ServiceIndex:        cfg.Indices.Services,
 		AllTagsAsFields:     cfg.Tags.AllAsFields,
 		TagKeysAsFields:     tags,
 		TagDotReplacement:   cfg.Tags.DotReplacement,
-		UseReadWriteAliases: cfg.UseReadWriteAliases,
+		UseReadWriteAliases: useReadWriteAliases,
 		Logger:              logger,
 		MetricsFactory:      mFactory,
 		ServiceCacheTTL:     cfg.ServiceCacheTTL,