mesos.hpp File Reference

#include <memory>
#include <string>
#include <utility>
#include <vector>
#include <gmock/gmock.h>
#include <mesos/executor.hpp>
#include <mesos/scheduler.hpp>
#include <mesos/v1/executor.hpp>
#include <mesos/v1/resources.hpp>
#include <mesos/v1/resource_provider.hpp>
#include <mesos/v1/scheduler.hpp>
#include <mesos/v1/executor/executor.hpp>
#include <mesos/v1/scheduler/scheduler.hpp>
#include <mesos/authentication/secret_generator.hpp>
#include <mesos/authorizer/authorizer.hpp>
#include <mesos/fetcher/fetcher.hpp>
#include <mesos/master/detector.hpp>
#include <process/future.hpp>
#include <process/gmock.hpp>
#include <process/gtest.hpp>
#include <process/http.hpp>
#include <process/io.hpp>
#include <process/owned.hpp>
#include <process/pid.hpp>
#include <process/process.hpp>
#include <process/queue.hpp>
#include <process/subprocess.hpp>
#include <process/ssl/flags.hpp>
#include <process/ssl/gtest.hpp>
#include <stout/bytes.hpp>
#include <stout/foreach.hpp>
#include <stout/gtest.hpp>
#include <stout/lambda.hpp>
#include <stout/none.hpp>
#include <stout/option.hpp>
#include <stout/stringify.hpp>
#include <stout/try.hpp>
#include <stout/unreachable.hpp>
#include <stout/uuid.hpp>
#include "authentication/executor/jwt_secret_generator.hpp"
#include "common/http.hpp"
#include "common/protobuf_utils.hpp"
#include "messages/messages.hpp"
#include "master/master.hpp"
#include "sched/constants.hpp"
#include "resource_provider/detector.hpp"
#include "slave/constants.hpp"
#include "slave/csi_server.hpp"
#include "slave/slave.hpp"
#include "slave/containerizer/containerizer.hpp"
#include "slave/containerizer/mesos/containerizer.hpp"
#include "tests/cluster.hpp"
#include "tests/limiter.hpp"
#include "tests/utils.hpp"

Go to the source code of this file.

Classes
struct	mesos::internal::tests::SlaveOptions
class	mesos::internal::tests::MesosTest
class	mesos::internal::tests::ContainerizerTest< T >
class	mesos::internal::tests::ContainerizerTest< slave::MesosContainerizer >
struct	mesos::internal::tests::common::DefaultCredential< TCredential >
struct	mesos::internal::tests::common::DefaultCredential2< TCredential >
struct	mesos::internal::tests::common::DefaultFrameworkInfo< TFrameworkInfo, TCredential >
class	mesos::internal::tests::MockScheduler
class	mesos::internal::tests::MockExecutor
class	mesos::internal::tests::TestingMesosSchedulerDriver
class	mesos::internal::tests::scheduler::MockHTTPScheduler< Mesos, Event >
class	mesos::internal::tests::scheduler::TestMesos< Mesos, Event >
class	mesos::internal::tests::executor::MockHTTPExecutor< Mesos, Event >
class	mesos::internal::tests::executor::TestMesos< Mesos, Event >
class	mesos::internal::tests::resource_provider::TestResourceProviderProcess< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >
class	mesos::internal::tests::resource_provider::TestResourceProvider< Event, Call, Driver, ResourceProviderInfo, ResourceProviderID, Resource, Resources, OperationState, Operation >
class	mesos::internal::tests::MockAuthorizer
class	mesos::internal::tests::MockGarbageCollector
class	mesos::internal::tests::MockSecretGenerator
struct	mesos::internal::tests::ParamExecutorType
struct	mesos::internal::tests::ParamExecutorType::Printer
struct	mesos::internal::tests::ParamDiskQuota
struct	mesos::internal::tests::ParamDiskQuota::Printer

Namespaces
	mesos
	mesos::internal
	mesos::internal::tests
	mesos::internal::tests::v1
	mesos::internal::tests::common
	mesos::internal::tests::internal
	mesos::internal::tests::scheduler
	mesos::internal::tests::v1::scheduler
	mesos::internal::tests::executor
	mesos::internal::tests::v1::executor
	mesos::internal::tests::resource_provider
	mesos::internal::tests::v1::resource_provider

