Package org.openqa.selenium.grid.distributor

Class Distributor

java.lang.Object

org.openqa.selenium.grid.distributor.Distributor

All Implemented Interfaces:

Predicate<HttpRequest>, HttpHandler, Routable, HasReadyState

Direct Known Subclasses:

LocalDistributor, RemoteDistributor

public abstract class Distributor
extends Object
implements HasReadyState, Predicate<HttpRequest>, Routable

Responsible for being the central place where the Nodes on which Sessions run are determined.

This class responds to the following URLs:

Verb	URL Template	Meaning
POST	/session	This is exactly the same as the New Session command from the WebDriver spec.
POST	/se/grid/distributor/node	Adds a new Node to this distributor. Please read the javadocs for Node for how the Node should be serialized.
DELETE	/se/grid/distributor/node/{nodeId}	Remove the Node identified by nodeId from this distributor. It is expected that any sessions running on the Node are allowed to complete: this simply means that no new sessions will be scheduled on this Node.

Field Summary

Fields

Modifier and Type	Field	Description
protected final Tracer	tracer

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Distributor(Tracer tracer, HttpClient.Factory httpClientFactory, Secret registrationSecret)

Method Summary

Modifier and Type	Method	Description
abstract Distributor	add(Node node)
abstract boolean	drain(NodeId nodeId)
HttpResponse	execute(HttpRequest req)
abstract DistributorStatus	getStatus()
boolean	matches(HttpRequest req)
abstract Either<SessionNotCreatedException,CreateSessionResponse>	newSession(SessionRequest request)
abstract void	remove(NodeId nodeId)
boolean	test(HttpRequest httpRequest)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openqa.selenium.status.HasReadyState

isReady

Methods inherited from interface java.util.function.Predicate

and, negate, or

Methods inherited from interface org.openqa.selenium.remote.http.Routable

with

Field Details

tracer

protected final Tracer tracer

Constructor Details

Distributor

protected Distributor(Tracer tracer,
 HttpClient.Factory httpClientFactory,
 Secret registrationSecret)

Method Details

newSession

public abstract Either<SessionNotCreatedException,CreateSessionResponse> newSession(SessionRequest request)
                                                                             throws SessionNotCreatedException

Throws:

SessionNotCreatedException

add

public abstract Distributor add(Node node)

drain

public abstract boolean drain(NodeId nodeId)

remove

public abstract void remove(NodeId nodeId)

getStatus

public abstract DistributorStatus getStatus()

test

public boolean test(HttpRequest httpRequest)

Specified by:

test in interface Predicate<HttpRequest>

matches

public boolean matches(HttpRequest req)

Specified by:

matches in interface Routable

execute

public HttpResponse execute(HttpRequest req)
                     throws UncheckedIOException

Specified by:

execute in interface HttpHandler

Throws:

UncheckedIOException