@@ -264,8 +264,8 @@ export function deleteItems<T extends KubernetesObject>(
264
264
export function addOrUpdateObject < T extends KubernetesObject > (
265
265
objects : CacheMap < T > ,
266
266
obj : T ,
267
- addCallback ?: Array < ObjectCallback < T > > ,
268
- updateCallback ?: Array < ObjectCallback < T > > ,
267
+ addCallbacks ?: Array < ObjectCallback < T > > ,
268
+ updateCallbacks ?: Array < ObjectCallback < T > > ,
269
269
) : void {
270
270
let namespaceObjects = objects . get ( obj . metadata ! . namespace || '' ) ;
271
271
if ( ! namespaceObjects ) {
@@ -277,14 +277,14 @@ export function addOrUpdateObject<T extends KubernetesObject>(
277
277
const found = namespaceObjects . get ( name ) ;
278
278
if ( ! found ) {
279
279
namespaceObjects . set ( name , obj ) ;
280
- if ( addCallback ) {
281
- addCallback . forEach ( ( elt : ObjectCallback < T > ) => elt ( obj ) ) ;
280
+ if ( addCallbacks ) {
281
+ addCallbacks . forEach ( ( elt : ObjectCallback < T > ) => elt ( obj ) ) ;
282
282
}
283
283
} else {
284
284
if ( ! isSameVersion ( found , obj ) ) {
285
285
namespaceObjects . set ( name , obj ) ;
286
- if ( updateCallback ) {
287
- updateCallback . forEach ( ( elt : ObjectCallback < T > ) => elt ( obj ) ) ;
286
+ if ( updateCallbacks ) {
287
+ updateCallbacks . forEach ( ( elt : ObjectCallback < T > ) => elt ( obj ) ) ;
288
288
}
289
289
}
290
290
}
@@ -302,7 +302,7 @@ function isSameVersion<T extends KubernetesObject>(o1: T, o2: T): boolean {
302
302
export function deleteObject < T extends KubernetesObject > (
303
303
objects : CacheMap < T > ,
304
304
obj : T ,
305
- deleteCallback ?: Array < ObjectCallback < T > > ,
305
+ deleteCallbacks ?: Array < ObjectCallback < T > > ,
306
306
) : void {
307
307
const namespace = obj . metadata ! . namespace || '' ;
308
308
const name = obj . metadata ! . name || '' ;
@@ -313,8 +313,8 @@ export function deleteObject<T extends KubernetesObject>(
313
313
}
314
314
const deleted = namespaceObjects . delete ( name ) ;
315
315
if ( deleted ) {
316
- if ( deleteCallback ) {
317
- deleteCallback . forEach ( ( elt : ObjectCallback < T > ) => elt ( obj ) ) ;
316
+ if ( deleteCallbacks ) {
317
+ deleteCallbacks . forEach ( ( elt : ObjectCallback < T > ) => elt ( obj ) ) ;
318
318
}
319
319
if ( namespaceObjects . size === 0 ) {
320
320
objects . delete ( namespace ) ;
0 commit comments