Trait RenderQueue 

pub trait RenderQueue: Send + Sync {
    // Required methods
    fn enqueue<'a>(
        &'a self,
        job: RenderJob,
    ) -> BoxFuture<'a, ServiceResult<RenderJobId>>;
    fn lease<'a>(
        &'a self,
        worker_id: &'a WorkerId,
        ttl: Duration,
    ) -> BoxFuture<'a, ServiceResult<Option<RenderLease>>>;
    fn ack<'a>(
        &'a self,
        lease_id: RenderLeaseId,
    ) -> BoxFuture<'a, ServiceResult<()>>;
    fn nack<'a>(
        &'a self,
        lease_id: RenderLeaseId,
        reason: ServiceError,
    ) -> BoxFuture<'a, ServiceResult<()>>;
    fn heartbeat<'a>(
        &'a self,
        lease_id: &'a RenderLeaseId,
        ttl: Duration,
    ) -> BoxFuture<'a, ServiceResult<()>>;
}

Required Methods

fn enqueue<'a>( &'a self, job: RenderJob, ) -> BoxFuture<'a, ServiceResult<RenderJobId>>

fn lease<'a>( &'a self, worker_id: &'a WorkerId, ttl: Duration, ) -> BoxFuture<'a, ServiceResult<Option<RenderLease>>>

fn ack<'a>( &'a self, lease_id: RenderLeaseId, ) -> BoxFuture<'a, ServiceResult<()>>

fn nack<'a>( &'a self, lease_id: RenderLeaseId, reason: ServiceError, ) -> BoxFuture<'a, ServiceResult<()>>

fn heartbeat<'a>( &'a self, lease_id: &'a RenderLeaseId, ttl: Duration, ) -> BoxFuture<'a, ServiceResult<()>>

Implementors

impl RenderQueue for InMemoryRenderQueue