Add helm value to enable cluster peering

charts/consul/templates/connect-inject-deployment.yaml

@@ -1,3 +1,4 @@
+{{- if and .Values.global.peering.enabled (not .Values.connectInject.enabled) }}{{ fail "setting global.peering.enabled to true requires connectInject.enabled to be true" }}{{ end }}
 {{- if (or (and (ne (.Values.connectInject.enabled | toString) "-") .Values.connectInject.enabled) (and (eq (.Values.connectInject.enabled | toString) "-") .Values.global.enabled)) }}
 {{- if not (or (and (ne (.Values.client.enabled | toString) "-") .Values.client.enabled) (and (eq (.Values.client.enabled | toString) "-") .Values.global.enabled)) }}{{ fail "clients must be enabled for connect injection" }}{{ end }}
 {{- if not .Values.client.grpc }}{{ fail "client.grpc must be true for connect injection" }}{{ end }}
@@ -111,6 +112,9 @@ spec:
                 {{- else }}
                 -default-enable-transparent-proxy=false \
                 {{- end }}
+                {{- if .Values.global.peering.enabled }}
+                -enable-peering=true \
+                {{- end }}
                 {{- if .Values.global.openshift.enabled }}
                 -enable-openshift \
                 {{- end }}

charts/consul/templates/crd-exportedservices.yaml

@@ -76,8 +76,8 @@ spec:
                               the service to.
                             type: string
                           peerName:
-                            description: PeerName is the name of the peer to export
-                              the service to.
+                            description: '[Experimental] PeerName is the name of the
+                              peer to export the service to.'
                             type: string
                         type: object
                       type: array

charts/consul/templates/crd-peeringacceptors.yaml

@@ -1,4 +1,4 @@
-{{- if .Values.connectInject.enabled }}
+{{- if and .Values.connectInject.enabled .Values.global.peering.enabled }}
 ---
 apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition

charts/consul/templates/crd-peeringdialers.yaml

@@ -1,4 +1,4 @@
-{{- if .Values.connectInject.enabled }}
+{{- if and .Values.connectInject.enabled .Values.global.peering.enabled }}
 ---
 apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition

charts/consul/templates/crd-serviceintentions.yaml

@@ -102,7 +102,8 @@ spec:
                       description: Partition is the Admin Partition for the Name parameter.
                       type: string
                     peer:
-                      description: Peer is the peer name for the Name parameter.
+                      description: '[Experimental] Peer is the peer name for the Name
+                        parameter.'
                       type: string
                     permissions:
                       description: Permissions is the list of all additional L7 attributes

charts/consul/test/unit/connect-inject-deployment.bats

@@ -1730,6 +1730,43 @@ EOF
   [ "${actual}" = "true" ]
 }
 
+#--------------------------------------------------------------------
+# peering
+
+@test "connectInject/Deployment: peering is not set by default" {
+  cd `chart_dir`
+  local actual=$(helm template \
+      -s templates/connect-inject-deployment.yaml  \
+      --set 'connectInject.enabled=true' \
+      . | tee /dev/stderr |
+      yq '.spec.template.spec.containers[0].command | any(contains("-enable-peering=true"))' | tee /dev/stderr)
+
+  [ "${actual}" = "false" ]
+}
+
+@test "connectInject/Deployment: -enable-peering=true is set when global.peering.enabled is true" {
+  cd `chart_dir`
+  local actual=$(helm template \
+      -s templates/connect-inject-deployment.yaml  \
+      --set 'connectInject.enabled=true' \
+      --set 'global.peering.enabled=true' \
+      . | tee /dev/stderr |
+      yq '.spec.template.spec.containers[0].command | any(contains("-enable-peering=true"))' | tee /dev/stderr)
+
+  [ "${actual}" = "true" ]
+}
+
+@test "connectInject/Deployment: fails if peering is enabled but connect inject is not" {
+  cd `chart_dir`
+  run helm template \
+      -s templates/connect-inject-deployment.yaml  \
+      --set 'connectInject.enabled=false' \
+      --set 'global.peering.enabled=true' .
+  [ "$status" -eq 1 ]
+  [[ "$output" =~ "setting global.peering.enabled to true requires connectInject.enabled to be true" ]]
+}
+
+
 #--------------------------------------------------------------------
 # openshift
 

charts/consul/values.yaml

@@ -29,6 +29,13 @@ global:
   # Consul into Kubernetes will have, e.g. `service-name.service.consul`.
   domain: consul
 
+  # [Experimental] Configures the Cluster Peering feature. Requires Consul v1.13+ and Consul-K8s v0.45+.
+  peering:
+    # If true, the Helm chart will enable Cluster Peering for the cluster. This will enable peering controllers and
+    # allow use of the PeeringAcceptor and PeeringDialer CRDs to establish peerings for service mesh.
+    # @type boolean
+    enabled: false
+
   # [Enterprise Only] Enabling `adminPartitions` allows creation of Admin Partitions in Kubernetes clusters.
   # It additionally indicates that you are running Consul Enterprise v1.11+ with a valid Consul Enterprise
   # license. Admin partitions enables deploying services across partitions, while sharing

