hendrik/lens
1
0
Fork 0
mirror of https://github.com/lensapp/lens.git synced 2025-05-20 05:10:56 +00:00
Code Issues Projects Releases Wiki Activity

fix ClusterManager cluster auto-init

Browse Source 
Signed-off-by: Jari Kolehmainen <jari.kolehmainen@gmail.com>
This commit is contained in:
Jari Kolehmainen 2021-01-29 12:08:37 +02:00
parent 1da282444a
commit 92e30ddaa2
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/cluster-manager.ts
View File

@ -1,7 +1,7 @@
import "../common/cluster-ipc"; import "../common/cluster-ipc";
import type http from "http"; import type http from "http";
import { ipcMain } from "electron"; import { ipcMain } from "electron";
import { autorun } from "mobx"; import { autorun, reaction } from "mobx";
import { clusterStore, getClusterIdFromHost } from "../common/cluster-store"; import { clusterStore, getClusterIdFromHost } from "../common/cluster-store";
import { Cluster } from "./cluster"; import { Cluster } from "./cluster";
import logger from "./logger"; import logger from "./logger";
@ -12,14 +12,14 @@ export class ClusterManager extends Singleton {
constructor(public readonly port: number) { constructor(public readonly port: number) {
super(); super();
// auto-init clusters // auto-init clusters
autorun(() => { reaction(() => clusterStore.enabledClustersList, (clusters) => {
clusterStore.enabledClustersList.forEach(cluster => { clusters.forEach((cluster) => {
if (!cluster.initialized && !cluster.initializing) { if (!cluster.initialized && !cluster.initializing) {
logger.info(`[CLUSTER-MANAGER]: init cluster`, cluster.getMeta()); logger.info(`[CLUSTER-MANAGER]: init cluster`, cluster.getMeta());
cluster.init(port); cluster.init(port);
} }
}); });
}); }, { fireImmediately: true });
// auto-stop removed clusters // auto-stop removed clusters
autorun(() => { autorun(() => {