Macros
#define	DEFAULT_EXECUTOR_INFO   createExecutorInfo("default", "exit 1")
#define	DEFAULT_CREDENTIAL   DefaultCredential::create()
#define	DEFAULT_CREDENTIAL_2   DefaultCredential2::create()
#define	DEFAULT_FRAMEWORK_INFO   DefaultFrameworkInfo::create()
#define	DEFAULT_EXECUTOR_ID   DEFAULT_EXECUTOR_INFO.executor_id()
#define	FUTURE_PROTOBUF(message, from, to)   FutureProtobuf(message, from, to)
#define	DROP_PROTOBUF(message, from, to)   FutureProtobuf(message, from, to, true)
#define	DROP_PROTOBUFS(message, from, to)   DropProtobufs(message, from, to)
#define	EXPECT_NO_FUTURE_PROTOBUFS(message, from, to)   ExpectNoFutureProtobufs(message, from, to)
#define	FUTURE_HTTP_PROTOBUF(message, path, contentType)   FutureHttp(message, path, contentType)
#define	DROP_HTTP_PROTOBUF(message, path, contentType)   FutureHttp(message, path, contentType, true)
#define	DROP_HTTP_PROTOBUFS(message, path, contentType)   DropHttpProtobufs(message, path, contentType)
#define	EXPECT_NO_FUTURE_HTTP_PROTOBUFS(message, path, contentType)   ExpectNoFutureHttpProtobufs(message, path, contentType)
#define	FUTURE_CALL(message, unionType, from, to)   FutureUnionProtobuf(message, unionType, from, to)
#define	DROP_CALL(message, unionType, from, to)   FutureUnionProtobuf(message, unionType, from, to, true)
#define	DROP_CALLS(message, unionType, from, to)   DropUnionProtobufs(message, unionType, from, to)
#define	EXPECT_NO_FUTURE_CALLS(message, unionType, from, to)   ExpectNoFutureUnionProtobufs(message, unionType, from, to)
#define	FUTURE_CALL_MESSAGE(message, unionType, from, to)   process::FutureUnionMessage(message, unionType, from, to)
#define	DROP_CALL_MESSAGE(message, unionType, from, to)   process::FutureUnionMessage(message, unionType, from, to, true)
#define	FUTURE_HTTP_CALL(message, unionType, path, contentType)   FutureUnionHttp(message, unionType, path, contentType)
#define	DROP_HTTP_CALL(message, unionType, path, contentType)   FutureUnionHttp(message, unionType, path, contentType, true)
#define	DROP_HTTP_CALLS(message, unionType, path, contentType)   DropUnionHttpProtobufs(message, unionType, path, contentType)
#define	EXPECT_NO_FUTURE_HTTP_CALLS(message, unionType, path, contentType)   ExpectNoFutureUnionHttpProtobufs(message, unionType, path, contentType)

Typedefs
using	mesos::internal::tests::internal::DefaultCredential = common::DefaultCredential< Credential >
using	mesos::internal::tests::internal::DefaultCredential2 = common::DefaultCredential2< Credential >
using	mesos::internal::tests::internal::DefaultFrameworkInfo = common::DefaultFrameworkInfo< FrameworkInfo, Credential >
using	mesos::internal::tests::v1::DefaultCredential = common::DefaultCredential< mesos::v1::Credential >
using	mesos::internal::tests::v1::DefaultCredential2 = common::DefaultCredential2< mesos::v1::Credential >
using	mesos::internal::tests::v1::DefaultFrameworkInfo = common::DefaultFrameworkInfo< mesos::v1::FrameworkInfo, mesos::v1::Credential >
using	mesos::internal::tests::v1::scheduler::APIResult = mesos::v1::scheduler::APIResult
using	mesos::internal::tests::v1::scheduler::Call = mesos::v1::scheduler::Call
using	mesos::internal::tests::v1::scheduler::Event = mesos::v1::scheduler::Event
using	mesos::internal::tests::v1::scheduler::Mesos = mesos::v1::scheduler::Mesos
using	mesos::internal::tests::v1::scheduler::Response = mesos::v1::scheduler::Response
using	mesos::internal::tests::v1::scheduler::TestMesos = tests::scheduler::TestMesos< mesos::v1::scheduler::Mesos, mesos::v1::scheduler::Event >
using	mesos::internal::tests::v1::MockHTTPScheduler = tests::scheduler::MockHTTPScheduler< mesos::v1::scheduler::Mesos, mesos::v1::scheduler::Event >
using	mesos::internal::tests::v1::executor::Call = mesos::v1::executor::Call
using	mesos::internal::tests::v1::executor::Event = mesos::v1::executor::Event
using	mesos::internal::tests::v1::executor::Mesos = mesos::v1::executor::Mesos
using	mesos::internal::tests::v1::executor::TestMesos = tests::executor::TestMesos< mesos::v1::executor::Mesos, mesos::v1::executor::Event >
using	mesos::internal::tests::v1::MockHTTPExecutor = tests::executor::MockHTTPExecutor< mesos::v1::executor::Mesos, mesos::v1::executor::Event >
using	mesos::internal::tests::v1::resource_provider::Call = mesos::v1::resource_provider::Call
using	mesos::internal::tests::v1::resource_provider::Event = mesos::v1::resource_provider::Event
using	mesos::internal::tests::v1::TestResourceProviderProcess = tests::resource_provider::TestResourceProviderProcess< mesos::v1::resource_provider::Event, mesos::v1::resource_provider::Call, mesos::v1::resource_provider::Driver, mesos::v1::ResourceProviderInfo, mesos::v1::ResourceProviderID, mesos::v1::Resource, mesos::v1::Resources, mesos::v1::OperationState, mesos::v1::Offer::Operation >
using	mesos::internal::tests::v1::TestResourceProvider = tests::resource_provider::TestResourceProvider< mesos::v1::resource_provider::Event, mesos::v1::resource_provider::Call, mesos::v1::resource_provider::Driver, mesos::v1::ResourceProviderInfo, mesos::v1::ResourceProviderID, mesos::v1::Resource, mesos::v1::Resources, mesos::v1::OperationState, mesos::v1::Offer::Operation >

