pub struct RebalancerLoop { /* private fields */ }Expand description
The driver itself.
Implementations§
Source§impl RebalancerLoop
impl RebalancerLoop
pub fn new( cfg: RebalancerLoopConfig, metrics: Arc<dyn LoadMetricsProvider>, dispatcher: Arc<dyn MigrationDispatcher>, gate: Arc<dyn ElectionGate>, routing: Arc<RwLock<RoutingTable>>, topology: Arc<RwLock<ClusterTopology>>, ) -> Self
Sourcepub fn kick_handle(&self) -> Arc<Notify> ⓘ
pub fn kick_handle(&self) -> Arc<Notify> ⓘ
Return a handle that callers can use to trigger an immediate
sweep. Cloning the Arc<Notify> is cheap; every clone
shares the same waker.
Sourcepub fn loop_metrics(&self) -> Arc<LoopMetrics> ⓘ
pub fn loop_metrics(&self) -> Arc<LoopMetrics> ⓘ
Shared handle to this loop’s standardized metrics. Lifecycle owners register this with the cluster registry on spawn.
Sourcepub async fn run(self: Arc<Self>, shutdown: Receiver<bool>)
pub async fn run(self: Arc<Self>, shutdown: Receiver<bool>)
Run the driver until shutdown flips to true.
Sourcepub async fn sweep_once(&self)
pub async fn sweep_once(&self)
Run a single sweep. Exposed for tests that drive the loop
manually rather than through run.
Auto Trait Implementations§
impl Freeze for RebalancerLoop
impl !RefUnwindSafe for RebalancerLoop
impl Send for RebalancerLoop
impl Sync for RebalancerLoop
impl Unpin for RebalancerLoop
impl UnsafeUnpin for RebalancerLoop
impl !UnwindSafe for RebalancerLoop
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
Source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.
Source§impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
Source§unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
Returns whether the given value has been niched. Read more
Source§fn resolve_niched(out: Place<NichedOption<T, N1>>)
fn resolve_niched(out: Place<NichedOption<T, N1>>)
Writes data to
out indicating that a T is niched.Source§impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
Source§fn to_subset(&self) -> Option<SS>
fn to_subset(&self) -> Option<SS>
The inverse inclusion map: attempts to construct
self from the equivalent element of its
superset. Read moreSource§fn is_in_subset(&self) -> bool
fn is_in_subset(&self) -> bool
Checks if
self is actually part of its subset T (and can be converted to it).Source§fn to_subset_unchecked(&self) -> SS
fn to_subset_unchecked(&self) -> SS
Use with care! Same as
self.to_subset but without any property checks. Always succeeds.Source§fn from_subset(element: &SS) -> SP
fn from_subset(element: &SS) -> SP
The inclusion map: converts
self to the equivalent element of its superset.