17 #ifndef __STATUS_UPDATE_MANAGER_OPERATION_HPP__ 18 #define __STATUS_UPDATE_MANAGER_OPERATION_HPP__ 39 typedef StatusUpdateManagerProcess<
41 UpdateOperationStatusRecord,
65 const lambda::function<
66 void(
const UpdateOperationStatusMessage&)>& forward,
67 const lambda::function<
const std::string(
const id::UUID&)>& getPath);
73 const UpdateOperationStatusMessage&
update,
85 const id::UUID& operationUuid,
86 const id::UUID& statusUuid);
105 const std::list<id::UUID>& operationUuids,
113 void cleanup(
const FrameworkID& frameworkId);
125 UpdateOperationStatusRecord,
126 UpdateOperationStatusMessage>>
process;
132 #endif // __STATUS_UPDATE_MANAGER_OPERATION_HPP__ OperationStatusUpdateManager()
Try< Nothing > checkpoint(const std::string &path, const std::string &message, bool sync, bool downgradeResources)
Definition: state.hpp:123
StatusUpdateManagerProcess< id::UUID, UpdateOperationStatusRecord, UpdateOperationStatusMessage >::State OperationStatusUpdateManagerState
Definition: operation.hpp:42
void initialize(const lambda::function< void(const UpdateOperationStatusMessage &)> &forward, const lambda::function< const std::string(const id::UUID &)> &getPath)
Definition: status_update_manager_process.hpp:78
process::Future< bool > acknowledgement(const id::UUID &operationUuid, const id::UUID &statusUuid)
void cleanup(const FrameworkID &frameworkId)
process::Future< OperationStatusUpdateManagerState > recover(const std::list< id::UUID > &operationUuids, bool strict)
Definition: operation.hpp:44
Definition: attributes.hpp:24
Definition: executor.hpp:48
OperationStatusUpdateManager & operator=(const OperationStatusUpdateManager &that)=delete
process::Future< Nothing > update(const UpdateOperationStatusMessage &update, bool checkpoint=true)
~OperationStatusUpdateManager()