Rename: Use start/stop dispatching terminology

Signed-off-by: Mathias L. Baumann <[email protected]>

Author: Marenz

src/frequenz/dispatch/_dispatcher.py

@@ -192,7 +192,7 @@ def start(self) -> None:
         """Start the local dispatch service."""
         self._bg_service.start()
 
-    async def manage(
+    async def start_dispatching(
         self,
         dispatch_type: str,
         *,
@@ -233,6 +233,16 @@ def id_identity(dispatch: Dispatch) -> int:
         self._actor_dispatchers[dispatch_type] = dispatcher
         dispatcher.start()
 
+    async def stop_dispatching(self, dispatch_type: str) -> None:
+        """Stop managing actors for a given dispatch type.
+
+        Args:
+            dispatch_type: The type of the dispatch to stop managing.
+        """
+        dispatcher = self._actor_dispatchers.pop(dispatch_type, None)
+        if dispatcher is not None:
+            await dispatcher.stop()
+
     @property
     def client(self) -> Client:
         """Return the client."""

tests/test_mananging_actor.py

@@ -259,7 +259,7 @@ async def test_manage_abstraction(
     generator: DispatchGenerator,
     strategy: MergeByIdentity | None,
 ) -> None:
-    """Test Dispatcher.manage sets up correctly."""
+    """Test Dispatcher.start_dispatching sets up correctly."""
     identity: Callable[[Dispatch], int] = (
         strategy.identity if strategy else lambda dispatch: dispatch.id
     )
@@ -295,7 +295,7 @@ async def new_mock_receiver(
             "frequenz.dispatch._dispatcher.Dispatcher.new_running_state_event_receiver",
             new_mock_receiver,
         ):
-            await dispatcher.manage(
+            await dispatcher.start_dispatching(
                 dispatch_type="MANAGE_TEST",
                 actor_factory=MockActor,
                 merge_strategy=strategy,