Skip to content

Commit

Permalink
refactor: controller-runtime v0.16.0
Browse files Browse the repository at this point in the history
  • Loading branch information
KevFan committed Sep 6, 2023
1 parent 7dcbc3d commit b1331a4
Show file tree
Hide file tree
Showing 11 changed files with 190 additions and 217 deletions.
12 changes: 2 additions & 10 deletions bundle/manifests/kuadrant-operator.clusterserviceversion.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,7 @@ metadata:
capabilities: Basic Install
categories: Integration & Delivery
containerImage: quay.io/kuadrant/kuadrant-operator:latest
createdAt: "2023-07-11T10:58:10Z"
createdAt: "2023-08-31T12:27:50Z"
operators.operatorframework.io/builder: operator-sdk-v1.28.1
operators.operatorframework.io/project_layout: go.kubebuilder.io/v3
repository: https://github.com/Kuadrant/kuadrant-operator
Expand Down Expand Up @@ -410,7 +410,7 @@ spec:
spec:
containers:
- args:
- --config=controller_manager_config.yaml
- --leader-elect
command:
- /manager
env:
Expand Down Expand Up @@ -442,18 +442,10 @@ spec:
memory: 200Mi
securityContext:
allowPrivilegeEscalation: false
volumeMounts:
- mountPath: /controller_manager_config.yaml
name: manager-config
subPath: controller_manager_config.yaml
securityContext:
runAsNonRoot: true
serviceAccountName: kuadrant-operator-controller-manager
terminationGracePeriodSeconds: 10
volumes:
- configMap:
name: kuadrant-operator-manager-config
name: manager-config
permissions:
- rules:
- apiGroups:
Expand Down
10 changes: 1 addition & 9 deletions config/default/manager_config_patch.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -9,12 +9,4 @@ spec:
containers:
- name: manager
args:
- "--config=controller_manager_config.yaml"
volumeMounts:
- name: manager-config
mountPath: /controller_manager_config.yaml
subPath: controller_manager_config.yaml
volumes:
- name: manager-config
configMap:
name: manager-config
- "--leader-elect"
11 changes: 0 additions & 11 deletions config/manager/controller_manager_config.yaml

This file was deleted.

4 changes: 0 additions & 4 deletions config/manager/kustomization.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,6 @@ resources:
generatorOptions:
disableNameSuffixHash: true

