@Test public void jobExecutionsAll() { Collection<JobExecution> jes = jobExecutionService.jobExecutions(empty(), empty(), MAX_VALUE); Assertions.assertThat(jes).hasSize(6); }
public Collection<JobExecution> jobExecutions(Optional<String> jobNameRegexp, Optional<String> exitCode, int maxNumberOfExecutionsPerJobName) { logger.debug("Getting job executions(jobNameRegexp={}, exitCode={}, maxNumberOfExecutionsPerJobName={})", jobNameRegexp, exitCode, maxNumberOfExecutionsPerJobName); return jobExecutionProvider.getJobExecutions(jobNameRegexp, exitCode, maxNumberOfExecutionsPerJobName).stream() .map(JobExecution::fromSpring) .collect(Collectors.toList()); }
JobExecutionService { public Collection<JobExecution> jobExecutions(Optional<String> jobNameRegexp, Optional<String> exitCode, int maxNumberOfExecutionsPerJobName) { logger.debug("Getting job executions(jobNameRegexp={}, exitCode={}, maxNumberOfExecutionsPerJobName={})", jobNameRegexp, exitCode, maxNumberOfExecutionsPerJobName); return jobExecutionProvider.getJobExecutions(jobNameRegexp, exitCode, maxNumberOfExecutionsPerJobName).stream() .map(JobExecution::fromSpring) .collect(Collectors.toList()); } }
JobExecutionService { public Collection<JobExecution> jobExecutions(Optional<String> jobNameRegexp, Optional<String> exitCode, int maxNumberOfExecutionsPerJobName) { logger.debug("Getting job executions(jobNameRegexp={}, exitCode={}, maxNumberOfExecutionsPerJobName={})", jobNameRegexp, exitCode, maxNumberOfExecutionsPerJobName); return jobExecutionProvider.getJobExecutions(jobNameRegexp, exitCode, maxNumberOfExecutionsPerJobName).stream() .map(JobExecution::fromSpring) .collect(Collectors.toList()); } @Autowired  JobExecutionService(JobExplorer jobExplorer, CachedJobExecutionProvider jobExecutionProvider, AdHocStarter adHocStarter); }
JobExecutionService { public Collection<JobExecution> jobExecutions(Optional<String> jobNameRegexp, Optional<String> exitCode, int maxNumberOfExecutionsPerJobName) { logger.debug("Getting job executions(jobNameRegexp={}, exitCode={}, maxNumberOfExecutionsPerJobName={})", jobNameRegexp, exitCode, maxNumberOfExecutionsPerJobName); return jobExecutionProvider.getJobExecutions(jobNameRegexp, exitCode, maxNumberOfExecutionsPerJobName).stream() .map(JobExecution::fromSpring) .collect(Collectors.toList()); } @Autowired  JobExecutionService(JobExplorer jobExplorer, CachedJobExecutionProvider jobExecutionProvider, AdHocStarter adHocStarter); JobExecution jobExecution(long executionId); Collection<JobExecution> jobExecutions(Optional<String> jobNameRegexp,
                                                  Optional<String> exitCode,
                                                  int maxNumberOfExecutionsPerJobName); JobExecution launch(JobConfig jobConfig); Job job(String jobName); }
JobExecutionService { public Collection<JobExecution> jobExecutions(Optional<String> jobNameRegexp, Optional<String> exitCode, int maxNumberOfExecutionsPerJobName) { logger.debug("Getting job executions(jobNameRegexp={}, exitCode={}, maxNumberOfExecutionsPerJobName={})", jobNameRegexp, exitCode, maxNumberOfExecutionsPerJobName); return jobExecutionProvider.getJobExecutions(jobNameRegexp, exitCode, maxNumberOfExecutionsPerJobName).stream() .map(JobExecution::fromSpring) .collect(Collectors.toList()); } @Autowired  JobExecutionService(JobExplorer jobExplorer, CachedJobExecutionProvider jobExecutionProvider, AdHocStarter adHocStarter); JobExecution jobExecution(long executionId); Collection<JobExecution> jobExecutions(Optional<String> jobNameRegexp,
                                                  Optional<String> exitCode,
                                                  int maxNumberOfExecutionsPerJobName); JobExecution launch(JobConfig jobConfig); Job job(String jobName);  }