public Mono deletePod()

in src/main/java/com/epam/aidial/kubernetes/KubernetesClient.java [290:313]

23 lines of code
2 McCabe index (conditional complexity)


    public Mono<Boolean> deletePod(String namespace, String name) {
        return handleMissing(Mono.create(sink -> {
            CoreV1Api batchV1Api = new CoreV1Api(apiClient);
            log.info("Deleting pod {}", name);
            try {
                batchV1Api.deleteNamespacedPod(name, namespace)
                        .gracePeriodSeconds(0)
                        .executeAsync(new NoProgressApiCallback<>() {
                            @Override
                            public void onFailure(ApiException e, int i, Map<String, List<String>> map) {
                                sink.error(e);
                            }

                            @Override
                            public void onSuccess(V1Pod pod, int i, Map<String, List<String>> map) {
                                log.info("Pod {} has been deleted", name);
                                sink.success();
                            }
                        });
            } catch (ApiException e) {
                sink.error(e);
            }
        }));
    }