mesos::internal::slave Namespace Reference

Namespaces
	appc
	cni
	compatibility
	containerizer
	csi
	docker
	paths
	provisioner
	state
	validation
	volume

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	CSIServer
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
class	HugetlbSubsystemProcess
	Represent cgroups hugetlb subsystem. More...
struct	ImageInfo
class	IOSwitchboard
class	IOSwitchboardServer
class	IsolatorTracker
class	Launcher
class	LauncherTracker
class	LinuxCapabilitiesIsolatorProcess
class	LinuxDevicesIsolatorProcess
class	LinuxFilesystemIsolatorProcess
class	LinuxLauncher
class	LinuxNNPIsolatorProcess
class	LinuxSeccompIsolatorProcess
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	VolumeCSIIsolatorProcess
class	VolumeGidManager
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::PortRange >	getPortRanges (const IntervalSet< uint16_t > &ports)
bool	operator== (const CSIVolume &left, const CSIVolume &right)
Try< int >	calculateOOMScoreAdj (const Bytes &memRequest)
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	DEFAULT_EXECUTOR_HEARTBEAT_INTERVAL = Minutes(30)
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	DEFAULT_AUTHENTICATION_BACKOFF_FACTOR = Seconds(1)
constexpr Duration	DEFAULT_AUTHENTICATION_TIMEOUT_MIN = Seconds(5)
constexpr Duration	DEFAULT_AUTHENTICATION_TIMEOUT_MAX = Minutes(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 char	AGENT_EXECUTORS_SOCKET_FILENAME [] = "agent.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	MESOS_EXECUTOR [] = "mesos-executor"
constexpr char	COMPONENT_NAME_CONTAINERIZER [] = "containerizer"
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"
constexpr char	CGROUP_SEPARATOR [] = "mesos"
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

(

)

Try<int> mesos::internal::slave::calculateOOMScoreAdj

(

const Bytes &

memRequest

)

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

executorInfo	ExecutorInfo being launched.
directory	Path to the sandbox directory.
slaveId	SlaveID where this executor is being launched.
slavePid	PID of the slave launching the executor.
checkpoint	Whether or not the framework is checkpointing.
flags	Flags 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 CSIVolume &  left, const CSIVolume &  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_EXECUTORS_SOCKET_FILENAME[] = "agent.sock"

constexpr char mesos::internal::slave::AGENT_LOG_VIRTUAL_PATH[] = "/slave/log"

constexpr char mesos::internal::slave::AUFS_BACKEND[] = "aufs"

constexpr char mesos::internal::slave::BIND_BACKEND[] = "bind"

constexpr char mesos::internal::slave::CGROUP_SEPARATOR[] = "mesos"

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::COMPONENT_NAME_CONTAINERIZER[] = "containerizer"

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 Duration mesos::internal::slave::DEFAULT_AUTHENTICATION_TIMEOUT_MAX = Minutes(1)

constexpr Duration mesos::internal::slave::DEFAULT_AUTHENTICATION_TIMEOUT_MIN = Seconds(5)

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 Duration mesos::internal::slave::DEFAULT_EXECUTOR_HEARTBEAT_INTERVAL = Minutes(30)

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"

constexpr char mesos::internal::slave::MESOS_EXECUTOR[] = "mesos-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)