com.mesosphere.sdk.offer.evaluate

Class PodInfoBuilder

java.lang.Object

com.mesosphere.sdk.offer.evaluate.PodInfoBuilder

public class PodInfoBuilder
extends java.lang.Object

A PodInfoBuilder encompasses a mutable group of org.apache.mesos.Protos.TaskInfo.Builders and, optionally, a org.apache.mesos.Protos.ExecutorInfo.Builder. This supports the modification of task infos during the evaluation process, allowing e.g. dynamic ports to be represented as environment variables in the task to which they are attached.

Constructor Summary

Constructors

Constructor and Description
PodInfoBuilder(PodInstanceRequirement podInstanceRequirement, java.lang.String serviceName, java.util.UUID targetConfigId, SchedulerConfig schedulerConfig, java.util.Collection<Protos.TaskInfo> currentPodTasks, Protos.FrameworkID frameworkID, boolean useDefaultExecutor, java.util.Map<TaskSpec,GoalStateOverride> overrideMap)

Method Summary

Modifier and Type	Method and Description
void	addAssignedOverlayPort(long port)
java.util.Set<java.lang.Long>	getAssignedOverlayPorts()
java.util.Optional<Protos.ExecutorInfo.Builder>	getExecutorBuilder()
java.util.Collection<Protos.Resource.Builder>	getExecutorResourceBuilders()
static Protos.Resource	getExistingExecutorVolume(VolumeSpec volumeSpec, java.lang.String resourceId, java.lang.String persistenceId, boolean useDefaultExecutor)
int	getIndex()
PodInstance	getPodInstance()
java.util.Optional<java.lang.Long>	getPriorPortForTask(java.lang.String taskSpecName, PortSpec portSpec) This is the only carry-over from old tasks: If a port was dynamically allocated, we want to avoid reallocating it on task relaunch.
Protos.TaskInfo.Builder	getTaskBuilder(java.lang.String taskSpecName)
java.util.Collection<Protos.TaskInfo.Builder>	getTaskBuilders()
static java.util.Map<java.lang.String,java.lang.String>	getTaskEnvironment(java.lang.String serviceName, PodInstance podInstance, TaskSpec taskSpec) Generates a Task environment containing the configured environment values from the CommandSpec, along with a set of default environment variables that all SDK tasks get for free.
java.util.Collection<Protos.Resource.Builder>	getTaskResourceBuilders()
java.lang.String	getType()
boolean	isAssignedOverlayPort(long candidatePort)
void	setExecutorBuilder(Protos.ExecutorInfo.Builder executorBuilder)
void	setExecutorVolume(VolumeSpec volumeSpec)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

PodInfoBuilder

public PodInfoBuilder(PodInstanceRequirement podInstanceRequirement,
                      java.lang.String serviceName,
                      java.util.UUID targetConfigId,
                      SchedulerConfig schedulerConfig,
                      java.util.Collection<Protos.TaskInfo> currentPodTasks,
                      Protos.FrameworkID frameworkID,
                      boolean useDefaultExecutor,
                      java.util.Map<TaskSpec,GoalStateOverride> overrideMap)
               throws InvalidRequirementException

Throws:

InvalidRequirementException

Method Detail

getTaskBuilders

public java.util.Collection<Protos.TaskInfo.Builder> getTaskBuilders()

getTaskBuilder

public Protos.TaskInfo.Builder getTaskBuilder(java.lang.String taskSpecName)

getExecutorBuilder

public java.util.Optional<Protos.ExecutorInfo.Builder> getExecutorBuilder()

setExecutorBuilder

public void setExecutorBuilder(Protos.ExecutorInfo.Builder executorBuilder)

getPriorPortForTask

public java.util.Optional<java.lang.Long> getPriorPortForTask(java.lang.String taskSpecName,
                                                              PortSpec portSpec)

This is the only carry-over from old tasks: If a port was dynamically allocated, we want to avoid reallocating it on task relaunch.

getTaskResourceBuilders

public java.util.Collection<Protos.Resource.Builder> getTaskResourceBuilders()

getExecutorResourceBuilders

public java.util.Collection<Protos.Resource.Builder> getExecutorResourceBuilders()

isAssignedOverlayPort

public boolean isAssignedOverlayPort(long candidatePort)

addAssignedOverlayPort

public void addAssignedOverlayPort(long port)

getAssignedOverlayPorts

public java.util.Set<java.lang.Long> getAssignedOverlayPorts()

setExecutorVolume

public void setExecutorVolume(VolumeSpec volumeSpec)

getExistingExecutorVolume

public static Protos.Resource getExistingExecutorVolume(VolumeSpec volumeSpec,
                                                        java.lang.String resourceId,
                                                        java.lang.String persistenceId,
                                                        boolean useDefaultExecutor)

getTaskEnvironment

public static java.util.Map<java.lang.String,java.lang.String> getTaskEnvironment(java.lang.String serviceName,
                                                                                  PodInstance podInstance,
                                                                                  TaskSpec taskSpec)

Generates a Task environment containing the configured environment values from the CommandSpec, along with a set of default environment variables that all SDK tasks get for free.

getType

public java.lang.String getType()

getIndex

public int getIndex()

getPodInstance

public PodInstance getPodInstance()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object