@@ -191,10 +191,20 @@ var _ = Describe("Informer Cache", func() {
191
191
192
192
Describe ("as an Informer" , func () {
193
193
It ("should be able to get informer for the object" , func (done Done ) {
194
- By ("getting an shared index informer for a pod" )
194
+ By ("getting a shared index informer for a pod" )
195
195
pod := & kcorev1.Pod {
196
- ObjectMeta : kmetav1.ObjectMeta {Name : "informer-obj" , Namespace : "default" },
197
- Spec : kcorev1.PodSpec {Containers : []kcorev1.Container {{Name : "nginx" , Image : "nginx" }}},
196
+ ObjectMeta : kmetav1.ObjectMeta {
197
+ Name : "informer-obj" ,
198
+ Namespace : "default" ,
199
+ },
200
+ Spec : kcorev1.PodSpec {
201
+ Containers : []kcorev1.Container {
202
+ {
203
+ Name : "nginx" ,
204
+ Image : "nginx" ,
205
+ },
206
+ },
207
+ },
198
208
}
199
209
sii , err := informerCache .GetInformer (pod )
200
210
Expect (err ).NotTo (HaveOccurred ())
@@ -203,9 +213,10 @@ var _ = Describe("Informer Cache", func() {
203
213
204
214
By ("adding an event handler listening for object creation which sends the object to a channel" )
205
215
out := make (chan interface {})
206
- sii . AddEventHandler (kcache. ResourceEventHandlerFuncs { AddFunc : func (obj interface {}) {
216
+ addFunc := func (obj interface {}) {
207
217
out <- obj
208
- }})
218
+ }
219
+ sii .AddEventHandler (kcache.ResourceEventHandlerFuncs {AddFunc : addFunc })
209
220
210
221
By ("adding an object" )
211
222
cl , err := client .New (cfg , client.Options {})
@@ -227,16 +238,27 @@ var _ = Describe("Informer Cache", func() {
227
238
228
239
By ("adding an event handler listening for object creation which sends the object to a channel" )
229
240
out := make (chan interface {})
230
- sii . AddEventHandler (kcache. ResourceEventHandlerFuncs { AddFunc : func (obj interface {}) {
241
+ addFunc := func (obj interface {}) {
231
242
out <- obj
232
- }})
243
+ }
244
+ sii .AddEventHandler (kcache.ResourceEventHandlerFuncs {AddFunc : addFunc })
233
245
234
246
By ("adding an object" )
235
247
cl , err := client .New (cfg , client.Options {})
236
248
Expect (err ).NotTo (HaveOccurred ())
237
249
pod := & kcorev1.Pod {
238
- ObjectMeta : kmetav1.ObjectMeta {Name : "informer-gvk" , Namespace : "default" },
239
- Spec : kcorev1.PodSpec {Containers : []kcorev1.Container {{Name : "nginx" , Image : "nginx" }}},
250
+ ObjectMeta : kmetav1.ObjectMeta {
251
+ Name : "informer-gvk" ,
252
+ Namespace : "default" ,
253
+ },
254
+ Spec : kcorev1.PodSpec {
255
+ Containers : []kcorev1.Container {
256
+ {
257
+ Name : "nginx" ,
258
+ Image : "nginx" ,
259
+ },
260
+ },
261
+ },
240
262
}
241
263
Expect (cl .Create (context .TODO (), pod )).To (Succeed ())
242
264
0 commit comments