mesos::internal::tests Namespace Reference

Namespaces
	cluster
	common
	executor
	internal
	resource_provider
	scheduler
	v1

Classes
class	ActiveUserTestHelper
class	CapabilitiesTestHelper
class	ContainerizerTest
class	ContainerizerTest< slave::MesosContainerizer >
class	DockerArchive
class	Environment
class	Flags
class	HttpServerTestHelper
class	KillPolicyTestHelper
class	LinuxRootfs
class	MemoryTestHelper
class	MesosTest
class	MockAuthorizer
class	MockContainerizer
class	MockCSIPlugin
class	MockDocker
class	MockDockerContainerizer
class	MockDockerContainerizerProcess
class	MockExecutor
class	MockFetcherProcess
class	MockGarbageCollector
class	MockIsolator
class	MockQoSController
class	MockRateLimiter
class	MockRegistrar
class	MockResourceEstimator
class	MockScheduler
class	MockSecretGenerator
class	MockSlave
class	Module
struct	ParamDiskQuota
struct	ParamExecutorType
class	Rootfs
class	SetnsTestHelper
struct	SlaveOptions
class	TestAllocator
class	TestContainerizer
class	TestDiskProfileServer
class	TestDiskProfileServerProcess
class	TestingMesosSchedulerDriver
class	TestLauncher
class	ZooKeeperTest
class	ZooKeeperTestServer

Enumerations
enum	ModuleID {   TestMemIsolator, TestCpuIsolator, TestCRAMMD5Authenticatee, TestCRAMMD5Authenticator,   TestHook, TestAnonymous, TestDRFAllocator, TestNoopResourceEstimator,   TestLocalAuthorizer, TestSandboxContainerLogger, TestMasterContender, TestMasterDetector,   LogrotateContainerLogger, TestHttpBasicAuthenticator }

Functions
Quota	createQuota (const std::string &guarantees, const std::string &limits)
Quota	createQuota (const std::string &resources)
WeightInfo	createWeightInfo (const std::string &role, double weight)
	ACTION_P (InvokeInitialize, allocator)
	ACTION_P (InvokeRecover, allocator)
	ACTION_P (InvokeAddFramework, allocator)
	ACTION_P (InvokeRemoveFramework, allocator)
	ACTION_P (InvokeActivateFramework, allocator)
	ACTION_P (InvokeDeactivateFramework, allocator)
	ACTION_P (InvokeUpdateFramework, allocator)
	ACTION_P (InvokeAddSlave, allocator)
	ACTION_P (InvokeRemoveSlave, allocator)
	ACTION_P (InvokeUpdateSlave, allocator)
	ACTION_P (InvokeAddResourceProvider, allocator)
	ACTION_P (InvokeActivateSlave, allocator)
	ACTION_P (InvokeDeactivateSlave, allocator)
	ACTION_P (InvokeUpdateWhitelist, allocator)
	ACTION_P (InvokeRequestResources, allocator)
	ACTION_P (InvokeUpdateAllocation, allocator)
	ACTION_P (InvokeUpdateAvailable, allocator)
	ACTION_P (InvokeUpdateUnavailability, allocator)
	ACTION_P (InvokeUpdateInverseOffer, allocator)
	ACTION_P (InvokeGetInverseOfferStatuses, allocator)
	ACTION_P (InvokeTransitionOfferedToAllocated, allocator)
	ACTION_P (InvokeRecoverResources, allocator)
	ACTION_P2 (InvokeRecoverResourcesWithFilters, allocator, timeout)
	ACTION_P (InvokeSuppressOffers, allocator)
	ACTION_P (InvokeReviveOffers, allocator)
	ACTION_P (InvokeUpdateQuota, allocator)
	ACTION_P (InvokeUpdateWeights, allocator)
	ACTION_P (InvokePause, allocator)
	ACTION_P (InvokeResume, allocator)
