clockwork/schedule

Types

pub type Message {
  Run
  Stop
}

</>

pub type Schedule {
  Schedule(subject: process.Subject(Message))
}

Schedule(subject: process.Subject(Message))

opaque </>

pub opaque type Scheduler

</>

pub fn new(id: String, cron: Cron, job: fn() -> Nil) -> Scheduler

</>

pub fn start(
  scheduler: Scheduler,
) -> Result(Schedule, StartError)

</>

pub fn stop(schedule: Schedule) -> Nil

</>

pub fn with_logging(scheduler: Scheduler) -> Scheduler

</>

pub fn with_telemetry(scheduler: Scheduler) -> Scheduler

</>

pub fn with_time_offset(
  scheduler: Scheduler,
  offset: Duration,
) -> Scheduler