com.mesosphere.sdk.offer.evaluate

Class OfferEvaluator

java.lang.Object

com.mesosphere.sdk.offer.evaluate.OfferEvaluator

public class OfferEvaluator
extends java.lang.Object

The OfferEvaluator processes Protos.Offers and produces OfferRecommendations. The determination of what OfferRecommendations, if any should be made are made in reference to PodInstanceRequirements.

Constructor Summary

Constructors

Constructor and Description
OfferEvaluator(StateStore stateStore, OfferOutcomeTracker offerOutcomeTracker, java.lang.String serviceName, java.util.UUID targetConfigId, SchedulerConfig schedulerConfig, boolean useDefaultExecutor)

Method Summary

Modifier and Type	Method and Description
java.util.List<OfferRecommendation>	evaluate(PodInstanceRequirement podInstanceRequirement, java.util.List<Protos.Offer> offers)
java.util.List<OfferEvaluationStage>	getEvaluationPipeline(PodInstanceRequirement podInstanceRequirement, java.util.Collection<Protos.TaskInfo> allTasks, java.util.Map<java.lang.String,Protos.TaskInfo> thisPodTasks)
(package private) java.util.UUID	getTargetConfig(PodInstanceRequirement podInstanceRequirement, java.util.Collection<Protos.TaskInfo> taskInfos)
(package private) static void	logOutcome(java.lang.StringBuilder stringBuilder, EvaluationOutcome outcome, java.lang.String indent)

Methods inherited from class java.lang.Object

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

Constructor Detail

OfferEvaluator

public OfferEvaluator(StateStore stateStore,
                      OfferOutcomeTracker offerOutcomeTracker,
                      java.lang.String serviceName,
                      java.util.UUID targetConfigId,
                      SchedulerConfig schedulerConfig,
                      boolean useDefaultExecutor)

Method Detail

evaluate

public java.util.List<OfferRecommendation> evaluate(PodInstanceRequirement podInstanceRequirement,
                                                    java.util.List<Protos.Offer> offers)
                                             throws InvalidRequirementException,
                                                    java.io.IOException

Throws:

InvalidRequirementException

java.io.IOException

getEvaluationPipeline

public java.util.List<OfferEvaluationStage> getEvaluationPipeline(PodInstanceRequirement podInstanceRequirement,
                                                                  java.util.Collection<Protos.TaskInfo> allTasks,
                                                                  java.util.Map<java.lang.String,Protos.TaskInfo> thisPodTasks)
                                                           throws java.io.IOException

Throws:

java.io.IOException

logOutcome

static void logOutcome(java.lang.StringBuilder stringBuilder,
                       EvaluationOutcome outcome,
                       java.lang.String indent)

getTargetConfig

java.util.UUID getTargetConfig(PodInstanceRequirement podInstanceRequirement,
                               java.util.Collection<Protos.TaskInfo> taskInfos)