Fixups after Node refactor
Test Plan: Tested in the CTS revision.
X-Origin-Diff: phab/D618
GitOrigin-RevId: 4c591d463a0709fc944f52e32069cb7ababd55ca
diff --git a/core/internal/kubernetes/clusternet/clusternet.go b/core/internal/kubernetes/clusternet/clusternet.go
index e41ba8a..bb1f183 100644
--- a/core/internal/kubernetes/clusternet/clusternet.go
+++ b/core/internal/kubernetes/clusternet/clusternet.go
@@ -202,11 +202,17 @@
// Run runs the ClusterNet service. See package description for what it does.
func (s *Service) Run(ctx context.Context) error {
logger := supervisor.Logger(ctx)
+ s.logger = logger
wgClient, err := wgctrl.New()
if err != nil {
return fmt.Errorf("failed to connect to netlink's WireGuard config endpoint: %w", err)
}
+ s.wgClient = wgClient
+
+ if err := s.ensureOnDiskKey(); err != nil {
+ return fmt.Errorf("failed to ensure on-disk key: %w", err)
+ }
wgInterface := &Wireguard{LinkAttrs: netlink.LinkAttrs{Name: clusterNetDeviceName, Flags: net.FlagUp}}
if err := netlink.LinkAdd(wgInterface); err != nil {