Struct archivist_lib::logs::servers::LogServer
source · pub struct LogServer { /* private fields */ }
Implementations§
source§impl LogServer
impl LogServer
pub fn new(logs_repo: Arc<LogsRepository>) -> Self
sourcepub fn spawn(&self, stream: LogRequestStream)
pub fn spawn(&self, stream: LogRequestStream)
Spawn a task to handle requests from components reading the shared log.
sourcepub async fn wait_for_servers_to_complete(&self)
pub async fn wait_for_servers_to_complete(&self)
Instructs the server to finish handling all connections and return when they have finished draining logs.
Auto Trait Implementations§
impl !Freeze for LogServer
impl !RefUnwindSafe for LogServer
impl Send for LogServer
impl Sync for LogServer
impl Unpin for LogServer
impl !UnwindSafe for LogServer
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more