template<typename T = master::allocator::HierarchicalDRFAllocator>
mesos::allocator::Allocator *	createAllocator ()
process::Future< Nothing >	pullDockerImage (const std::string &imageName)
void	createDockerIPv6UserNetwork ()
void	removeDockerIPv6UserNetwork ()
void	assertDockerKillStatus (process::Future< Option< int >> &status)
mesos::Environment	createEnvironment (const hashmap< std::string, std::string > &map)
	ACTION_P5 (LaunchTasks, executor, tasks, cpus, mem, role)
	ACTION (DeclineOffers)
	ACTION_P (DeclineOffers, filters)
	ACTION_P (EnqueueOffers, queue)
	ACTION_P (SendStatusUpdateFromTask, state)
	ACTION_P (SendStatusUpdateFromTaskID, state)
	ACTION_P (SendFrameworkMessage, data)
template<typename T >
T	_FutureProtobuf (const process::Message &message)
template<typename T , typename From , typename To >
process::Future< T >	FutureProtobuf (T t, From from, To to, bool drop=false)
template<typename Message , typename UnionType , typename From , typename To >
process::Future< Message >	FutureUnionProtobuf (Message message, UnionType unionType, From from, To to, bool drop=false)
template<typename Message , typename Path >
process::Future< Message >	FutureHttp (Message message, Path path, ContentType contentType, bool drop=false)
template<typename Message , typename UnionType , typename Path >
process::Future< Message >	FutureUnionHttp (Message message, UnionType unionType, Path path, ContentType contentType, bool drop=false)
template<typename T , typename From , typename To >
void	DropProtobufs (T t, From from, To to)
template<typename Message , typename UnionType , typename From , typename To >
void	DropUnionProtobufs (Message message, UnionType unionType, From from, To to)
template<typename Message , typename Path >
void	DropHttpProtobufs (Message message, Path path, ContentType contentType, bool drop=false)
template<typename Message , typename UnionType , typename Path >
void	DropUnionHttpProtobufs (Message message, UnionType unionType, Path path, ContentType contentType, bool drop=false)
template<typename T , typename From , typename To >
void	ExpectNoFutureProtobufs (T t, From from, To to)
template<typename Message , typename UnionType , typename From , typename To >
void	ExpectNoFutureUnionProtobufs (Message message, UnionType unionType, From from, To to)
template<typename Message , typename Path >
void	ExpectNoFutureHttpProtobufs (Message message, Path path, ContentType contentType, bool drop=false)
template<typename Message , typename UnionType , typename Path >
void	ExpectNoFutureUnionHttpProtobufs (Message message, UnionType unionType, Path path, ContentType contentType, bool drop=false)
	MATCHER_P (OffersHaveAnyResource, filter,"")
	MATCHER_P (OffersHaveResource, resource,"")
	MATCHER_P (TaskStatusTaskIdEq, taskId,"")
	MATCHER_P (TaskStatusStateEq, taskState,"")
	MATCHER_P (TaskStatusUpdateTaskIdEq, taskId,"")
	MATCHER_P (TaskStatusUpdateStateEq, taskState,"")
	MATCHER_P (AuthorizationRequestHasTaskID, taskId,"")
	MATCHER_P (OptionTaskHasTaskID, taskId,"")
	MATCHER_P (OptionTaskGroupHasTaskID, taskId,"")
Try< Nothing >	initModules (const Option< Modules > &modules)
Try< std::string >	getModuleName (ModuleID id)
Resources	allocatedResources (const Resources &resources, const std::string &role)
Resource	createPorts (const ::mesos::Value::Ranges &ranges)
Try<::mesos::Value::Ranges >	fragment (const ::mesos::Value::Range &bounds, size_t numRanges)
::mesos::Value::Range	createRange (uint64_t begin, uint64_t end)
void	execute (const std::string &script)
JSON::Object	Metrics ()
template<typename T >
bool	metricEquals (const std::string &metric, const T &value)
std::string	getModulePath (const std::string &name)
std::string	getLibMesosPath ()
std::string	getLauncherDir ()
std::string	getTestHelperPath (const std::string &name)
std::string	getTestScriptPath (const std::string &name)
std::string	getTestHelperDir ()
std::string	getSbinDir ()
std::string	getWebUIDir ()
Try< uint16_t >	getFreePort ()
Try< net::IP::Network >	getNonLoopbackIP ()
inline::testing::AssertionResult	AssertZKGet (const char *expectedExpr, const char *zkExpr, const char *pathExpr, const std::string &expected, ZooKeeper *zk, const std::string &path)

