Merge pull request #1571 from rkokkelk/issue/1496
Fix: use service labels instead of container for service discovery with Docker Swarm
This commit is contained in:
commit
27958c9f69
1 changed files with 8 additions and 6 deletions
|
@ -63,10 +63,10 @@ export async function servicesFromDocker() {
|
||||||
const serviceServers = await Promise.all(
|
const serviceServers = await Promise.all(
|
||||||
Object.keys(servers).map(async (serverName) => {
|
Object.keys(servers).map(async (serverName) => {
|
||||||
try {
|
try {
|
||||||
|
const isSwarm = !!servers[serverName].swarm;
|
||||||
const docker = new Docker(getDockerArguments(serverName).conn);
|
const docker = new Docker(getDockerArguments(serverName).conn);
|
||||||
const containers = await docker.listContainers({
|
const listProperties = { all: true };
|
||||||
all: true,
|
const containers = await ((isSwarm) ? docker.listServices(listProperties) : docker.listContainers(listProperties));
|
||||||
});
|
|
||||||
|
|
||||||
// bad docker connections can result in a <Buffer ...> object?
|
// bad docker connections can result in a <Buffer ...> object?
|
||||||
// in any case, this ensures the result is the expected array
|
// in any case, this ensures the result is the expected array
|
||||||
|
@ -76,17 +76,19 @@ export async function servicesFromDocker() {
|
||||||
|
|
||||||
const discovered = containers.map((container) => {
|
const discovered = containers.map((container) => {
|
||||||
let constructedService = null;
|
let constructedService = null;
|
||||||
|
const containerLabels = isSwarm ? shvl.get(container, 'Spec.Labels') : container.Labels;
|
||||||
|
const containerName = isSwarm ? shvl.get(container, 'Spec.Name') : container.Names[0];
|
||||||
|
|
||||||
Object.keys(container.Labels).forEach((label) => {
|
Object.keys(containerLabels).forEach((label) => {
|
||||||
if (label.startsWith("homepage.")) {
|
if (label.startsWith("homepage.")) {
|
||||||
if (!constructedService) {
|
if (!constructedService) {
|
||||||
constructedService = {
|
constructedService = {
|
||||||
container: container.Names[0].replace(/^\//, ""),
|
container: containerName.replace(/^\//, ""),
|
||||||
server: serverName,
|
server: serverName,
|
||||||
type: 'service'
|
type: 'service'
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
shvl.set(constructedService, label.replace("homepage.", ""), substituteEnvironmentVars(container.Labels[label]));
|
shvl.set(constructedService, label.replace("homepage.", ""), substituteEnvironmentVars(containerLabels[label]));
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue