@k8slens/extensions

Globals / "src/renderer/api/kube-watch-api" / KubeWatchApi

Class: KubeWatchApi

Hierarchy

• KubeWatchApi

Index

Constructors

• constructor

Properties

• evtSource
• maxReconnectsOnError
• onData
• reconnectAttempts
• reconnectTimeoutMs
• subscribers

Accessors

• activeApis

Methods

• addListener
• connect
• disconnect
• getQuery
• getSubscribersCount
• onError
• onMessage
• onRouteEvent
• reconnect
• reset
• subscribe
• writeLog

Constructors

constructor

+ new KubeWatchApi(): KubeWatchApi

Defined in src/renderer/api/kube-watch-api.ts:35

Returns: KubeWatchApi

Properties

evtSource

• Protected evtSource: EventSource

Defined in src/renderer/api/kube-watch-api.ts:30

---

maxReconnectsOnError

• Protected maxReconnectsOnError: number = 10

Defined in src/renderer/api/kube-watch-api.ts:34

---

onData

• Protected onData: EventEmitter\<[IKubeWatchEvent\]> = new EventEmitter\<[IKubeWatchEvent]>()

Defined in src/renderer/api/kube-watch-api.ts:31

---

reconnectAttempts

• Protected reconnectAttempts: number = this.maxReconnectsOnError

Defined in src/renderer/api/kube-watch-api.ts:35

---

reconnectTimeoutMs

• Protected reconnectTimeoutMs: number = 5000

Defined in src/renderer/api/kube-watch-api.ts:33

---

subscribers

• Protected subscribers: ObservableMap\<KubeApi\, number> = observable.map\()

Defined in src/renderer/api/kube-watch-api.ts:32

Accessors

activeApis

• get activeApis(): KubeApi\[]

Defined in src/renderer/api/kube-watch-api.ts:44

Returns: KubeApi\[]

Methods

addListener

▸ addListener(store: KubeObjectStore, callback: (evt: IKubeWatchEvent) => void): (Anonymous function)

Defined in src/renderer/api/kube-watch-api.ts:149

Parameters:

Name	Type
store	KubeObjectStore
callback	(evt: IKubeWatchEvent) => void

Returns: (Anonymous function)

---

connect

▸ Protectedconnect(): void

Defined in src/renderer/api/kube-watch-api.ts:75

Returns: void

---

disconnect

▸ Protecteddisconnect(): void

Defined in src/renderer/api/kube-watch-api.ts:95

Returns: void

---

getQuery

▸ ProtectedgetQuery(): Partial\<IKubeWatchRouteQuery>

Defined in src/renderer/api/kube-watch-api.ts:63

Returns: Partial\<IKubeWatchRouteQuery>

---

getSubscribersCount

▸ getSubscribersCount(api: KubeApi): number

Defined in src/renderer/api/kube-watch-api.ts:48

Parameters:

Name	Type
api	KubeApi

Returns: number

---

onError

▸ ProtectedonError(evt: MessageEvent): void

Defined in src/renderer/api/kube-watch-api.ts:133

Parameters:

Name	Type
evt	MessageEvent

Returns: void

---

onMessage

▸ ProtectedonMessage(evt: MessageEvent): void

Defined in src/renderer/api/kube-watch-api.ts:102

Parameters:

Name	Type
evt	MessageEvent

Returns: void

---

onRouteEvent

▸ ProtectedonRouteEvent(event: IKubeWatchRouteEvent): Promise\

Defined in src/renderer/api/kube-watch-api.ts:112

Parameters:

Name	Type
event	IKubeWatchRouteEvent

Returns: Promise\

---

reconnect

▸ reconnect(): void

Defined in src/renderer/api/kube-watch-api.ts:88

Returns: void

---

reset

▸ reset(): void

Defined in src/renderer/api/kube-watch-api.ts:163

Returns: void

---

subscribe

▸ subscribe(...apis: KubeApi[]): (Anonymous function)

Defined in src/renderer/api/kube-watch-api.ts:52

Parameters:

Name	Type
...apis	KubeApi[]

Returns: (Anonymous function)

---

writeLog

▸ ProtectedwriteLog(...data: any[]): void

Defined in src/renderer/api/kube-watch-api.ts:143

Parameters:

Name	Type
...data	any[]

Returns: void

---

Last update: November 10, 2020