Variables
constexpr char	DOCKER_IPv6_NETWORK [] = "mesos-docker-ip6-test"
Environment *	environment
Flags	flags
constexpr char	READONLY_HTTP_AUTHENTICATION_REALM [] = "test-readonly-realm"
constexpr char	READWRITE_HTTP_AUTHENTICATION_REALM [] = "test-readwrite-realm"
constexpr char	DEFAULT_TEST_ROLE [] = "default-role"
constexpr char	DEFAULT_JWT_SECRET_KEY []

Enumeration Type Documentation

enum mesos::internal::tests::ModuleID

Enumerator
TestMemIsolator
TestCpuIsolator
TestCRAMMD5Authenticatee
TestCRAMMD5Authenticator
TestHook
TestAnonymous
TestDRFAllocator
TestNoopResourceEstimator
TestLocalAuthorizer
TestSandboxContainerLogger
TestMasterContender
TestMasterDetector
LogrotateContainerLogger
TestHttpBasicAuthenticator

Function Documentation

template<typename T >

T mesos::internal::tests::_FutureProtobuf

(

const process::Message &

message

)

mesos::internal::tests::ACTION

(

DeclineOffers

)

mesos::internal::tests::ACTION_P	(	InvokeInitialize	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeRecover	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeAddFramework	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeRemoveFramework	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeActivateFramework	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeDeactivateFramework	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeUpdateFramework	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeAddSlave	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeRemoveSlave	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeUpdateSlave	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeAddResourceProvider	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeActivateSlave	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeDeactivateSlave	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeUpdateWhitelist	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeRequestResources	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeUpdateAllocation	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeUpdateAvailable	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeUpdateUnavailability	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeUpdateInverseOffer	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeGetInverseOfferStatuses	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeTransitionOfferedToAllocated	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeRecoverResources	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeSuppressOffers	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeReviveOffers	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeUpdateQuota	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeUpdateWeights	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokePause	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	InvokeResume	,
		allocator
	)

mesos::internal::tests::ACTION_P	(	DeclineOffers	,
		filters
	)

mesos::internal::tests::ACTION_P	(	EnqueueOffers	,
		queue
	)

mesos::internal::tests::ACTION_P	(	SendStatusUpdateFromTask	,
		state
	)

mesos::internal::tests::ACTION_P	(	SendStatusUpdateFromTaskID	,
		state
	)

mesos::internal::tests::ACTION_P	(	SendFrameworkMessage	,
		data
	)

mesos::internal::tests::ACTION_P2	(	InvokeRecoverResourcesWithFilters	,
		allocator	,
		timeout
	)

mesos::internal::tests::ACTION_P5	(	LaunchTasks	,
		executor	,
		tasks	,
		cpus	,
		mem	,
		role
	)

Resources mesos::internal::tests::allocatedResources	(	const Resources &	resources,
		const std::string &	role
	)

void mesos::internal::tests::assertDockerKillStatus ( process::Future< Option< int >> &  status )

inline

inline ::testing::AssertionResult mesos::internal::tests::AssertZKGet	(	const char *	expectedExpr,
		const char *	zkExpr,
		const char *	pathExpr,
		const std::string &	expected,
		ZooKeeper *	zk,
		const std::string &	path
	)

template<typename T = master::allocator::HierarchicalDRFAllocator>

mesos::allocator::Allocator* mesos::internal::tests::createAllocator

(

)

void mesos::internal::tests::createDockerIPv6UserNetwork ( )

inline

mesos::Environment mesos::internal::tests::createEnvironment ( const hashmap< std::string, std::string > &  map )

inline

Resource mesos::internal::tests::createPorts

(

const ::mesos::Value::Ranges &

ranges

)

Quota mesos::internal::tests::createQuota	(	const std::string &	guarantees,
		const std::string &	limits
	)

Quota mesos::internal::tests::createQuota

(

const std::string &

resources

)

::mesos::Value::Range mesos::internal::tests::createRange	(	uint64_t	begin,
		uint64_t	end
	)

WeightInfo mesos::internal::tests::createWeightInfo	(	const std::string &	role,
		double	weight
	)

