Struct cala_server::job::Jobs

pub struct Jobs { /* private fields */ }

Implementations

impl Jobs

pub fn new( pool: &PgPool, config: JobExecutorConfig, registry: JobRegistry, ) -> Self

pub async fn create_and_spawn_in_op<I: JobInitializer + Default, D: Serialize>( &self, op: &mut AtomicOperation<'_>, id: impl Into<JobId> + Debug, name: String, description: Option<String>, data: D, ) -> Result<Job, JobError>

pub async fn create_and_spawn_at_in_op<I: JobInitializer + Default, D: Serialize>( &self, op: &mut AtomicOperation<'_>, name: String, description: Option<String>, data: D, schedule_at: DateTime<Utc>, ) -> Result<Job, JobError>

pub async fn list( &self, query: PaginatedQueryArgs<JobByNameCursor>, ) -> Result<PaginatedQueryRet<Job, JobByNameCursor>, JobError>

pub async fn find(&self, id: JobId) -> Result<Job, JobError>

Trait Implementations

impl Clone for Jobs

fn clone(&self) -> Jobs

Returns a copy of the value.

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

Performs copy-assignment from source.