configMapGenerator:
- files:
- controller_manager_config.yaml
name: manager-config
apiVersion: kustomize.config.k8s.io/v1beta1
kind: Kustomization
images:
Expand Down
5 changes: 2 additions & 3 deletions controllers/authpolicy_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,6 @@ import (
"sigs.k8s.io/controller-runtime/pkg/client"
"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
"sigs.k8s.io/controller-runtime/pkg/handler"
"sigs.k8s.io/controller-runtime/pkg/source"
gatewayapiv1beta1 "sigs.k8s.io/gateway-api/apis/v1beta1"

api "github.com/kuadrant/kuadrant-operator/api/v1beta1"
Expand Down Expand Up @@ -202,10 +201,10 @@ func (r *AuthPolicyReconciler) SetupWithManager(mgr ctrl.Manager) error {
return ctrl.NewControllerManagedBy(mgr).
For(&api.AuthPolicy{}).
Watches(
&source.Kind{Type: &gatewayapiv1beta1.HTTPRoute{}},
&gatewayapiv1beta1.HTTPRoute{},
handler.EnqueueRequestsFromMapFunc(httpRouteEventMapper.MapToAuthPolicy),
).
Watches(&source.Kind{Type: &gatewayapiv1beta1.Gateway{}},
Watches(&gatewayapiv1beta1.Gateway{},
handler.EnqueueRequestsFromMapFunc(gatewayEventMapper.MapToAuthPolicy)).
Complete(r)
}
5 changes: 3 additions & 2 deletions controllers/gateway_eventmapper.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package controllers

import (
"context"
"fmt"

"github.com/go-logr/logr"
Expand All @@ -16,11 +17,11 @@ type GatewayEventMapper struct {
Logger logr.Logger
}

func (m *GatewayEventMapper) MapToRateLimitPolicy(obj client.Object) []reconcile.Request {
func (m *GatewayEventMapper) MapToRateLimitPolicy(_ context.Context, obj client.Object) []reconcile.Request {
return m.mapToPolicyRequest(obj, "ratelimitpolicy", &common.KuadrantRateLimitPolicyRefsConfig{})
}

func (m *GatewayEventMapper) MapToAuthPolicy(obj client.Object) []reconcile.Request {
func (m *GatewayEventMapper) MapToAuthPolicy(_ context.Context, obj client.Object) []reconcile.Request {
return m.mapToPolicyRequest(obj, "authpolicy", &common.KuadrantAuthPolicyRefsConfig{})
}

Expand Down
6 changes: 4 additions & 2 deletions controllers/httproute_eventmapper.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
package controllers

import (
"context"

"github.com/go-logr/logr"
"sigs.k8s.io/controller-runtime/pkg/client"
"sigs.k8s.io/controller-runtime/pkg/reconcile"
Expand All @@ -13,11 +15,11 @@ type HTTPRouteEventMapper struct {
Logger logr.Logger
}

func (m *HTTPRouteEventMapper) MapToRateLimitPolicy(obj client.Object) []reconcile.Request {
func (m *HTTPRouteEventMapper) MapToRateLimitPolicy(_ context.Context, obj client.Object) []reconcile.Request {
return m.mapToPolicyRequest(obj, "ratelimitpolicy", common.RateLimitPolicyBackRefAnnotation)
}

func (m *HTTPRouteEventMapper) MapToAuthPolicy(obj client.Object) []reconcile.Request {
func (m *HTTPRouteEventMapper) MapToAuthPolicy(_ context.Context, obj client.Object) []reconcile.Request {
return m.mapToPolicyRequest(obj, "authpolicy", common.AuthPolicyBackRefAnnotation)
}

Expand Down
5 changes: 2 additions & 3 deletions controllers/ratelimitpolicy_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@ import (
"sigs.k8s.io/controller-runtime/pkg/client"
"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
"sigs.k8s.io/controller-runtime/pkg/handler"
"sigs.k8s.io/controller-runtime/pkg/source"
gatewayapiv1beta1 "sigs.k8s.io/gateway-api/apis/v1beta1"

kuadrantv1beta2 "github.com/kuadrant/kuadrant-operator/api/v1beta2"
Expand Down Expand Up @@ -240,13 +239,13 @@ func (r *RateLimitPolicyReconciler) SetupWithManager(mgr ctrl.Manager) error {
return ctrl.NewControllerManagedBy(mgr).
For(&kuadrantv1beta2.RateLimitPolicy{}).
Watches(
&source.Kind{Type: &gatewayapiv1beta1.HTTPRoute{}},
&gatewayapiv1beta1.HTTPRoute{},
handler.EnqueueRequestsFromMapFunc(httpRouteEventMapper.MapToRateLimitPolicy),
).
// Currently the purpose is to generate events when rlp references change in gateways
// so the status of the rlps targeting a route can be keep in sync
Watches(
&source.Kind{Type: &gatewayapiv1beta1.Gateway{}},
&gatewayapiv1beta1.Gateway{},
handler.EnqueueRequestsFromMapFunc(gatewayEventMapper.MapToRateLimitPolicy),
).
Complete(r)
Expand Down
74 changes: 39 additions & 35 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -10,50 +10,52 @@ require (
github.com/kuadrant/authorino v0.14.0
github.com/kuadrant/authorino-operator v0.8.0
github.com/kuadrant/limitador-operator v0.4.0
github.com/onsi/ginkgo/v2 v2.7.0
github.com/onsi/gomega v1.24.2
go.uber.org/zap v1.24.0
github.com/onsi/ginkgo/v2 v2.11.0
github.com/onsi/gomega v1.27.10
go.uber.org/zap v1.25.0
golang.org/x/exp v0.0.0-20230817173708-d852ddb80c63
golang.org/x/sync v0.1.0
golang.org/x/sync v0.3.0
google.golang.org/protobuf v1.31.0
gotest.tools v2.2.0+incompatible
istio.io/api v0.0.0-20230712174848-a2b2de508c88
istio.io/client-go v1.17.4-0.20230712175648-f1263a806483
istio.io/istio v0.0.0-20230719200611-681b4f65a752
k8s.io/api v0.26.1
k8s.io/apiextensions-apiserver v0.26.1
k8s.io/apimachinery v0.26.1
k8s.io/client-go v0.26.1
k8s.io/klog/v2 v2.80.1
k8s.io/api v0.28.0
k8s.io/apiextensions-apiserver v0.28.0
k8s.io/apimachinery v0.28.0
k8s.io/client-go v0.28.0
k8s.io/klog/v2 v2.100.1
k8s.io/utils v0.0.0-20230726121419-3b25d923346b
sigs.k8s.io/controller-runtime v0.14.6
sigs.k8s.io/controller-runtime v0.16.0
sigs.k8s.io/gateway-api v0.6.2
)

require (
cloud.google.com/go v0.108.0 // indirect
cloud.google.com/go/compute v1.15.1 // indirect
cloud.google.com/go v0.110.0 // indirect
cloud.google.com/go/compute v1.19.0 // indirect
cloud.google.com/go/compute/metadata v0.2.3 // indirect
cloud.google.com/go/logging v1.6.1 // indirect
cloud.google.com/go/longrunning v0.4.0 // indirect
cloud.google.com/go/logging v1.7.0 // indirect
cloud.google.com/go/longrunning v0.4.1 // indirect
github.com/beorn7/perks v1.0.1 // indirect
github.com/cespare/xxhash/v2 v2.2.0 // indirect
github.com/davecgh/go-spew v1.1.1 // indirect
github.com/emicklei/go-restful/v3 v3.10.1 // indirect
github.com/evanphx/json-patch v5.6.0+incompatible // indirect
github.com/evanphx/json-patch/v5 v5.6.0 // indirect
github.com/fsnotify/fsnotify v1.6.0 // indirect
github.com/go-logr/zapr v1.2.3 // indirect
github.com/go-logr/zapr v1.2.4 // indirect
github.com/go-openapi/jsonpointer v0.19.6 // indirect
github.com/go-openapi/jsonreference v0.20.1 // indirect
github.com/go-openapi/jsonreference v0.20.2 // indirect
github.com/go-openapi/swag v0.22.3 // indirect
github.com/go-task/slim-sprig v0.0.0-20230315185526-52ccab3ef572 // indirect
github.com/gogo/protobuf v1.3.2 // indirect
github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
github.com/golang/protobuf v1.5.3 // indirect
github.com/google/gnostic v0.6.9 // indirect
github.com/google/gnostic-models v0.6.8 // indirect
github.com/google/gofuzz v1.2.0 // indirect
github.com/googleapis/enterprise-certificate-proxy v0.2.1 // indirect
github.com/googleapis/gax-go/v2 v2.7.0 // indirect
github.com/google/pprof v0.0.0-20221212185716-aee1124e3a93 // indirect
github.com/googleapis/enterprise-certificate-proxy v0.2.3 // indirect
github.com/googleapis/gax-go/v2 v2.7.1 // indirect
github.com/imdario/mergo v0.3.12 // indirect
github.com/inconshreveable/mousetrap v1.1.0 // indirect
github.com/josharian/intern v1.0.0 // indirect
Expand All @@ -64,33 +66,35 @@ require (
github.com/modern-go/reflect2 v1.0.2 // indirect
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
github.com/pkg/errors v0.9.1 // indirect
github.com/prometheus/client_golang v1.15.0 // indirect
github.com/prometheus/client_model v0.3.0 // indirect
github.com/prometheus/common v0.42.0 // indirect
github.com/prometheus/procfs v0.9.0 // indirect
github.com/prometheus/client_golang v1.16.0 // indirect
github.com/prometheus/client_model v0.4.0 // indirect
github.com/prometheus/common v0.44.0 // indirect
github.com/prometheus/procfs v0.10.1 // indirect
github.com/spf13/cobra v1.7.0 // indirect
github.com/spf13/pflag v1.0.5 // indirect
go.opencensus.io v0.24.0 // indirect
go.uber.org/atomic v1.10.0 // indirect
go.uber.org/multierr v1.9.0 // indirect
golang.org/x/net v0.9.0 // indirect
golang.org/x/oauth2 v0.5.0 // indirect
go.uber.org/multierr v1.11.0 // indirect
golang.org/x/net v0.14.0 // indirect
golang.org/x/oauth2 v0.8.0 // indirect
golang.org/x/sys v0.11.0 // indirect
golang.org/x/term v0.7.0 // indirect
golang.org/x/text v0.9.0 // indirect
golang.org/x/term v0.11.0 // indirect
golang.org/x/text v0.12.0 // indirect
golang.org/x/time v0.3.0 // indirect
gomodules.xyz/jsonpatch/v2 v2.2.0 // indirect
google.golang.org/api v0.107.0 // indirect
golang.org/x/tools v0.12.1-0.20230815132531-74c255bcf846 // indirect
gomodules.xyz/jsonpatch/v2 v2.4.0 // indirect
google.golang.org/api v0.114.0 // indirect
google.golang.org/appengine v1.6.7 // indirect
google.golang.org/genproto v0.0.0-20230110181048-76db0878b65f // indirect
google.golang.org/genproto v0.0.0-20230526161137-0005af68ea54 // indirect
google.golang.org/genproto/googleapis/api v0.0.0-20230525234035-dd9d682886f9 // indirect
google.golang.org/genproto/googleapis/rpc v0.0.0-20230525234030-28d5490b6b19 // indirect
google.golang.org/grpc v1.54.0 // indirect
gopkg.in/inf.v0 v0.9.1 // indirect
gopkg.in/natefinch/lumberjack.v2 v2.0.0 // indirect
gopkg.in/natefinch/lumberjack.v2 v2.2.1 // indirect
gopkg.in/yaml.v2 v2.4.0 // indirect
gopkg.in/yaml.v3 v3.0.1 // indirect
istio.io/pkg v0.0.0-20230523222708-7056be172a30 // indirect
k8s.io/component-base v0.26.1 // indirect
k8s.io/kube-openapi v0.0.0-20230109183929-3758b55a6596 // indirect
k8s.io/component-base v0.28.0 // indirect
k8s.io/kube-openapi v0.0.0-20230717233707-2695361300d9 // indirect
sigs.k8s.io/json v0.0.0-20221116044647-bc3834ca7abd // indirect
sigs.k8s.io/structured-merge-diff/v4 v4.2.3 // indirect
sigs.k8s.io/yaml v1.3.0 // indirect
Expand Down
Loading

0 comments on commit b1331a4

Please sign in to comment.