Apache Mesos
Public Member Functions | List of all members
mesos::internal::OperationStatusUpdateManager Class Reference

#include <operation.hpp>

Public Member Functions

 OperationStatusUpdateManager ()
 
 ~OperationStatusUpdateManager ()
 
 OperationStatusUpdateManager (const OperationStatusUpdateManager &that)=delete
 
OperationStatusUpdateManageroperator= (const OperationStatusUpdateManager &that)=delete
 
void initialize (const lambda::function< void(const UpdateOperationStatusMessage &)> &forward, const lambda::function< const std::string(const id::UUID &)> &getPath)
 
process::Future< Nothingupdate (const UpdateOperationStatusMessage &update, bool checkpoint=true)
 
process::Future< bool > acknowledgement (const id::UUID &operationUuid, const id::UUID &statusUuid)
 
process::Future< OperationStatusUpdateManagerStaterecover (const std::list< id::UUID > &operationUuids, bool strict)
 
void cleanup (const FrameworkID &frameworkId)
 
void pause ()
 
void resume ()
 

Constructor & Destructor Documentation

mesos::internal::OperationStatusUpdateManager::OperationStatusUpdateManager ( )
mesos::internal::OperationStatusUpdateManager::~OperationStatusUpdateManager ( )
mesos::internal::OperationStatusUpdateManager::OperationStatusUpdateManager ( const OperationStatusUpdateManager that)
delete

Member Function Documentation

process::Future<bool> mesos::internal::OperationStatusUpdateManager::acknowledgement ( const id::UUID operationUuid,
const id::UUID statusUuid 
)
void mesos::internal::OperationStatusUpdateManager::cleanup ( const FrameworkID &  frameworkId)
void mesos::internal::OperationStatusUpdateManager::initialize ( const lambda::function< void(const UpdateOperationStatusMessage &)> &  forward,
const lambda::function< const std::string(const id::UUID &)> &  getPath 
)
OperationStatusUpdateManager& mesos::internal::OperationStatusUpdateManager::operator= ( const OperationStatusUpdateManager that)
delete
void mesos::internal::OperationStatusUpdateManager::pause ( )
process::Future<OperationStatusUpdateManagerState> mesos::internal::OperationStatusUpdateManager::recover ( const std::list< id::UUID > &  operationUuids,
bool  strict 
)
void mesos::internal::OperationStatusUpdateManager::resume ( )
process::Future<Nothing> mesos::internal::OperationStatusUpdateManager::update ( const UpdateOperationStatusMessage &  update,
bool  checkpoint = true 
)

The documentation for this class was generated from the following file: