From 4db96b22df24ae6a1c886d3da2309b0fbccdb2a4 Mon Sep 17 00:00:00 2001 From: siloneco Date: Sat, 17 Dec 2022 11:16:59 +0900 Subject: [PATCH] :bug: Fixed initial servers not registering --- src/main/java/net/azisaba/kuvel/KuvelServiceHandler.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/main/java/net/azisaba/kuvel/KuvelServiceHandler.java b/src/main/java/net/azisaba/kuvel/KuvelServiceHandler.java index 155bb245..6c867980 100644 --- a/src/main/java/net/azisaba/kuvel/KuvelServiceHandler.java +++ b/src/main/java/net/azisaba/kuvel/KuvelServiceHandler.java @@ -158,6 +158,12 @@ public void setAndRunServerDiscovery(@Nullable ServerDiscovery newServerDiscover InetSocketAddress address = new InetSocketAddress(pod.getStatus().getPodIP(), 25565); plugin.getProxy().registerServer(new ServerInfo(entry.getKey(), address)); + String initialServerStr = pod.getMetadata().getLabels() + .getOrDefault(LabelKeys.INITIAL_SERVER.getKey(), "false"); + if (Boolean.parseBoolean(initialServerStr)) { + initialServerNames.add(entry.getKey()); + } + for (LoadBalancer loadBalancer : loadBalancerServerMap.values()) { if (pod.hasOwnerReferenceFor(loadBalancer.getReplicaSetUid())) { loadBalancer.addEndpoint(entry.getKey());