ComputerSurge/docker-traefik-labels
3
0
Fork 0
forked from github-starred/docker-traefik-labels
Code Pull Requests Actions Packages Releases Activity

add poll info

Browse Source
This commit is contained in:
ElevenNotes
2024-02-01 11:02:49 +01:00
parent b09f41e04f
commit 53d0fb843d
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
rootfs/labels/main.js
View File

@@ -65,6 +65,7 @@ class Labels{
this.#redis.on('ready', async()=>{
elevenLogJSON('info', `connected to redis`);
await this.#ping();
elevenLogJSON('info', `start initial poll after container start`);
await this.#poll();
});
@@ -90,7 +91,6 @@ class Labels{
}
}
}, (this.#config?.ping?.interval || this.#defaults.ping.interval)*1000);
await this.#ping();
}
for(const node in this.#nodes){
@@ -113,7 +113,6 @@ class Labels{
}
this.#nodes[node].labels.ping = true;
}catch(e){
elevenLogJSON('error', JSON.stringify({ping:{exception:e.toString()}}));
if(this.#nodes[node].labels.ping && !this.#nodes[node].labels.firstConnect){
elevenLogJSON('warning', `connection to node [${node}] lost!`);
}else if(this.#nodes[node].labels.firstConnect){
@@ -140,12 +139,12 @@ class Labels{
}
}
}, (this.#config?.poll?.interval || this.#defaults.poll.interval)*1000);
await this.#poll();
}
for(const node in this.#nodes){
try{
await this.#nodes[node].listContainers((error, containers) => {
elevenLogJSON('info', `poll started on node [${node}]`);
if(!error){
containers.forEach(async(container) => {
await this.#inspect(node, container.Id, 'poll');