Apache Mesos
Namespaces | Classes | Enumerations | Functions | Variables
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  ParamExecutorType
 
class  Rootfs
 
class  SetnsTestHelper
 
class  TestAllocator
 
class  TestContainerizer
 
class  TestDiskProfileServer
 
class  TestDiskProfileServerProcess
 
class  TestingMesosSchedulerDriver
 
class  TestLauncher
 
class  TestStore
 
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::AllocatorcreateAllocator ()
 
process::Future< NothingpullDockerImage (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 >
_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,"")
 
 MATCHER_P (AuthorizationRequestHasTaskID, taskId,"")
 
 MATCHER_P (OptionTaskHasTaskID, taskId,"")
 
 MATCHER_P (OptionTaskGroupHasTaskID, taskId,"")
 
Try< NothinginitModules (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::NetworkgetNonLoopbackIP ()
 
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"
 
Environmentenvironment
 
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

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 
)
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)
::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,
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,
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,
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  ,
""   
)
mesos::internal::tests::MATCHER_P ( AuthorizationRequestHasTaskID  ,
taskId  ,
""   
)
mesos::internal::tests::MATCHER_P ( OptionTaskHasTaskID  ,
taskId  ,
""   
)
mesos::internal::tests::MATCHER_P ( OptionTaskGroupHasTaskID  ,
taskId  ,
""   
)
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"