Functions
template<typename TCommandInfo >
TCommandInfo	mesos::internal::tests::common::createCommandInfo (const Option< std::string > &value=None(), const std::vector< std::string > &arguments={})
template<typename TExecutorInfo , typename TExecutorID , typename TResources , typename TCommandInfo , typename TFrameworkID >
TExecutorInfo	mesos::internal::tests::common::createExecutorInfo (const TExecutorID &executorId, const Option< TCommandInfo > &command, const Option< TResources > &resources, const Option< typename TExecutorInfo::Type > &type, const Option< TFrameworkID > &frameworkId)
template<typename TExecutorInfo , typename TExecutorID , typename TResources , typename TCommandInfo , typename TFrameworkID >
TExecutorInfo	mesos::internal::tests::common::createExecutorInfo (const std::string &_executorId, const Option< TCommandInfo > &command, const Option< TResources > &resources, const Option< typename TExecutorInfo::Type > &type, const Option< TFrameworkID > &frameworkId)
template<typename TExecutorInfo , typename TExecutorID , typename TResources , typename TCommandInfo , typename TFrameworkID >
TExecutorInfo	mesos::internal::tests::common::createExecutorInfo (const std::string &executorId, const Option< TCommandInfo > &command=None(), const Option< std::string > &resources=None(), const Option< typename TExecutorInfo::Type > &type=None(), const Option< TFrameworkID > &frameworkId=None())
template<typename TExecutorInfo , typename TExecutorID , typename TResources , typename TCommandInfo , typename TFrameworkID >
TExecutorInfo	mesos::internal::tests::common::createExecutorInfo (const TExecutorID &executorId, const Option< TCommandInfo > &command, const std::string &resources, const Option< typename TExecutorInfo::Type > &type=None(), const Option< TFrameworkID > &frameworkId=None())
template<typename TExecutorInfo , typename TExecutorID , typename TResources , typename TCommandInfo , typename TFrameworkID >
TExecutorInfo	mesos::internal::tests::common::createExecutorInfo (const std::string &executorId, const std::string &command, const Option< std::string > &resources=None(), const Option< typename TExecutorInfo::Type > &type=None(), const Option< TFrameworkID > &frameworkId=None())
template<typename TImage >
TImage	mesos::internal::tests::common::createDockerImage (const std::string &imageName)
template<typename TVolume >
TVolume	mesos::internal::tests::common::createVolumeSandboxPath (const std::string &containerPath, const std::string &sandboxPath, const typename TVolume::Mode &mode)
template<typename TVolume , typename TMountPropagation >
TVolume	mesos::internal::tests::common::createVolumeHostPath (const std::string &containerPath, const std::string &hostPath, const typename TVolume::Mode &mode, const Option< typename TMountPropagation::Mode > &mountPropagationMode=None())
template<typename TVolume , typename TImage >
TVolume	mesos::internal::tests::common::createVolumeFromDockerImage (const std::string &containerPath, const std::string &imageName, const typename TVolume::Mode &mode)
template<typename TVolume >
TVolume	mesos::internal::tests::common::createVolumeCsi (const std::string &pluginName, const std::string &volumeId, const std::string &containerPath, const typename TVolume::Mode &mode, const typename TVolume::Source::CSIVolume::VolumeCapability::AccessMode::Mode &accessMode)
template<typename TNetworkInfo >
TNetworkInfo	mesos::internal::tests::common::createNetworkInfo (const std::string &networkName)
template<typename TContainerInfo , typename TVolume , typename TImage >
TContainerInfo	mesos::internal::tests::common::createContainerInfo (const Option< std::string > &imageName=None(), const std::vector< TVolume > &volumes={})
SlaveID	mesos::internal::tests::common::getAgentID (const Offer &offer)
mesos::v1::AgentID	mesos::internal::tests::common::getAgentID (const mesos::v1::Offer &offer)
void	mesos::internal::tests::common::setAgentID (TaskInfo *task, const SlaveID &slaveId)
void	mesos::internal::tests::common::setAgentID (mesos::v1::TaskInfo *task, const mesos::v1::AgentID &agentId)
template<typename TTaskInfo , typename TExecutorID , typename TSlaveID , typename TResources , typename TExecutorInfo , typename TCommandInfo , typename TOffer , typename TScalar >
TTaskInfo	mesos::internal::tests::common::createTask (const TSlaveID &slaveId, const TResources &resourceRequests, const TCommandInfo &command, const Option< TExecutorID > &executorId=None(), const std::string &name="test-task", const std::string &id=id::UUID::random().toString(), const google::protobuf::Map< std::string, TScalar > &resourceLimits={})
template<typename TTaskInfo , typename TExecutorID , typename TSlaveID , typename TResources , typename TExecutorInfo , typename TCommandInfo , typename TOffer , typename TScalar >
TTaskInfo	mesos::internal::tests::common::createTask (const TSlaveID &slaveId, const TResources &resourceRequests, const std::string &command, const Option< TExecutorID > &executorId=None(), const std::string &name="test-task", const std::string &id=id::UUID::random().toString(), const google::protobuf::Map< std::string, TScalar > &resourceLimits={})
template<typename TTaskInfo , typename TExecutorID , typename TSlaveID , typename TResources , typename TExecutorInfo , typename TCommandInfo , typename TOffer , typename TScalar >
TTaskInfo	mesos::internal::tests::common::createTask (const TOffer &offer, const std::string &command, const Option< TExecutorID > &executorId=None(), const std::string &name="test-task", const std::string &id=id::UUID::random().toString(), const google::protobuf::Map< std::string, TScalar > &resourceLimits={})
template<typename TTaskGroupInfo , typename TTaskInfo >
TTaskGroupInfo	mesos::internal::tests::common::createTaskGroupInfo (const std::vector< TTaskInfo > &tasks)
template<typename TResource >
TResource::ReservationInfo	mesos::internal::tests::common::createStaticReservationInfo (const std::string &role)
template<typename TResource , typename TLabels >
TResource::ReservationInfo	mesos::internal::tests::common::createDynamicReservationInfo (const std::string &role, const Option< std::string > &principal=None(), const Option< TLabels > &labels=None())
template<typename TResource , typename TResources , typename... TReservationInfos>
TResource	mesos::internal::tests::common::createReservedResource (const std::string &name, const std::string &value, const TReservationInfos &...reservations)
template<typename TResource , typename TVolume >
TResource::DiskInfo	mesos::internal::tests::common::createDiskInfo (const Option< std::string > &persistenceId, const Option< std::string > &containerPath, const Option< typename TVolume::Mode > &mode=None(), const Option< std::string > &hostPath=None(), const Option< typename TResource::DiskInfo::Source > &source=None(), const Option< std::string > &principal=None())
template<typename TResource >
TResource::DiskInfo::Source	mesos::internal::tests::common::createDiskSourcePath (const Option< std::string > &root=None(), const Option< std::string > &id=None(), const Option< std::string > &profile=None())
template<typename TResource >
TResource::DiskInfo::Source	mesos::internal::tests::common::createDiskSourceMount (const Option< std::string > &root=None(), const Option< std::string > &id=None(), const Option< std::string > &profile=None())
template<typename TResource >
TResource::DiskInfo::Source	mesos::internal::tests::common::createDiskSourceBlock (const Option< std::string > &id=None(), const Option< std::string > &profile=None())
template<typename TResource >
TResource::DiskInfo::Source	mesos::internal::tests::common::createDiskSourceRaw (const Option< std::string > &id=None(), const Option< std::string > &profile=None())
template<typename TResource , typename TResources , typename TVolume >
TResource	mesos::internal::tests::common::createDiskResource (const std::string &value, const std::string &role, const Option< std::string > &persistenceID, const Option< std::string > &containerPath, const Option< typename TResource::DiskInfo::Source > &source=None(), bool isShared=false)
template<typename TResource , typename TResources , typename TVolume >
TResource	mesos::internal::tests::common::createPersistentVolume (const Bytes &size, const std::string &role, const std::string &persistenceId, const std::string &containerPath, const Option< std::string > &reservationPrincipal=None(), const Option< typename TResource::DiskInfo::Source > &source=None(), const Option< std::string > &creatorPrincipal=None(), bool isShared=false)
template<typename TResource , typename TResources , typename TVolume >
TResource	mesos::internal::tests::common::createPersistentVolume (TResource volume, const std::string &persistenceId, const std::string &containerPath, const Option< std::string > &reservationPrincipal=None(), const Option< std::string > &creatorPrincipal=None(), bool isShared=false)
template<typename TCredential >
process::http::Headers	mesos::internal::tests::common::createBasicAuthHeaders (const TCredential &credential)
template<typename TWeightInfo >
google::protobuf::RepeatedPtrField< TWeightInfo >	mesos::internal::tests::common::createWeightInfos (const std::string &weightsFlag)
template<typename TWeightInfo >
hashmap< std::string, double >	mesos::internal::tests::common::convertToHashmap (const google::protobuf::RepeatedPtrField< TWeightInfo > weightInfos)
template<typename TDomainInfo >
TDomainInfo	mesos::internal::tests::common::createDomainInfo (const std::string &regionName, const std::string &zoneName)
template<typename TResources , typename TOperationID , typename TOffer >
TOffer::Operation	mesos::internal::tests::common::RESERVE (const TResources &resources, const Option< TOperationID > &operationId=None())
template<typename TResources , typename TOperationID , typename TOffer >
TOffer::Operation	mesos::internal::tests::common::UNRESERVE (const TResources &resources, const Option< TOperationID > &operationId=None())
template<typename TResources , typename TOperationID , typename TOffer >
TOffer::Operation	mesos::internal::tests::common::CREATE (const TResources &volumes, const Option< TOperationID > &operationId=None())
template<typename TResources , typename TOperationID , typename TOffer >
TOffer::Operation	mesos::internal::tests::common::DESTROY (const TResources &volumes, const Option< TOperationID > &operationId=None())
template<typename TResource , typename TOperationID , typename TOffer >
TOffer::Operation	mesos::internal::tests::common::GROW_VOLUME (const TResource &volume, const TResource &addition, const Option< TOperationID > &operationId=None())
template<typename TResource , typename TValueScalar , typename TOperationID , typename TOffer >
TOffer::Operation	mesos::internal::tests::common::SHRINK_VOLUME (const TResource &volume, const TValueScalar &subtract, const Option< TOperationID > &operationId=None())
template<typename TOffer , typename TTaskInfo >
TOffer::Operation	mesos::internal::tests::common::LAUNCH (const std::vector< TTaskInfo > &tasks)
template<typename TExecutorInfo , typename TTaskGroupInfo , typename TOffer >
TOffer::Operation	mesos::internal::tests::common::LAUNCH_GROUP (const TExecutorInfo &executorInfo, const TTaskGroupInfo &taskGroup)
template<typename TResource , typename TTargetType , typename TOperationID , typename TOffer >
TOffer::Operation	mesos::internal::tests::common::CREATE_DISK (const TResource &source, const TTargetType &targetType, const Option< std::string > &targetProfile=None(), const Option< TOperationID > &operationId=None())
template<typename TResource , typename TOperationID , typename TOffer >
TOffer::Operation	mesos::internal::tests::common::DESTROY_DISK (const TResource &source, const Option< TOperationID > &operationId=None())
template<typename TParameters , typename TParameter >
TParameters	mesos::internal::tests::common::parameterize (const ACLs &acls)
template<typename... Args>
ExecutorInfo	mesos::internal::tests::internal::createExecutorInfo (Args &&...args)
CommandInfo	mesos::internal::tests::internal::createCommandInfo (const Option< std::string > &value=None(), const std::vector< std::string > &arguments={})
mesos::slave::ContainerConfig	mesos::internal::tests::internal::createContainerConfig (const Option< TaskInfo > &taskInfo, const ExecutorInfo &executorInfo, const std::string &sandboxDirectory, const Option< std::string > &user=None())
mesos::slave::ContainerConfig	mesos::internal::tests::internal::createContainerConfig (const CommandInfo &commandInfo, const Option< ContainerInfo > &containerInfo=None(), const Option< mesos::slave::ContainerClass > &containerClass=None(), const Option< std::string > &user=None())
mesos::slave::ContainerConfig	mesos::internal::tests::internal::createContainerConfig (const CommandInfo &commandInfo, const std::string &resources, const std::string &sandboxDirectory, const Option< ContainerInfo > &containerInfo=None(), const Option< std::string > &user=None())
template<typename... Args>
Image	mesos::internal::tests::internal::createDockerImage (Args &&...args)
template<typename... Args>
Volume	mesos::internal::tests::internal::createVolumeSandboxPath (Args &&...args)
template<typename... Args>
Volume	mesos::internal::tests::internal::createVolumeHostPath (Args &&...args)
template<typename... Args>
Volume	mesos::internal::tests::internal::createVolumeFromDockerImage (Args &&...args)
template<typename... Args>
Volume	mesos::internal::tests::internal::createVolumeCsi (Args &&...args)
template<typename... Args>
NetworkInfo	mesos::internal::tests::internal::createNetworkInfo (Args &&...args)
ContainerInfo	mesos::internal::tests::internal::createContainerInfo (const Option< std::string > &imageName=None(), const std::vector< Volume > &volumes={})
template<typename... Args>
TaskInfo	mesos::internal::tests::internal::createTask (Args &&...args)
TaskGroupInfo	mesos::internal::tests::internal::createTaskGroupInfo (const std::vector< TaskInfo > &tasks)
Resource::ReservationInfo	mesos::internal::tests::internal::createStaticReservationInfo (const std::string &role)
Resource::ReservationInfo	mesos::internal::tests::internal::createDynamicReservationInfo (const std::string &role, const Option< std::string > &principal=None(), const Option< Labels > &labels=None())
template<typename... Args>
Resource	mesos::internal::tests::internal::createReservedResource (Args &&...args)
template<typename... Args>
Resource::DiskInfo	mesos::internal::tests::internal::createDiskInfo (Args &&...args)
template<typename... Args>
Resource::DiskInfo::Source	mesos::internal::tests::internal::createDiskSourcePath (Args &&...args)
template<typename... Args>
Resource::DiskInfo::Source	mesos::internal::tests::internal::createDiskSourceMount (Args &&...args)
template<typename... Args>
Resource::DiskInfo::Source	mesos::internal::tests::internal::createDiskSourceBlock (Args &&...args)
template<typename... Args>
Resource::DiskInfo::Source	mesos::internal::tests::internal::createDiskSourceRaw (Args &&...args)
template<typename... Args>
Resource	mesos::internal::tests::internal::createDiskResource (Args &&...args)
template<typename... Args>
Resource	mesos::internal::tests::internal::createPersistentVolume (Args &&...args)
template<typename... Args>
process::http::Headers	mesos::internal::tests::internal::createBasicAuthHeaders (Args &&...args)
template<typename... Args>
google::protobuf::RepeatedPtrField< WeightInfo >	mesos::internal::tests::internal::createWeightInfos (Args &&...args)
template<typename... Args>
hashmap< std::string, double >	mesos::internal::tests::internal::convertToHashmap (Args &&...args)
template<typename... Args>
DomainInfo	mesos::internal::tests::internal::createDomainInfo (Args &&...args)
template<typename... Args>
Offer::Operation	mesos::internal::tests::internal::RESERVE (Args &&...args)
template<typename... Args>
Offer::Operation	mesos::internal::tests::internal::UNRESERVE (Args &&...args)
template<typename... Args>
Offer::Operation	mesos::internal::tests::internal::CREATE (Args &&...args)
template<typename... Args>
Offer::Operation	mesos::internal::tests::internal::DESTROY (Args &&...args)
template<typename... Args>
Offer::Operation	mesos::internal::tests::internal::GROW_VOLUME (Args &&...args)
template<typename... Args>
Offer::Operation	mesos::internal::tests::internal::SHRINK_VOLUME (Args &&...args)
Offer::Operation	mesos::internal::tests::internal::LAUNCH (const std::vector< TaskInfo > &tasks)
template<typename... Args>
Offer::Operation	mesos::internal::tests::internal::LAUNCH_GROUP (Args &&...args)
template<typename... Args>
Offer::Operation	mesos::internal::tests::internal::CREATE_DISK (Args &&...args)
template<typename... Args>
Offer::Operation	mesos::internal::tests::internal::DESTROY_DISK (Args &&...args)
template<typename... Args>
Parameters	mesos::internal::tests::internal::parameterize (Args &&...args)
template<typename... Args>
mesos::v1::ExecutorInfo	mesos::internal::tests::v1::createExecutorInfo (Args &&...args)
mesos::v1::CommandInfo	mesos::internal::tests::v1::createCommandInfo (const Option< std::string > &value=None(), const std::vector< std::string > &arguments={})
template<typename... Args>
mesos::v1::Image	mesos::internal::tests::v1::createDockerImage (Args &&...args)
template<typename... Args>
mesos::v1::Volume	mesos::internal::tests::v1::createVolumeSandboxPath (Args &&...args)
template<typename... Args>
mesos::v1::Volume	mesos::internal::tests::v1::createVolumeHostPath (Args &&...args)
template<typename... Args>
mesos::v1::Volume	mesos::internal::tests::v1::createVolumeFromDockerImage (Args &&...args)
template<typename... Args>
mesos::v1::Volume	mesos::internal::tests::v1::createVolumeCsi (Args &&...args)
template<typename... Args>
mesos::v1::NetworkInfo	mesos::internal::tests::v1::createNetworkInfo (Args &&...args)
mesos::v1::ContainerInfo	mesos::internal::tests::v1::createContainerInfo (const Option< std::string > &imageName=None(), const std::vector< mesos::v1::Volume > &volumes={})
template<typename... Args>
mesos::v1::TaskInfo	mesos::internal::tests::v1::createTask (Args &&...args)
mesos::v1::TaskGroupInfo	mesos::internal::tests::v1::createTaskGroupInfo (const std::vector< mesos::v1::TaskInfo > &tasks)
mesos::v1::Resource::ReservationInfo	mesos::internal::tests::v1::createStaticReservationInfo (const std::string &role)
mesos::v1::Resource::ReservationInfo	mesos::internal::tests::v1::createDynamicReservationInfo (const std::string &role, const Option< std::string > &principal=None(), const Option< mesos::v1::Labels > &labels=None())
template<typename... Args>
mesos::v1::Resource	mesos::internal::tests::v1::createReservedResource (Args &&...args)
template<typename... Args>
mesos::v1::Resource::DiskInfo	mesos::internal::tests::v1::createDiskInfo (Args &&...args)
template<typename... Args>
mesos::v1::Resource::DiskInfo::Source	mesos::internal::tests::v1::createDiskSourcePath (Args &&...args)
template<typename... Args>
mesos::v1::Resource::DiskInfo::Source	mesos::internal::tests::v1::createDiskSourceMount (Args &&...args)
template<typename... Args>
mesos::v1::Resource::DiskInfo::Source	mesos::internal::tests::v1::createDiskSourceBlock (Args &&...args)
template<typename... Args>
mesos::v1::Resource::DiskInfo::Source	mesos::internal::tests::v1::createDiskSourceRaw (Args &&...args)
template<typename... Args>
mesos::v1::Resource	mesos::internal::tests::v1::createDiskResource (Args &&...args)
template<typename... Args>
mesos::v1::Resource	mesos::internal::tests::v1::createPersistentVolume (Args &&...args)
template<typename... Args>
process::http::Headers	mesos::internal::tests::v1::createBasicAuthHeaders (Args &&...args)
template<typename... Args>
google::protobuf::RepeatedPtrField< mesos::v1::WeightInfo >	mesos::internal::tests::v1::createWeightInfos (Args &&...args)
template<typename... Args>
hashmap< std::string, double >	mesos::internal::tests::v1::convertToHashmap (Args &&...args)
template<typename... Args>
mesos::v1::Offer::Operation	mesos::internal::tests::v1::RESERVE (Args &&...args)
template<typename... Args>
mesos::v1::Offer::Operation	mesos::internal::tests::v1::UNRESERVE (Args &&...args)
template<typename... Args>
mesos::v1::Offer::Operation	mesos::internal::tests::v1::CREATE (Args &&...args)
template<typename... Args>
mesos::v1::Offer::Operation	mesos::internal::tests::v1::DESTROY (Args &&...args)
template<typename... Args>
mesos::v1::Offer::Operation	mesos::internal::tests::v1::GROW_VOLUME (Args &&...args)
template<typename... Args>
mesos::v1::Offer::Operation	mesos::internal::tests::v1::SHRINK_VOLUME (Args &&...args)
mesos::v1::Offer::Operation	mesos::internal::tests::v1::LAUNCH (const std::vector< mesos::v1::TaskInfo > &tasks)
template<typename... Args>
mesos::v1::Offer::Operation	mesos::internal::tests::v1::LAUNCH_GROUP (Args &&...args)
template<typename... Args>
mesos::v1::Offer::Operation	mesos::internal::tests::v1::CREATE_DISK (Args &&...args)
template<typename... Args>
mesos::v1::Offer::Operation	mesos::internal::tests::v1::DESTROY_DISK (Args &&...args)
template<typename... Args>
mesos::v1::Parameters	mesos::internal::tests::v1::parameterize (Args &&...args)
mesos::v1::scheduler::Call	mesos::internal::tests::v1::createCallAccept (const mesos::v1::FrameworkID &frameworkId, const mesos::v1::Offer &offer, const std::vector< mesos::v1::Offer::Operation > &operations, const Option< mesos::v1::Filters > &filters=None())
mesos::v1::scheduler::Call	mesos::internal::tests::v1::createCallAcknowledge (const mesos::v1::FrameworkID &frameworkId, const mesos::v1::AgentID &agentId, const mesos::v1::scheduler::Event::Update &update)
mesos::v1::scheduler::Call	mesos::internal::tests::v1::createCallAcknowledgeOperationStatus (const mesos::v1::FrameworkID &frameworkId, const mesos::v1::AgentID &agentId, const Option< mesos::v1::ResourceProviderID > &resourceProviderId, const mesos::v1::scheduler::Event::UpdateOperationStatus &update)
mesos::v1::scheduler::Call	mesos::internal::tests::v1::createCallKill (const mesos::v1::FrameworkID &frameworkId, const mesos::v1::TaskID &taskId, const Option< mesos::v1::AgentID > &agentId=None(), const Option< mesos::v1::KillPolicy > &killPolicy=None())
mesos::v1::scheduler::Call	mesos::internal::tests::v1::createCallReconcileOperations (const mesos::v1::FrameworkID &frameworkId, const std::vector< mesos::v1::scheduler::Call::ReconcileOperations::Operation > &operations={})
mesos::v1::scheduler::Call	mesos::internal::tests::v1::createCallSubscribe (const mesos::v1::FrameworkInfo &frameworkInfo, const Option< mesos::v1::FrameworkID > &frameworkId=None())
mesos::Environment	mesos::internal::tests::createEnvironment (const hashmap< std::string, std::string > &map)
	mesos::internal::tests::ACTION_P5 (LaunchTasks, executor, tasks, cpus, mem, role)
	mesos::internal::tests::ACTION (DeclineOffers)
	mesos::internal::tests::ACTION_P (DeclineOffers, filters)
	mesos::internal::tests::ACTION_P (EnqueueOffers, queue)
	mesos::internal::tests::v1::scheduler::MATCHER_P (OffersHaveAnyResource, filter,"")
	mesos::internal::tests::v1::scheduler::MATCHER_P (OperationStatusUpdateOperationIdEq, operationId,"")
	mesos::internal::tests::v1::scheduler::ACTION (DeclineOffers)
	mesos::internal::tests::v1::scheduler::ACTION_P (SendSubscribe, frameworkInfo)
	mesos::internal::tests::v1::scheduler::ACTION_P2 (SendSubscribe, frameworkInfo, frameworkId)
	mesos::internal::tests::v1::scheduler::ACTION_P2 (SendAcknowledge, frameworkId, agentId)
	mesos::internal::tests::v1::scheduler::ACTION_P2 (SendAcknowledgeOperationStatus, frameworkId, agentId)
	mesos::internal::tests::v1::scheduler::ACTION_P3 (SendAcknowledgeOperationStatus, frameworkId, agentId, resourceProviderId)
	mesos::internal::tests::v1::executor::ACTION_P2 (SendSubscribe, frameworkId, executorId)
	mesos::internal::tests::v1::executor::ACTION_P3 (SendUpdateFromTask, frameworkId, executorId, state)
	mesos::internal::tests::v1::executor::ACTION_P3 (SendUpdateFromTaskID, frameworkId, executorId, state)
