Skip to content

Commit a825280

Browse files
committed
Update code for controller-runtime 0.16.0
Minor changes
1 parent eb2364a commit a825280

File tree

4 files changed

+21
-12
lines changed

4 files changed

+21
-12
lines changed

examples/guestbook-operator/main.go

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ import (
3030
ctrl "sigs.k8s.io/controller-runtime"
3131
"sigs.k8s.io/controller-runtime/pkg/healthz"
3232
"sigs.k8s.io/controller-runtime/pkg/log/zap"
33+
metricsserver "sigs.k8s.io/controller-runtime/pkg/metrics/server"
3334
"sigs.k8s.io/kubebuilder-declarative-pattern/pkg/patterns/addon"
3435

3536
addonsv1alpha1 "sigs.k8s.io/kubebuilder-declarative-pattern/examples/guestbook-operator/api/v1alpha1"
@@ -68,9 +69,10 @@ func main() {
6869
addon.Init()
6970

7071
mgr, err := ctrl.NewManager(ctrl.GetConfigOrDie(), ctrl.Options{
71-
Scheme: scheme,
72-
MetricsBindAddress: metricsAddr,
73-
Port: 9443,
72+
Scheme: scheme,
73+
Metrics: metricsserver.Options{
74+
BindAddress: "0", // Disable the metrics server
75+
},
7476
HealthProbeBindAddress: probeAddr,
7577
LeaderElection: enableLeaderElection,
7678
LeaderElectionID: "c3cffa1a.example.org",

pkg/patterns/declarative/metrics_test.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,12 +38,14 @@ import (
3838
"k8s.io/klog/v2"
3939
"sigs.k8s.io/controller-runtime/pkg/client/fake"
4040
"sigs.k8s.io/controller-runtime/pkg/manager"
41+
metricsserver "sigs.k8s.io/controller-runtime/pkg/metrics/server"
4142
"sigs.k8s.io/controller-runtime/pkg/reconcile"
43+
"sigs.k8s.io/yaml"
44+
4245
"sigs.k8s.io/kubebuilder-declarative-pattern/applylib/applyset"
4346
"sigs.k8s.io/kubebuilder-declarative-pattern/mockkubeapiserver"
4447
"sigs.k8s.io/kubebuilder-declarative-pattern/pkg/patterns/declarative/pkg/applier"
4548
"sigs.k8s.io/kubebuilder-declarative-pattern/pkg/patterns/declarative/pkg/manifest"
46-
"sigs.k8s.io/yaml"
4749
)
4850

4951
func fakeParent() runtime.Object {
@@ -276,7 +278,9 @@ func TestAddIfNotPresent(t *testing.T) {
276278

277279
// Create manager
278280
mgrOpt := manager.Options{
279-
MetricsBindAddress: "0", // Don't open unneeded ports
281+
Metrics: metricsserver.Options{
282+
BindAddress: "0", // Disable the metrics server, don't open unneeded ports
283+
},
280284
}
281285
mgr, err := manager.New(restConfig, mgrOpt)
282286
if err != nil {

pkg/patterns/declarative/pkg/applier/direct.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ import (
1111

1212
"k8s.io/apimachinery/pkg/api/meta"
1313
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
14+
"k8s.io/apimachinery/pkg/types"
1415
utilerrors "k8s.io/apimachinery/pkg/util/errors"
1516
"k8s.io/apimachinery/pkg/util/sets"
1617
"k8s.io/cli-runtime/pkg/genericclioptions"
@@ -135,8 +136,8 @@ func (d *DirectApplier) Apply(ctx context.Context, opt ApplierOptions) error {
135136
printFlags := genericclioptions.NewPrintFlags("apply")
136137
applyOpts := &apply.ApplyOptions{
137138
Recorder: &genericclioptions.NoopRecorder{},
138-
VisitedUids: sets.NewString(),
139-
VisitedNamespaces: sets.NewString(),
139+
VisitedUids: sets.New[types.UID](),
140+
VisitedNamespaces: sets.New[string](),
140141
PrintFlags: printFlags,
141142
IOStreams: ioStreams,
142143
FieldManager: "kubectl-client-side-apply",

pkg/test/testreconciler/simpletest/controller_test.go

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -13,12 +13,13 @@ import (
1313
"k8s.io/klog/v2"
1414
"k8s.io/klog/v2/klogr"
1515
ctrl "sigs.k8s.io/controller-runtime"
16-
"sigs.k8s.io/kubebuilder-declarative-pattern/pkg/restmapper"
16+
metricsserver "sigs.k8s.io/controller-runtime/pkg/metrics/server"
1717

1818
"sigs.k8s.io/kubebuilder-declarative-pattern/mockkubeapiserver"
1919
"sigs.k8s.io/kubebuilder-declarative-pattern/pkg/patterns/addon/pkg/loaders"
2020
"sigs.k8s.io/kubebuilder-declarative-pattern/pkg/patterns/declarative"
2121
"sigs.k8s.io/kubebuilder-declarative-pattern/pkg/patterns/declarative/pkg/applier"
22+
"sigs.k8s.io/kubebuilder-declarative-pattern/pkg/restmapper"
2223
"sigs.k8s.io/kubebuilder-declarative-pattern/pkg/test/httprecorder"
2324
"sigs.k8s.io/kubebuilder-declarative-pattern/pkg/test/testharness"
2425

@@ -68,10 +69,11 @@ func testSimpleReconciler(h *testharness.Harness, testdir string, applier applie
6869

6970
logger := klogr.New()
7071
mgr, err := ctrl.NewManager(restConfig, ctrl.Options{
71-
Scheme: scheme,
72-
MetricsBindAddress: "",
73-
Port: 0,
74-
LeaderElection: false,
72+
Scheme: scheme,
73+
Metrics: metricsserver.Options{
74+
BindAddress: "0", // Disable the metrics server
75+
},
76+
LeaderElection: false,
7577

7678
// MapperProvider provides the rest mapper used to map go types to Kubernetes APIs
7779
MapperProvider: restmapper.NewControllerRESTMapper,

0 commit comments

Comments
 (0)