Struct BackgroundJobServer

pub struct BackgroundJobServer { /* private fields */ }

Background job server that manages job processing

Implementations

impl BackgroundJobServer

pub fn new( config: ServerConfig, storage: Arc<dyn Storage>, worker_registry: Arc<WorkerRegistry>, ) -> Self

Create a new background job server

pub fn with_retry_policy( config: ServerConfig, storage: Arc<dyn Storage>, worker_registry: Arc<WorkerRegistry>, retry_policy: RetryPolicy, ) -> Self

Create a new background job server with custom retry policy

pub async fn start(&self) -> Result<()>

Start the background job server

pub async fn stop(&self) -> Result<()>

Stop the background job server

pub async fn is_running(&self) -> bool

Check if the server is running

pub fn config(&self) -> &ServerConfig

Get server configuration

Trait Implementations

impl Clone for BackgroundJobServer

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.