@Test public void testNoCellIsSelectedForNonGpuJob() { assertThat(router.routeKey(JobDescriptor.getDefaultInstance())).isEmpty(); }
@Override public Optional<Cell> routeKey(JobDescriptor jobDescriptor) { return selector.select(instanceTypeRouteKeyResolver.apply(jobDescriptor), c -> true); }
SpecialInstanceTypeRouter implements CellRouter { @Override public Optional<Cell> routeKey(JobDescriptor jobDescriptor) { return selector.select(instanceTypeRouteKeyResolver.apply(jobDescriptor), c -> true); } }
SpecialInstanceTypeRouter implements CellRouter { @Override public Optional<Cell> routeKey(JobDescriptor jobDescriptor) { return selector.select(instanceTypeRouteKeyResolver.apply(jobDescriptor), c -> true); } SpecialInstanceTypeRouter(CellInfoResolver cellInfoResolver,
                                     Function<JobDescriptor, String> instanceTypeRouteKeyResolver,
                                     TitusFederationConfiguration federationConfiguration); }
SpecialInstanceTypeRouter implements CellRouter { @Override public Optional<Cell> routeKey(JobDescriptor jobDescriptor) { return selector.select(instanceTypeRouteKeyResolver.apply(jobDescriptor), c -> true); } SpecialInstanceTypeRouter(CellInfoResolver cellInfoResolver,
                                     Function<JobDescriptor, String> instanceTypeRouteKeyResolver,
                                     TitusFederationConfiguration federationConfiguration); @Override Optional<Cell> routeKey(JobDescriptor jobDescriptor); static SpecialInstanceTypeRouter getGpuInstanceTypeRouter(CellInfoResolver cellInfoResolver,
                                                                     TitusFederationConfiguration federationConfiguration); }
SpecialInstanceTypeRouter implements CellRouter { @Override public Optional<Cell> routeKey(JobDescriptor jobDescriptor) { return selector.select(instanceTypeRouteKeyResolver.apply(jobDescriptor), c -> true); } SpecialInstanceTypeRouter(CellInfoResolver cellInfoResolver,
                                     Function<JobDescriptor, String> instanceTypeRouteKeyResolver,
                                     TitusFederationConfiguration federationConfiguration); @Override Optional<Cell> routeKey(JobDescriptor jobDescriptor); static SpecialInstanceTypeRouter getGpuInstanceTypeRouter(CellInfoResolver cellInfoResolver,
                                                                     TitusFederationConfiguration federationConfiguration);  }