@Test public void testGetPipelines() { List<Pipeline> result = pipelineRegistry.getPipelines(0, 1000, PipelineRegistry.PIPELINE_NAME_SORT, true); assertTrue(result.isEmpty()); List<Pipeline> pipelines = mockPipelineList("", ELEMENTS_COUNT); pipelines.forEach(pipeline -> pipelineRegistry.registerPipeline(pipeline)); result = pipelineRegistry.getPipelines(0, 1000, PipelineRegistry.PIPELINE_NAME_SORT, true); for (Pipeline pipeline : pipelines) { assertTrue(result.contains(pipeline)); } }
@Override public List<Pipeline> getPipelines(final int page, final int pageSize, final String sort, final boolean sortOrder) { final List<Pipeline> values = pipelineByName.values() .stream() .map(PipelineRegistryEntry::getPipeline).collect(Collectors.toList()); return sortPagedResult(values, page, pageSize, sort, sortOrder); }
InMemoryPipelineRegistry implements PipelineRegistry { @Override public List<Pipeline> getPipelines(final int page, final int pageSize, final String sort, final boolean sortOrder) { final List<Pipeline> values = pipelineByName.values() .stream() .map(PipelineRegistryEntry::getPipeline).collect(Collectors.toList()); return sortPagedResult(values, page, pageSize, sort, sortOrder); } }
InMemoryPipelineRegistry implements PipelineRegistry { @Override public List<Pipeline> getPipelines(final int page, final int pageSize, final String sort, final boolean sortOrder) { final List<Pipeline> values = pipelineByName.values() .stream() .map(PipelineRegistryEntry::getPipeline).collect(Collectors.toList()); return sortPagedResult(values, page, pageSize, sort, sortOrder); } InMemoryPipelineRegistry(); }
InMemoryPipelineRegistry implements PipelineRegistry { @Override public List<Pipeline> getPipelines(final int page, final int pageSize, final String sort, final boolean sortOrder) { final List<Pipeline> values = pipelineByName.values() .stream() .map(PipelineRegistryEntry::getPipeline).collect(Collectors.toList()); return sortPagedResult(values, page, pageSize, sort, sortOrder); } InMemoryPipelineRegistry(); @Override void registerPipeline(final Pipeline pipeline); @Override void registerPipeline(final Pipeline pipeline,
                                 final ProviderType providerType); @Override Pipeline getPipelineByName(final String pipelineId); @Override List<Pipeline> getPipelines(final int page,
                                       final int pageSize,
                                       final String sort,
                                       final boolean sortOrder); @Override List<Pipeline> getPipelines(final String providerType,
                                       final String version,
                                       final int page,
                                       final int pageSize,
                                       final String sort,
                                       final boolean sortOrder); @Override ProviderType getProviderType(final String pipelineId); }
InMemoryPipelineRegistry implements PipelineRegistry { @Override public List<Pipeline> getPipelines(final int page, final int pageSize, final String sort, final boolean sortOrder) { final List<Pipeline> values = pipelineByName.values() .stream() .map(PipelineRegistryEntry::getPipeline).collect(Collectors.toList()); return sortPagedResult(values, page, pageSize, sort, sortOrder); } InMemoryPipelineRegistry(); @Override void registerPipeline(final Pipeline pipeline); @Override void registerPipeline(final Pipeline pipeline,
                                 final ProviderType providerType); @Override Pipeline getPipelineByName(final String pipelineId); @Override List<Pipeline> getPipelines(final int page,
                                       final int pageSize,
                                       final String sort,
                                       final boolean sortOrder); @Override List<Pipeline> getPipelines(final String providerType,
                                       final String version,
                                       final int page,
                                       final int pageSize,
                                       final String sort,
                                       final boolean sortOrder); @Override ProviderType getProviderType(final String pipelineId);  }