@@ -24,7 +24,7 @@ import (
24
24
25
25
appsv1 "k8s.io/api/apps/v1"
26
26
corev1 "k8s.io/api/core/v1"
27
- controllers "sigs.k8s.io/controller-runtime"
27
+ ctrl "sigs.k8s.io/controller-runtime"
28
28
"sigs.k8s.io/controller-runtime/pkg/client"
29
29
)
30
30
@@ -34,17 +34,17 @@ import (
34
34
// ReplicaSetReconciler.
35
35
//
36
36
// * Start the application.
37
- // TODO(pwittrock): Update this example when we have better dependency injection support
37
+ // TODO(pwittrock): Update this example when we have better dependency injection support.
38
38
func Example () {
39
- var log = controllers .Log .WithName ("builder-examples" )
39
+ var log = ctrl .Log .WithName ("builder-examples" )
40
40
41
- manager , err := controllers .NewManager (controllers .GetConfigOrDie (), controllers .Options {})
41
+ manager , err := ctrl .NewManager (ctrl .GetConfigOrDie (), ctrl .Options {})
42
42
if err != nil {
43
43
log .Error (err , "could not create manager" )
44
44
os .Exit (1 )
45
45
}
46
46
47
- err = controllers .
47
+ err = ctrl .
48
48
NewControllerManagedBy (manager ). // Create the Controller
49
49
For (& appsv1.ReplicaSet {}). // ReplicaSet is the Application API
50
50
Owns (& corev1.Pod {}). // ReplicaSet owns Pods created by it
@@ -54,7 +54,7 @@ func Example() {
54
54
os .Exit (1 )
55
55
}
56
56
57
- if err := manager .Start (controllers .SetupSignalHandler ()); err != nil {
57
+ if err := manager .Start (ctrl .SetupSignalHandler ()); err != nil {
58
58
log .Error (err , "could not start manager" )
59
59
os .Exit (1 )
60
60
}
@@ -72,15 +72,15 @@ func Example() {
72
72
// ReplicaSetReconciler.
73
73
//
74
74
// * Start the application.
75
- // TODO(pwittrock): Update this example when we have better dependency injection support
75
+ // TODO(pwittrock): Update this example when we have better dependency injection support.
76
76
func Example_updateLeaderElectionDurations () {
77
- var log = controllers .Log .WithName ("builder-examples" )
77
+ var log = ctrl .Log .WithName ("builder-examples" )
78
78
leaseDuration := 100 * time .Second
79
79
renewDeadline := 80 * time .Second
80
80
retryPeriod := 20 * time .Second
81
- manager , err := controllers .NewManager (
82
- controllers .GetConfigOrDie (),
83
- controllers .Options {
81
+ manager , err := ctrl .NewManager (
82
+ ctrl .GetConfigOrDie (),
83
+ ctrl .Options {
84
84
LeaseDuration : & leaseDuration ,
85
85
RenewDeadline : & renewDeadline ,
86
86
RetryPeriod : & retryPeriod ,
@@ -90,7 +90,7 @@ func Example_updateLeaderElectionDurations() {
90
90
os .Exit (1 )
91
91
}
92
92
93
- err = controllers .
93
+ err = ctrl .
94
94
NewControllerManagedBy (manager ). // Create the Controller
95
95
For (& appsv1.ReplicaSet {}). // ReplicaSet is the Application API
96
96
Owns (& corev1.Pod {}). // ReplicaSet owns Pods created by it
@@ -100,7 +100,7 @@ func Example_updateLeaderElectionDurations() {
100
100
os .Exit (1 )
101
101
}
102
102
103
- if err := manager .Start (controllers .SetupSignalHandler ()); err != nil {
103
+ if err := manager .Start (ctrl .SetupSignalHandler ()); err != nil {
104
104
log .Error (err , "could not start manager" )
105
105
os .Exit (1 )
106
106
}
@@ -117,28 +117,28 @@ type ReplicaSetReconciler struct {
117
117
//
118
118
// * Read the ReplicaSet
119
119
// * Read the Pods
120
- // * Set a Label on the ReplicaSet with the Pod count
121
- func (a * ReplicaSetReconciler ) Reconcile (ctx context.Context , req controllers .Request ) (controllers .Result , error ) {
120
+ // * Set a Label on the ReplicaSet with the Pod count.
121
+ func (a * ReplicaSetReconciler ) Reconcile (ctx context.Context , req ctrl .Request ) (ctrl .Result , error ) {
122
122
// Read the ReplicaSet
123
123
rs := & appsv1.ReplicaSet {}
124
124
err := a .Get (ctx , req .NamespacedName , rs )
125
125
if err != nil {
126
- return controllers .Result {}, err
126
+ return ctrl .Result {}, err
127
127
}
128
128
129
129
// List the Pods matching the PodTemplate Labels
130
130
pods := & corev1.PodList {}
131
131
err = a .List (ctx , pods , client .InNamespace (req .Namespace ), client .MatchingLabels (rs .Spec .Template .Labels ))
132
132
if err != nil {
133
- return controllers .Result {}, err
133
+ return ctrl .Result {}, err
134
134
}
135
135
136
136
// Update the ReplicaSet
137
137
rs .Labels ["pod-count" ] = fmt .Sprintf ("%v" , len (pods .Items ))
138
138
err = a .Update (context .TODO (), rs )
139
139
if err != nil {
140
- return controllers .Result {}, err
140
+ return ctrl .Result {}, err
141
141
}
142
142
143
- return controllers .Result {}, nil
143
+ return ctrl .Result {}, nil
144
144
}
0 commit comments