■ ■ ■ ■ ■ ■
src/main/java/io/onedev/k8shelper/KubernetesHelper.java
| skipped 805 lines |
806 | 806 | | List<Action> actions = jobData.getActions(); |
807 | 807 | | |
808 | 808 | | new CompositeExecutable(actions).execute(commandHandler, new ArrayList<>()); |
809 | | - | |
810 | | - | installJVMCert(); |
811 | | - | |
812 | | - | Client client = ClientBuilder.newClient(); |
813 | | - | try { |
814 | | - | logger.info("Reporting job caches to '{}'...", serverUrl); |
815 | | - | WebTarget target = client.target(serverUrl).path("api/k8s/report-job-caches"); |
816 | | - | Invocation.Builder builder = target.request(); |
817 | | - | builder.header(HttpHeaders.AUTHORIZATION, BEARER + " " + jobToken); |
818 | | - | StringBuilder toStringBuilder = new StringBuilder(); |
819 | | - | for (CacheInstance instance: getCacheInstances(getCacheHome()).keySet()) |
820 | | - | toStringBuilder.append(instance.toString()).append(";"); |
821 | | - | Response response = builder.post(Entity.entity(toStringBuilder.toString(), MediaType.APPLICATION_OCTET_STREAM)); |
822 | | - | try { |
823 | | - | checkStatus(response); |
824 | | - | } finally { |
825 | | - | response.close(); |
826 | | - | } |
827 | | - | } finally { |
828 | | - | client.close(); |
829 | | - | } |
830 | 809 | | } |
831 | 810 | | } |
832 | 811 | | |
| skipped 240 lines |