Class TestExecutor

src/examples/test_executor.cpp:31–76

class TestExecutor : public Executor
{
public:
  ~TestExecutor() override {}

  void registered(ExecutorDriver* driver,
                          const ExecutorInfo& executorInfo,
                          const FrameworkInfo& frameworkInfo,
                          const SlaveInfo& slaveInfo) override
  {
    cout << "Registered executor on " << slaveInfo.hostname() << endl;
  }

  void reregistered(ExecutorDriver* driver,
                            const SlaveInfo& slaveInfo) override
  {
    cout << "Re-registered executor on " << slaveInfo.hostname() << endl;
  }

  void disconnected(ExecutorDriver* driver) override {}

  void launchTask(ExecutorDriver* driver, const TaskInfo& task) override
  {
    cout << "Starting task " << task.task_id().value() << endl;

    TaskStatus status;
    status.mutable_task_id()->MergeFrom(task.task_id());
    status.set_state(TASK_RUNNING);

    driver->sendStatusUpdate(status);

    // This is where one would perform the requested task.

    cout << "Finishing task " << task.task_id().value() << endl;

    status.mutable_task_id()->MergeFrom(task.task_id());
    status.set_state(TASK_FINISHED);

    driver->sendStatusUpdate(status);
  }

  void killTask(ExecutorDriver* driver, const TaskID& taskId) override {}
  void frameworkMessage(ExecutorDriver* driver, const string& data) override {}
  void shutdown(ExecutorDriver* driver) override {}
  void error(ExecutorDriver* driver, const string& message) override {}
};


int main(int argc, char** argv)