Skip to content

Commit d807e3f

Browse files
committed
Serve status over named pipe on windows workers
Signed-off-by: Kimmo Lehto <[email protected]>
1 parent 2c578da commit d807e3f

File tree

1 file changed

+22
-2
lines changed

1 file changed

+22
-2
lines changed

cmd/worker/worker_windows.go

Lines changed: 22 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,10 @@ import (
1212

1313
"github.com/k0sproject/k0s/internal/pkg/dir"
1414
"github.com/k0sproject/k0s/internal/pkg/log"
15+
"github.com/k0sproject/k0s/pkg/build"
1516
"github.com/k0sproject/k0s/pkg/component/manager"
17+
"github.com/k0sproject/k0s/pkg/component/prober"
18+
"github.com/k0sproject/k0s/pkg/component/status"
1619
"github.com/k0sproject/k0s/pkg/component/worker"
1720
"github.com/k0sproject/k0s/pkg/config"
1821
"github.com/k0sproject/k0s/pkg/constant"
@@ -45,6 +48,23 @@ func initLogging(ctx context.Context, logDir string) error {
4548
return nil
4649
}
4750

48-
func addPlatformSpecificComponents(context.Context, *manager.Manager, *config.CfgVars, EmbeddingController, *worker.CertificateManager) {
49-
// no-op
51+
func addPlatformSpecificComponents(ctx context.Context, m *manager.Manager, k0sVars *config.CfgVars, controller EmbeddingController, certManager *worker.CertificateManager) {
52+
if controller != nil {
53+
return
54+
}
55+
56+
m.Add(ctx, &status.Status{
57+
Prober: prober.DefaultProber,
58+
StatusInformation: status.K0sStatus{
59+
Pid: os.Getpid(),
60+
Role: "worker",
61+
Args: os.Args,
62+
Version: build.Version,
63+
Workloads: true,
64+
SingleNode: false,
65+
K0sVars: k0sVars,
66+
},
67+
CertManager: certManager,
68+
Socket: k0sVars.StatusSocketPath,
69+
})
5070
}

0 commit comments

Comments
 (0)