Commit 2c6211e6 authored by Paulo Pires's avatar Paulo Pires

Fixed typos.

parent 4d455120
...@@ -87,7 +87,7 @@ $ kubectl get endpoints hazelcast -o yaml ...@@ -87,7 +87,7 @@ $ kubectl get endpoints hazelcast -o yaml
apiVersion: v1beta1 apiVersion: v1beta1
creationTimestamp: 2015-01-05T05:51:50Z creationTimestamp: 2015-01-05T05:51:50Z
endpoints: endpoints:
- 10.244.1.10:9042 - xxx.xxx.xxx.xxx:5701
id: hazelcast id: hazelcast
kind: Endpoints kind: Endpoints
namespace: default namespace: default
...@@ -261,7 +261,7 @@ public class HazelcastDiscoveryController implements CommandLineRunner { ...@@ -261,7 +261,7 @@ public class HazelcastDiscoveryController implements CommandLineRunner {
public void run(String... args) { public void run(String... args) {
log.info("Asking k8s registry at {}..", getKubeApi()); log.info("Asking k8s registry at {}..", getKubeApi());
KubernetesFactory kubernetesFactory = new KubernetesFactory(getKubeApi()); KubernetesFactory kubernetesFactory = new KubernetesFactory(getKubeApi());
final List<PodSchema> hazelcastPods = retrieveHazelcasPods( final List<PodSchema> hazelcastPods = retrieveHazelcastPods(
kubernetesFactory.createKubernetes()); kubernetesFactory.createKubernetes());
log.info("Found {} pods running Hazelcast.", hazelcastPods.size()); log.info("Found {} pods running Hazelcast.", hazelcastPods.size());
if (!hazelcastPods.isEmpty()) { if (!hazelcastPods.isEmpty()) {
...@@ -269,7 +269,7 @@ public class HazelcastDiscoveryController implements CommandLineRunner { ...@@ -269,7 +269,7 @@ public class HazelcastDiscoveryController implements CommandLineRunner {
} }
} }
public List<PodSchema> retrieveHazelcasPods(final Kubernetes kubernetes) { public List<PodSchema> retrieveHazelcastPods(final Kubernetes kubernetes) {
final List<PodSchema> hazelcastPods = new CopyOnWriteArrayList<>(); final List<PodSchema> hazelcastPods = new CopyOnWriteArrayList<>();
kubernetes.getPods().getItems().parallelStream().filter(pod -> pod. kubernetes.getPods().getItems().parallelStream().filter(pod -> pod.
getLabels().get(hazelcastPodLabelKey).equals(hazelcastPodLabelValue)). getLabels().get(hazelcastPodLabelKey).equals(hazelcastPodLabelValue)).
......
...@@ -5,7 +5,6 @@ desiredState: ...@@ -5,7 +5,6 @@ desiredState:
replicas: 1 replicas: 1
replicaSelector: replicaSelector:
name: hazelcast name: hazelcast
# This is identical to the pod config above
podTemplate: podTemplate:
desiredState: desiredState:
manifest: manifest:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment