Package io.deephaven.enterprise.controller.assignment

Class RoundRobinAssignmentPolicy

java.lang.Object

io.deephaven.enterprise.controller.assignment.RoundRobinAssignmentPolicy

All Implemented Interfaces:

AssignmentPolicy

public class RoundRobinAssignmentPolicy
extends Object
implements AssignmentPolicy

An AssignmentPolicy that assigns users to replicas in a round-robin fashion.

Constructor Summary

Constructors

Constructor	Description
RoundRobinAssignmentPolicy(@NotNull QueryUserAssignmentLogger logger, @Nullable String policyParameters)	Create a new Round Robin policy

Method Summary

Modifier and Type	Method	Description
void	afterConfigurationChanged(@NotNull PersistentQueryConfiguration prev, @NotNull PersistentQueryConfiguration current)	Notify the policy that the query configuration changed.
void	beforeConfigurationChanged(@NotNull PersistentQueryConfiguration prev, @NotNull PersistentQueryConfiguration current)	Notify the policy that the query configuration changed.
int	getOrAssignSlot(@NotNull UserContext user, @NotNull PersistentQueryInfo queryInfo)	Get the slot assignment, or assign a slot for the specified user and query.

Methods inherited from class java.lang.Object

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

Constructor Details

RoundRobinAssignmentPolicy

public RoundRobinAssignmentPolicy(@NotNull
 @NotNull QueryUserAssignmentLogger logger,
 @Nullable
 @Nullable String policyParameters)
                           throws io.deephaven.shadow.jackson.com.fasterxml.jackson.core.JsonProcessingException

Create a new Round Robin policy

Parameters:

logger - a logger to record assignment changes

policyParameters - policy parameters -- not used

Throws:

io.deephaven.shadow.jackson.com.fasterxml.jackson.core.JsonProcessingException - if policyParameters could not be parsed

Method Details

getOrAssignSlot

public int getOrAssignSlot(@NotNull
 @NotNull UserContext user,
 @NotNull
 @NotNull PersistentQueryInfo queryInfo)

Description copied from interface: AssignmentPolicy

Get the slot assignment, or assign a slot for the specified user and query.

Specified by:

getOrAssignSlot in interface AssignmentPolicy

Parameters:

user - The user to assign

queryInfo - the QueryInfo to assign a slot for

Returns:

the slot assignment for the user.

beforeConfigurationChanged

public void beforeConfigurationChanged(@NotNull
 @NotNull PersistentQueryConfiguration prev,
 @NotNull
 @NotNull PersistentQueryConfiguration current)

Description copied from interface: AssignmentPolicy

Notify the policy that the query configuration changed.

Specified by:

beforeConfigurationChanged in interface AssignmentPolicy

Parameters:

prev - the old configuration

current - the new configuration

afterConfigurationChanged

public void afterConfigurationChanged(@NotNull
 @NotNull PersistentQueryConfiguration prev,
 @NotNull
 @NotNull PersistentQueryConfiguration current)

Description copied from interface: AssignmentPolicy

Notify the policy that the query configuration changed.

Specified by:

afterConfigurationChanged in interface AssignmentPolicy

Parameters:

prev - the old configuration

current - the new configuration