com.mesosphere.sdk.state

Class PersistentLaunchRecorder

java.lang.Object

com.mesosphere.sdk.state.PersistentLaunchRecorder

All Implemented Interfaces:

OperationRecorder

public class PersistentLaunchRecorder
extends java.lang.Object
implements OperationRecorder

Records the result of launched tasks to persistent storage.

Constructor Summary

Constructors

Constructor and Description
PersistentLaunchRecorder(StateStore stateStore, ServiceSpec serviceSpec)

Method Summary

Modifier and Type	Method and Description
(package private) java.util.Optional<PodInstance>	getPodInstance(Protos.TaskInfo taskInfo)
void	record(OfferRecommendation offerRecommendation)
(package private) void	updateTaskResourcesWithinResourceSet(PodInstance podInstance, Protos.TaskInfo taskInfo) This method keeps the resources associated with tasks in the state store up to date, when a task which shares their resource-set is launched.

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistentLaunchRecorder

public PersistentLaunchRecorder(StateStore stateStore,
                                ServiceSpec serviceSpec)

Method Detail

record

public void record(OfferRecommendation offerRecommendation)
            throws java.lang.Exception

Specified by:

record in interface OperationRecorder

Throws:

java.lang.Exception

getPodInstance

java.util.Optional<PodInstance> getPodInstance(Protos.TaskInfo taskInfo)
                                        throws TaskException

Throws:

TaskException

updateTaskResourcesWithinResourceSet

void updateTaskResourcesWithinResourceSet(PodInstance podInstance,
                                          Protos.TaskInfo taskInfo)

This method keeps the resources associated with tasks in the state store up to date, when a task which shares their resource-set is launched.

Parameters:

podInstance - the parent pod associated with the task being launched

taskInfo - the task being launched