pub async fn restart_ingester(&mut self) {
        self.ingester = Some(
            self.ingester
                .take()
                .expect("ingester not initialized")
                .restart_server()
                .await,
        )
    }
/// Restart ingester.
///
/// This will break all currently connected clients!
Restart ingester.
This will break all currently connected clients!
Restart ingester . This will break all currently connected clients!
pub async fn restart_ingester(&mut self) {
        self.ingester = Some(
            self.ingester
                .take()
                .expect("ingester not initialized")
                .restart_server()
                .await,
        )
    }
pub async fn restart_ingester ( & mut self ) { self . ingester = Some ( self . ingester . take ( ) . expect ( " " ) . restart_server ( ) . await , ) }
Restart ingester.
Restart ingester .
&mut self
&mut self