water.server

Class LeaderNodeRequestFilter

java.lang.Object

water.server.LeaderNodeRequestFilter

All Implemented Interfaces:

water.webserver.iface.RequestAuthExtension

public class LeaderNodeRequestFilter
extends java.lang.Object
implements water.webserver.iface.RequestAuthExtension

Only the H2O leader node should be queried by the end user at any time (reproducibility). While running eg. on Kubernetes, it is easy for to misconfigure services and let the traffic flow to non-leader nodes. If an H2O cluster is used in such a way, the results provided to the user might be irreproducible/incorrect and the user has no way to easily find out.

To solve this issue, this filter blocks all incoming requests on non-leader nodes when H2O is configured to have non-leader node access disabled. Some APIs intended for internal use (mainly used by other products such as Sparkling Water) might still remain active. All user-facing APIs, mostly the ones used by Python/R/Flow clients are disabled.

Constructor Summary

Constructors

Constructor and Description
LeaderNodeRequestFilter()

Method Summary

Modifier and Type	Method and Description
boolean	handle(java.lang.String target, javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response)
boolean	isEnabled()

Methods inherited from class java.lang.Object

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

Methods inherited from interface water.webserver.iface.RequestAuthExtension

getName

Constructor Detail

LeaderNodeRequestFilter

public LeaderNodeRequestFilter()

Method Detail

handle

public boolean handle(java.lang.String target,
                      javax.servlet.http.HttpServletRequest request,
                      javax.servlet.http.HttpServletResponse response)
               throws java.io.IOException

Specified by:

handle in interface water.webserver.iface.RequestAuthExtension

Throws:

java.io.IOException

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface water.webserver.iface.RequestAuthExtension