feat: intercp communication with catalog (#5445)

Signed-off-by: Jakub Dyszkiewicz <[email protected]>

api/system/v1alpha1/inter_cp_ping.proto

@@ -0,0 +1,16 @@
+syntax = "proto3";
+
+package kuma.system.v1alpha1;
+
+option go_package = "github.com/kumahq/kuma/api/system/v1alpha1";
+
+message PingRequest {
+  string instance_id = 1;
+  string address = 2;
+  uint32 inter_cp_port = 3;
+  bool ready = 4;
+}
+
+message PingResponse { bool leader = 1; }
+
+service InterCpPingService { rpc Ping(PingRequest) returns (PingResponse); }

app/kuma-cp/cmd/run.go

@@ -18,6 +18,7 @@ import (
 	"github.com/kumahq/kuma/pkg/gc"
 	"github.com/kumahq/kuma/pkg/hds"
 	"github.com/kumahq/kuma/pkg/insights"
+	"github.com/kumahq/kuma/pkg/intercp"
 	kds_global "github.com/kumahq/kuma/pkg/kds/global"
 	kds_zone "github.com/kumahq/kuma/pkg/kds/zone"
 	mads_server "github.com/kumahq/kuma/pkg/mads/server"
@@ -135,6 +136,10 @@ func newRunCmdWithOpts(opts kuma_cmd.RunCmdOpts) *cobra.Command {
 				runLog.Error(err, "unable to set up GC")
 				return err
 			}
+			if err := intercp.Setup(rt); err != nil {
+				runLog.Error(err, "unable to set up Control Plane Intercommunication")
+				return err
+			}
 
 			runLog.Info("starting Control Plane", "version", kuma_version.Build.Version)
 			if err := rt.Start(gracefulCtx.Done()); err != nil {

app/kumactl/cmd/install/testdata/install-control-plane.cni-enabled.golden.yaml

@@ -581,6 +581,10 @@ spec:
               valueFrom:
                 fieldRef:
                   fieldPath: metadata.name
+            - name: KUMA_INTER_CP_CATALOG_INSTANCE_ADDRESS
+              valueFrom:
+                fieldRef:
+                  fieldPath: status.podIP
           args:
             - run
             - --log-level=info