src/cache
ListWatch
class ListWatch<T extends KubernetesObject> implements ObjectCache<T>, Informer<T>
constructor
public constructor(
path: string, watch: Watch, listFn: ListPromise<T>, autoStart: boolean = true, labelSelector?: string, fieldSelector?: string, )
off
public off(verb: string, cb: any): void
list
public list(namespace?: string | undefined): ReadonlyArray<T>
cacheMapFromList
function cacheMapFromList<T extends KubernetesObject>(newObjects: T[]): CacheMap<T>
deleteItems
function deleteItems<T extends KubernetesObject>(
oldObjects: CacheMap<T>, newObjects: T[], deleteCallback?: ObjectCallback<T>[],): CacheMap<T>
addOrUpdateObject
function addOrUpdateObject<T extends KubernetesObject>(
objects: CacheMap<T>, obj: T, addCallbacks?: ObjectCallback<T>[], updateCallbacks?: ObjectCallback<T>[],): void
deleteObject
function deleteObject<T extends KubernetesObject>(
objects: CacheMap<T>, obj: T, deleteCallbacks?: ObjectCallback<T>[],): void