Apache Mesos
Public Member Functions | Static Public Member Functions | List of all members
mesos::internal::checks::Checker Class Reference

#include <checker.hpp>

Public Member Functions

 ~Checker ()
 
 Checker (const Checker &)=delete
 
Checkeroperator= (const Checker &)=delete
 
void pause ()
 
void resume ()
 

Static Public Member Functions

static Try< process::Owned< Checker > > create (const CheckInfo &check, const std::string &launcherDir, const lambda::function< void(const CheckStatusInfo &)> &callback, const TaskID &taskId, Variant< runtime::Plain, runtime::Docker, runtime::Nested > runtime)
 Attempts to create a Checker object. More...
 

Constructor & Destructor Documentation

mesos::internal::checks::Checker::~Checker ( )
mesos::internal::checks::Checker::Checker ( const Checker )
delete

Member Function Documentation

static Try<process::Owned<Checker> > mesos::internal::checks::Checker::create ( const CheckInfo &  check,
const std::string &  launcherDir,
const lambda::function< void(const CheckStatusInfo &)> &  callback,
const TaskID &  taskId,
Variant< runtime::Plain, runtime::Docker, runtime::Nested runtime 
)
static

Attempts to create a Checker object.

In case of success, checking starts immediately after initialization.

The check performed is based off the check type and the given runtime.

Parameters
checkThe protobuf message definition of a check.
launcherDirA directory where Mesos helper binaries are located. Executor must have access to this directory for TCP checks.
callbackA callback Checker uses to send check status updates to its owner (usually an executor).
taskIdThe TaskID of the target task.
runtimeThe runtime that launched the task.
Returns
A Checker object or an error if create fails.
Todo:
A better approach would be to return a stream of updates, e.g., process::Stream<CheckStatusInfo> rather than invoking a callback.
Checker& mesos::internal::checks::Checker::operator= ( const Checker )
delete
void mesos::internal::checks::Checker::pause ( )
void mesos::internal::checks::Checker::resume ( )

The documentation for this class was generated from the following file: