public Mono createSecret()

in src/main/java/com/epam/aidial/kubernetes/KubernetesClient.java [42:67]

24 lines of code
2 McCabe index (conditional complexity)


    public Mono<Void> createSecret(String namespace, V1Secret secret) {
        return Mono.create(sink -> {
            V1ObjectMeta metadata = secret.getMetadata();
            String name = metadata.getName();

            CoreV1Api coreApi = new CoreV1Api(apiClient);
            log.info("Creating secret {}", name);
            try {
                coreApi.createNamespacedSecret(namespace, secret)
                        .executeAsync(new NoProgressApiCallback<>() {
                            @Override
                            public void onFailure(ApiException e, int i, Map<String, List<String>> map) {
                                sink.error(e);
                            }

                            @Override
                            public void onSuccess(V1Secret state, int i, Map<String, List<String>> map) {
                                log.info("Secret {} has been successfully created", name);
                                sink.success();
                            }
                        });
            } catch (ApiException e) {
                sink.error(e);
            }
        });
    }