pub struct ControllerManager { /* private fields */ }Expand description
Main controller manager
This is the central component that coordinates all controller operations. It manages:
- Raft consensus layer
- Metadata storage
- Request processing
- RPC server
- Lifecycle management
Implementations§
Source§impl ControllerManager
impl ControllerManager
Sourcepub async fn new(config: ControllerConfig) -> Result<Self>
pub async fn new(config: ControllerConfig) -> Result<Self>
Create a new controller manager
Sourcepub async fn get_leader(&self) -> Option<u64>
pub async fn get_leader(&self) -> Option<u64>
Get the current leader ID
Sourcepub async fn is_running(&self) -> bool
pub async fn is_running(&self) -> bool
Check if the controller is running
Sourcepub fn raft(&self) -> &Arc<RaftController>
pub fn raft(&self) -> &Arc<RaftController>
Get the Raft controller
Sourcepub fn metadata(&self) -> &Arc<MetadataStore>
pub fn metadata(&self) -> &Arc<MetadataStore>
Get the metadata store
Sourcepub fn processor(&self) -> &Arc<ProcessorManager>
pub fn processor(&self) -> &Arc<ProcessorManager>
Get the processor manager
Trait Implementations§
Auto Trait Implementations§
impl Freeze for ControllerManager
impl !RefUnwindSafe for ControllerManager
impl Send for ControllerManager
impl Sync for ControllerManager
impl Unpin for ControllerManager
impl !UnwindSafe for ControllerManager
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