org.apache.flink.runtime.leaderelection

Interface LeaderElectionDriverFactory

All Known Implementing Classes:

KubernetesLeaderElectionDriverFactory, ZooKeeperLeaderElectionDriverFactory

public interface LeaderElectionDriverFactory

Factory for LeaderElectionDriver.

Method Summary

Modifier and Type	Method and Description
LeaderElectionDriver	create(LeaderElectionDriver.Listener leaderElectionListener) Creates a LeaderElectionDriver for the given leader contender description.

Method Detail

create

LeaderElectionDriver create(LeaderElectionDriver.Listener leaderElectionListener)
                     throws Exception

Creates a LeaderElectionDriver for the given leader contender description. Moreover, it registers the given leader election listener with the service.

Parameters:

leaderElectionListener - listener for the callbacks of the LeaderElectionDriver

Returns:

created LeaderElectionDriver instance

Throws:

Exception - if the creation fails