-
Notifications
You must be signed in to change notification settings - Fork 35
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Introduced split_clusters_during_rolling_update #36
Introduced split_clusters_during_rolling_update #36
Conversation
if(!pods.contains(podIP)) | ||
pods.add(podIP); | ||
} | ||
String parentDeployment = Optional.ofNullable(obj.at("metadata")) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@belaban Are you OK with this change?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Big change: I'd like to test this with minikube first... however the turnaround time for this is quite high .. stay tuned.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ok, no problem. Take your time and keep me posted ;)
@@ -206,6 +218,33 @@ public void findMembers(List<Address> members, boolean initial_discovery, Respon | |||
list.stream().filter(phys_addr -> !cluster_members.contains(phys_addr)).forEach(cluster_members::add); | |||
} | |||
|
|||
if (split_clusters_during_rolling_update) { | |||
if(physical_addr != null) { | |||
String senderIp = ((IpAddress)physical_addr).getIpAddress().getHostAddress(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@belaban Could you please have a look at this? Can I safely cast to IpAddress
? I didn't find any problems but maybe there are some corner cases?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
No, this should be find as I don't have other impls of PhysicalAddress
Fixes #33