Apache Mesos
|
Classes | |
class | InterpreterLock |
RAII utility class for acquiring the Python global interpreter lock. More... | |
struct | MesosExecutorDriverImpl |
Python object structure for MesosExecutorDriverImpl objects. More... | |
struct | MesosSchedulerDriverImpl |
Python object structure for MesosSchedulerDriverImpl objects. More... | |
class | ProxyExecutor |
Proxy Executor implementation that will call into Python. More... | |
class | ProxyScheduler |
Proxy Scheduler implementation that will call into Python. More... | |
Functions | |
PyObject * | MesosExecutorDriverImpl_new (PyTypeObject *type, PyObject *args, PyObject *kwds) |
Create, but don't initialize, a new MesosExecutorDriverImpl (called by Python before init method). More... | |
int | MesosExecutorDriverImpl_init (MesosExecutorDriverImpl *self, PyObject *args, PyObject *kwds) |
Initialize a MesosExecutorDriverImpl with constructor arguments. More... | |
void | MesosExecutorDriverImpl_dealloc (MesosExecutorDriverImpl *self) |
Free a MesosExecutorDriverImpl. More... | |
int | MesosExecutorDriverImpl_traverse (MesosExecutorDriverImpl *self, visitproc visit, void *arg) |
Traverse fields of a MesosExecutorDriverImpl on a cyclic GC search. More... | |
int | MesosExecutorDriverImpl_clear (MesosExecutorDriverImpl *self) |
Clear fields of a MesosExecutorDriverImpl that can participate in GC cycles. More... | |
PyObject * | MesosExecutorDriverImpl_start (MesosExecutorDriverImpl *self) |
PyObject * | MesosExecutorDriverImpl_stop (MesosExecutorDriverImpl *self) |
PyObject * | MesosExecutorDriverImpl_abort (MesosExecutorDriverImpl *self) |
PyObject * | MesosExecutorDriverImpl_join (MesosExecutorDriverImpl *self) |
PyObject * | MesosExecutorDriverImpl_run (MesosExecutorDriverImpl *self) |
PyObject * | MesosExecutorDriverImpl_sendStatusUpdate (MesosExecutorDriverImpl *self, PyObject *args) |
PyObject * | MesosExecutorDriverImpl_sendFrameworkMessage (MesosExecutorDriverImpl *self, PyObject *args) |
template<typename T > | |
bool | readPythonProtobuf (PyObject *obj, T *t) |
Convert a Python protocol buffer object into a C++ one by serializing it to a string and deserializing the result back in C++. More... | |
template<typename T > | |
PyObject * | createPythonProtobuf (const T &t, const char *typeName) |
Convert a C++ protocol buffer object into a Python one by serializing it to a string and deserializing the result back in Python. More... | |
template<typename T > | |
std::enable_if< std::is_base_of< google::protobuf::Message, T >::value, std::unique_ptr< T > >::type | construct (PyObject *obj) |
template<typename T > | |
std::enable_if< !std::is_base_of< google::protobuf::Message, T >::value, std::unique_ptr< T > >::type | construct (PyObject *obj) |
template<> | |
std::unique_ptr< std::string > | construct< std::string > (PyObject *obj) |
template<typename T > | |
std::unique_ptr< std::vector< T > > | constructFromIterable (PyObject *iterable) |
PyObject * | MesosSchedulerDriverImpl_new (PyTypeObject *type, PyObject *args, PyObject *kwds) |
Create, but don't initialize, a new MesosSchedulerDriverImpl (called by Python before init method). More... | |
int | MesosSchedulerDriverImpl_init (MesosSchedulerDriverImpl *self, PyObject *args, PyObject *kwds) |
Initialize a MesosSchedulerDriverImpl with constructor arguments. More... | |
void | MesosSchedulerDriverImpl_dealloc (MesosSchedulerDriverImpl *self) |
Free a MesosSchedulerDriverImpl. More... | |
int | MesosSchedulerDriverImpl_traverse (MesosSchedulerDriverImpl *self, visitproc visit, void *arg) |
Traverse fields of a MesosSchedulerDriverImpl on a cyclic GC search. More... | |
int | MesosSchedulerDriverImpl_clear (MesosSchedulerDriverImpl *self) |
Clear fields of a MesosSchedulerDriverImpl that can participate in GC cycles. More... | |
PyObject * | MesosSchedulerDriverImpl_start (MesosSchedulerDriverImpl *self) |
PyObject * | MesosSchedulerDriverImpl_stop (MesosSchedulerDriverImpl *self, PyObject *args) |
PyObject * | MesosSchedulerDriverImpl_abort (MesosSchedulerDriverImpl *self) |
PyObject * | MesosSchedulerDriverImpl_join (MesosSchedulerDriverImpl *self) |
PyObject * | MesosSchedulerDriverImpl_run (MesosSchedulerDriverImpl *self) |
PyObject * | MesosSchedulerDriverImpl_requestResources (MesosSchedulerDriverImpl *self, PyObject *args) |
PyObject * | MesosSchedulerDriverImpl_launchTasks (MesosSchedulerDriverImpl *self, PyObject *args) |
PyObject * | MesosSchedulerDriverImpl_killTask (MesosSchedulerDriverImpl *self, PyObject *args) |
PyObject * | MesosSchedulerDriverImpl_acceptOffers (MesosSchedulerDriverImpl *self, PyObject *args) |
PyObject * | MesosSchedulerDriverImpl_declineOffer (MesosSchedulerDriverImpl *self, PyObject *args) |
PyObject * | MesosSchedulerDriverImpl_reviveOffers (MesosSchedulerDriverImpl *self, PyObject *pyRoles) |
PyObject * | MesosSchedulerDriverImpl_suppressOffers (MesosSchedulerDriverImpl *self, PyObject *pyRoles) |
PyObject * | MesosSchedulerDriverImpl_acknowledgeStatusUpdate (MesosSchedulerDriverImpl *self, PyObject *args) |
PyObject * | MesosSchedulerDriverImpl_sendFrameworkMessage (MesosSchedulerDriverImpl *self, PyObject *args) |
PyObject * | MesosSchedulerDriverImpl_reconcileTasks (MesosSchedulerDriverImpl *self, PyObject *args) |
PyObject * | MesosSchedulerDriverImpl_updateFramework (MesosSchedulerDriverImpl *self, PyObject *args) |
Variables | |
PyTypeObject | MesosExecutorDriverImplType |
Python type object for MesosExecutorDriverImpl. More... | |
PyMethodDef | MesosExecutorDriverImpl_methods [] |
List of Python methods in MesosExecutorDriverImpl. More... | |
PyObject * | mesos_pb2 |
The Python module object for mesos_pb2 (which contains the protobuf classes generated for Python). More... | |
PyTypeObject | MesosSchedulerDriverImplType |
Python type object for MesosSchedulerDriverImpl. More... | |
PyMethodDef | MesosSchedulerDriverImpl_methods [] |
List of Python methods in MesosSchedulerDriverImpl. More... | |
std::enable_if< std::is_base_of<google::protobuf::Message, T>::value, std::unique_ptr<T> >::type mesos::python::construct | ( | PyObject * | obj | ) |
std::enable_if< !std::is_base_of<google::protobuf::Message, T>::value, std::unique_ptr<T> >::type mesos::python::construct | ( | PyObject * | obj | ) |
|
inline |
std::unique_ptr<std::vector<T> > mesos::python::constructFromIterable | ( | PyObject * | iterable | ) |
PyObject* mesos::python::createPythonProtobuf | ( | const T & | t, |
const char * | typeName | ||
) |
Convert a C++ protocol buffer object into a Python one by serializing it to a string and deserializing the result back in Python.
Returns the resulting PyObject* on success or raises a Python exception and returns nullptr on failure.
PyObject* mesos::python::MesosExecutorDriverImpl_abort | ( | MesosExecutorDriverImpl * | self | ) |
int mesos::python::MesosExecutorDriverImpl_clear | ( | MesosExecutorDriverImpl * | self | ) |
Clear fields of a MesosExecutorDriverImpl that can participate in GC cycles.
void mesos::python::MesosExecutorDriverImpl_dealloc | ( | MesosExecutorDriverImpl * | self | ) |
Free a MesosExecutorDriverImpl.
int mesos::python::MesosExecutorDriverImpl_init | ( | MesosExecutorDriverImpl * | self, |
PyObject * | args, | ||
PyObject * | kwds | ||
) |
Initialize a MesosExecutorDriverImpl with constructor arguments.
PyObject* mesos::python::MesosExecutorDriverImpl_join | ( | MesosExecutorDriverImpl * | self | ) |
PyObject* mesos::python::MesosExecutorDriverImpl_new | ( | PyTypeObject * | type, |
PyObject * | args, | ||
PyObject * | kwds | ||
) |
Create, but don't initialize, a new MesosExecutorDriverImpl (called by Python before init method).
PyObject* mesos::python::MesosExecutorDriverImpl_run | ( | MesosExecutorDriverImpl * | self | ) |
PyObject* mesos::python::MesosExecutorDriverImpl_sendFrameworkMessage | ( | MesosExecutorDriverImpl * | self, |
PyObject * | args | ||
) |
PyObject* mesos::python::MesosExecutorDriverImpl_sendStatusUpdate | ( | MesosExecutorDriverImpl * | self, |
PyObject * | args | ||
) |
PyObject* mesos::python::MesosExecutorDriverImpl_start | ( | MesosExecutorDriverImpl * | self | ) |
PyObject* mesos::python::MesosExecutorDriverImpl_stop | ( | MesosExecutorDriverImpl * | self | ) |
int mesos::python::MesosExecutorDriverImpl_traverse | ( | MesosExecutorDriverImpl * | self, |
visitproc | visit, | ||
void * | arg | ||
) |
Traverse fields of a MesosExecutorDriverImpl on a cyclic GC search.
PyObject* mesos::python::MesosSchedulerDriverImpl_abort | ( | MesosSchedulerDriverImpl * | self | ) |
PyObject* mesos::python::MesosSchedulerDriverImpl_acceptOffers | ( | MesosSchedulerDriverImpl * | self, |
PyObject * | args | ||
) |
PyObject* mesos::python::MesosSchedulerDriverImpl_acknowledgeStatusUpdate | ( | MesosSchedulerDriverImpl * | self, |
PyObject * | args | ||
) |
int mesos::python::MesosSchedulerDriverImpl_clear | ( | MesosSchedulerDriverImpl * | self | ) |
Clear fields of a MesosSchedulerDriverImpl that can participate in GC cycles.
void mesos::python::MesosSchedulerDriverImpl_dealloc | ( | MesosSchedulerDriverImpl * | self | ) |
Free a MesosSchedulerDriverImpl.
PyObject* mesos::python::MesosSchedulerDriverImpl_declineOffer | ( | MesosSchedulerDriverImpl * | self, |
PyObject * | args | ||
) |
int mesos::python::MesosSchedulerDriverImpl_init | ( | MesosSchedulerDriverImpl * | self, |
PyObject * | args, | ||
PyObject * | kwds | ||
) |
Initialize a MesosSchedulerDriverImpl with constructor arguments.
PyObject* mesos::python::MesosSchedulerDriverImpl_join | ( | MesosSchedulerDriverImpl * | self | ) |
PyObject* mesos::python::MesosSchedulerDriverImpl_killTask | ( | MesosSchedulerDriverImpl * | self, |
PyObject * | args | ||
) |
PyObject* mesos::python::MesosSchedulerDriverImpl_launchTasks | ( | MesosSchedulerDriverImpl * | self, |
PyObject * | args | ||
) |
PyObject* mesos::python::MesosSchedulerDriverImpl_new | ( | PyTypeObject * | type, |
PyObject * | args, | ||
PyObject * | kwds | ||
) |
Create, but don't initialize, a new MesosSchedulerDriverImpl (called by Python before init method).
PyObject* mesos::python::MesosSchedulerDriverImpl_reconcileTasks | ( | MesosSchedulerDriverImpl * | self, |
PyObject * | args | ||
) |
PyObject* mesos::python::MesosSchedulerDriverImpl_requestResources | ( | MesosSchedulerDriverImpl * | self, |
PyObject * | args | ||
) |
PyObject* mesos::python::MesosSchedulerDriverImpl_reviveOffers | ( | MesosSchedulerDriverImpl * | self, |
PyObject * | pyRoles | ||
) |
PyObject* mesos::python::MesosSchedulerDriverImpl_run | ( | MesosSchedulerDriverImpl * | self | ) |
PyObject* mesos::python::MesosSchedulerDriverImpl_sendFrameworkMessage | ( | MesosSchedulerDriverImpl * | self, |
PyObject * | args | ||
) |
PyObject* mesos::python::MesosSchedulerDriverImpl_start | ( | MesosSchedulerDriverImpl * | self | ) |
PyObject* mesos::python::MesosSchedulerDriverImpl_stop | ( | MesosSchedulerDriverImpl * | self, |
PyObject * | args | ||
) |
PyObject* mesos::python::MesosSchedulerDriverImpl_suppressOffers | ( | MesosSchedulerDriverImpl * | self, |
PyObject * | pyRoles | ||
) |
int mesos::python::MesosSchedulerDriverImpl_traverse | ( | MesosSchedulerDriverImpl * | self, |
visitproc | visit, | ||
void * | arg | ||
) |
Traverse fields of a MesosSchedulerDriverImpl on a cyclic GC search.
PyObject* mesos::python::MesosSchedulerDriverImpl_updateFramework | ( | MesosSchedulerDriverImpl * | self, |
PyObject * | args | ||
) |
bool mesos::python::readPythonProtobuf | ( | PyObject * | obj, |
T * | t | ||
) |
Convert a Python protocol buffer object into a C++ one by serializing it to a string and deserializing the result back in C++.
Returns true on success, or prints an error and returns false on failure.
PyObject* mesos::python::mesos_pb2 |
The Python module object for mesos_pb2 (which contains the protobuf classes generated for Python).
PyMethodDef mesos::python::MesosExecutorDriverImpl_methods[] |
List of Python methods in MesosExecutorDriverImpl.
PyTypeObject mesos::python::MesosExecutorDriverImplType |
Python type object for MesosExecutorDriverImpl.
PyMethodDef mesos::python::MesosSchedulerDriverImpl_methods[] |
List of Python methods in MesosSchedulerDriverImpl.
PyTypeObject mesos::python::MesosSchedulerDriverImplType |
Python type object for MesosSchedulerDriverImpl.