Enum scheduler_service_lib::State

pub enum State<JobRequest: Serialize + Clone, Step: Serialize + Clone, JobOutputInfo: Serialize + Clone> {
    Idle,
    RequestToStart {
        job_id: Uuid,
        request: JobRequest,
    },
    Running {
        job_id: Uuid,
        start: NaiveDateTime,
        request: JobRequest,
        step: Option<Step>,
    },
    Finished {
        job_id: Uuid,
        start: NaiveDateTime,
        end: NaiveDateTime,
        request: JobRequest,
        info: Option<JobOutputInfo>,
    },
    Failed {
        job_id: Uuid,
        start: NaiveDateTime,
        end: NaiveDateTime,
        request: JobRequest,
        info_msg: String,
    },
}

Variants

Idle

RequestToStart

Fields

job_id: Uuid

request: JobRequest

Running

Fields

job_id: Uuid

start: NaiveDateTime

request: JobRequest

step: Option<Step>

Finished

Fields

job_id: Uuid

start: NaiveDateTime

end: NaiveDateTime

request: JobRequest

info: Option<JobOutputInfo>

Failed

Fields

job_id: Uuid

start: NaiveDateTime

end: NaiveDateTime

request: JobRequest

info_msg: String

Implementations

impl<JobRequest: Clone + Serialize, Step: Serialize + Clone, JobOutputInfo: Serialize + Clone> State<JobRequest, Step, JobOutputInfo>

pub fn update_running_step(&mut self, new_step: Step)

pub fn assert_is_finished(&self)

pub fn run_requested(&self) -> Option<(Uuid, JobRequest)>

pub fn new_run_requested(&mut self, request: JobRequest) -> Result<Uuid, Error>

pub fn new_run_started(&mut self) -> Result<(), Error>

pub fn run_finished(&mut self, info: Option<JobOutputInfo>) -> Result<(), Error>

pub fn has_id(&self, id: &Uuid) -> bool

pub fn persist<P: AsRef<Path>>(&self, path: P) -> Result<(), Error>

Trait Implementations

impl<JobRequest: Clone + Serialize + Clone, Step: Clone + Serialize + Clone, JobOutputInfo: Clone + Serialize + Clone> Clone for State<JobRequest, Step, JobOutputInfo>

fn clone(&self) -> State<JobRequest, Step, JobOutputInfo>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<JobRequest: Debug + Serialize + Clone, Step: Debug + Serialize + Clone, JobOutputInfo: Debug + Serialize + Clone> Debug for State<JobRequest, Step, JobOutputInfo>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de, JobRequest, Step, JobOutputInfo> Deserialize<'de> for State<JobRequest, Step, JobOutputInfo>where JobRequest: Deserialize<'de> + Serialize + Clone, Step: Deserialize<'de> + Serialize + Clone, JobOutputInfo: Deserialize<'de> + Serialize + Clone,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<JobRequest: Debug + Serialize + Clone, Step: Debug + Serialize + Clone, JobOutputInfo: Debug + Serialize + Clone> Display for State<JobRequest, Step, JobOutputInfo>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<JobRequest: PartialEq + Serialize + Clone, Step: PartialEq + Serialize + Clone, JobOutputInfo: PartialEq + Serialize + Clone> PartialEq<State<JobRequest, Step, JobOutputInfo>> for State<JobRequest, Step, JobOutputInfo>

fn eq(&self, other: &State<JobRequest, Step, JobOutputInfo>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<JobRequest, Step, JobOutputInfo> Serialize for State<JobRequest, Step, JobOutputInfo>where JobRequest: Serialize + Serialize + Clone, Step: Serialize + Serialize + Clone, JobOutputInfo: Serialize + Serialize + Clone,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<JobRequest: Eq + Serialize + Clone, Step: Eq + Serialize + Clone, JobOutputInfo: Eq + Serialize + Clone> Eq for State<JobRequest, Step, JobOutputInfo>

impl<JobRequest: Serialize + Clone, Step: Serialize + Clone, JobOutputInfo: Serialize + Clone> StructuralEq for State<JobRequest, Step, JobOutputInfo>

impl<JobRequest: Serialize + Clone, Step: Serialize + Clone, JobOutputInfo: Serialize + Clone> StructuralPartialEq for State<JobRequest, Step, JobOutputInfo>