process::Owned< EndpointDetector >	mesos::internal::tests::resource_provider::createEndpointDetector (const process::UPID &pid)
	mesos::internal::tests::ACTION_P (SendStatusUpdateFromTask, state)
	mesos::internal::tests::ACTION_P (SendStatusUpdateFromTaskID, state)
	mesos::internal::tests::ACTION_P (SendFrameworkMessage, data)
template<typename T >
T	mesos::internal::tests::_FutureProtobuf (const process::Message &message)
template<typename T , typename From , typename To >
process::Future< T >	mesos::internal::tests::FutureProtobuf (T t, From from, To to, bool drop=false)
template<typename Message , typename UnionType , typename From , typename To >
process::Future< Message >	mesos::internal::tests::FutureUnionProtobuf (Message message, UnionType unionType, From from, To to, bool drop=false)
template<typename Message , typename Path >
process::Future< Message >	mesos::internal::tests::FutureHttp (Message message, Path path, ContentType contentType, bool drop=false)
template<typename Message , typename UnionType , typename Path >
process::Future< Message >	mesos::internal::tests::FutureUnionHttp (Message message, UnionType unionType, Path path, ContentType contentType, bool drop=false)
template<typename T , typename From , typename To >
void	mesos::internal::tests::DropProtobufs (T t, From from, To to)
template<typename Message , typename UnionType , typename From , typename To >
void	mesos::internal::tests::DropUnionProtobufs (Message message, UnionType unionType, From from, To to)
template<typename Message , typename Path >
void	mesos::internal::tests::DropHttpProtobufs (Message message, Path path, ContentType contentType, bool drop=false)
template<typename Message , typename UnionType , typename Path >
void	mesos::internal::tests::DropUnionHttpProtobufs (Message message, UnionType unionType, Path path, ContentType contentType, bool drop=false)
template<typename T , typename From , typename To >
void	mesos::internal::tests::ExpectNoFutureProtobufs (T t, From from, To to)
template<typename Message , typename UnionType , typename From , typename To >
void	mesos::internal::tests::ExpectNoFutureUnionProtobufs (Message message, UnionType unionType, From from, To to)
template<typename Message , typename Path >
void	mesos::internal::tests::ExpectNoFutureHttpProtobufs (Message message, Path path, ContentType contentType, bool drop=false)
template<typename Message , typename UnionType , typename Path >
void	mesos::internal::tests::ExpectNoFutureUnionHttpProtobufs (Message message, UnionType unionType, Path path, ContentType contentType, bool drop=false)
	mesos::internal::tests::MATCHER_P (OffersHaveAnyResource, filter,"")
	mesos::internal::tests::MATCHER_P (OffersHaveResource, resource,"")
	mesos::internal::tests::MATCHER_P (TaskStatusTaskIdEq, taskId,"")
	mesos::internal::tests::MATCHER_P (TaskStatusStateEq, taskState,"")
	mesos::internal::tests::MATCHER_P (TaskStatusUpdateTaskIdEq, taskId,"")
	mesos::internal::tests::MATCHER_P (TaskStatusUpdateStateEq, taskState,"")
	mesos::internal::tests::MATCHER_P (AuthorizationRequestHasTaskID, taskId,"")
	mesos::internal::tests::MATCHER_P (OptionTaskHasTaskID, taskId,"")
	mesos::internal::tests::MATCHER_P (OptionTaskGroupHasTaskID, taskId,"")