template<typename Message , typename Path >

void mesos::internal::tests::DropHttpProtobufs	(	Message	message,
		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 Path >

void mesos::internal::tests::DropUnionHttpProtobufs	(	Message	message,
		UnionType	unionType,
		Path	path,
		ContentType	contentType,
		bool	drop = false
	)

template<typename Message , typename UnionType , typename From , typename To >

void mesos::internal::tests::DropUnionProtobufs	(	Message	message,
		UnionType	unionType,
		From	from,
		To	to
	)

void mesos::internal::tests::execute

(

const std::string &

script

)

template<typename Message , typename Path >

void mesos::internal::tests::ExpectNoFutureHttpProtobufs	(	Message	message,
		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 Path >

void mesos::internal::tests::ExpectNoFutureUnionHttpProtobufs	(	Message	message,
		UnionType	unionType,
		Path	path,
		ContentType	contentType,
		bool	drop = false
	)

template<typename Message , typename UnionType , typename From , typename To >

void mesos::internal::tests::ExpectNoFutureUnionProtobufs	(	Message	message,
		UnionType	unionType,
		From	from,
		To	to
	)

Try<::mesos::Value::Ranges> mesos::internal::tests::fragment	(	const ::mesos::Value::Range &	bounds,
		size_t	numRanges
	)

template<typename Message , typename Path >

process::Future<Message> mesos::internal::tests::FutureHttp	(	Message	message,
		Path	path,
		ContentType	contentType,
		bool	drop = false
	)

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

process::Future<Message> mesos::internal::tests::FutureUnionHttp	(	Message	message,
		UnionType	unionType,
		Path	path,
		ContentType	contentType,
		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
	)

Try<uint16_t> mesos::internal::tests::getFreePort

(

)

std::string mesos::internal::tests::getLauncherDir

(

)

std::string mesos::internal::tests::getLibMesosPath

(

)

Try<std::string> mesos::internal::tests::getModuleName

(

ModuleID

id

)

std::string mesos::internal::tests::getModulePath

(

const std::string &

name

)

Try<net::IP::Network> mesos::internal::tests::getNonLoopbackIP

(

)

std::string mesos::internal::tests::getSbinDir

(

)

std::string mesos::internal::tests::getTestHelperDir

(

)

std::string mesos::internal::tests::getTestHelperPath

(

const std::string &

name

)

std::string mesos::internal::tests::getTestScriptPath

(

const std::string &

name

)

std::string mesos::internal::tests::getWebUIDir

(

)

Try<Nothing> mesos::internal::tests::initModules

(

const Option< Modules > &

modules

)

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	,
		""
	)

template<typename T >

bool mesos::internal::tests::metricEquals	(	const std::string &	metric,
		const T &	value
	)

JSON::Object mesos::internal::tests::Metrics

(

)

process::Future<Nothing> mesos::internal::tests::pullDockerImage ( const std::string &  imageName )

inline

void mesos::internal::tests::removeDockerIPv6UserNetwork ( )

inline

Variable Documentation

constexpr char mesos::internal::tests::DEFAULT_JWT_SECRET_KEY[]

Initial value:

=
  "72kUKUFtghAjNbIOvLzfF2RxNBfeM64Bri8g9WhpyaunwqRB/yozHAqSnyHbddAV"
  "PcWRQlrJAt871oWgSH+n52vMZ3aVI+AFMzXSo8+sUfMk83IGp0WJefhzeQsjDlGH"
  "GYQgCAuGim0BE2X5U+lEue8s697uQpAO8L/FFRuDH2s"

constexpr char mesos::internal::tests::DEFAULT_TEST_ROLE[] = "default-role"

constexpr char mesos::internal::tests::DOCKER_IPv6_NETWORK[] = "mesos-docker-ip6-test"

Environment* mesos::internal::tests::environment

Flags mesos::internal::tests::flags

constexpr char mesos::internal::tests::READONLY_HTTP_AUTHENTICATION_REALM[] = "test-readonly-realm"

constexpr char mesos::internal::tests::READWRITE_HTTP_AUTHENTICATION_REALM[] = "test-readwrite-realm"