com.mesosphere.sdk.offer

Class ResourceCleanerScheduler

java.lang.Object

com.mesosphere.sdk.offer.ResourceCleanerScheduler

public class ResourceCleanerScheduler
extends java.lang.Object

This scheduler performs UNRESERVE and DESTROY operations on resources which are identified as unexpected by the ResourceCleaner.

Constructor Summary

Constructors

Constructor and Description
ResourceCleanerScheduler(ResourceCleaner resourceCleaner, OfferAccepter offerAccepter)

Method Summary

Modifier and Type	Method and Description
protected java.util.Map<Protos.SlaveID,java.util.List<OfferRecommendation>>	groupRecommendationsByAgent(java.util.List<OfferRecommendation> recommendations) Groups recommendations by agent.
java.util.List<OfferID>	resourceOffers(SchedulerDriver driver, java.util.List<Offer> offers)

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceCleanerScheduler

public ResourceCleanerScheduler(ResourceCleaner resourceCleaner,
                                OfferAccepter offerAccepter)

Method Detail

resourceOffers

public java.util.List<OfferID> resourceOffers(SchedulerDriver driver,
                                              java.util.List<Offer> offers)

groupRecommendationsByAgent

protected java.util.Map<Protos.SlaveID,java.util.List<OfferRecommendation>> groupRecommendationsByAgent(java.util.List<OfferRecommendation> recommendations)

Groups recommendations by agent. Visibility is protected to enable testing.