@@ -255,8 +255,8 @@ export function deleteItems<T extends KubernetesObject>(
255
255
export function addOrUpdateObject < T extends KubernetesObject > (
256
256
objects : CacheMap < T > ,
257
257
obj : T ,
258
- addCallback ?: Array < ObjectCallback < T > > ,
259
- updateCallback ?: Array < ObjectCallback < T > > ,
258
+ addCallbacks ?: Array < ObjectCallback < T > > ,
259
+ updateCallbacks ?: Array < ObjectCallback < T > > ,
260
260
) : void {
261
261
let namespaceObjects = objects . get ( obj . metadata ! . namespace || '' ) ;
262
262
if ( ! namespaceObjects ) {
@@ -268,14 +268,14 @@ export function addOrUpdateObject<T extends KubernetesObject>(
268
268
const found = namespaceObjects . get ( name ) ;
269
269
if ( ! found ) {
270
270
namespaceObjects . set ( name , obj ) ;
271
- if ( addCallback ) {
272
- addCallback . forEach ( ( elt : ObjectCallback < T > ) => elt ( obj ) ) ;
271
+ if ( addCallbacks ) {
272
+ addCallbacks . forEach ( ( elt : ObjectCallback < T > ) => elt ( obj ) ) ;
273
273
}
274
274
} else {
275
275
if ( ! isSameVersion ( found , obj ) ) {
276
276
namespaceObjects . set ( name , obj ) ;
277
- if ( updateCallback ) {
278
- updateCallback . forEach ( ( elt : ObjectCallback < T > ) => elt ( obj ) ) ;
277
+ if ( updateCallbacks ) {
278
+ updateCallbacks . forEach ( ( elt : ObjectCallback < T > ) => elt ( obj ) ) ;
279
279
}
280
280
}
281
281
}
@@ -293,7 +293,7 @@ function isSameVersion<T extends KubernetesObject>(o1: T, o2: T): boolean {
293
293
export function deleteObject < T extends KubernetesObject > (
294
294
objects : CacheMap < T > ,
295
295
obj : T ,
296
- deleteCallback ?: Array < ObjectCallback < T > > ,
296
+ deleteCallbacks ?: Array < ObjectCallback < T > > ,
297
297
) : void {
298
298
const namespace = obj . metadata ! . namespace || '' ;
299
299
const name = obj . metadata ! . name || '' ;
@@ -304,8 +304,8 @@ export function deleteObject<T extends KubernetesObject>(
304
304
}
305
305
const deleted = namespaceObjects . delete ( name ) ;
306
306
if ( deleted ) {
307
- if ( deleteCallback ) {
308
- deleteCallback . forEach ( ( elt : ObjectCallback < T > ) => elt ( obj ) ) ;
307
+ if ( deleteCallbacks ) {
308
+ deleteCallbacks . forEach ( ( elt : ObjectCallback < T > ) => elt ( obj ) ) ;
309
309
}
310
310
if ( namespaceObjects . size === 0 ) {
311
311
objects . delete ( namespace ) ;
0 commit comments