Struct DelayedJobsClient 

pub struct DelayedJobsClient { /* private fields */ }

Access to the /v1/clockwork/delayed endpoints.

Obtain via Clockwork::delayed.

Implementations

impl DelayedJobsClient

pub async fn list(&self) -> Result<Vec<DelayedJob>, Error>

List all delayed jobs.

Maps to GET /v1/clockwork/delayed.

Example

use nautilus_rs::Clockwork;

let clockwork = Clockwork::new("vrn_clockwork_live_sk_…");
for job in clockwork.delayed().list().await? {
    println!("{} runs at {}", job.name, job.run_at);
}

pub async fn create( &self, params: CreateDelayedJobParams, ) -> Result<DelayedJob, Error>

Schedule a new one-off delayed job.

Maps to POST /v1/clockwork/delayed.

Example

use nautilus_rs::{Clockwork, CreateDelayedJobParams};

let clockwork = Clockwork::new("vrn_clockwork_live_sk_…");
let job = clockwork.delayed().create(CreateDelayedJobParams {
    name: "send-reminder".into(),
    run_at: "2026-01-01T12:00:00Z".into(),
    url: "https://example.com/hooks/reminder".into(),
    ..Default::default()
}).await?;
println!("scheduled job {}", job.id);

pub async fn cancel(&self, job_id: &str) -> Result<(), Error>

Cancel a pending delayed job.

Maps to DELETE /v1/clockwork/delayed/{id}.

pub async fn executions(&self, job_id: &str) -> Result<Vec<Execution>, Error>

List the execution history for a delayed job.

Maps to GET /v1/clockwork/delayed/{id}/executions.