mesos::internal::tests Namespace Reference

Namespaces
	cluster
	common
	executor
	internal
	resource_provider
	scheduler
	v1

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

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

Functions
	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 (InvokeRecoverResources, allocator)
	ACTION_P2 (InvokeRecoverResourcesWithFilters, allocator, timeout)
	ACTION_P (InvokeSuppressOffers, allocator)
	ACTION_P (InvokeReviveOffers, allocator)
	ACTION_P (InvokeSetQuota, allocator)
	ACTION_P (InvokeRemoveQuota, allocator)
	ACTION_P (InvokeUpdateWeights, allocator)
template<typename T = master::allocator::HierarchicalDRFAllocator>
mesos::allocator::Allocator *	createAllocator ()
mesos::Environment	createEnvironment (const hashmap< std::string, std::string > &map)
void	createDockerIPv6UserNetwork ()
void	removeDockerIPv6UserNetwork ()
	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, taskInfo,"")
	MATCHER_P (TaskStatusStateEq, taskState,"")
	MATCHER_P (TaskStatusUpdateTaskIdEq, taskInfo,"")
	MATCHER_P (TaskStatusUpdateStateEq, taskState,"")
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 ()
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
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 []
constexpr char	DOCKER_IPv6_NETWORK [] = "mesos-docker-ip6-test"

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	(	InvokeRecoverResources	,
		allocator
	)

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

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

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

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

mesos::internal::tests::ACTION_P	(	InvokeUpdateWeights	,
		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
	)

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

)

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

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

mesos::internal::tests::MATCHER_P	(	TaskStatusStateEq	,
		taskState	,
		""
	)

mesos::internal::tests::MATCHER_P	(	TaskStatusUpdateTaskIdEq	,
		taskInfo	,
		""
	)

mesos::internal::tests::MATCHER_P	(	TaskStatusUpdateStateEq	,
		taskState	,
		""
	)

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

(

)

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"