[GitHub] [flink] zentol commented on a diff in pull request #22384: [FLINK-31776][runtime] Introduces LeaderElection sub-interface

["zentol (via GitHub)" <gi...@apache.org>]

zentol commented on code in PR #22384:
URL: https://github.com/apache/flink/pull/22384#discussion_r1170045731


##########
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/LeaderElectionService.java:
##########
@@ -53,24 +50,35 @@ public interface LeaderElectionService {
     void stop() throws Exception;
 
     /**
-     * Confirms that the {@link LeaderContender} has accepted the leadership identified by the given
-     * leader session id. It also publishes the leader address under which the leader is reachable.
-     *
-     * <p>The rational behind this method is to establish an order between setting the new leader
-     * session ID in the {@link LeaderContender} and publishing the new leader session ID as well as
-     * the leader address to the leader retrieval services.
-     *
-     * @param leaderSessionID The new leader session ID
-     * @param leaderAddress The address of the new leader
+     * {@code LeaderElection} serves as a proxy between {@code LeaderElectionService} and {@link
+     * LeaderContender}.
      */
-    void confirmLeadership(UUID leaderSessionID, String leaderAddress);
+    interface LeaderElection {

Review Comment:
   Cant hurt to separate them :shrug:



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org