Apache Mesos
Namespaces | Classes | Functions | Variables
mesos::internal::slave Namespace Reference

Namespaces

 appc
 
 cni
 
 compatibility
 
 containerizer
 
 docker
 
 paths
 
 provisioner
 
 state
 
 validation
 

Classes

class  AppcRuntimeIsolatorProcess
 
class  AufsBackend
 
class  Backend
 
class  BindBackend
 
class  BlkioSubsystemProcess
 Represent cgroups blkio subsystem. More...
 
class  CgroupsIsolatorProcess
 
class  ComposingContainerizer
 
class  ContainerDaemon
 
class  ContainerDaemonProcess
 
class  Containerizer
 
class  CopyBackend
 
class  CpuacctSubsystemProcess
 Represent cgroups cpuacct subsystem. More...
 
class  CpusetSubsystemProcess
 Represent cgroups cpuset subsystem. More...
 
class  CpuSubsystemProcess
 Represent cgroups cpu subsystem. More...
 
class  DevicesSubsystemProcess
 Represent cgroups devices subsystem. More...
 
class  DiskUsageCollector
 
class  DockerContainerizer
 
class  DockerContainerizerProcess
 
class  DockerRuntimeIsolatorProcess
 
class  DockerVolumeIsolatorProcess
 
class  EnvironmentSecretIsolatorProcess
 
class  EphemeralPortsAllocator
 
class  Executor
 
class  Fetcher
 
class  FetcherProcess
 
class  Flags
 
class  Framework
 
class  GarbageCollector
 
class  GarbageCollectorProcess
 
struct  Gpu
 
class  Http
 
struct  HttpConnection
 
class  HugetlbSubsystemProcess
 Represent cgroups hugetlb subsystem. More...
 
struct  ImageInfo
 
class  IOSwitchboard
 
class  IOSwitchboardServer
 
class  Launcher
 
class  LinuxCapabilitiesIsolatorProcess
 
class  LinuxDevicesIsolatorProcess
 
class  LinuxFilesystemIsolatorProcess
 
class  LinuxLauncher
 
class  LoadQoSController
 
class  MemorySubsystemProcess
 Represent cgroups memory subsystem. More...
 
class  MesosContainerizer
 
class  MesosContainerizerLaunch
 
class  MesosContainerizerMount
 
class  MesosContainerizerProcess
 
class  MesosIsolator
 
class  MesosIsolatorProcess
 
struct  Metrics
 
class  NamespacesIPCIsolatorProcess
 
class  NamespacesPidIsolatorProcess
 
struct  NetClsHandle
 
class  NetClsHandleManager
 
class  NetClsSubsystemProcess
 Represent cgroups net_cls subsystem. More...
 
class  NetPrioSubsystemProcess
 Represent cgroups net_prio subsystem. More...
 
class  NetworkCniIsolatorProcess
 
class  NetworkCniIsolatorSetup
 
class  NetworkPortsIsolatorProcess
 
class  NoopQoSController
 
class  NoopResourceEstimator
 
struct  NvidiaComponents
 
class  NvidiaGpuAllocator
 
class  NvidiaGpuIsolatorProcess
 
class  NvidiaVolume
 
class  OverlayBackend
 
class  PerfEventSubsystemProcess
 Represent cgroups perf_event subsystem. More...
 
class  PidsSubsystemProcess
 Represent cgroups pids subsystem. More...
 
class  PortMappingIsolatorProcess
 
class  PortMappingStatistics
 
class  PortMappingUpdate
 
class  PosixCpuIsolatorProcess
 
class  PosixDiskIsolatorProcess
 
class  PosixFilesystemIsolatorProcess
 
class  PosixIsolatorProcess
 
class  PosixMemIsolatorProcess
 
class  PosixRLimitsIsolatorProcess
 
class  Provisioner
 
class  ProvisionerProcess
 
struct  ProvisionInfo
 
