Fixups after Node refactor
Test Plan: Tested in the CTS revision.
X-Origin-Diff: phab/D618
GitOrigin-RevId: 4c591d463a0709fc944f52e32069cb7ababd55ca
diff --git a/core/cmd/init/main.go b/core/cmd/init/main.go
index 0c19ef9..701cea6 100644
--- a/core/cmd/init/main.go
+++ b/core/cmd/init/main.go
@@ -54,7 +54,7 @@
// be configurable by loading it from the EnrolmentConfig. Fow now, it's static and same across all clusters.
kubernetesConfig = kubernetes.Config{
ServiceIPRange: net.IPNet{ // TODO(q3k): Decide if configurable / final value
- IP: net.IP{192, 168, 188, 0},
+ IP: net.IP{10, 0, 255, 1},
Mask: net.IPMask{0xff, 0xff, 0xff, 0x00}, // /24, but Go stores as a literal mask
},
ClusterNet: net.IPNet{
diff --git a/core/internal/cluster/manager.go b/core/internal/cluster/manager.go
index dfdab36..38c2945 100644
--- a/core/internal/cluster/manager.go
+++ b/core/internal/cluster/manager.go
@@ -294,6 +294,8 @@
return fmt.Errorf("joining a cluster without a golden ticket not yet implemented")
}
+ m.goldenTicket = enrolmentConfig.GoldenTicket
+
// Otherwise, we begin enrolling with the Golden Ticket.
m.next(ctx, StateCharlie)
return nil
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 {
diff --git a/core/internal/launch/launch.go b/core/internal/launch/launch.go
index 90eb00b..f20d721 100644
--- a/core/internal/launch/launch.go
+++ b/core/internal/launch/launch.go
@@ -235,7 +235,7 @@
return err
}
- qemuArgs := []string{"-machine", "q35", "-accel", "kvm", "-nographic", "-nodefaults", "-m", "2048",
+ qemuArgs := []string{"-machine", "q35", "-accel", "kvm", "-nographic", "-nodefaults", "-m", "4096",
"-cpu", "host", "-smp", "sockets=1,cpus=1,cores=2,threads=2,maxcpus=4",
"-drive", "if=pflash,format=raw,readonly,file=external/edk2/OVMF_CODE.fd",
"-drive", "if=pflash,format=raw,snapshot=on,file=external/edk2/OVMF_VARS.fd",