feat: generate default configs using reconciliation cycle

Author: teoincontatto

stackgres-k8s/e2e/spec/default-mutator

@@ -17,6 +17,7 @@ public interface StackGresContext {
   String CLUSTER_UID_KEY = "cluster-uid";
   String CLUSTER_SCOPE_KEY = "cluster-scope";
   String CLUSTER_NAMESPACE_KEY = "cluster-namespace";
+  String CLUSTER_DEFAULT_CONFIG_KEY = "cluster-default-config";
   String RIGHT_VALUE = Boolean.TRUE.toString();
   String WRONG_VALUE = Boolean.FALSE.toString();
   String RESTAPI_KEY = "restapi";
@@ -32,6 +33,7 @@ public interface StackGresContext {
   String DISTRIBUTED_LOGS_CLUSTER_NAME_KEY = "distributed-logs-name";
   String DISTRIBUTED_LOGS_CLUSTER_NAMESPACE_KEY = "distributed-logs-namespace";
   String DISTRIBUTED_LOGS_CLUSTER_UID_KEY = "distributed-logs-uid";
+  String DISTRIBUTED_LOGS_DEFAULT_CONFIG_KEY = "distributed-logs-default-config";
   String DBOPS_APP_NAME = "StackGresDbOps";
   String DBOPS_NAME_KEY = "dbops-name";
   String DBOPS_UID_KEY = "dbops-uid";
@@ -45,6 +47,7 @@ public interface StackGresContext {
   String SHARDED_CLUSTER_NAME_KEY = "shardedcluster-name";
   String SHARDED_CLUSTER_UID_KEY = "shardedcluster-uid";
   String SHARDED_CLUSTER_NAMESPACE_KEY = "shardedcluster-namespace";
+  String SHARDED_CLUSTER_DEFAULT_CONFIG_KEY = "shardedcluster-default-config";
   String COORDINATOR_KEY = "coordinator";
   String SHARDS_KEY = "shards";
   String SHARDED_BACKUP_KEY = "sharded-backup";

stackgres-k8s/src/common/src/main/java/io/stackgres/common/StackGresContext.java

@@ -38,6 +38,13 @@ public ClusterLabelMapper labelMapper() {
     return labelMapper;
   }
 
+  @Override
+  public Map<String, String> defaultConfigLabels(StackGresCluster resource) {
+    return ImmutableMap.<String, String>builder().putAll(genericLabels(resource))
+        .put(labelMapper().defaultConfigKey(resource), StackGresContext.RIGHT_VALUE)
+        .build();
+  }
+
   @Override
   public Map<String, String> clusterLabels(StackGresCluster resource) {
     return ImmutableMap.<String, String>builder().putAll(clusterLabelsWithoutUid(resource))

stackgres-k8s/src/common/src/main/java/io/stackgres/common/labels/ClusterLabelFactory.java

@@ -5,6 +5,10 @@
 
 package io.stackgres.common.labels;
 
+import java.util.Map;
+
+import com.google.common.collect.ImmutableMap;
+import io.stackgres.common.StackGresContext;
 import io.stackgres.common.crd.sgdistributedlogs.StackGresDistributedLogs;
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
@@ -26,4 +30,11 @@ public DistributedLogsLabelMapper labelMapper() {
     return labelMapper;
   }
 
+  @Override
+  public Map<String, String> defaultConfigLabels(StackGresDistributedLogs resource) {
+    return ImmutableMap.<String, String>builder().putAll(genericLabels(resource))
+        .put(labelMapper().defaultConfigKey(resource), StackGresContext.RIGHT_VALUE)
+        .build();
+  }
+
 }

stackgres-k8s/src/common/src/main/java/io/stackgres/common/labels/DistributedLogsLabelFactory.java

@@ -13,6 +13,8 @@
 public interface LabelFactoryForCluster
     extends LabelFactory<StackGresCluster> {
 
+  Map<String, String> defaultConfigLabels(StackGresCluster resource);
+
   Map<String, String> clusterLabels(StackGresCluster resource);
 
   Map<String, String> clusterLabelsWithoutUid(StackGresCluster resource);

stackgres-k8s/src/common/src/main/java/io/stackgres/common/labels/LabelFactoryForCluster.java

@@ -5,11 +5,15 @@
 
 package io.stackgres.common.labels;
 
+import java.util.Map;
+
 import io.stackgres.common.crd.sgdistributedlogs.StackGresDistributedLogs;
 
 public interface LabelFactoryForDistributedLogs
     extends LabelFactory<StackGresDistributedLogs> {
 
+  Map<String, String> defaultConfigLabels(StackGresDistributedLogs resource);
+
   @Override
   LabelMapperForDistributedLogs labelMapper();
 

stackgres-k8s/src/common/src/main/java/io/stackgres/common/labels/LabelFactoryForDistributedLogs.java

@@ -12,6 +12,8 @@
 public interface LabelFactoryForShardedCluster
     extends LabelFactory<StackGresShardedCluster> {
 
+  Map<String, String> defaultConfigLabels(StackGresShardedCluster resource);
+
   Map<String, String> coordinatorLabels(StackGresShardedCluster resource);
 
   Map<String, String> coordinatorLabelsWithoutUid(StackGresShardedCluster resource);

stackgres-k8s/src/common/src/main/java/io/stackgres/common/labels/LabelFactoryForShardedCluster.java

@@ -13,6 +13,10 @@
 public interface LabelMapperForCluster
     extends LabelMapper<StackGresCluster> {
 
+  default String defaultConfigKey(StackGresCluster resource) {
+    return getKeyPrefix(resource) + StackGresContext.CLUSTER_DEFAULT_CONFIG_KEY;
+  }
+
   default String clusterKey(StackGresCluster resource) {
     return getKeyPrefix(resource) + StackGresContext.CLUSTER_KEY;
   }

stackgres-k8s/src/common/src/main/java/io/stackgres/common/labels/LabelMapperForCluster.java

@@ -5,9 +5,14 @@
 
 package io.stackgres.common.labels;
 
+import io.stackgres.common.StackGresContext;
 import io.stackgres.common.crd.sgdistributedlogs.StackGresDistributedLogs;
 
 public interface LabelMapperForDistributedLogs
     extends LabelMapper<StackGresDistributedLogs> {
 
+  default String defaultConfigKey(StackGresDistributedLogs resource) {
+    return getKeyPrefix(resource) + StackGresContext.DISTRIBUTED_LOGS_DEFAULT_CONFIG_KEY;
+  }
+
 }

stackgres-k8s/src/common/src/main/java/io/stackgres/common/labels/LabelMapperForDistributedLogs.java

@@ -11,6 +11,10 @@
 public interface LabelMapperForShardedCluster
     extends LabelMapper<StackGresShardedCluster> {
 
+  default String defaultConfigKey(StackGresShardedCluster resource) {
+    return getKeyPrefix(resource) + StackGresContext.SHARDED_CLUSTER_DEFAULT_CONFIG_KEY;
+  }
+
   default String coordinatorKey(StackGresShardedCluster resource) {
     return getKeyPrefix(resource) + StackGresContext.COORDINATOR_KEY;
   }