struct  ResourceProvider
 
class  SandboxContainerLogger
 
class  SharedFilesystemIsolatorProcess
 
class  Slave
 
class  Store
 
class  SubprocessLauncher
 
class  Subsystem
 An abstraction for cgroups subsystem. More...
 
class  SubsystemProcess
 
class  TaskStatusUpdateManager
 
struct  TaskStatusUpdateStream
 
class  VolumeHostPathIsolatorProcess
 
class  VolumeImageIsolatorProcess
 
class  VolumeSandboxPathIsolatorProcess
 
class  VolumeSecretIsolatorProcess
 
class  WindowsCpuIsolatorProcess
 
class  WindowsFilesystemIsolatorProcess
 
class  WindowsMemIsolatorProcess
 
class  XfsDiskIsolatorProcess
 

Functions

Duration DEFAULT_MASTER_PING_TIMEOUT ()
 
std::vector< SlaveInfo::Capability > AGENT_CAPABILITIES ()
 
std::ostream & operator<< (std::ostream &stream, const MesosContainerizerProcess::State &state)
 
std::ostream & operator<< (std::ostream &stream, const NetClsHandle &obj)
 
bool operator== (const DockerVolume &left, const DockerVolume &right)
 
bool operator< (const Gpu &left, const Gpu &right)
 
bool operator> (const Gpu &left, const Gpu &right)
 
bool operator<= (const Gpu &left, const Gpu &right)
 
bool operator>= (const Gpu &left, const Gpu &right)
 
bool operator== (const Gpu &left, const Gpu &right)
 
bool operator!= (const Gpu &left, const Gpu &right)
 
std::ostream & operator<< (std::ostream &stream, const Gpu &gpu)
 
std::string PORT_MAPPING_VETH_PREFIX ()
 
std::string PORT_MAPPING_BIND_MOUNT_ROOT ()
 
std::string PORT_MAPPING_BIND_MOUNT_SYMLINK_ROOT ()
 
std::vector< routing::filter::ip::PortRangegetPortRanges (const IntervalSet< uint16_t > &ports)
 
std::ostream & operator<< (std::ostream &stream, const Executor &executor)
 
std::map< std::string, std::string > executorEnvironment (const Flags &flags, const ExecutorInfo &executorInfo, const std::string &directory, const SlaveID &slaveId, const process::PID< Slave > &slavePid, const Option< Secret > &authenticationToken, bool checkpoint)
 Returns a map of environment variables necessary in order to launch an executor. More...
 
std::ostream & operator<< (std::ostream &stream, Executor::State state)
 
std::ostream & operator<< (std::ostream &stream, Framework::State state)
 
std::ostream & operator<< (std::ostream &stream, Slave::State state)
 

Variables

constexpr Duration EXECUTOR_REGISTRATION_TIMEOUT = Minutes(1)
 
constexpr Duration EXECUTOR_REREGISTRATION_TIMEOUT = Seconds(2)
 
constexpr Duration MAX_EXECUTOR_REREGISTRATION_TIMEOUT = Seconds(15)
 
constexpr Duration DEFAULT_EXECUTOR_SHUTDOWN_GRACE_PERIOD = Seconds(5)
 
constexpr Duration RECOVERY_TIMEOUT = Minutes(15)
 
constexpr Duration STATUS_UPDATE_RETRY_INTERVAL_MIN = Seconds(10)
 
constexpr Duration STATUS_UPDATE_RETRY_INTERVAL_MAX = Minutes(10)
 
constexpr Duration DEFAULT_REGISTRATION_BACKOFF_FACTOR = Seconds(1)
 
constexpr Duration REGISTER_RETRY_INTERVAL_MAX = Minutes(1)
 
constexpr Duration AUTHENTICATION_RETRY_INTERVAL_MAX = Minutes(1)
 
constexpr Duration DEFAULT_AUTHENTICATION_BACKOFF_FACTOR = Seconds(1)
 
