Struct ora::ScheduleDefinition
source · pub struct ScheduleDefinition {
pub policy: SchedulePolicy,
pub immediate: bool,
pub missed_tasks: MissedTasksPolicy,
pub new_task: NewTask,
pub labels: HashMap<String, Value, RandomState>,
}Expand description
A schedule supports repeatedly spawning jobs based on the given settings.
Fields§
§policy: SchedulePolicyThe task schedule policy.
immediate: boolWhether to immediately spawn a task when the schedule is first processed.
missed_tasks: MissedTasksPolicyThe policy for missed tasks.
new_task: NewTaskParameters for newly spawned tasks.
labels: HashMap<String, Value, RandomState>Schedule labels.
Implementations§
source§impl ScheduleDefinition
impl ScheduleDefinition
sourcepub fn new(policy: SchedulePolicy, new_task: NewTask) -> ScheduleDefinition
pub fn new(policy: SchedulePolicy, new_task: NewTask) -> ScheduleDefinition
Create a new schedule.
sourcepub fn immediate(self, immediate: bool) -> ScheduleDefinition
pub fn immediate(self, immediate: bool) -> ScheduleDefinition
Set whether a task should be immediately scheduled when the schedule is added.
sourcepub fn on_missed_tasks(self, policy: MissedTasksPolicy) -> ScheduleDefinition
pub fn on_missed_tasks(self, policy: MissedTasksPolicy) -> ScheduleDefinition
Set the missed tasks policy.
sourcepub fn with_label(self, name: &str, value: impl Serialize) -> ScheduleDefinition
pub fn with_label(self, name: &str, value: impl Serialize) -> ScheduleDefinition
Trait Implementations§
source§impl Clone for ScheduleDefinition
impl Clone for ScheduleDefinition
source§fn clone(&self) -> ScheduleDefinition
fn clone(&self) -> ScheduleDefinition
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moresource§impl Debug for ScheduleDefinition
impl Debug for ScheduleDefinition
source§impl<'de> Deserialize<'de> for ScheduleDefinition
impl<'de> Deserialize<'de> for ScheduleDefinition
source§fn deserialize<__D>(
__deserializer: __D
) -> Result<ScheduleDefinition, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>( __deserializer: __D ) -> Result<ScheduleDefinition, <__D as Deserializer<'de>>::Error>where __D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
source§impl Serialize for ScheduleDefinition
impl Serialize for ScheduleDefinition
source§fn serialize<__S>(
&self,
__serializer: __S
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
fn serialize<__S>( &self, __serializer: __S ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where __S: Serializer,
Serialize this value into the given Serde serializer. Read more
Auto Trait Implementations§
impl RefUnwindSafe for ScheduleDefinition
impl Send for ScheduleDefinition
impl Sync for ScheduleDefinition
impl Unpin for ScheduleDefinition
impl UnwindSafe for ScheduleDefinition
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<W> IntoHandler for Wwhere
W: Send + Sync + 'static,
impl<W> IntoHandler for Wwhere W: Send + Sync + 'static,
source§fn handler<T>(self) -> Arc<dyn RawHandler + Sync + Send, Global>where
Self: Handler<T>,
T: Task,
fn handler<T>(self) -> Arc<dyn RawHandler + Sync + Send, Global>where Self: Handler<T>, T: Task,
Convert
self into a RawHandler that can be registered
in workers.source§fn handler_with_selector<T>(
self,
selector: WorkerSelector
) -> Arc<dyn RawHandler + Sync + Send, Global>where
Self: Handler<T>,
T: Task,
fn handler_with_selector<T>( self, selector: WorkerSelector ) -> Arc<dyn RawHandler + Sync + Send, Global>where Self: Handler<T>, T: Task,
Convert
self into a RawHandler that can be registered
in workers with the given selector.