Election Utility

Election is a utility with the algorithms for partition leader election:

leaderForControlledShutdown Utility

leaderForControlledShutdown(
  controllerContext: ControllerContext,
  leaderAndIsrs: Seq[(TopicPartition, LeaderAndIsr)]): Seq[ElectionResult]

leaderForControlledShutdown…​FIXME

Note
 leaderForControlledShutdown is used when ZkPartitionStateMachine is requested to doElectLeaderForPartitions for ControlledShutdownPartitionLeaderElectionStrategy.

leaderForControlledShutdown Internal Method

leaderForControlledShutdown(
  partition: TopicPartition,
  leaderAndIsr: LeaderAndIsr,
  shuttingDownBrokerIds: Set[Int],
  controllerContext: ControllerContext): ElectionResult

leaderForControlledShutdown…​FIXME

Note
 leaderForControlledShutdown is used when Election utility is used to leaderForControlledShutdown.

leaderForOffline Utility

leaderForOffline(
  controllerContext: ControllerContext,
  partitionsWithUncleanLeaderElectionState: Seq[(TopicPartition, Option[LeaderAndIsr], Boolean)]): Seq[ElectionResult]

leaderForOffline…​FIXME

Note
 leaderForOffline is used when ZkPartitionStateMachine is requested to doElectLeaderForPartitions for OfflinePartitionLeaderElectionStrategy.

leaderForOffline Internal Method

leaderForOffline(
  partition: TopicPartition,
  leaderAndIsrOpt: Option[LeaderAndIsr],
  uncleanLeaderElectionEnabled: Boolean,
  controllerContext: ControllerContext): ElectionResult

leaderForOffline…​FIXME

Note
 leaderForOffline is used when Election utility is used to leaderForOffline.

leaderForPreferredReplica Utility

leaderForPreferredReplica(
  controllerContext: ControllerContext,
  leaderAndIsrs: Seq[(TopicPartition, LeaderAndIsr)]): Seq[ElectionResult]

leaderForPreferredReplica…​FIXME

Note
 leaderForPreferredReplica is used when ZkPartitionStateMachine is requested to doElectLeaderForPartitions for PreferredReplicaPartitionLeaderElectionStrategy.

leaderForPreferredReplica Internal Method

leaderForPreferredReplica(
  partition: TopicPartition,
  leaderAndIsr: LeaderAndIsr,
  controllerContext: ControllerContext): ElectionResult

leaderForPreferredReplica…​FIXME

Note
 leaderForPreferredReplica is used when Election utility is used to leaderForPreferredReplica.

leaderForReassign Utility

leaderForReassign(
  controllerContext: ControllerContext,
  leaderAndIsrs: Seq[(TopicPartition, LeaderAndIsr)]): Seq[ElectionResult]

leaderForReassign…​FIXME

Note
 leaderForReassign is used when ZkPartitionStateMachine is requested to doElectLeaderForPartitions for ReassignPartitionLeaderElectionStrategy.

leaderForReassign Internal Method

leaderForReassign(
  partition: TopicPartition,
  leaderAndIsr: LeaderAndIsr,
  controllerContext: ControllerContext): ElectionResult

leaderForReassign…​FIXME

Note
 leaderForReassign is used when Election utility is used to leaderForReassign.

results matching ""

    No results matching ""