constexpr Duration GC_DELAY = Weeks(1)
 
constexpr Duration DISK_WATCH_INTERVAL = Minutes(1)
 
constexpr double GC_DISK_HEADROOM = 0.1
 
constexpr size_t MAX_COMPLETED_FRAMEWORKS = 50
 
constexpr size_t DEFAULT_MAX_COMPLETED_EXECUTORS_PER_FRAMEWORK = 150
 
constexpr size_t MAX_CONTAINER_ID_LENGTH = 242
 
constexpr size_t MAX_COMPLETED_TASKS_PER_EXECUTOR = 200
 
constexpr double DEFAULT_CPUS = 1
 
constexpr Bytes DEFAULT_MEM = Gigabytes(1)
 
constexpr Bytes DEFAULT_DISK = Gigabytes(10)
 
constexpr char DEFAULT_PORTS [] = "[31000-32000]"
 
constexpr double DEFAULT_EXECUTOR_CPUS = 0.1
 
constexpr Bytes DEFAULT_EXECUTOR_MEM = Megabytes(32)
 
constexpr char DEFAULT_DOCKER_HOST_RESOURCE [] = "/var/run/docker.sock"
 
constexpr Duration DOCKER_REMOVE_DELAY = Hours(6)
 
constexpr Duration DOCKER_INSPECT_DELAY = Seconds(1)
 
constexpr Duration DOCKER_INSPECT_TIMEOUT = Seconds(5)
 
constexpr size_t DOCKER_PS_MAX_INSPECT_CALLS = 100
 
constexpr Duration DOCKER_VERSION_WAIT_TIMEOUT = Seconds(5)
 
constexpr Duration DOCKER_FORCE_KILL_TIMEOUT = Seconds(1)
 
constexpr char DEFAULT_AUTHENTICATEE [] = "crammd5"
 
constexpr char DEFAULT_AUTHORIZER [] = "local"
 
constexpr char READONLY_HTTP_AUTHENTICATION_REALM [] = "mesos-agent-readonly"
 
constexpr char READWRITE_HTTP_AUTHENTICATION_REALM [] = "mesos-agent-readwrite"
 
constexpr char EXECUTOR_HTTP_AUTHENTICATION_REALM [] = "mesos-agent-executor"
 
constexpr char RESOURCE_PROVIDER_HTTP_AUTHENTICATION_REALM []
 
constexpr Bytes DEFAULT_FETCHER_CACHE_SIZE = Gigabytes(2)
 
constexpr Duration DEFAULT_FETCHER_STALL_TIMEOUT = Minutes(1)
 
constexpr char MESOS_DEFAULT_EXECUTOR [] = "mesos-default-executor"
 
constexpr char AGENT_LOG_VIRTUAL_PATH [] = "/slave/log"
 
const std::string DOCKER_NAME_PREFIX
 
const std::string DOCKER_NAME_SEPERATOR
 
const std::string DOCKER_SYMLINK_DIRECTORY
 
constexpr char MESOS_CONTAINERIZER [] = "mesos-containerizer"
 
const uint64_t CPU_SHARES_PER_CPU = 1024
 
const uint64_t CPU_SHARES_PER_CPU_REVOCABLE = 10
 
const uint64_t MIN_CPU_SHARES = 2
 
const Duration CPU_CFS_PERIOD = Milliseconds(100)
 
const Duration MIN_CPU_CFS_QUOTA = Milliseconds(1)
 
const Bytes MIN_MEMORY = Megabytes(32)
 
const std::string CGROUP_SUBSYSTEM_BLKIO_NAME = "blkio"
 
const std::string CGROUP_SUBSYSTEM_CPU_NAME = "cpu"
 
const std::string CGROUP_SUBSYSTEM_CPUACCT_NAME = "cpuacct"
 
const std::string CGROUP_SUBSYSTEM_CPUSET_NAME = "cpuset"
 
