@Test public void testSearch() throws Exception { DockerHubRegistry defaultRegisrty = (DockerHubRegistry) registryRepository.getDefaultRegistry(); SearchResult ubuntu = defaultRegisrty.search("ubuntu", 0, 1000); Assert.assertNotNull(ubuntu.getResults()); Assert.assertNotNull(ubuntu); }
@Override public SearchResult search(String query, final int page, final int size) { RegistrySearchHelper rsh = new RegistrySearchHelper(query, page, size); for (RegistryService service : map.values()) { rsh.search(service); } rsh.search(defaultRegistry); return rsh.collect(); }
RegistryRepository implements SupportSearch { @Override public SearchResult search(String query, final int page, final int size) { RegistrySearchHelper rsh = new RegistrySearchHelper(query, page, size); for (RegistryService service : map.values()) { rsh.search(service); } rsh.search(defaultRegistry); return rsh.collect(); } }
RegistryRepository implements SupportSearch { @Override public SearchResult search(String query, final int page, final int size) { RegistrySearchHelper rsh = new RegistrySearchHelper(query, page, size); for (RegistryService service : map.values()) { rsh.search(service); } rsh.search(defaultRegistry); return rsh.collect(); } RegistryRepository(KvMapperFactory mapperFactory,
                              DockerHubRegistry defaultRegistry,
                              RegistryFactory factory,
                              @Qualifier(RegistryEvent.BUS) MessageBus<RegistryEvent> eventBus); }
RegistryRepository implements SupportSearch { @Override public SearchResult search(String query, final int page, final int size) { RegistrySearchHelper rsh = new RegistrySearchHelper(query, page, size); for (RegistryService service : map.values()) { rsh.search(service); } rsh.search(defaultRegistry); return rsh.collect(); } RegistryRepository(KvMapperFactory mapperFactory,
                              DockerHubRegistry defaultRegistry,
                              RegistryFactory factory,
                              @Qualifier(RegistryEvent.BUS) MessageBus<RegistryEvent> eventBus); void init(List<RegistryConfig> configs); void register(RegistryService registryService); void unRegister(String name); List<ImageCatalog> getCatalog(Collection<String> names); Collection<String> getAvailableRegistries(); String resolveRegistryNameByImageName(String imageName); RegistryService getRegistryByImageName(String imageName); RegistryService getByName(String registryName); @Override SearchResult search(String query, final int page, final int size); }
RegistryRepository implements SupportSearch { @Override public SearchResult search(String query, final int page, final int size) { RegistrySearchHelper rsh = new RegistrySearchHelper(query, page, size); for (RegistryService service : map.values()) { rsh.search(service); } rsh.search(defaultRegistry); return rsh.collect(); } RegistryRepository(KvMapperFactory mapperFactory,
                              DockerHubRegistry defaultRegistry,
                              RegistryFactory factory,
                              @Qualifier(RegistryEvent.BUS) MessageBus<RegistryEvent> eventBus); void init(List<RegistryConfig> configs); void register(RegistryService registryService); void unRegister(String name); List<ImageCatalog> getCatalog(Collection<String> names); Collection<String> getAvailableRegistries(); String resolveRegistryNameByImageName(String imageName); RegistryService getRegistryByImageName(String imageName); RegistryService getByName(String registryName); @Override SearchResult search(String query, final int page, final int size);  }