com.mesosphere.sdk.offer.evaluate.placement

Class AbstractRoundRobinRule

java.lang.Object

com.mesosphere.sdk.offer.evaluate.placement.AbstractRoundRobinRule

All Implemented Interfaces:

PlacementRule

Direct Known Subclasses:

RoundRobinByAttributeRule, RoundRobinByHostnameRule, RoundRobinByRegionRule, RoundRobinByZoneRule

abstract class AbstractRoundRobinRule
extends java.lang.Object
implements PlacementRule

Base implementation of common round-robin logic.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Optional<java.lang.Integer>	distinctKeyCount
protected StringMatcher	taskFilter

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractRoundRobinRule(StringMatcher taskFilter, java.util.Optional<java.lang.Integer> distinctKeyCount)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o) Must be explicitly implemented by all PlacementRules.
EvaluationOutcome	filter(Offer offer, PodInstance podInstance, java.util.Collection<TaskInfo> tasks) Returns whether the provided Offer, combined with the accompanying TaskInfos, passes or fails this placement constraint.
protected abstract java.lang.String	getKey(Offer offer) Returns a key to round robin against from the provided Offer, or null if none was found.
protected abstract java.lang.String	getKey(TaskInfo task) Returns a key to round robin against from the provided TaskInfo, or null if none was found.
int	hashCode()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.mesosphere.sdk.offer.evaluate.placement.PlacementRule

getPlacementFields

Field Detail

taskFilter

protected final StringMatcher taskFilter

distinctKeyCount

protected final java.util.Optional<java.lang.Integer> distinctKeyCount

Constructor Detail

AbstractRoundRobinRule

protected AbstractRoundRobinRule(StringMatcher taskFilter,
                                 java.util.Optional<java.lang.Integer> distinctKeyCount)

Method Detail

getKey

protected abstract java.lang.String getKey(Offer offer)

Returns a key to round robin against from the provided Offer, or null if none was found.

getKey

protected abstract java.lang.String getKey(TaskInfo task)

Returns a key to round robin against from the provided TaskInfo, or null if none was found.

filter

public EvaluationOutcome filter(Offer offer,
                                PodInstance podInstance,
                                java.util.Collection<TaskInfo> tasks)

Description copied from interface: PlacementRule

Returns whether the provided Offer, combined with the accompanying TaskInfos, passes or fails this placement constraint.

Specified by:

filter in interface PlacementRule

Parameters:

offer - the offer to be examined

tasks - the currently deployed tasks in the system, possibly including a duplicate of the task being launched as represented in the offerRequirement. Use PlacementUtils.areEquivalent(TaskInfo, PodInstance) to detect duplicates

Returns:

an EvaluationOutcome object describing whether the placement succeeded or failed and why

equals

public boolean equals(java.lang.Object o)

Description copied from interface: PlacementRule

Must be explicitly implemented by all PlacementRules.

Specified by:

equals in interface PlacementRule

Overrides:

equals in class java.lang.Object

See Also:

TaskUtils.areDifferent( com.mesosphere.sdk.specification.TaskSpec, com.mesosphere.sdk.specification.TaskSpec)

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object