Struct Scheduler

pub struct Scheduler {
    pub adaptor: String,
    pub identifier: String,
    /* private fields */
}

Represents a scheduler that can be used to submit jobs and retrieve queue information.

Fields

adaptor: String

identifier: String

Implementations

impl Scheduler

pub async fn cancel_job<J>(&mut self, job: J) -> Result<JobStatus>

where J: Into<Job>,

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

pub async fn create<S1, S2, S3>( adaptor: S1, location: S2, credential: Credential, xenon_endpoint: S3, properties: Option<HashMap<String, String>>, ) -> Result<Self>

where S1: Into<String>, S2: Into<String>, S3: Into<String>,

pub async fn create_local<S1>(xenon_endpoint: S1) -> Result<Self>

where S1: Into<String>,

pub async fn get_credential(&mut self) -> Result<Option<Credential>>

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

pub async fn get_default_runtime(&mut self) -> Result<u32>

pub async fn get_filesystem(&mut self) -> Result<FileSystem>

pub async fn get_job_status<J>(&mut self, job: J) -> Result<JobStatus>

where J: Into<Job>,

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

where J: Into<Job> + Clone,

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

pub async fn get_location(&mut self) -> Result<String>

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

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

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

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

pub async fn list_schedulers<S1>(xenon_endpoint: S1) -> Result<Vec<String>>

where S1: Into<String>,

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

pub async fn restore<S1, S2>(identifier: S1, xenon_endpoint: S2) -> Result<Self>

where S1: Into<String>, S2: Into<String>,

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

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

where J: Into<Job>,

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

where J: Into<Job>,