Enum ScheduleAt 

pub enum ScheduleAt {
    Interval(TimeDuration),
    Time(Timestamp),
}

When a scheduled reducer should execute, either at a specific point in time, or at regular intervals for repeating schedules.

Stored in reducer-scheduling tables as a column.

This is a special type.

Variants

Interval(TimeDuration)

A regular interval at which the repeated reducer is scheduled. Value is a TimeDuration, which has nanosecond precision.

Time(Timestamp)

A specific time to which the reducer is scheduled.

Implementations

impl ScheduleAt

pub fn to_duration_from(&self, from: Timestamp) -> Duration

Converts the ScheduleAt to a std::time::Duration from now.

Returns std::time::Duration::ZERO if self represents a time in the past.

pub fn to_timestamp_from(&self, from: Timestamp) -> Timestamp

Converts the ScheduleAt to a Timestamp.

If self is an interval, returns from + dur.

pub fn get_type() -> AlgebraicType

Get the special AlgebraicType for ScheduleAt.

Trait Implementations

impl Clone for ScheduleAt

fn clone(&self) -> ScheduleAt

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ScheduleAt

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ScheduleAt

fn deserialize<D: Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error>

Deserialize this value from the given deserializer.

impl From<Duration> for ScheduleAt

fn from(value: Duration) -> Self

Converts to this type from the input type.

impl From<SystemTime> for ScheduleAt

fn from(value: SystemTime) -> Self

Converts to this type from the input type.

impl From<TimeDuration> for ScheduleAt

fn from(value: TimeDuration) -> Self

Converts to this type from the input type.

impl From<Timestamp> for ScheduleAt

fn from(value: Timestamp) -> Self

Converts to this type from the input type.

impl GroundSpacetimeType for ScheduleAt

fn get_type() -> AlgebraicType

Returns the AlgebraicType representation of Self.

impl PartialEq for ScheduleAt

fn eq(&self, other: &ScheduleAt) -> bool

Tests for self and other values to be equal, and is used by ==.

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

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

impl Serialize for ScheduleAt

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

Serialize self in the data format of S using the provided serializer.

impl SpacetimeType for ScheduleAt

fn make_type<S: TypespaceBuilder>(_ts: &mut S) -> AlgebraicType

Returns an AlgebraicType representing the type for Self in SATS and in the typing context in typespace. This is used by the automatic type registration system in Rust modules.

impl TryFrom<AlgebraicValue> for ScheduleAt

type Error = ValueDeserializeError

The type returned in the event of a conversion error.

fn try_from(value: AlgebraicValue) -> Result<Self, Self::Error>

Performs the conversion.

impl Copy for ScheduleAt

impl Eq for ScheduleAt

impl StructuralPartialEq for ScheduleAt