org.openqa.selenium.grid.distributor

Class Distributor

java.lang.Object

org.openqa.selenium.grid.distributor.Distributor

All Implemented Interfaces:

java.util.function.Predicate<org.openqa.selenium.remote.http.HttpRequest>, CommandHandler

Direct Known Subclasses:

LocalDistributor, RemoteDistributor

public abstract class Distributor
extends java.lang.Object
implements java.util.function.Predicate<org.openqa.selenium.remote.http.HttpRequest>, CommandHandler

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.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Distributor(org.openqa.selenium.remote.tracing.DistributedTracer tracer, org.openqa.selenium.remote.http.HttpClient.Factory httpClientFactory)

Method Summary

Modifier and Type	Method and Description
abstract Distributor	add(Node node)
void	execute(org.openqa.selenium.remote.http.HttpRequest req, org.openqa.selenium.remote.http.HttpResponse resp)
abstract DistributorStatus	getStatus()
abstract CreateSessionResponse	newSession(org.openqa.selenium.remote.http.HttpRequest request)
abstract void	remove(java.util.UUID nodeId)
boolean	test(org.openqa.selenium.remote.http.HttpRequest req)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Predicate

and, isEqual, negate, or

Constructor Detail

Distributor

protected Distributor(org.openqa.selenium.remote.tracing.DistributedTracer tracer,
                      org.openqa.selenium.remote.http.HttpClient.Factory httpClientFactory)

Method Detail

newSession

public abstract CreateSessionResponse newSession(org.openqa.selenium.remote.http.HttpRequest request)
                                          throws org.openqa.selenium.SessionNotCreatedException

Throws:

org.openqa.selenium.SessionNotCreatedException

add

public abstract Distributor add(Node node)

remove

public abstract void remove(java.util.UUID nodeId)

getStatus

public abstract DistributorStatus getStatus()

test

public boolean test(org.openqa.selenium.remote.http.HttpRequest req)

Specified by:

test in interface java.util.function.Predicate<org.openqa.selenium.remote.http.HttpRequest>

execute

public void execute(org.openqa.selenium.remote.http.HttpRequest req,
                    org.openqa.selenium.remote.http.HttpResponse resp)
             throws java.io.IOException

Specified by:

execute in interface CommandHandler

Throws:

java.io.IOException