com.mesosphere.sdk.offer

Class MesosResourcePool

java.lang.Object

com.mesosphere.sdk.offer.MesosResourcePool

public class MesosResourcePool
extends java.lang.Object

A representation of the pool of resources available in a single Offer. Tracks the consumption of the Offer's resources.

Constructor Summary

Constructors

Constructor and Description
MesosResourcePool(Offer offer, java.util.Optional<java.lang.String> role) Creates a new pool of resources based on what's available in the provided Offer.

Method Summary

Modifier and Type	Method and Description
java.util.Optional<MesosResource>	consumeAtomic(java.lang.String resourceName, Value value)
java.util.Optional<MesosResource>	consumeReservableMerged(java.lang.String name, Value desiredValue, java.lang.String preReservedRole)
java.util.Optional<MesosResource>	consumeReserved(java.lang.String name, Value value, java.lang.String resourceId)
void	free(MesosResource mesosResource)
java.util.Map<java.lang.String,MesosResource>	getDynamicallyReservedPoolByResourceId() Returns the resources which were dynamically reserved.
Offer	getOffer() Returns the underlying offer which this resource pool represents.
java.util.Map<java.lang.String,java.util.Map<java.lang.String,Value>>	getReservableMergedPoolByRole() Returns the resources which are reservable.
java.util.Optional<MesosResource>	getReservedResourceById(java.lang.String resourceId) Returns the reserved resource, if present.
java.util.Map<java.lang.String,java.util.List<MesosResource>>	getUnreservedAtomicPool() Returns the unreserved resources which cannot be partially consumed from an Offer.
java.util.Map<java.lang.String,Value>	getUnreservedMergedPool()

Methods inherited from class java.lang.Object

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

Constructor Detail

MesosResourcePool

public MesosResourcePool(Offer offer,
                         java.util.Optional<java.lang.String> role)

Creates a new pool of resources based on what's available in the provided Offer.

Method Detail

getOffer

public Offer getOffer()

Returns the underlying offer which this resource pool represents.

getUnreservedAtomicPool

public java.util.Map<java.lang.String,java.util.List<MesosResource>> getUnreservedAtomicPool()

Returns the unreserved resources which cannot be partially consumed from an Offer. For example, a MOUNT volume cannot be partially consumed, it's all-or-nothing.

getDynamicallyReservedPoolByResourceId

public java.util.Map<java.lang.String,MesosResource> getDynamicallyReservedPoolByResourceId()

Returns the resources which were dynamically reserved.

getReservableMergedPoolByRole

public java.util.Map<java.lang.String,java.util.Map<java.lang.String,Value>> getReservableMergedPoolByRole()

Returns the resources which are reservable. These may have been pre-reserved (dynamically or statically) or never reserved.

getUnreservedMergedPool

public java.util.Map<java.lang.String,Value> getUnreservedMergedPool()

getReservedResourceById

public java.util.Optional<MesosResource> getReservedResourceById(java.lang.String resourceId)

Returns the reserved resource, if present.

consumeReserved

public java.util.Optional<MesosResource> consumeReserved(java.lang.String name,
                                                         Value value,
                                                         java.lang.String resourceId)

consumeAtomic

public java.util.Optional<MesosResource> consumeAtomic(java.lang.String resourceName,
                                                       Value value)

consumeReservableMerged

public java.util.Optional<MesosResource> consumeReservableMerged(java.lang.String name,
                                                                 Value desiredValue,
                                                                 java.lang.String preReservedRole)

free

public void free(MesosResource mesosResource)