control-plane/api/v1alpha1/exportedservices_types.go

@@ -68,7 +68,7 @@ type ExportedService struct {
 type ServiceConsumer struct {
 	// Partition is the admin partition to export the service to.
 	Partition string `json:"partition,omitempty"`
-	// PeerName is the name of the peer to export the service to.
+	// [Experimental] PeerName is the name of the peer to export the service to.
 	PeerName string `json:"peerName,omitempty"`
 }
 

control-plane/api/v1alpha1/serviceintentions_types.go

@@ -78,7 +78,7 @@ type SourceIntention struct {
 	Name string `json:"name,omitempty"`
 	// Namespace is the namespace for the Name parameter.
 	Namespace string `json:"namespace,omitempty"`
-	// Peer is the peer name for the Name parameter.
+	// [Experimental] Peer is the peer name for the Name parameter.
 	Peer string `json:"peer,omitempty"`
 	// Partition is the Admin Partition for the Name parameter.
 	Partition string `json:"partition,omitempty"`

control-plane/config/crd/bases/consul.hashicorp.com_exportedservices.yaml

@@ -69,8 +69,8 @@ spec:
                               the service to.
                             type: string
                           peerName:
-                            description: PeerName is the name of the peer to export
-                              the service to.
+                            description: '[Experimental] PeerName is the name of the
+                              peer to export the service to.'
                             type: string
                         type: object
                       type: array

control-plane/config/crd/bases/consul.hashicorp.com_serviceintentions.yaml

@@ -95,7 +95,8 @@ spec:
                       description: Partition is the Admin Partition for the Name parameter.
                       type: string
                     peer:
-                      description: Peer is the peer name for the Name parameter.
+                      description: '[Experimental] Peer is the peer name for the Name
+                        parameter.'
                       type: string
                     permissions:
                       description: Permissions is the list of all additional L7 attributes

control-plane/subcommand/inject-connect/command.go

@@ -93,6 +93,9 @@ type Command struct {
 	flagDefaultEnableTransparentProxy          bool
 	flagTransparentProxyDefaultOverwriteProbes bool
 
+	// Peering flags.
+	flagEnablePeering bool
+
 	// Consul DNS flags.
 	flagEnableConsulDNS bool
 	flagResourcePrefix  string
@@ -133,6 +136,7 @@ func (c *Command) init() {
 		"Docker image for Envoy.")
 	c.flagSet.StringVar(&c.flagConsulK8sImage, "consul-k8s-image", "",
 		"Docker image for consul-k8s. Used for the connect sidecar.")
+	c.flagSet.BoolVar(&c.flagEnablePeering, "enable-peering", false, "Enable cluster peering controllers.")
 	c.flagSet.StringVar(&c.flagEnvoyExtraArgs, "envoy-extra-args", "",
 		"Extra envoy command line args to be set when starting envoy (e.g \"--log-level debug --disable-hot-restart\").")
 	c.flagSet.StringVar(&c.flagACLAuthMethod, "acl-auth-method", "",
@@ -426,26 +430,29 @@ func (c *Command) Run(args []string) int {
 		return 1
 	}
 
-	if err = (&connectinject.PeeringAcceptorController{
-		Client:       mgr.GetClient(),
-		ConsulClient: c.consulClient,
-		Log:          ctrl.Log.WithName("controller").WithName("peering-acceptor"),
-		Scheme:       mgr.GetScheme(),
-		Context:      ctx,
-	}).SetupWithManager(mgr); err != nil {
-		setupLog.Error(err, "unable to create controller", "controller", "peering-acceptor")
-		return 1
-	}
-	if err = (&connectinject.PeeringDialerController{
-		Client:       mgr.GetClient(),
-		ConsulClient: c.consulClient,
-		Log:          ctrl.Log.WithName("controller").WithName("peering-dialer"),
-		Scheme:       mgr.GetScheme(),
-		Context:      ctx,
-	}).SetupWithManager(mgr); err != nil {
-		setupLog.Error(err, "unable to create controller", "controller", "peering-dialer")
-		return 1
+	if c.flagEnablePeering {
+		if err = (&connectinject.PeeringAcceptorController{
+			Client:       mgr.GetClient(),
+			ConsulClient: c.consulClient,
+			Log:          ctrl.Log.WithName("controller").WithName("peering-acceptor"),
+			Scheme:       mgr.GetScheme(),
+			Context:      ctx,
+		}).SetupWithManager(mgr); err != nil {
+			setupLog.Error(err, "unable to create controller", "controller", "peering-acceptor")
+			return 1
+		}
+		if err = (&connectinject.PeeringDialerController{
+			Client:       mgr.GetClient(),
+			ConsulClient: c.consulClient,
+			Log:          ctrl.Log.WithName("controller").WithName("peering-dialer"),
+			Scheme:       mgr.GetScheme(),
+			Context:      ctx,
+		}).SetupWithManager(mgr); err != nil {
+			setupLog.Error(err, "unable to create controller", "controller", "peering-dialer")
+			return 1
+		}
 	}
+
 	mgr.GetWebhookServer().CertDir = c.flagCertDir
 
 	mgr.GetWebhookServer().Register("/mutate",