Not able to mock kubernetesClient.pods().inNamespace().list() #5681
Replies: 1 comment 13 replies
-
|
Could you please clarify what mocking tool you're using. If you're not using the Kubernetes Mock Server (which we provide as JUnit extension), then I'd suggest to do so. Using other Mocking tools such as Mockito can be extremely complicated and hard to maintain. |
Beta Was this translation helpful? Give feedback.
-
|
@rohanKanojia Please find the application code & test code below : public Boolean setup() {
KubernetesClient kc = new KubernetesClientBuilder().build();
try {
if (fooBar(kc)) {
return true;
}
} catch (UnsatisfiedExternalDependencyException e) {
e.printStackTrace();
return false;
}
return false;
}
public boolean fooBar(KubernetesClient kc) throws UnsatisfiedExternalDependencyException {
PodList podList = kc.pods().inNamespace(namespace).list();
List<String> svcPodsList = new ArrayList<>();
podsAvailcheck(podList, svcPodsList);
if(!svcPodsList.isEmpty()) {
boolean podAvail = kc.pods().inNamespace(namespace).withName(svcPodsList.get(0)).isReady();
boolean secretAvail = kc.secrets().inNamespace(namespace).withName("secret-test").isReady();
if (podAvail && secretAvail) {
try {
fooBar2(kc);
} catch (xException e) {
LOG.error("Exception occured {} ", e.getMessage());
}
return true;
}
}
throw new UnsatisfiedExternalDependencyException("test exception");
}
private static void podsAvailcheck(PodList podList, List<String> svcPodsList) {
if(!podList.getItems().isEmpty()) {
for (Pod pod : podList.getItems()) {
if(null != pod.getMetadata() && null != pod.getMetadata().getName()
&& !pod.getMetadata().getName().isEmpty() && pod.getMetadata().getName().contains("pods-test")) {
svcPodsList.add(pod.getMetadata().getName());
}
}
}
}
private void fooBar2(KubernetesClient kc) throws xException {
String key1 = kc.secrets().inNamespace(namespace).withName("secret-test").get().getData().get("abc");
String key2 = kc.secrets().inNamespace(namespace).withName("secret-test").get().getData().get("xyz");
}Test Code import io.fabric8.kubernetes.client.server.mock.EnableKubernetesMockClient;
@EnableKubernetesMockClient
class ServiceAvailabilityTest {
private KubernetesClient kubernetesClient;
private KubernetesMockServer server;
@BeforeEach
void setUp() {
ReflectionTestUtils.setField(ServiceAvailability, "namespace", "ns");
}
@Test
void test() throws UnsatisfiedExternalDependencyException {
// Given
ServiceAvailability sa = new ServiceAvailability();
// When
Pod pod1 = kubernetesClient.pods().resource(
new PodBuilder().withNewMetadata().withName("pod1").addToLabels("testKey", "testValue").endMetadata().build()).create();
Pod pod2 = kubernetesClient.pods().resource(
new PodBuilder().withNewMetadata().withName("pod2").addToLabels("testKey", "testValue").endMetadata().build()).create();
Pod pod3 = kubernetesClient.pods().resource(
new PodBuilder().withNewMetadata().withName("pod3").addToLabels("testKey", "testValue").endMetadata()
.build())
.create();
List<Pod> listPod = new ArrayList();
listPod.add(pod1);
listPod.add(pod2);
listPod.add(pod3);
PodList podList = new PodList();
podList.setItems(listPod);
assertNotNull(podList);
boolean result = sa.fooBar(kubernetesClient);
assertTrue(result);
}
}I could see the above podList in application code is still empty when the above test case has pods set through setItems. |
Beta Was this translation helpful? Give feedback.
-
|
From what I can see you're not specifying namespace while creating I think it should work if you add |
Beta Was this translation helpful? Give feedback.
-
|
Ohh yeah! I've missed that, you're right the pods are being added to namespace |
Beta Was this translation helpful? Give feedback.
-
|
You should be able to do it by updating Pod status. You can see an example of what to put in Pod status in ResourceTest |
Beta Was this translation helpful? Give feedback.
-
|
Thanks a ton @rohanKanojia for the support, I was able to mock using the resources shared. |
Beta Was this translation helpful? Give feedback.
-
Hi @manusa / @rohanKanojia / Team
I'm trying to mock this line "PodList podList = kc.pods().inNamespace(namespace).list();" in the below method.
but it is being failed with UnknownHostException:
I've tried mocking in multiple ways but it is being failed with this Caused by: java.net.UnknownHostException: kubernetes.default.svc.
Please let me know, if there is away to write junits for listing pods. Thanks in advance.
Thanks,
Srihitha.
Beta Was this translation helpful? Give feedback.
All reactions