in src/main/java/com/epam/aidial/kubernetes/KubernetesClient.java [69:91]
public Mono<Boolean> deleteSecret(String namespace, String name) {
return handleMissing(Mono.create(sink -> {
CoreV1Api coreApi = new CoreV1Api(apiClient);
log.info("Deleting secret {}", name);
try {
coreApi.deleteNamespacedSecret(name, namespace)
.executeAsync(new NoProgressApiCallback<>() {
@Override
public void onFailure(ApiException e, int i, Map<String, List<String>> map) {
sink.error(e);
}
@Override
public void onSuccess(V1Status state, int i, Map<String, List<String>> map) {
log.info("Secret {} has been deleted", name);
sink.success();
}
});
} catch (ApiException e) {
sink.error(e);
}
}));
}