@Test public void onNewConfigsFromScheduler_shouldStartContainerLogFileStreamingWithAllMatchingContainers() { List<LogstashConfig> dockerFrameworks = asLogstashConfigList(framework1, framework2, framework3); List<LogstashConfig> hostFrameworks = asLogstashConfigList(hostFramework); configureAsRunningFrameworks(framework1, framework3); configManager.onNewConfigsFromScheduler(hostFrameworks, dockerFrameworks); verify(streamManager, times(2)).setupContainerLogfileStreaming( dockerFrameworkArgumentCaptor.capture()); assertTrue(asContainerIdSet(framework1, framework3).contains( dockerFrameworkArgumentCaptor.getAllValues().get(0).getContainerId())); assertTrue(asContainerIdSet(framework1, framework3).contains( dockerFrameworkArgumentCaptor.getAllValues().get(1).getContainerId())); }
public void onNewConfigsFromScheduler(List<LogstashConfig> hostInfo, List<LogstashConfig> dockerInfo) { LOGGER.info("onNewConfigsFromScheduler, {}\n-------\n{}", dockerInfo, hostInfo); this.dockerInfo = dockerInfo; this.hostInfo = hostInfo; LOGGER.info("New configuration received. Reconfiguring..."); updateDockerStreams(); logstash.update(dockerInfo, hostInfo); }
ConfigManager { public void onNewConfigsFromScheduler(List<LogstashConfig> hostInfo, List<LogstashConfig> dockerInfo) { LOGGER.info("onNewConfigsFromScheduler, {}\n-------\n{}", dockerInfo, hostInfo); this.dockerInfo = dockerInfo; this.hostInfo = hostInfo; LOGGER.info("New configuration received. Reconfiguring..."); updateDockerStreams(); logstash.update(dockerInfo, hostInfo); } }
ConfigManager { public void onNewConfigsFromScheduler(List<LogstashConfig> hostInfo, List<LogstashConfig> dockerInfo) { LOGGER.info("onNewConfigsFromScheduler, {}\n-------\n{}", dockerInfo, hostInfo); this.dockerInfo = dockerInfo; this.hostInfo = hostInfo; LOGGER.info("New configuration received. Reconfiguring..."); updateDockerStreams(); logstash.update(dockerInfo, hostInfo); } ConfigManager(LogstashService logstash, ContainerizerClient containerizerClient,
        DockerLogStreamManager dockerLogStreamManager); }
ConfigManager { public void onNewConfigsFromScheduler(List<LogstashConfig> hostInfo, List<LogstashConfig> dockerInfo) { LOGGER.info("onNewConfigsFromScheduler, {}\n-------\n{}", dockerInfo, hostInfo); this.dockerInfo = dockerInfo; this.hostInfo = hostInfo; LOGGER.info("New configuration received. Reconfiguring..."); updateDockerStreams(); logstash.update(dockerInfo, hostInfo); } ConfigManager(LogstashService logstash, ContainerizerClient containerizerClient,
        DockerLogStreamManager dockerLogStreamManager); void onNewConfigsFromScheduler(List<LogstashConfig> hostInfo,
        List<LogstashConfig> dockerInfo); }
ConfigManager { public void onNewConfigsFromScheduler(List<LogstashConfig> hostInfo, List<LogstashConfig> dockerInfo) { LOGGER.info("onNewConfigsFromScheduler, {}\n-------\n{}", dockerInfo, hostInfo); this.dockerInfo = dockerInfo; this.hostInfo = hostInfo; LOGGER.info("New configuration received. Reconfiguring..."); updateDockerStreams(); logstash.update(dockerInfo, hostInfo); } ConfigManager(LogstashService logstash, ContainerizerClient containerizerClient,
        DockerLogStreamManager dockerLogStreamManager); void onNewConfigsFromScheduler(List<LogstashConfig> hostInfo,
        List<LogstashConfig> dockerInfo); static final Logger LOGGER; public List<LogstashConfig> dockerInfo; }