Variables
constexpr char	mesos::internal::tests::READONLY_HTTP_AUTHENTICATION_REALM [] = "test-readonly-realm"
constexpr char	mesos::internal::tests::READWRITE_HTTP_AUTHENTICATION_REALM [] = "test-readwrite-realm"
constexpr char	mesos::internal::tests::DEFAULT_TEST_ROLE [] = "default-role"
constexpr char	mesos::internal::tests::DEFAULT_JWT_SECRET_KEY []

Macro Definition Documentation

#define DEFAULT_CREDENTIAL   DefaultCredential::create()

#define DEFAULT_CREDENTIAL_2   DefaultCredential2::create()

#define DEFAULT_EXECUTOR_ID   DEFAULT_EXECUTOR_INFO.executor_id()

#define DEFAULT_EXECUTOR_INFO   createExecutorInfo("default", "exit 1")

#define DEFAULT_FRAMEWORK_INFO   DefaultFrameworkInfo::create()

#define DROP_CALL	(		message,
			unionType,
			from,
			to
	)		FutureUnionProtobuf(message, unionType, from, to, true)

#define DROP_CALL_MESSAGE	(		message,
			unionType,
			from,
			to
	)		process::FutureUnionMessage(message, unionType, from, to, true)

#define DROP_CALLS	(		message,
			unionType,
			from,
			to
	)		DropUnionProtobufs(message, unionType, from, to)

