Struct xenon::compute::Scheduler

pub struct Scheduler {
    pub adaptor: String,
    pub identifier: String,
    // some fields omitted
}

Fields

adaptor: String

identifier: String

Implementations

impl Scheduler

pub fn cancel_job(&self, job: Job) -> Result<JobStatus>

pub fn close(&mut self) -> Result<()>

pub fn create(
    adaptor: String,
    channel: Channel,
    credential: Credential,
    location: String,
    properties: HashMap<String, String>
) -> Result<Scheduler>

pub fn get_default_queue_name(&self) -> Result<String>

pub fn get_job_status(&self, job: Job) -> Result<JobStatus>

pub fn get_job_statuses(&self, jobs: Vec<Job>) -> Result<Vec<JobStatus>>

pub fn get_jobs(&self, queues: Option<Vec<String>>) -> Result<Vec<Job>>

pub fn get_properties(&self) -> Result<HashMap<String, String>>

pub fn get_queue_names(&self) -> Result<Vec<String>>

pub fn get_queue_status(&self, queue: String) -> Result<QueueStatus>

pub fn get_queue_statuses(
    &self,
    queues: Option<Vec<String>>
) -> Result<Vec<QueueStatus>>

pub fn is_open(&mut self) -> Result<bool>

pub fn submit_batch_job(&self, description: JobDescription) -> Result<Job>

pub fn wait_until_done(
    &self,
    job: Job,
    timeout: Option<u64>
) -> Result<JobStatus>

pub fn wait_until_running(
    &self,
    job: Job,
    timeout: Option<u64>
) -> Result<JobStatus>

Trait Implementations

impl Drop for Scheduler

fn drop(&mut self)