@Test void testGetJobPodLabels() { Job job = getMockedJob(); Map<String, String> labels = JobOperationsImpl.getJobPodLabels(job); assertNotNull(labels); assertEquals(1, labels.size()); assertEquals(job.getMetadata().getUid(), labels.get("controller-uid")); }
static Map<String, String> getJobPodLabels(Job job) { Map<String, String> labels = new HashMap<>(); if (job != null && job.getMetadata() != null && job.getMetadata().getUid() != null) { labels.put("controller-uid", job.getMetadata().getUid()); } return labels; }
JobOperationsImpl extends HasMetadataOperation<Job, JobList, DoneableJob, ScalableResource<Job, DoneableJob>> implements ScalableResource<Job, DoneableJob> { static Map<String, String> getJobPodLabels(Job job) { Map<String, String> labels = new HashMap<>(); if (job != null && job.getMetadata() != null && job.getMetadata().getUid() != null) { labels.put("controller-uid", job.getMetadata().getUid()); } return labels; } }
JobOperationsImpl extends HasMetadataOperation<Job, JobList, DoneableJob, ScalableResource<Job, DoneableJob>> implements ScalableResource<Job, DoneableJob> { static Map<String, String> getJobPodLabels(Job job) { Map<String, String> labels = new HashMap<>(); if (job != null && job.getMetadata() != null && job.getMetadata().getUid() != null) { labels.put("controller-uid", job.getMetadata().getUid()); } return labels; } JobOperationsImpl(OkHttpClient client, Config config);  JobOperationsImpl(OkHttpClient client, Config config, String namespace);  JobOperationsImpl(OperationContext context); private  JobOperationsImpl(OperationContext context, Integer podLogWaitTimeout); }
JobOperationsImpl extends HasMetadataOperation<Job, JobList, DoneableJob, ScalableResource<Job, DoneableJob>> implements ScalableResource<Job, DoneableJob> { static Map<String, String> getJobPodLabels(Job job) { Map<String, String> labels = new HashMap<>(); if (job != null && job.getMetadata() != null && job.getMetadata().getUid() != null) { labels.put("controller-uid", job.getMetadata().getUid()); } return labels; } JobOperationsImpl(OkHttpClient client, Config config);  JobOperationsImpl(OkHttpClient client, Config config, String namespace);  JobOperationsImpl(OperationContext context); private  JobOperationsImpl(OperationContext context, Integer podLogWaitTimeout); @Override JobOperationsImpl newInstance(OperationContext context); @Override ScalableResource<Job, DoneableJob> load(InputStream is); @Override ScalableResource<Job, DoneableJob> fromServer(); @Override Job scale(int count); @Override Scale scale(); @Override Scale scale(Scale scale); @Override Job scale(int count, boolean wait); String getLog(); String getLog(Boolean isPretty); @Override Reader getLogReader(); @Override LogWatch watchLog(); @Override LogWatch watchLog(OutputStream out); @Override Loggable<String, LogWatch> withLogWaitTimeout(Integer logWaitTimeout); @Override Job replace(Job job); }
JobOperationsImpl extends HasMetadataOperation<Job, JobList, DoneableJob, ScalableResource<Job, DoneableJob>> implements ScalableResource<Job, DoneableJob> { static Map<String, String> getJobPodLabels(Job job) { Map<String, String> labels = new HashMap<>(); if (job != null && job.getMetadata() != null && job.getMetadata().getUid() != null) { labels.put("controller-uid", job.getMetadata().getUid()); } return labels; } JobOperationsImpl(OkHttpClient client, Config config);  JobOperationsImpl(OkHttpClient client, Config config, String namespace);  JobOperationsImpl(OperationContext context); private  JobOperationsImpl(OperationContext context, Integer podLogWaitTimeout); @Override JobOperationsImpl newInstance(OperationContext context); @Override ScalableResource<Job, DoneableJob> load(InputStream is); @Override ScalableResource<Job, DoneableJob> fromServer(); @Override Job scale(int count); @Override Scale scale(); @Override Scale scale(Scale scale); @Override Job scale(int count, boolean wait); String getLog(); String getLog(Boolean isPretty); @Override Reader getLogReader(); @Override LogWatch watchLog(); @Override LogWatch watchLog(OutputStream out); @Override Loggable<String, LogWatch> withLogWaitTimeout(Integer logWaitTimeout); @Override Job replace(Job job);  }