Apache Mesos
|
#include <operation.hpp>
Public Member Functions | |
OperationStatusUpdateManager () | |
~OperationStatusUpdateManager () | |
OperationStatusUpdateManager (const OperationStatusUpdateManager &that)=delete | |
OperationStatusUpdateManager & | operator= (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< Nothing > | update (const UpdateOperationStatusMessage &update, bool checkpoint=true) |
process::Future< bool > | acknowledgement (const id::UUID &operationUuid, const id::UUID &statusUuid) |
process::Future< OperationStatusUpdateManagerState > | recover (const std::list< id::UUID > &operationUuids, bool strict) |
void | cleanup (const FrameworkID &frameworkId) |
void | pause () |
void | resume () |
mesos::internal::OperationStatusUpdateManager::OperationStatusUpdateManager | ( | ) |
mesos::internal::OperationStatusUpdateManager::~OperationStatusUpdateManager | ( | ) |
|
delete |
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 | ||
) |
|
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 |
||
) |