Trait ora_client::TaskOperations

source · 
pub trait TaskOperations: Debug + Send + Sync + 'static {

Show 15 methods    // Required methods
    fn id(&self) -> Uuid;
    fn status<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<TaskStatus>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn target<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<UnixNanos>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn definition<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<TaskDefinition>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn result<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<Option<RawTaskResult>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn wait_result<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<RawTaskResult>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn schedule<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ScheduleOperations>>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn added_at<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<UnixNanos>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn ready_at<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn started_at<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn succeeded_at<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn failed_at<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn cancelled_at<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn cancel<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn worker_id<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<Option<Uuid>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;

}

Required Methods§

source

fn id(&self) -> Uuid

source

fn status<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<TaskStatus>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn target<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<UnixNanos>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn definition<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<TaskDefinition>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn result<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<RawTaskResult>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn wait_result<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<RawTaskResult>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn schedule<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ScheduleOperations>>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn added_at<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<UnixNanos>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn ready_at<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn started_at<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn succeeded_at<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn failed_at<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn cancelled_at<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn cancel<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn worker_id<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<Uuid>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Implementations on Foreign Types§

source§

impl TaskOperations for Arc<dyn TaskOperations>

source§

fn id(&self) -> Uuid

source§

fn status<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<TaskStatus>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source§

fn target<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<UnixNanos>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source§

fn definition<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<TaskDefinition>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source§

fn result<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<RawTaskResult>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source§

fn wait_result<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<RawTaskResult>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source§

fn schedule<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<Arc<dyn ScheduleOperations>>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source§

fn added_at<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<UnixNanos>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source§

fn ready_at<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source§

fn started_at<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source§

fn succeeded_at<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source§

fn failed_at<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source§

fn cancelled_at<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<UnixNanos>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source§

fn cancel<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source§

fn worker_id<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<Uuid>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Implementors§