apis: add traffic distribution and internal traffic policies fields

Signed-off-by: Arthur Outhenin-Chalandre <[email protected]>

Author: MrFreezeex

config/crd/multicluster.x-k8s.io_serviceimports.yaml

@@ -72,6 +72,15 @@ spec:
                 - ports
                 - type
               properties:
+                internalTrafficPolicy:
+                  description: |-
+                    InternalTrafficPolicy describes how nodes distribute service traffic they
+                    receive on the ClusterIP. If set to "Local", the proxy will assume that pods
+                    only want to talk to endpoints of the service on the same node as the pod,
+                    dropping the traffic if there are no local endpoints. The default value,
+                    "Cluster", uses the standard behavior of routing to all endpoints evenly
+                    (possibly modified by topology and other features).
+                  type: string
                 ips:
                   description: ip will be used as the VIP for this service when type is ClusterSetIP.
                   type: array
@@ -145,6 +154,15 @@ spec:
                             Default value is 10800(for 3 hours).
                           type: integer
                           format: int32
+                trafficDistribution:
+                  description: |-
+                    TrafficDistribution offers a way to express preferences for how traffic
+                    is distributed to Service endpoints. Implementations can use this field
+                    as a hint, but are not required to guarantee strict adherence. If the
+                    field is not set, the implementation will apply its default routing
+                    strategy. If set to "PreferClose", implementations should prioritize
+                    endpoints that are in the same zone.
+                  type: string
                 type:
                   description: |-
                     type defines the type of this service.

pkg/apis/v1alpha1/serviceexport.go

@@ -265,6 +265,14 @@ const (
 	// annotations.
 	ServiceExportReasonAnnotationsConflict ServiceExportConditionReason = "AnnotationsConflict"
 
+	// ServiceExportReasonInternalTrafficPolicyConflict is used with the "Conflict"
+	// condition when the exported service has a conflict related to internal traffic policy.
+	ServiceExportReasonInternalTrafficPolicyConflict ServiceExportConditionReason = "InternalTrafficPolicyConflict"
+
+	// ServiceExportReasonTrafficDistributionConflict is used with the "Conflict"
+	// condition when the exported service has a conflict related to traffic distribution.
+	ServiceExportReasonTrafficDistributionConflict ServiceExportConditionReason = "TrafficDistributionConflict"
+
 	// ServiceExportReasonNoConflicts is used with the "Conflict" condition
 	// when the condition is False.
 	ServiceExportReasonNoConflicts ServiceExportConditionReason = "NoConflicts"

pkg/apis/v1alpha1/serviceimport.go

@@ -84,6 +84,24 @@ type ServiceImportSpec struct {
 	// sessionAffinityConfig contains session affinity configuration.
 	// +optional
 	SessionAffinityConfig *v1.SessionAffinityConfig `json:"sessionAffinityConfig,omitempty"`
+
+	// InternalTrafficPolicy describes how nodes distribute service traffic they
+	// receive on the ClusterIP. If set to "Local", the proxy will assume that pods
+	// only want to talk to endpoints of the service on the same node as the pod,
+	// dropping the traffic if there are no local endpoints. The default value,
+	// "Cluster", uses the standard behavior of routing to all endpoints evenly
+	// (possibly modified by topology and other features).
+	// +optional
+	InternalTrafficPolicy *v1.ServiceInternalTrafficPolicy `json:"internalTrafficPolicy,omitempty"`
+
+	// TrafficDistribution offers a way to express preferences for how traffic
+	// is distributed to Service endpoints. Implementations can use this field
+	// as a hint, but are not required to guarantee strict adherence. If the
+	// field is not set, the implementation will apply its default routing
+	// strategy. If set to "PreferClose", implementations should prioritize
+	// endpoints that are in the same zone.
+	// +optional
+	TrafficDistribution *string `json:"trafficDistribution,omitempty"`
 }
 
 // ServicePort represents the port on which the service is exposed