2024-03 Calcium integration

lighty-core/lighty-clustering/src/main/java/io/lighty/core/cluster/kubernetes/KubernetesClusteringHandlerImpl.java

@@ -19,13 +19,11 @@
 import java.util.List;
 import java.util.Optional;
 import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 import org.eclipse.jdt.annotation.NonNull;
 import org.opendaylight.controller.cluster.ActorSystemProvider;
 import org.opendaylight.controller.cluster.datastore.admin.ClusterAdminRpcService;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.md.sal.cluster.admin.rev151013.AddReplicasForAllShardsInputBuilder;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -100,16 +98,6 @@ private void askForShards(final ClusterAdminRpcService clusterAdminRPCService) {
         if (!Cluster.get(actorSystemProvider.getActorSystem()).selfAddress()
                 .equals(Cluster.get(actorSystemProvider.getActorSystem()).state().getLeader())) {
             LOG.info("RPC call - Asking for Shard Snapshots");
-            try {
-                final var rpcResult = clusterAdminRPCService.addReplicasForAllShards(
-                        new AddReplicasForAllShardsInputBuilder().build()).get();
-                LOG.debug("RPC call - Asking for Shard Snapshots result: {}", rpcResult.getResult());
-            } catch (ExecutionException e) {
-                LOG.error("RPC call - Asking for Shard Snapshots failed", e);
-            } catch (InterruptedException e) {
-                LOG.error("RPC call - Asking for Shard Snapshots interrupted", e);
-                Thread.currentThread().interrupt();
-            }
         }
     }
 

lighty-core/lighty-clustering/src/main/java/io/lighty/core/cluster/kubernetes/MemberRemovedListener.java

@@ -56,37 +56,8 @@ public Receive createReceive() {
         return receiveBuilder()
                 .match(ClusterEvent.MemberRemoved.class, removedMember -> {
                     LOG.info("Member detected as removed, processing: {}", removedMember.member().address());
-                    processRemovedMember(removedMember.member());
                 })
                 .build();
     }
 
-    private void processRemovedMember(Member member) {
-        LOG.info("Removing shard replicas for member {}. May result in WARN (DOES_NOT_EXIST) messages if already"
-                + "removed by another member.", member.address());
-        List<String> removedMemberRoles = member.getRoles().stream()
-                .filter(role -> !role.contains("default")).collect(Collectors.toList());
-
-        try {
-            for (String removedMemberRole : removedMemberRoles) {
-                ListenableFuture<RpcResult<RemoveAllShardReplicasOutput>> rpcResultListenableFuture =
-                        clusterAdminRPCService.removeAllShardReplicas(new RemoveAllShardReplicasInputBuilder()
-                                .setMemberName(removedMemberRole).build());
-                RpcResult<RemoveAllShardReplicasOutput> removeAllShardReplicasResult = rpcResultListenableFuture.get();
-                if (removeAllShardReplicasResult.isSuccessful()) {
-                    LOG.info("RPC RemoveAllShards for member {} executed successfully", removedMemberRole);
-                } else {
-                    LOG.warn("RPC RemoveAllShards for member {} failed: {}", removedMemberRole,
-                            removeAllShardReplicasResult.getErrors());
-                }
-            }
-            LOG.info("Shard replicas removed for member {}", member.address());
-        } catch (ExecutionException e) {
-            LOG.error("Unable to remove shard replicas for member {}", member.address(), e);
-        } catch (InterruptedException e) {
-            LOG.error("Interrupted while removing shard replicas for member {}", member.address(), e);
-            Thread.currentThread().interrupt();
-        }
-    }
-
 }