feat: switch off stop-writes-sys-memory-pct metric for aerosspike enterprise

Author: Volchkov Andrey

embedded-aerospike-enterprise/src/main/java/com/playtika/testcontainers/aerospike/enterprise/AerospikeEnterpriseConfigurer.java

@@ -15,26 +15,44 @@ public class AerospikeEnterpriseConfigurer {
     private final AerospikeProperties aerospikeProperties;
     private final AerospikeEnterpriseProperties enterpriseProperties;
 
-    public void configure(GenericContainer<?> aerospikeContainer)  throws IOException, InterruptedException {
+    public void configure(GenericContainer<?> aerospikeContainer) throws IOException, InterruptedException {
         if (aerospikeProperties.getFeatureKey() == null || aerospikeProperties.getFeatureKey().isEmpty()) {
             log.warn("Evaluation feature key file not provided by 'embedded.aerospike.featureKey' property. " +
                     "Pay attention to license details: https://github.com/aerospike/aerospike-server.docker/blob/master/enterprise/ENTERPRISE_LICENSE");
         }
-
+        switchOffStopWritesSysMemoryPctMetric(aerospikeContainer);
         setupDisallowExpunge(aerospikeContainer);
     }
 
+    private void switchOffStopWritesSysMemoryPctMetric(GenericContainer<?> aerospikeContainer) throws IOException, InterruptedException {
+        log.info("Switching off 'stop-writes-sys-memory-pct'...");
+        String namespace = aerospikeProperties.getNamespace();
+        Container.ExecResult result = aerospikeContainer.execInContainer("asadm", "--enable", "-e",
+                String.format("manage config namespace %s param stop-writes-sys-memory-pct to 100", namespace));
+        logStdout(result);
+        if (result.getExitCode() != 0) {
+            throw new IllegalStateException("Failed switch off 'stop-writes-sys-memory-pct': " + result.getStderr());
+        }
+        log.info("Success switching off 'stop-writes-sys-memory-pct'");
+    }
+
     private void setupDisallowExpunge(GenericContainer<?> aerospikeContainer) throws IOException, InterruptedException {
         if (!enterpriseProperties.isDurableDeletes()) {
             return;
         }
         log.info("Setting up 'disallow-expunge' to true...");
         String namespace = aerospikeProperties.getNamespace();
-        Container.ExecResult result = aerospikeContainer.execInContainer("asadm", "-e",
-                String.format("enable; manage config namespace %s param disallow-expunge to true", namespace));
-        if (result.getStderr().length() > 0) {
+        Container.ExecResult result = aerospikeContainer.execInContainer("asadm", "--enable", "-e",
+                String.format("manage config namespace %s param disallow-expunge to true", namespace));
+        logStdout(result);
+        if (result.getExitCode() != 0) {
             throw new IllegalStateException("Failed to set up 'disallow-expunge' to true: " + result.getStderr());
         }
-        log.info("Set up 'disallow-expunge' to true: {}", result.getStdout());
+        log.info("Success setting up 'disallow-expunge' to true");
+    }
+
+    private static void logStdout(Container.ExecResult result) {
+        log.debug("Aerospike asadm util stdout: \n{}\n{}", result.getStdout(), result.getStderr());
     }
+
 }

embedded-aerospike-enterprise/src/main/java/com/playtika/testcontainers/aerospike/enterprise/EnterpriseAerospikeTestOperationsAutoConfiguration.java

@@ -21,8 +21,9 @@ public class EnterpriseAerospikeTestOperationsAutoConfiguration {
     @Bean
     @ConditionalOnProperty(value = "embedded.aerospike.time-travel.enabled", havingValue = "true", matchIfMissing = true)
     public ExpiredDocumentsCleaner expiredDocumentsCleaner(AerospikeClient client,
+                                                           AerospikeEnterpriseProperties aerospikeEnterpriseProperties,
                                                            AerospikeProperties properties) {
-        return new AerospikeExpiredDocumentsCleaner(client, properties.getNamespace(), true);
+        return new AerospikeExpiredDocumentsCleaner(client, properties.getNamespace(), aerospikeEnterpriseProperties.isDurableDeletes());
     }
 
 }

embedded-aerospike-enterprise/src/test/java/com/playtika/testcontainers/aerospike/enterprise/ValidateEnterpriseAerospikeBootstrapConfigurationTest.java

@@ -20,13 +20,13 @@ void failOnNonEnterpriseImage() {
 
     @Test
     void failOnUnsuitableEnterpriseImageVersion() {
-        contextRunner.withPropertyValues("embedded.aerospike.dockerImage=aerospike/aerospike-server-enterprise:6.1.0.16_1")
+        contextRunner.withPropertyValues("embedded.aerospike.dockerImage=aerospike/aerospike-server-enterprise:6.1.0.16")
                 .run(context -> assertThat(context).hasFailed());
     }
 
     @Test
     void skipValidation() {
-        contextRunner.withPropertyValues("embedded.aerospike.dockerImage=aerospike-server:6.1.0.16_1",
+        contextRunner.withPropertyValues("embedded.aerospike.dockerImage=aerospike-server:6.1.0.16",
                 "embedded.aerospike.enabled=false")
                 .run(context -> assertThat(context).hasNotFailed());
 

embedded-aerospike-enterprise/src/test/resources/log4j2.xml

@@ -6,7 +6,7 @@
         </Console>
     </Appenders>
     <Loggers>
-        <Logger name="com.playtika.testcontainer" level="info"/>
+        <Logger name="com.playtika.testcontainers" level="info"/>
         <Logger name="org.springframework" level="error"/>
         <Root level="error">
             <AppenderRef ref="Console"/>