const std::string CGROUP_SUBSYSTEM_DEVICES_NAME = "devices"
 
const std::string CGROUP_SUBSYSTEM_HUGETLB_NAME = "hugetlb"
 
const std::string CGROUP_SUBSYSTEM_MEMORY_NAME = "memory"
 
const std::string CGROUP_SUBSYSTEM_NET_CLS_NAME = "net_cls"
 
const std::string CGROUP_SUBSYSTEM_NET_PRIO_NAME = "net_prio"
 
const std::string CGROUP_SUBSYSTEM_PERF_EVENT_NAME = "perf_event"
 
const std::string CGROUP_SUBSYSTEM_PIDS_NAME = "pids"
 
constexpr char NET_ISOLATOR_BW_LIMIT [] = "bw_limit"
 
constexpr char NET_ISOLATOR_BLOAT_REDUCTION [] = "bloat_reduction"
 
constexpr char AUFS_BACKEND [] = "aufs"
 
constexpr char BIND_BACKEND [] = "bind"
 
constexpr char COPY_BACKEND [] = "copy"
 
constexpr char OVERLAY_BACKEND [] = "overlay"
 

Function Documentation

std::vector<SlaveInfo::Capability> mesos::internal::slave::AGENT_CAPABILITIES ( )
Duration mesos::internal::slave::DEFAULT_MASTER_PING_TIMEOUT ( )
std::map<std::string, std::string> mesos::internal::slave::executorEnvironment ( const Flags flags,
const ExecutorInfo &  executorInfo,
const std::string &  directory,
const SlaveID &  slaveId,
const process::PID< Slave > &  slavePid,
const Option< Secret > &  authenticationToken,
bool  checkpoint 
)

Returns a map of environment variables necessary in order to launch an executor.

Parameters
executorInfoExecutorInfo being launched.
directoryPath to the sandbox directory.
slaveIdSlaveID where this executor is being launched.
slavePidPID of the slave launching the executor.
checkpointWhether or not the framework is checkpointing.
flagsFlags used to launch the slave.
Returns
Map of environment variables (name, value).
std::vector<routing::filter::ip::PortRange> mesos::internal::slave::getPortRanges ( const IntervalSet< uint16_t > &  ports)
bool mesos::internal::slave::operator!= ( const Gpu left,
const Gpu right 
)
bool mesos::internal::slave::operator< ( const Gpu left,
const Gpu right 
)
std::ostream& mesos::internal::slave::operator<< ( std::ostream &  stream,
const NetClsHandle obj 
)
std::ostream& mesos::internal::slave::operator<< ( std::ostream &  stream,
const Gpu gpu 
)
std::ostream& mesos::internal::slave::operator<< ( std::ostream &  stream,
const MesosContainerizerProcess::State &  state 
)
std::ostream& mesos::internal::slave::operator<< ( std::ostream &  stream,
const Executor executor 
)
std::ostream& mesos::internal::slave::operator<< ( std::ostream &  stream,
Executor::State  state 
)
std::ostream& mesos::internal::slave::operator<< ( std::ostream &  stream,
Framework::State  state 
)
std::ostream& mesos::internal::slave::operator<< ( std::ostream &  stream,
Slave::State  state 
)
bool mesos::internal::slave::operator<= ( const Gpu left,
const Gpu right 
)
bool mesos::internal::slave::operator== ( const DockerVolume &  left,
const DockerVolume &  right 
)
inline
bool mesos::internal::slave::operator== ( const Gpu left,
const Gpu right 
)
bool mesos::internal::slave::operator> ( const Gpu left,
const Gpu right 
)
bool mesos::internal::slave::operator>= ( const Gpu left,
const Gpu right 
)
std::string mesos::internal::slave::PORT_MAPPING_BIND_MOUNT_ROOT ( )
inline
std::string mesos::internal::slave::PORT_MAPPING_BIND_MOUNT_SYMLINK_ROOT ( )
inline
std::string mesos::internal::slave::PORT_MAPPING_VETH_PREFIX ( )
inline

