Apache Mesos
Classes | Functions | Variables
mesos::python Namespace Reference

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...
 

Function Documentation

template<typename T >
std::enable_if< std::is_base_of<google::protobuf::Message, T>::value, std::unique_ptr<T> >::type mesos::python::construct ( PyObject *  obj)
template<typename T >
std::enable_if< !std::is_base_of<google::protobuf::Message, T>::value, std::unique_ptr<T> >::type mesos::python::construct ( PyObject *  obj)
template<>
std::unique_ptr<std::string> mesos::python::construct< std::string > ( PyObject *  obj)
inline
template<typename T >
std::unique_ptr<std::vector<T> > mesos::python::constructFromIterable ( PyObject *  iterable)
template<typename T >
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.

See http://docs.python.org/extending/newtypes.html.

void mesos::python::MesosExecutorDriverImpl_dealloc ( MesosExecutorDriverImpl self)
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.

See http://docs.python.org/extending/newtypes.html.

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.

See http://docs.python.org/extending/newtypes.html.

void mesos::python::MesosSchedulerDriverImpl_dealloc ( MesosSchedulerDriverImpl self)
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.

See http://docs.python.org/extending/newtypes.html.

PyObject* mesos::python::MesosSchedulerDriverImpl_updateFramework ( MesosSchedulerDriverImpl self,
PyObject *  args 
)
template<typename T >
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.

Variable Documentation

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.