Apache Mesos
mesos::internal::master::Master Member List

This is the complete list of members for mesos::internal::master::Master, including all inherited members.

___reregisterSlave(const process::UPID &pid, ReregisterSlaveMessage &&incomingMessage, const process::Future< bool > &updated)mesos::internal::master::Masterprotected
__registerSlave(const process::UPID &pid, RegisterSlaveMessage &&registerSlaveMessage, const process::Future< bool > &admit)mesos::internal::master::Masterprotected
__removeSlave(Slave *slave, const std::string &message, const Option< TimeInfo > &unreachableTime)mesos::internal::master::Masterprotected
__reregisterSlave(const process::UPID &pid, ReregisterSlaveMessage &&incomingMessage, const process::Future< bool > &readmit)mesos::internal::master::Masterprotected
_agentReregisterTimeout(const SlaveID &slaveId)mesos::internal::master::Masterprotected
_authenticate(const process::UPID &pid, const process::Future< Option< std::string >> &future)mesos::internal::master::Masterprotected
_consume(process::MessageEvent &&event)mesos::internal::master::Masterprotected
_consume(process::ExitedEvent &&event)mesos::internal::master::Masterprotected
_exited(Framework *framework)mesos::internal::master::Masterprotected
_failoverFramework(Framework *framework)mesos::internal::master::Masterprotected
_markUnreachable(const SlaveInfo &slave, const TimeInfo &unreachableTime, bool duringMasterFailover, const std::string &message, bool registrarResult)mesos::internal::master::Masterprotected
_recover(const Registry &registry)mesos::internal::master::Master
_registerSlave(const process::UPID &pid, RegisterSlaveMessage &&registerSlaveMessage, const Option< process::http::authentication::Principal > &principal, const process::Future< bool > &authorized)mesos::internal::master::Masterprotected
_removeOffer(Framework *framework, Offer *offer)mesos::internal::master::Masterprotected
_removeSlave(Slave *slave, const process::Future< bool > &registrarResult, const std::string &removalCause, Option< process::metrics::Counter > reason=None())mesos::internal::master::Masterprotected
_reregisterSlave(const process::UPID &pid, ReregisterSlaveMessage &&incomingMessage, const Option< process::http::authentication::Principal > &principal, const process::Future< bool > &authorized)mesos::internal::master::Masterprotected
addExecutor(const ExecutorInfo &executorInfo, Framework *framework, Slave *slave)mesos::internal::master::Masterprotected
addFramework(Framework *framework,::mesos::allocator::FrameworkOptions &&allocatorOptions)mesos::internal::master::Masterprotected
addOperation(Framework *framework, Slave *slave, Operation *operation)mesos::internal::master::Masterprotected
addSlave(Slave *slave, std::vector< Archive::Framework > &&completedFrameworks)mesos::internal::master::Masterprotected
addTask(const TaskInfo &task, Framework *framework, Slave *slave)mesos::internal::master::Masterprotected
agentReregisterTimeout(const SlaveID &slaveId)mesos::internal::master::Masterprotected
apply(Slave *slave, const Offer::Operation &operation)mesos::internal::master::Masterprotected
authenticate(const process::UPID &from, const process::UPID &pid)mesos::internal::master::Master
AuthenticatedHttpRequestHandler typedefprocess::ProcessBaseprotected
authenticationTimeout(process::Future< Option< std::string >> future)mesos::internal::master::Masterprotected
authorize(const Option< process::http::authentication::Principal > &principal, authorization::ActionObject &&actionObject)mesos::internal::master::Masterprotected
authorize(const Option< process::http::authentication::Principal > &principal, std::vector< authorization::ActionObject > &&actionObjects)mesos::internal::master::Masterprotected
connectAndActivateRecoveredFramework(Framework *framework, const Option< process::UPID > &pid, const Option< StreamingHttpConnection< v1::scheduler::Event >> &http, const process::Owned< ObjectApprovers > &objectApprovers)mesos::internal::master::Masterprotected
consume(process::MessageEvent &&event) overridemesos::internal::master::Masterprotectedvirtual
consume(process::ExitedEvent &&event) overridemesos::internal::master::Masterprotectedvirtual
Process< Master >::consume(DispatchEvent &&event) overrideprocess::ProcessBaseprotectedvirtual
Process< Master >::consume(HttpEvent &&event) overrideprocess::ProcessBaseprotectedvirtual
Process< Master >::consume(TerminateEvent &&event) overrideprocess::ProcessBaseprotectedvirtual
contended(const process::Future< process::Future< Nothing >> &candidacy)mesos::internal::master::Masterprotected
deactivate(Framework *framework, bool rescind)mesos::internal::master::Masterprotected
deactivate(Slave *slave)mesos::internal::master::Masterprotected
deactivateFramework(const process::UPID &from, const FrameworkID &frameworkId)mesos::internal::master::Master
delegate(const std::string &name, const UPID &pid)process::ProcessBaseinlineprotected
detected(const process::Future< Option< MasterInfo >> &_leader)mesos::internal::master::Master
discardOffer(Offer *offer, const Option< Filters > &filters=None())mesos::internal::master::Masterprotected
disconnect(Framework *framework)mesos::internal::master::Masterprotected
disconnect(Slave *slave)mesos::internal::master::Masterprotected
eventCount()process::ProcessBaseprotected
exceededCapacity(const process::MessageEvent &event, const Option< std::string > &principal, uint64_t capacity)mesos::internal::master::Masterprotected
executorMessage(const process::UPID &from, ExecutorToFrameworkMessage &&executorToFrameworkMessage)mesos::internal::master::Master
exited(const process::UPID &pid) overridemesos::internal::master::Masterprotectedvirtual
exited(const FrameworkID &frameworkId, const StreamingHttpConnection< v1::scheduler::Event > &http)mesos::internal::master::Masterprotected
exited(const id::UUID &id)mesos::internal::master::Masterprotected
exitedExecutor(const process::UPID &from, const SlaveID &slaveId, const FrameworkID &frameworkId, const ExecutorID &executorId, int32_t status)mesos::internal::master::Master
failoverFramework(Framework *framework, const process::UPID &newPid, const process::Owned< ObjectApprovers > &objectApprovers)mesos::internal::master::Masterprotected
failoverFramework(Framework *framework, const StreamingHttpConnection< v1::scheduler::Event > &http, const process::Owned< ObjectApprovers > &objectApprovers)mesos::internal::master::Masterprotected
fileAttached(const process::Future< Nothing > &result, const std::string &path)mesos::internal::master::Masterprotected
finalize() overridemesos::internal::master::Masterprotectedvirtual
forward(const StatusUpdate &update, const process::UPID &acknowledgee, Framework *framework)mesos::internal::master::Masterprotected
Frameworkmesos::internal::master::Masterfriend
frameworkFailoverTimeout(const FrameworkID &frameworkId, const process::Time &reregisteredTime)mesos::internal::master::Master
FrameworkMetricsmesos::internal::master::Masterfriend
getFramework(const FrameworkID &frameworkId) const mesos::internal::master::Masterprotected
getInverseOffer(const OfferID &inverseOfferId) const mesos::internal::master::Masterprotected
getOffer(const OfferID &offerId) const mesos::internal::master::Masterprotected
HttpRequestHandler typedefprocess::ProcessBaseprotected
httpSequenceprocess::ProcessBase
info() const mesos::internal::master::Masterinline
initialize() overridemesos::internal::master::Masterprotectedvirtual
install(void(Master::*method)(const process::UPID &, const M &))ProtobufProcess< Master >inlineprotected
install(void(Master::*method)(const process::UPID &, M &&))ProtobufProcess< Master >inlineprotected
install(void(Master::*method)(const process::UPID &))ProtobufProcess< Master >inlineprotected
install(void(Master::*method)(const process::UPID &, PC...), MessageProperty< M, P >...param)ProtobufProcess< Master >inlineprotected
install(void(Master::*method)(const M &))ProtobufProcess< Master >inlineprotected
install(void(Master::*method)(M &&))ProtobufProcess< Master >inlineprotected
install(void(Master::*method)())ProtobufProcess< Master >inlineprotected
install(void(Master::*method)(PC...), MessageProperty< M, P >...param)ProtobufProcess< Master >inlineprotected
Process< Master >::install(const std::string &name, const MessageHandler &handler)process::ProcessBaseinlineprotected
Process< Master >::install(const std::string &name, void(T::*method)(const UPID &, const std::string &))process::ProcessBaseinlineprotected
inverseOffer(const FrameworkID &frameworkId, const hashmap< SlaveID, UnavailableResources > &resources)mesos::internal::master::Master
inverseOfferTimeout(const OfferID &inverseOfferId)mesos::internal::master::Masterprotected
isCompletedFramework(const FrameworkID &frameworkId) const mesos::internal::master::Masterprotected
isLaunchExecutor(const ExecutorID &executorId, Framework *framework, Slave *slave) const mesos::internal::master::Masterprotected
killTask(const process::UPID &from, const FrameworkID &frameworkId, const TaskID &taskId)mesos::internal::master::Master
launchTasks(const process::UPID &from, LaunchTasksMessage &&launchTasksMessage)mesos::internal::master::Master
link(const UPID &pid, const RemoteConnection remote=RemoteConnection::REUSE)process::ProcessBaseprotected
lost(const UPID &)process::ProcessBaseinlineprotectedvirtual
lostCandidacy(const process::Future< Nothing > &lost)mesos::internal::master::Master
markGone(const SlaveID &slaveId, const TimeInfo &goneTime)mesos::internal::master::Master
markUnreachable(const SlaveInfo &slave, bool duringMasterFailover, const std::string &message)mesos::internal::master::Master
Master(mesos::allocator::Allocator *allocator, Registrar *registrar, Files *files, mesos::master::contender::MasterContender *contender, mesos::master::detector::MasterDetector *detector, const Option< Authorizer * > &authorizer, const Option< std::shared_ptr< process::RateLimiter >> &slaveRemovalLimiter, const Flags &flags=Flags())mesos::internal::master::Master
ProtobufProcess< Master >::messageprocess::ProcessBase
MessageHandler typedefprocess::ProcessBaseprotected
MessageProperty typedefProtobufProcess< Master >protected
Metricsmesos::internal::master::Masterfriend
missingMinimumCapabilities(const MasterInfo &masterInfo, const Registry &registry)mesos::internal::master::Masterstatic
newFrameworkId()mesos::internal::master::Masterprotected
newOfferId()mesos::internal::master::Masterprotected
newSlaveId()mesos::internal::master::Masterprotected
offer(const FrameworkID &frameworkId, const hashmap< std::string, hashmap< SlaveID, Resources >> &resources)mesos::internal::master::Master
offerTimeout(const OfferID &offerId)mesos::internal::master::Masterprotected
ProcessBase(const std::string &id="")process::ProcessBaseexplicit
provide(const std::string &name, const std::string &path, const std::map< std::string, std::string > &types=mime::types)process::ProcessBaseinlineprotected
reconcileKnownSlave(Slave *slave, const std::vector< ExecutorInfo > &executors, const std::vector< Task > &tasks)mesos::internal::master::Masterprotected
reconcileTasks(const process::UPID &from, ReconcileTasksMessage &&reconcileTasksMessage)mesos::internal::master::Master
recover()mesos::internal::master::Masterprotected
recoveredSlavesTimeout(const Registry &registry)mesos::internal::master::Masterprotected
recoverFramework(const FrameworkInfo &info)mesos::internal::master::Masterprotected
registerFramework(const process::UPID &from, RegisterFrameworkMessage &&registerFrameworkMessage)mesos::internal::master::Master
registerSlave(const process::UPID &from, RegisterSlaveMessage &&registerSlaveMessage)mesos::internal::master::Master
RemoteConnection enum nameprocess::ProcessBaseprotected
removeExecutor(Slave *slave, const FrameworkID &frameworkId, const ExecutorID &executorId)mesos::internal::master::Masterprotected
removeFramework(Framework *framework)mesos::internal::master::Masterprotected
removeFramework(Slave *slave, Framework *framework)mesos::internal::master::Masterprotected
removeInverseOffer(InverseOffer *inverseOffer, bool rescind=false)mesos::internal::master::Masterprotected
removeOperation(Operation *operation)mesos::internal::master::Masterprotected
removeSlave(Slave *slave, const std::string &message, Option< process::metrics::Counter > reason=None())mesos::internal::master::Masterprotected
removeTask(Task *task, bool unreachable=false)mesos::internal::master::Masterprotected
reply(const google::protobuf::Message &message)ProtobufProcess< Master >inlineprotected
reregisterFramework(const process::UPID &from, ReregisterFrameworkMessage &&reregisterFrameworkMessage)mesos::internal::master::Master
reregisterSlave(const process::UPID &from, ReregisterSlaveMessage &&incomingMessage)mesos::internal::master::Master
rescindOffer(Offer *offer, const Option< Filters > &filters=None())mesos::internal::master::Masterprotected
resourceRequest(const process::UPID &from, const FrameworkID &frameworkId, const std::vector< Request > &requests)mesos::internal::master::Master
reviveOffers(const process::UPID &from, const FrameworkID &frameworkId, const std::vector< std::string > &role)mesos::internal::master::Master
Rolemesos::internal::master::Masterfriend
route(const std::string &name, const Option< std::string > &help, const HttpRequestHandler &handler, const RouteOptions &options=RouteOptions())process::ProcessBaseprotected
route(const std::string &name, const Option< std::string > &help, Future< http::Response >(T::*method)(const http::Request &), const RouteOptions &options=RouteOptions())process::ProcessBaseinlineprotected
route(const std::string &name, const std::string &realm, const Option< std::string > &help, const AuthenticatedHttpRequestHandler &handler, const RouteOptions &options=RouteOptions())process::ProcessBaseprotected
route(const std::string &name, const Option< std::string > &realm, const Option< std::string > &help, Future< http::Response >(T::*method)(const http::Request &, const Option< http::authentication::Principal > &), const RouteOptions &options=RouteOptions())process::ProcessBaseinlineprotected
schedulerMessage(const process::UPID &from, FrameworkToExecutorMessage &&frameworkToExecutorMessage)mesos::internal::master::Master
self() constprocess::Process< Master >inline
Self typedefprocess::Process< Master >protected
send(const process::UPID &to, const google::protobuf::Message &message)ProtobufProcess< Master >inlineprotected
Process< Master >::send(const UPID &to, const std::string &name, const char *data=nullptr, size_t length=0)process::ProcessBaseprotected
Process< Master >::send(const UPID &to, std::string &&name)process::ProcessBaseprotected
Process< Master >::send(const UPID &to, std::string &&name, std::string &&data)process::ProcessBaseprotected
sendBulkOperationFeedback(Slave *slave, OperationState operationState, const std::string &message)mesos::internal::master::Masterprotected
sendFrameworkUpdates(const Framework &framework)mesos::internal::master::Masterprotected
sendSlaveLost(const SlaveInfo &slaveInfo)mesos::internal::master::Masterprotected
serve(Event &&event)process::ProcessBaseinlineprotectedvirtual
Slavemesos::internal::master::Masterfriend
SlavesWritermesos::internal::master::Masterfriend
statusUpdate(StatusUpdateMessage &&statusUpdateMessage)mesos::internal::master::Master
statusUpdateAcknowledgement(const process::UPID &from, StatusUpdateAcknowledgementMessage &&statusUpdateAcknowledgementMessage)mesos::internal::master::Master
submitScheduler(const std::string &name)mesos::internal::master::Master
Subscribermesos::internal::master::Masterfriend
This typedefprocess::Process< Master >protected
throttled(process::MessageEvent &&event, const Option< std::string > &principal)mesos::internal::master::Masterprotected
unregisterFramework(const process::UPID &from, const FrameworkID &frameworkId)mesos::internal::master::Master
unregisterSlave(const process::UPID &from, const SlaveID &slaveId)mesos::internal::master::Master
updateFramework(Framework *framework, const FrameworkInfo &frameworkInfo,::mesos::scheduler::OfferConstraints &&offerConstraints,::mesos::allocator::FrameworkOptions &&allocatorOptions)mesos::internal::master::Masterprotected
updateOperation(Operation *operation, const UpdateOperationStatusMessage &update, bool convertResources=true)mesos::internal::master::Masterprotected
updateOperationStatus(UpdateOperationStatusMessage &&update)mesos::internal::master::Master
updateSlave(UpdateSlaveMessage &&message)mesos::internal::master::Master
updateSlaveFrameworks(Slave *slave, const std::vector< FrameworkInfo > &frameworks)mesos::internal::master::Masterprotected
updateTask(Task *task, const StatusUpdate &update)mesos::internal::master::Masterprotected
updateUnavailability(const MachineID &machineId, const Option< Unavailability > &unavailability)mesos::internal::master::Master
validateFrameworkAuthentication(const FrameworkInfo &frameworkInfo, const process::UPID &from)mesos::internal::master::Masterprotected
validation::offer::getInverseOffer(Master *master, const OfferID &offerId)mesos::internal::master::Masterfriend
validation::offer::getOffer(Master *master, const OfferID &offerId)mesos::internal::master::Masterfriend
validation::offer::getSlave(Master *master, const SlaveID &slaveId)mesos::internal::master::Masterfriend
~EventConsumer()process::EventConsumerinlinevirtual
~Master() overridemesos::internal::master::Master
~Process() overrideprocess::Process< Master >inline
~ProcessBase() overrideprocess::ProcessBase
~ProtobufProcess() overrideProtobufProcess< Master >inline