|
Scheduler驅(qū)動API（Scheduler Driver API） Scheduler Driver管理著scheduler的生命周期 (e.g., 開始、停止和等著完成) 并且和 Mesos Master通信 (e.g., 發(fā)布Tasks、殺死Tasks等). 注意這個接口通常不是由framework自身實現(xiàn)的，但它描述了可以與Mesos Master溝通的framework scheduler的可能的形式。 Please note that usage of this interface requires an instantiated MesosSchedulerDiver. Seesrc/examples/test_framework.cpp for an example of using the MesosSchedulerDriver. 請注意，這個接口的使用需要實例化mesos scheduler diver?？?/span>src/examples/test_framework.cpp正是使用mesos scheduler driver的例子。 聲名于 MESOS_HOME/include/mesos/scheduler.hpp。 // 啟動調(diào)度程序驅(qū)動程序。這需要在啟動任何其他驅(qū)動程序之前調(diào)用。 virtual Status start(); //停止調(diào)度程序驅(qū)動程序。如果的話， //這個Framework將永遠不會重新連接到Mesos，Mesos所以將注銷Framework并關(guān)閉這個Framework // 所有的Tasks和Executors。如果''failover''標志設置為true，所有的Executors和Tasks將繼續(xù)運行 //（對于一些Framework故障超時的情況）允許調(diào)度程序重新連接 //（通常是同一個進程，也有可能是不同的進程，例如，在不同的機器上的情況）。 virtual Status stop(bool failover = false); / /中止驅(qū)動，因此對Executors沒有沒有更多的回調(diào)。 / /中止和停止的語義被有意區(qū)分，所以代碼便可以檢測到一個中止的驅(qū)動程序（即通過 / / scheduler driver：：join返回狀態(tài)，見下文），如果需要的話（從同一個過程中） //實例化并啟動另一個驅(qū)動。 //注意stop()沒有自動調(diào)用里面的“abort()”。 virtual Status abort(); // 等待驅(qū)動被停止或中止，很可能當前線程被永久的卡住了。 //函數(shù)的返回狀態(tài)被用來判斷驅(qū)動是否終止. //（了解狀態(tài)描述查看mesos.proto）。 virtual Status join(); //啟動并立即連接（例如，塊）的驅(qū)動程序。 virtual Status run(); //從Mesos請求資源（通過mesos.proto查看請求的描述和怎樣處理，例如，從特定的Slaves 請求資源）。 //所有可用資源都是通過Scheduler::resourceOffers 異步地回調(diào)的。 virtual Status requestResources(const std::vector<Request>& requests); //發(fā)布給定的任務集。任何剩余資源（即，不被Tasks或他們的Executors使用）將被拒絕。 //特定的過濾器應用于所有未使用的資源（見mesos.proto過濾器描述）。 //當提供多個offers時，可利用資源被匯總。請注意，所有offers都必須是同一個Slave。 //用空任務集作為參數(shù)調(diào)用這個函數(shù)講拒絕offers的全部資源(見Scheduler::declineOffer)。 virtual Status launchTasks( const std::vector<OfferID>& offerIds, const std::vector<TaskInfo>& tasks, const Filters& filters = Filters()); //殺死指定任務。注意，想要殺死一個目前不可靠的任務。 //例如，如果當一個試圖殺死Tasks的Scheduler失敗時，需要再次嘗試。 //同樣的，如果未注冊/斷開，請求將被丟棄（這些語義可能在將來改變）。 virtual Status killTask(const TaskID& taskId); //接受給定的offers并對該offers的執(zhí)行一系列操作。 //查看mesos.proto里的Offer.Operationmesos.proto了解合適的的操作?？捎觅Y源匯總 //當提供多個offers時，可利用資源被匯總。請注意，所有offers都必須是同一個Slave。 //任何未使用的資源將被拒絕 / /指定的過濾器應用于所有未使用的資源（見過濾器說明mesos.proto）。 virtual Status acceptOffers( const std::vector<OfferID>& offerIds, const std::vector<Offer::Operation>& operations, const Filters& filters = Filters()); // 作為整體拒絕offer的全部資源并且對資源應用一個特定的過濾器。 //注意，這可以在任何時候發(fā)生，并不一定發(fā)生在Scheduler::resourceOffers回調(diào)期間。 virtual Status declineOffer( const OfferID& offerId, const Filters& filters = Filters()); //刪除框架先前設置的所有過濾器（通過launchtasks()設置的） 。 //這使得Framework可以接收來自那些被濾過器剔除的奴隸。 virtual Status reviveOffers(); //通知Mesos master停止向Framework發(fā)送offers。 //Scheduler應該調(diào)用reviveOffers()來恢復接受offers。 virtual Status suppressOffers(); //獲取狀態(tài)更新。這函數(shù)只在Scheduler永久的更新狀態(tài)時被調(diào)用 //必須通過構(gòu)造函數(shù)參數(shù)請求獲取具體的更新狀態(tài)，否則此方法的調(diào)用將導致驅(qū)動崩潰。 virtual Status acknowledgeStatusUpdate(const TaskStatus& status); / /Framework對它的一個Executor發(fā)送一個消息。這些消息的發(fā)送是不可靠的， / /不要期望一個Framework的信息以任何可靠的方式轉(zhuǎn)發(fā)。 virtual Status sendFrameworkMessage( const ExecutorsID& ExecutorsId, const SlaveID& slaveId, const std::string& data); //允許該框架查詢非終結(jié)Tasks的狀態(tài)。 //這會使Master盡可能的返回每個在‘statuses’的Tasks的最新Tasks狀態(tài) //不在‘statuses’里的任務將會做TASK_LOST更新。 //如果‘statuses’是空的，Master將傳回每個已知Tasks的最新狀態(tài)。 virtual Status reconcileTasks(const std::vector<TaskStatus>& statuses); |
|
|
來自： 碼農(nóng)書館 > 《mesos》