#define DROP_HTTP_CALL	(		message,
			unionType,
			path,
			contentType
	)		FutureUnionHttp(message, unionType, path, contentType, true)

#define DROP_HTTP_CALLS	(		message,
			unionType,
			path,
			contentType
	)		DropUnionHttpProtobufs(message, unionType, path, contentType)

#define DROP_HTTP_PROTOBUF	(		message,
			path,
			contentType
	)		FutureHttp(message, path, contentType, true)

#define DROP_HTTP_PROTOBUFS	(		message,
			path,
			contentType
	)		DropHttpProtobufs(message, path, contentType)

#define DROP_PROTOBUF	(		message,
			from,
			to
	)		FutureProtobuf(message, from, to, true)

#define DROP_PROTOBUFS	(		message,
			from,
			to
	)		DropProtobufs(message, from, to)

#define EXPECT_NO_FUTURE_CALLS	(		message,
			unionType,
			from,
			to
	)		ExpectNoFutureUnionProtobufs(message, unionType, from, to)

#define EXPECT_NO_FUTURE_HTTP_CALLS	(		message,
			unionType,
			path,
			contentType
	)		ExpectNoFutureUnionHttpProtobufs(message, unionType, path, contentType)

#define EXPECT_NO_FUTURE_HTTP_PROTOBUFS	(		message,
			path,
			contentType
	)		ExpectNoFutureHttpProtobufs(message, path, contentType)

#define EXPECT_NO_FUTURE_PROTOBUFS	(		message,
			from,
			to
	)		ExpectNoFutureProtobufs(message, from, to)

#define FUTURE_CALL	(		message,
			unionType,
			from,
			to
	)		FutureUnionProtobuf(message, unionType, from, to)

#define FUTURE_CALL_MESSAGE	(		message,
			unionType,
			from,
			to
	)		process::FutureUnionMessage(message, unionType, from, to)

#define FUTURE_HTTP_CALL	(		message,
			unionType,
			path,
			contentType
	)		FutureUnionHttp(message, unionType, path, contentType)

#define FUTURE_HTTP_PROTOBUF	(		message,
			path,
			contentType
	)		FutureHttp(message, path, contentType)

#define FUTURE_PROTOBUF	(		message,
			from,
			to
	)		FutureProtobuf(message, from, to)