water.k8s.api

Class KubernetesRestApi

java.lang.Object

water.k8s.api.KubernetesRestApi

All Implemented Interfaces:

java.lang.AutoCloseable

public class KubernetesRestApi
extends java.lang.Object
implements java.lang.AutoCloseable

This class represents a tiny (memory, cpu, dependencies) self-contained API only for Kubernetes, running separately on localhost on a specified port. When the Kubernetes extension is starting and attempting to form an H2O cluster, H2O's REST API is yet not fully initialized, as its startup relies on configuration obtained during the clustering phase. However, REST API services (readiness probe, liveness probe, startup probe) are required to be available since the very start of H2O K8S extension. Therefore, a separate REST API running on a distinct port is spawned.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	KUBERNETES_REST_API_PORT_KEY

Constructor Summary

Constructors

Constructor and Description
KubernetesRestApi() Creates, but not starts Kubernetes REST API.

Method Summary

Modifier and Type	Method and Description
void	addMappings()
void	close()
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

KUBERNETES_REST_API_PORT_KEY

public static final java.lang.String KUBERNETES_REST_API_PORT_KEY

See Also:

Constant Field Values

Constructor Detail

KubernetesRestApi

public KubernetesRestApi()
                  throws java.io.IOException

Creates, but not starts Kubernetes REST API. To start the REST API, please use one of the start methods available.

The REST API is bound to a default port of 8080, unless specified otherwise by H2O_KUBERNETES_API_PORT environment variable.

Throws:

java.io.IOException

Method Detail

addMappings

public void addMappings()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

start

public void start()
           throws java.io.IOException

Throws:

java.io.IOException