import { Reflector } from "https://deno.land/x/kubernetes_apis@v0.5.3/deps.ts";
Constructors
new
Reflector(lister: (opts: ListOpts) => Promise<ListOf<T>>, watcher: (opts: WatchOpts) => Promise<ReadableStream<WatchEvent<T, S>>>)Methods
_emit(evt: ReflectorEvent<T, S>, refVersion: string | null): void
getCached(namespace: string, name: string): (T & KindIdsReq) | undefined
goObserveAll<U>(cb: (iter: AsyncIterableIterator<ReflectorEvent<T, S>>) => Promise<U>): Promise<U>
isSynced(): boolean
listCached(): Iterable<T & KindIdsReq>
observeAll(): AsyncIterableIterator<ReflectorEvent<T, S>>
run(abortSignal?: AbortSignal)
stop()