add gatewayclass matching to gateways.

Author: zongzw

controllers/utils.go

@@ -35,6 +35,9 @@ func syncGatewaysAtStart(r *GatewayReconciler, ctx context.Context) error {
 		return fmt.Errorf("unable to list gateways: %s", err.Error())
 	} else {
 		for _, gw := range gws.Items {
+			if gw.Spec.GatewayClassName != gatewayv1beta1.ObjectName(pkg.ActiveSIGs.GatewayClass) {
+				continue
+			}
 			zlog.V(1).Info("found gw: " + utils.Keyname(gw.Namespace, gw.Name))
 			pkg.ActiveSIGs.SetGateway(gw.DeepCopy())
 		}

main.go

@@ -64,12 +64,15 @@ func init() {
 // 531  kubebuilder create api --group gateways --version v1 --kind Adc
 
 func main() {
-	var metricsAddr string
-	var enableLeaderElection bool
-	var probeAddr string
-	var bigipUrl string
-	var bigipUsername string
-	var bigipPassword string
+	var (
+		metricsAddr          string
+		enableLeaderElection bool
+		probeAddr            string
+		bigipUrl             string
+		bigipUsername        string
+		bigipPassword        string
+		gtcName              string
+	)
 
 	flag.StringVar(&metricsAddr, "metrics-bind-address", ":8080", "The address the metric endpoint binds to.")
 	flag.StringVar(&probeAddr, "health-probe-bind-address", ":8081", "The address the probe endpoint binds to.")
@@ -80,13 +83,15 @@ func main() {
 	flag.StringVar(&bigipUrl, "bigip-url", "", "The BIG-IP management IP address for provision resources.")
 	flag.StringVar(&bigipUsername, "bigip-username", "admin", "The BIG-IP username for connection.")
 	flag.StringVar(&bigipPassword, "bigip-password", "", "The BI-IP password for connection.")
+	flag.StringVar(&gtcName, "gateway-class", "bigip", "The BI-IP password for connection.")
 
 	opts := zap.Options{
 		Development: true,
 	}
 	opts.BindFlags(flag.CommandLine)
 	flag.Parse()
 
+	pkg.ActiveSIGs.GatewayClass = gtcName
 	bigip := f5_bigip.Initialize(bigipUrl, bigipUsername, bigipPassword, "debug")
 	utils.Initialize("debug")
 

pkg/types.go

@@ -20,11 +20,12 @@ type ParseRequest struct {
 }
 
 type SIGCache struct {
-	mutex     sync.RWMutex
-	Gateway   map[string]*gatewayv1beta1.Gateway
-	HTTPRoute map[string]*gatewayv1beta1.HTTPRoute
-	Endpoints map[string]*v1.Endpoints
-	Service   map[string]*v1.Service
+	mutex        sync.RWMutex
+	GatewayClass string
+	Gateway      map[string]*gatewayv1beta1.Gateway
+	HTTPRoute    map[string]*gatewayv1beta1.HTTPRoute
+	Endpoints    map[string]*v1.Endpoints
+	Service      map[string]*v1.Service
 	// Node      map[string]*v1.Node
 }
 

pkg/utils.go

@@ -18,11 +18,12 @@ func init() {
 	PendingParses = make(chan ParseRequest, 16)
 	slog = utils.SetupLog("", "debug")
 	ActiveSIGs = &SIGCache{
-		mutex:     sync.RWMutex{},
-		Gateway:   map[string]*gatewayv1beta1.Gateway{},
-		HTTPRoute: map[string]*gatewayv1beta1.HTTPRoute{},
-		Endpoints: map[string]*v1.Endpoints{},
-		Service:   map[string]*v1.Service{},
+		mutex:        sync.RWMutex{},
+		GatewayClass: "",
+		Gateway:      map[string]*gatewayv1beta1.Gateway{},
+		HTTPRoute:    map[string]*gatewayv1beta1.HTTPRoute{},
+		Endpoints:    map[string]*v1.Endpoints{},
+		Service:      map[string]*v1.Service{},
 		// Node:      map[string]*v1.Node{},
 	}
 }
@@ -32,7 +33,12 @@ func (c *SIGCache) SetGateway(obj *gatewayv1beta1.Gateway) {
 	defer c.mutex.Unlock()
 
 	if obj != nil {
-		c.Gateway[utils.Keyname(obj.Namespace, obj.Name)] = obj
+		keyname := utils.Keyname(obj.Namespace, obj.Name)
+		if obj.Spec.GatewayClassName == gatewayv1beta1.ObjectName(c.GatewayClass) {
+			c.Gateway[keyname] = obj
+		} else {
+			delete(c.Gateway, keyname)
+		}
 	}
 }