Struct ObjectImpl 

pub struct ObjectImpl { /* private fields */ }

Implementations

impl ObjectImpl

pub fn new(rhai_engine: Engine) -> Self

Trait Implementations

impl Default for ObjectImpl

fn default() -> Self

Returns the “default value” for a type.

impl Object for ObjectImpl

async fn create( &self, ctx: ObjectContext<'_>, job: Json<JobSpec>, ) -> HandlerResult<()>

Create a new cron job.

async fn replace( &self, ctx: ObjectContext<'_>, job: Json<JobSpec>, ) -> HandlerResult<()>

Create a new or replace an existing cron job.

async fn cancel(&self, ctx: ObjectContext<'_>) -> HandlerResult<()>

Cancel an existing cron job.

async fn run(&self, ctx: ObjectContext<'_>) -> HandlerResult<()>

Internal handler for running the cron job.

async fn get( &self, ctx: SharedObjectContext<'_>, ) -> HandlerResult<Json<JobSpec>>

Get the details of an existing cron job.

async fn get_next_run( &self, ctx: SharedObjectContext<'_>, ) -> HandlerResult<Json<NextRun>>

Get the next run time of an existing cron job.

fn serve(self) -> ServeObject<Self>

Returns a serving function to use with [::restate_sdk::endpoint::Builder::with_service].