pub struct RebuildActor { /* private fields */ }Expand description
Single-threaded actor that processes property-FTS rebuild requests one at a time. Shutdown is cooperative and controlled by an explicit token so public admin-service clones cannot keep the actor alive accidentally.
Implementations§
Source§impl RebuildActor
impl RebuildActor
Sourcepub fn start(
path: impl AsRef<Path>,
schema_manager: Arc<SchemaManager>,
receiver: Receiver<RebuildRequest>,
shutdown: Arc<AtomicBool>,
) -> Result<Self, EngineError>
pub fn start( path: impl AsRef<Path>, schema_manager: Arc<SchemaManager>, receiver: Receiver<RebuildRequest>, shutdown: Arc<AtomicBool>, ) -> Result<Self, EngineError>
Create the mpsc channel used to communicate with the rebuild thread.
Returns (sender, actor). The sender is given to
crate::admin::AdminService; the actor is kept in
crate::runtime::EngineRuntime for lifecycle management.
§Errors
Returns EngineError::Io if the thread cannot be spawned.
Trait Implementations§
Source§impl Debug for RebuildActor
impl Debug for RebuildActor
Auto Trait Implementations§
impl Freeze for RebuildActor
impl !RefUnwindSafe for RebuildActor
impl Send for RebuildActor
impl Sync for RebuildActor
impl Unpin for RebuildActor
impl UnsafeUnpin for RebuildActor
impl !UnwindSafe for RebuildActor
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