Struct AJ 

pub struct AJ {}

Implementations

impl AJ

pub fn start(backend: impl Backend + Send + Sync + 'static) -> ActorRef<AJ>

Start AJ with a custom backend

pub fn quick_start() -> ActorRef<AJ>

Quick start AJ with in-memory backend

pub async fn enqueue_job<M>( job: Job<M>, config: EnqueueConfig, queue_name: &str, ) -> Result<(), Error>

where M: Executable + Send + Sync + Clone + Serialize + DeserializeOwned + 'static,

pub async fn cancel_job<M>(job_id: String) -> Result<(), Error>

where M: Executable + Send + Sync + Clone + Serialize + DeserializeOwned + 'static,

pub async fn get_job<M>(job_id: &str) -> Option<Job<M>>

where M: Executable + Send + Sync + Clone + Serialize + DeserializeOwned + 'static,

pub async fn update_job<M>( job_id: &str, data: M, context: Option<JobContext>, ) -> Result<(), Error>

where M: Executable + BackgroundJob + Send + Sync + Clone + Serialize + DeserializeOwned + 'static,

pub async fn retry_job<M>(job_id: &str) -> Result<bool, Error>

where M: Executable + Send + Sync + Clone + Serialize + DeserializeOwned + 'static,

pub async fn add_job<M>(job: Job<M>, queue_name: &str) -> Result<String, Error>

where M: Executable + Send + Sync + Clone + Serialize + DeserializeOwned + 'static,

pub async fn update_work_queue<M>(config: WorkQueueConfig) -> Result<(), Error>

where M: Executable + Send + Sync + Clone + Serialize + DeserializeOwned + 'static,

pub async fn register_plugin( plugin: impl JobPlugin + Send + Sync + 'static, ) -> Result<(), Error>

Trait Implementations

impl Actor for AJ

type Mailbox = UnboundedMailbox<AJ>

The mailbox type used for the actor.

fn name() -> &'static str

The name of the actor, which can be useful for logging or debugging.

fn new_mailbox() -> (<AJ as Actor>::Mailbox, <<AJ as Actor>::Mailbox as Mailbox<AJ>>::Receiver)

Creates a new mailbox for the actor. This sets up the message queue and receiver for the actor.

fn on_start( &mut self, actor_ref: ActorRef<Self>, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

Called when the actor starts, before it processes any messages.

fn on_panic( &mut self, actor_ref: WeakActorRef<Self>, err: PanicError, ) -> impl Future<Output = Result<Option<ActorStopReason>, Box<dyn Error + Send + Sync>>> + Send

Called when the actor encounters a panic or an error during “tell” message handling.

fn on_link_died( &mut self, actor_ref: WeakActorRef<Self>, id: ActorID, reason: ActorStopReason, ) -> impl Future<Output = Result<Option<ActorStopReason>, Box<dyn Error + Send + Sync>>> + Send

Called when a linked actor dies.

fn on_stop( &mut self, actor_ref: WeakActorRef<Self>, reason: ActorStopReason, ) -> impl Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send

Called before the actor stops.

impl<M> Message<JustRunJob<M>> for AJ

where M: Executable + Send + Sync + Clone + Serialize + DeserializeOwned + 'static,

type Reply = ()

The reply sent back to the message caller.

async fn handle( &mut self, msg: JustRunJob<M>, _ctx: Context<'_, AJ, <AJ as Message<JustRunJob<M>>>::Reply>, ) -> <AJ as Message<JustRunJob<M>>>::Reply

Handler for this message.