Struct mesos::scheduler_client::SchedulerClient

pub struct SchedulerClient {
    pub url: String,
    pub framework_id: Arc<Mutex<Option<FrameworkID>>>,
}

Fields

url: String

framework_id: Arc<Mutex<Option<FrameworkID>>>

Methods

impl SchedulerClient

fn subscribe(&self, framework_info: FrameworkInfo, force: Option<bool>) -> Result<Response>

fn teardown(&self) -> Result<Response>

fn accept(&self, offer_ids: Vec<OfferID>, operations: Vec<Operation>, filters: Option<Filters>) -> Result<Response>

fn decline(&self, offer_ids: Vec<OfferID>, filters: Option<Filters>) -> Result<Response>

fn revive(&self) -> Result<Response>

fn kill(&self, task_id: TaskID, agent_id: Option<AgentID>) -> Result<Response>

fn shutdown(&self, executor_id: ExecutorID, agent_id: AgentID) -> Result<Response>

fn acknowledge(&self, agent_id: AgentID, task_id: TaskID, uuid: Vec<u8>) -> Result<Response>

fn reconcile_task(&self, task_id: TaskID, agent_id: Option<AgentID>) -> Result<Response>

fn reconcile(&self, tasks: Vec<Call_Reconcile_Task>) -> Result<Response>

fn message(&self, agent_id: AgentID, executor_id: ExecutorID, data: Vec<u8>) -> Result<Response>

fn request(&self, requests: Vec<Request>) -> Result<Response>

fn suppress(&self) -> Result<Response>

Trait Implementations

impl Clone for SchedulerClient

fn clone(&self) -> SchedulerClient

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.