inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-07-31 17:39:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Get alfresco logs for all nodes from a cluster

Browse Source
This commit is contained in:
Claudia Agache
2020-04-29 13:25:51 +03:00
parent d920cd3f71
commit 09efe2af90
1 changed files with 20 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
rm-automation/rm-automation-community-rest-api/src/main/java/org/alfresco/rest/rm/community/util/DockerHelper.java
View File

@@ -30,7 +30,7 @@ package org.alfresco.rest.rm.community.util;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collections; import java.util.Collections;
import java.util.List; import java.util.List;
import java.util.Optional; import java.util.stream.Collectors;
import com.github.dockerjava.api.DockerClient; import com.github.dockerjava.api.DockerClient;
import com.github.dockerjava.api.command.LogContainerCmd; import com.github.dockerjava.api.command.LogContainerCmd;
@@ -80,13 +80,12 @@ public class DockerHelper
* Method for returning logs of docker container * Method for returning logs of docker container
* *
* @param containerId - ID of the container * @param containerId - ID of the container
* @param timeStamp - get the logs since a specific timestamp
* @return list of strings, where every string is log line * @return list of strings, where every string is log line
*/ */
private List<String> getDockerLogs(String containerId) private List<String> getDockerLogs(String containerId, int timeStamp)
{ {
final List<String> logs = new ArrayList<>(); final List<String> logs = new ArrayList<>();
// get the logs since current time - 10 seconds
final int timeStamp = (int) (System.currentTimeMillis() / 1000) - 10;
final LogContainerCmd logContainerCmd = getDockerClient().logContainerCmd(containerId); final LogContainerCmd logContainerCmd = getDockerClient().logContainerCmd(containerId);
logContainerCmd.withStdOut(true) logContainerCmd.withStdOut(true)
@@ -121,22 +120,33 @@ public class DockerHelper
*/ */
public List<String> getAlfrescoLogs() public List<String> getAlfrescoLogs()
{ {
final Optional<Container> alfrescoContainer = findContainerByImageName(REPO_IMAGE_NAME); final List<Container> alfrescoContainers = findContainersByImageName(REPO_IMAGE_NAME);
return (alfrescoContainer.isPresent()) ? getDockerLogs(alfrescoContainer.get().getId()) : Collections.emptyList(); if (alfrescoContainers.isEmpty())
{
return Collections.emptyList();
}
else
{
List<String> alfrescoLogs = new ArrayList<>();
// get the logs since current time - 10 seconds
final int timeStamp = (int) (System.currentTimeMillis() / 1000) - 10;
alfrescoContainers.forEach(alfrescoContainer -> alfrescoLogs.addAll(getDockerLogs(alfrescoContainer.getId(), timeStamp)));
return alfrescoLogs;
}
} }
/** /**
* Method for finding a docker container after the image name * Method for finding docker containers after the image name
* *
* @param imageName - the name of the image used by container * @param imageName - the name of the image used by container
* @return the container * @return the containers
*/ */
private Optional<Container> findContainerByImageName(String imageName) private List<Container> findContainersByImageName(String imageName)
{ {
final List<Container> containers = getDockerClient().listContainersCmd().withShowAll(true).exec(); final List<Container> containers = getDockerClient().listContainersCmd().withShowAll(true).exec();
return containers.stream() return containers.stream()
.filter(container -> container.getImage().contains(imageName)) .filter(container -> container.getImage().contains(imageName))
.findFirst(); .collect(Collectors.toList());
} }
} }