Variable Documentation

constexpr char mesos::internal::slave::AGENT_LOG_VIRTUAL_PATH[] = "/slave/log"
constexpr char mesos::internal::slave::AUFS_BACKEND[] = "aufs"
constexpr Duration mesos::internal::slave::AUTHENTICATION_RETRY_INTERVAL_MAX = Minutes(1)
constexpr char mesos::internal::slave::BIND_BACKEND[] = "bind"
const std::string mesos::internal::slave::CGROUP_SUBSYSTEM_BLKIO_NAME = "blkio"
const std::string mesos::internal::slave::CGROUP_SUBSYSTEM_CPU_NAME = "cpu"
const std::string mesos::internal::slave::CGROUP_SUBSYSTEM_CPUACCT_NAME = "cpuacct"
const std::string mesos::internal::slave::CGROUP_SUBSYSTEM_CPUSET_NAME = "cpuset"
const std::string mesos::internal::slave::CGROUP_SUBSYSTEM_DEVICES_NAME = "devices"
const std::string mesos::internal::slave::CGROUP_SUBSYSTEM_HUGETLB_NAME = "hugetlb"
const std::string mesos::internal::slave::CGROUP_SUBSYSTEM_MEMORY_NAME = "memory"
const std::string mesos::internal::slave::CGROUP_SUBSYSTEM_NET_CLS_NAME = "net_cls"
const std::string mesos::internal::slave::CGROUP_SUBSYSTEM_NET_PRIO_NAME = "net_prio"
const std::string mesos::internal::slave::CGROUP_SUBSYSTEM_PERF_EVENT_NAME = "perf_event"
const std::string mesos::internal::slave::CGROUP_SUBSYSTEM_PIDS_NAME = "pids"
constexpr char mesos::internal::slave::COPY_BACKEND[] = "copy"
const Duration mesos::internal::slave::CPU_CFS_PERIOD = Milliseconds(100)
const uint64_t mesos::internal::slave::CPU_SHARES_PER_CPU = 1024
const uint64_t mesos::internal::slave::CPU_SHARES_PER_CPU_REVOCABLE = 10
constexpr char mesos::internal::slave::DEFAULT_AUTHENTICATEE[] = "crammd5"
constexpr Duration mesos::internal::slave::DEFAULT_AUTHENTICATION_BACKOFF_FACTOR = Seconds(1)
constexpr char mesos::internal::slave::DEFAULT_AUTHORIZER[] = "local"
constexpr double mesos::internal::slave::DEFAULT_CPUS = 1
constexpr Bytes mesos::internal::slave::DEFAULT_DISK = Gigabytes(10)
constexpr char mesos::internal::slave::DEFAULT_DOCKER_HOST_RESOURCE[] = "/var/run/docker.sock"
constexpr double mesos::internal::slave::DEFAULT_EXECUTOR_CPUS = 0.1
constexpr Bytes mesos::internal::slave::DEFAULT_EXECUTOR_MEM = Megabytes(32)
constexpr Duration mesos::internal::slave::DEFAULT_EXECUTOR_SHUTDOWN_GRACE_PERIOD = Seconds(5)
constexpr Bytes mesos::internal::slave::DEFAULT_FETCHER_CACHE_SIZE = Gigabytes(2)
constexpr Duration mesos::internal::slave::DEFAULT_FETCHER_STALL_TIMEOUT = Minutes(1)
constexpr size_t mesos::internal::slave::DEFAULT_MAX_COMPLETED_EXECUTORS_PER_FRAMEWORK = 150
constexpr Bytes mesos::internal::slave::DEFAULT_MEM = Gigabytes(1)
constexpr char mesos::internal::slave::DEFAULT_PORTS[] = "[31000-32000]"
constexpr Duration mesos::internal::slave::DEFAULT_REGISTRATION_BACKOFF_FACTOR = Seconds(1)
constexpr Duration mesos::internal::slave::DISK_WATCH_INTERVAL = Minutes(1)
constexpr Duration mesos::internal::slave::DOCKER_FORCE_KILL_TIMEOUT = Seconds(1)
constexpr Duration mesos::internal::slave::DOCKER_INSPECT_DELAY = Seconds(1)
constexpr Duration mesos::internal::slave::DOCKER_INSPECT_TIMEOUT = Seconds(5)
const std::string mesos::internal::slave::DOCKER_NAME_PREFIX
const std::string mesos::internal::slave::DOCKER_NAME_SEPERATOR
constexpr size_t mesos::internal::slave::DOCKER_PS_MAX_INSPECT_CALLS = 100
constexpr Duration mesos::internal::slave::DOCKER_REMOVE_DELAY = Hours(6)
const std::string mesos::internal::slave::DOCKER_SYMLINK_DIRECTORY
constexpr Duration mesos::internal::slave::DOCKER_VERSION_WAIT_TIMEOUT = Seconds(5)
constexpr char mesos::internal::slave::EXECUTOR_HTTP_AUTHENTICATION_REALM[] = "mesos-agent-executor"
constexpr Duration mesos::internal::slave::EXECUTOR_REGISTRATION_TIMEOUT = Minutes(1)
constexpr Duration mesos::internal::slave::EXECUTOR_REREGISTRATION_TIMEOUT = Seconds(2)
constexpr Duration mesos::internal::slave::GC_DELAY = Weeks(1)
constexpr double mesos::internal::slave::GC_DISK_HEADROOM = 0.1
constexpr size_t mesos::internal::slave::MAX_COMPLETED_FRAMEWORKS = 50
constexpr size_t mesos::internal::slave::MAX_COMPLETED_TASKS_PER_EXECUTOR = 200
constexpr size_t mesos::internal::slave::MAX_CONTAINER_ID_LENGTH = 242
constexpr Duration mesos::internal::slave::MAX_EXECUTOR_REREGISTRATION_TIMEOUT = Seconds(15)
constexpr char mesos::internal::slave::MESOS_CONTAINERIZER[] = "mesos-containerizer"
constexpr char mesos::internal::slave::MESOS_DEFAULT_EXECUTOR[] = "mesos-default-executor"
const Duration mesos::internal::slave::MIN_CPU_CFS_QUOTA = Milliseconds(1)
const uint64_t mesos::internal::slave::MIN_CPU_SHARES = 2
const Bytes mesos::internal::slave::MIN_MEMORY = Megabytes(32)
constexpr char mesos::internal::slave::NET_ISOLATOR_BLOAT_REDUCTION[] = "bloat_reduction"
constexpr char mesos::internal::slave::NET_ISOLATOR_BW_LIMIT[] = "bw_limit"
constexpr char mesos::internal::slave::OVERLAY_BACKEND[] = "overlay"
constexpr char mesos::internal::slave::READONLY_HTTP_AUTHENTICATION_REALM[] = "mesos-agent-readonly"
constexpr char mesos::internal::slave::READWRITE_HTTP_AUTHENTICATION_REALM[] = "mesos-agent-readwrite"
constexpr Duration mesos::internal::slave::RECOVERY_TIMEOUT = Minutes(15)
constexpr Duration mesos::internal::slave::REGISTER_RETRY_INTERVAL_MAX = Minutes(1)
constexpr char mesos::internal::slave::RESOURCE_PROVIDER_HTTP_AUTHENTICATION_REALM[]
Initial value:
=
"mesos-agent-resource-provider"
constexpr Duration mesos::internal::slave::STATUS_UPDATE_RETRY_INTERVAL_MAX = Minutes(10)
constexpr Duration mesos::internal::slave::STATUS_UPDATE_RETRY_INTERVAL_MIN = Seconds(10)