Class KubernetesProvider

constructor

• new KubernetesProvider(
      options: KubernetesProviderOptions,
      http: IDiscoveryHttp,
      runtime: IRuntimeServices,
  ): KubernetesProvider

  Parameters

  • options: KubernetesProviderOptions

    Namespace, API server, token, and port selection

  • http: IDiscoveryHttp

    The HTTP seam

  • runtime: IRuntimeServices

    Supplies the monotonic clock, timers, and fs

  Returns KubernetesProvider

Readonlykind

authHeader

• authHeader(): Promise<string>

  Resolves the bearer token, reading the projected file when no explicit token was configured.

  Returns Promise<string>

  The Authorization header value

  Throws

  If the projected token file does not exist (not running in a pod); configure token and apiServer explicitly. Any other read failure is rethrown unchanged.

isHealthy

• isHealthy(): Promise<boolean>

  M70c: probes the API server with a limit=1 EndpointSlice LIST through the existing seam. This is the probe that makes X10-3 visible: an UnknownIssuer TLS rejection surfaces here as down. 2xx means the API is reachable. The runtime aborts the request after 2 s, including a hung response body.

  Returns Promise<boolean>

listUrl

• listUrl(serviceName: string, extra?: Readonly<Record<string, string>>): string

  Builds the EndpointSlice list URL for a service.

  Parameters

  • serviceName: string

    Logical service name

  • Optionalextra: Readonly<Record<string, string>>

    Extra query parameters (the watch adds its own)

  Returns string

  The absolute URL

mapSlices

• mapSlices(body: unknown, serviceName: string): readonly ServiceInstance[]

  Maps an EndpointSlice list onto instances.

  Parameters

  • body: unknown

    The parsed list response

  • serviceName: string

    The service the slices belong to

  Returns readonly ServiceInstance[]

  The mapped instances

  Throws

  If several ports exist and none was named

resolve

• resolve(serviceName: string): Promise<readonly ServiceInstance[]>

  Reads the current instance list for a service.

  Parameters

  • serviceName: string

    Logical service name

  Returns Promise<readonly ServiceInstance[]>

  Every instance the backend reports, possibly empty

  Throws

  If the backend cannot be read

watch

• watch(
      serviceName: string,
      listener: (instances: readonly ServiceInstance[]) => void,
  ): Promise<Unsubscribe>

  Subscribes to instance-list changes.

  Push-based where the backend supports it, interval-polled where it does not. The listener always receives the full list.

  Parameters

  • serviceName: string

    Logical service name

  • listener: (instances: readonly ServiceInstance[]) => void

    Called with the full instance list on every change

  Returns Promise<Unsubscribe>

  Unsubscribe function that stops the underlying watch