feat: revert pre-hook and just allow for disabling default archivers so that extentions can just override them (#839)

Author: fieldju

kayenta-core/src/main/java/com/netflix/kayenta/config/KayentaConfiguration.java

@@ -25,7 +25,6 @@
 import com.google.common.collect.ImmutableList;
 import com.netflix.kayenta.atlas.config.KayentaSerializationConfigurationProperties;
 import com.netflix.kayenta.canary.CanaryMetricSetQueryConfig;
-import com.netflix.kayenta.events.CanaryExecutionCompletedEvent;
 import com.netflix.kayenta.metrics.MapBackedMetricsServiceRepository;
 import com.netflix.kayenta.metrics.MetricSetMixerService;
 import com.netflix.kayenta.metrics.MetricsRetryConfigurationProperties;
@@ -40,10 +39,8 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.Optional;
-import java.util.function.Consumer;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
@@ -73,12 +70,6 @@ AccountCredentialsRepository accountCredentialsRepository() {
     return new MapBackedAccountCredentialsRepository();
   }
 
-  @Bean
-  @Qualifier("pre-canary-execution-archive-hook")
-  Consumer<CanaryExecutionCompletedEvent> preCanaryArchiveHook() {
-    return (event) -> log.debug("no-op pre-canary execution archive hook");
-  }
-
   @Bean
   @ConditionalOnMissingBean(MetricsServiceRepository.class)
   MetricsServiceRepository metricsServiceRepository() {

kayenta-core/src/main/java/com/netflix/kayenta/events/listeners/ExecutionArchivalListener.kt

@@ -21,19 +21,17 @@ import com.netflix.kayenta.security.AccountCredentials
 import com.netflix.kayenta.security.AccountCredentialsRepository
 import com.netflix.kayenta.storage.ObjectType
 import com.netflix.kayenta.storage.StorageServiceRepository
-import java.util.function.Consumer
 import org.slf4j.Logger
 import org.slf4j.LoggerFactory.getLogger
-import org.springframework.beans.factory.annotation.Qualifier
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty
 import org.springframework.context.event.EventListener
 import org.springframework.stereotype.Component
 
+@ConditionalOnProperty(name = ["kayenta.default-archivers.enabled"], havingValue = "true", matchIfMissing = true)
 @Component
 class ExecutionArchivalListener(
   private val accountCredentialsRepository: AccountCredentialsRepository,
-  private val storageServiceRepository: StorageServiceRepository,
-  @Qualifier("pre-canary-execution-archive-hook")
-  private val preCanaryArchiveHook: Consumer<CanaryExecutionCompletedEvent>
+  private val storageServiceRepository: StorageServiceRepository
 ) {
 
   init {
@@ -42,7 +40,6 @@ class ExecutionArchivalListener(
 
   @EventListener
   fun onApplicationEvent(event: CanaryExecutionCompletedEvent) {
-    preCanaryArchiveHook.accept(event)
     val response = event.canaryExecutionStatusResponse
     val storageAccountName = response.storageAccountName
     if (storageAccountName != null) {

kayenta-standalone-canary-analysis/src/main/java/com/netflix/kayenta/standalonecanaryanalysis/config/StandaloneCanaryAnalysisModuleConfiguration.java

@@ -16,23 +16,13 @@
 
 package com.netflix.kayenta.standalonecanaryanalysis.config;
 
-import com.netflix.kayenta.standalonecanaryanalysis.event.StandaloneCanaryAnalysisExecutionCompletedEvent;
-import java.util.function.Consumer;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
-import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.Configuration;
 
 @Configuration
 @ConditionalOnProperty("kayenta.standalone-canary-analysis.enabled")
 @ComponentScan({"com.netflix.kayenta.standalonecanaryanalysis"})
 @Slf4j
-public class StandaloneCanaryAnalysisModuleConfiguration {
-  @Bean
-  @Qualifier("pre-scape-archive-hook")
-  Consumer<StandaloneCanaryAnalysisExecutionCompletedEvent> preScapeArchiveHook() {
-    return (event) -> log.debug("no-op pre-SCAPE archive hook");
-  }
-}
+public class StandaloneCanaryAnalysisModuleConfiguration {}

kayenta-standalone-canary-analysis/src/main/java/com/netflix/kayenta/standalonecanaryanalysis/event/listener/StandaloneCanaryAnalysisExecutionArchivalListener.java

@@ -6,35 +6,33 @@
 import com.netflix.kayenta.standalonecanaryanalysis.storage.StandaloneCanaryAnalysisObjectType;
 import com.netflix.kayenta.storage.StorageServiceRepository;
 import java.util.Optional;
-import java.util.function.Consumer;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.context.event.EventListener;
 import org.springframework.stereotype.Component;
 
 @Slf4j
 @Component
+@ConditionalOnProperty(
+    name = "kayenta.default-archivers.enabled",
+    havingValue = "true",
+    matchIfMissing = true)
 public class StandaloneCanaryAnalysisExecutionArchivalListener {
 
   private final AccountCredentialsRepository accountCredentialsRepository;
   private final StorageServiceRepository storageServiceRepository;
-  private final Consumer<StandaloneCanaryAnalysisExecutionCompletedEvent> preScapeArchiveHook;
 
   @Autowired
   public StandaloneCanaryAnalysisExecutionArchivalListener(
       AccountCredentialsRepository accountCredentialsRepository,
-      StorageServiceRepository storageServiceRepository,
-      @Qualifier("pre-scape-archive-hook")
-          Consumer<StandaloneCanaryAnalysisExecutionCompletedEvent> preScapeArchiveHook) {
+      StorageServiceRepository storageServiceRepository) {
     this.accountCredentialsRepository = accountCredentialsRepository;
     this.storageServiceRepository = storageServiceRepository;
-    this.preScapeArchiveHook = preScapeArchiveHook;
   }
 
   @EventListener
   public void onApplicationEvent(StandaloneCanaryAnalysisExecutionCompletedEvent event) {
-    preScapeArchiveHook.accept(event);
     var response = event.getCanaryAnalysisExecutionStatusResponse();
 
     Optional.ofNullable(response.getStorageAccountName())