com.mesosphere.sdk.offer

Class OfferUtils

java.lang.Object

com.mesosphere.sdk.offer.OfferUtils

public class OfferUtils
extends java.lang.Object

This class provides commonly used utilities for offer handling.

Constructor Summary

Constructors

Constructor and Description
OfferUtils()

Method Summary

Modifier and Type	Method and Description
static void	declineLong(SchedulerDriver driver, java.util.Collection<Protos.Offer> unusedOffers)
static void	declineShort(SchedulerDriver driver, java.util.Collection<Protos.Offer> unusedOffers)
static java.util.List<Protos.Offer>	filterOutAcceptedOffers(java.util.List<Protos.Offer> offers, java.util.Collection<Protos.OfferID> acceptedOfferIds) Filters out accepted offers and returns back a list of unused offers.
static boolean	isOfferAccepted(Protos.Offer offer, java.util.Collection<Protos.OfferID> acceptedOfferIds) Determines if a certain offer is part of the accepted OfferID collection.

Methods inherited from class java.lang.Object

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

Constructor Detail

OfferUtils

public OfferUtils()

Method Detail

filterOutAcceptedOffers

public static java.util.List<Protos.Offer> filterOutAcceptedOffers(java.util.List<Protos.Offer> offers,
                                                                   java.util.Collection<Protos.OfferID> acceptedOfferIds)

Filters out accepted offers and returns back a list of unused offers.

Parameters:

offers - An org.apache.mesos.Protos.Offer collection containing both ACCEPTED and UNACCEPTED offers.

acceptedOfferIds - A collection of OfferIDs that are already ACCEPTED.

Returns:

A List of offers are that not ACCEPTED yet; can be empty if there are no UNACCEPTED offers left.

isOfferAccepted

public static boolean isOfferAccepted(Protos.Offer offer,
                                      java.util.Collection<Protos.OfferID> acceptedOfferIds)

Determines if a certain offer is part of the accepted OfferID collection.

Parameters:

offer - An org.apache.mesos.Protos.Offer that needs to be checked for acceptance.

acceptedOfferIds - A Collection of accepted org.apache.mesos.Protos.OfferID.

Returns:

true if org.apache.mesos.Protos.Offer is accepted; false otherwise.

declineShort

public static void declineShort(SchedulerDriver driver,
                                java.util.Collection<Protos.Offer> unusedOffers)

declineLong

public static void declineLong(SchedulerDriver driver,
                               java.util.Collection<Protos.Offer> unusedOffers)