Struct GenBackgroundService 

pub struct GenBackgroundService<A> {
    pub threads: Option<usize>,
    /* private fields */
}

A generic type of background service

Fields

threads: Option<usize>

The number of threads. Default is 1

Implementations

impl<A> GenBackgroundService<A>

pub fn new(name: String, task: Arc<A>) -> GenBackgroundService<A>

Generates a background service that can run in the pingora runtime

pub fn task(&self) -> Arc<A>

Return the task behind Arc to be shared other logic.

Trait Implementations

impl<A> Service for GenBackgroundService<A>

where A: BackgroundService + Send + Sync + 'static,

fn start_service<'life0, 'async_trait>( &'life0 mut self, _fds: Option<Arc<Mutex<Fds>>>, shutdown: Receiver<bool>, _listeners_per_fd: usize, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, GenBackgroundService<A>: 'async_trait,

This function will be called when the server is ready to start the service.

fn name(&self) -> &str

The name of the service, just for logging and naming the threads assigned to this service

fn threads(&self) -> Option<usize>

The preferred number of threads to run this service