Package org.openqa.selenium.grid.distributor.local

Class LocalDistributor

java.lang.Object

org.openqa.selenium.grid.distributor.Distributor

org.openqa.selenium.grid.distributor.local.LocalDistributor

All Implemented Interfaces:

AutoCloseable, Predicate<HttpRequest>, HttpHandler, Routable, HasReadyState

public class LocalDistributor
extends Distributor
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
LocalDistributor(Tracer tracer, EventBus bus, HttpClient.Factory clientFactory, SessionMap sessions, NewSessionQueue sessionQueue, SlotSelector slotSelector, Secret registrationSecret, Duration healthcheckInterval, boolean rejectUnsupportedCaps, Duration sessionRequestRetryInterval, int newSessionThreadPoolSize, SlotMatcher slotMatcher)

Method Summary

Modifier and Type	Method	Description
LocalDistributor	add(Node node)
void	close()
static Distributor	create(Config config)
boolean	drain(NodeId nodeId)
int	getActiveSlots()
protected Set<NodeStatus>	getAvailableNodes()
long	getDownNodeCount()
int	getIdleSlots()
protected Node	getNodeFromURI(URI uri)
DistributorStatus	getStatus()
long	getUpNodeCount()
boolean	isReady()
Either<SessionNotCreatedException,CreateSessionResponse>	newSession(SessionRequest request)
void	refresh()
void	remove(NodeId nodeId)

Methods inherited from class org.openqa.selenium.grid.distributor.Distributor

execute, matches, test

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, negate, or

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

with

Constructor Details

LocalDistributor

public LocalDistributor(Tracer tracer,
 EventBus bus,
 HttpClient.Factory clientFactory,
 SessionMap sessions,
 NewSessionQueue sessionQueue,
 SlotSelector slotSelector,
 Secret registrationSecret,
 Duration healthcheckInterval,
 boolean rejectUnsupportedCaps,
 Duration sessionRequestRetryInterval,
 int newSessionThreadPoolSize,
 SlotMatcher slotMatcher)

Method Details

create

public static Distributor create(Config config)

isReady

public boolean isReady()

Specified by:

isReady in interface HasReadyState

add

public LocalDistributor add(Node node)

Specified by:

add in class Distributor

drain

public boolean drain(NodeId nodeId)

Specified by:

drain in class Distributor

remove

public void remove(NodeId nodeId)

Specified by:

remove in class Distributor

getStatus

public DistributorStatus getStatus()

Specified by:

getStatus in class Distributor

refresh

@Beta
public void refresh()

getAvailableNodes

protected Set<NodeStatus> getAvailableNodes()

newSession

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

Specified by:

newSession in class Distributor

Throws:

SessionNotCreatedException

getUpNodeCount

public long getUpNodeCount()

getDownNodeCount

public long getDownNodeCount()

getActiveSlots

public int getActiveSlots()

getIdleSlots

public int getIdleSlots()

close

public void close()

Specified by:

close in interface AutoCloseable

getNodeFromURI

protected Node getNodeFromURI(URI uri)