ReplicaStateMachine

ReplicaStateMachine is…​FIXME

handleStateChanges Method

handleStateChanges(
  replicas: Set[PartitionAndReplica],
  targetState: ReplicaState,
  callbacks: Callbacks): Unit

handleStateChanges…​FIXME

Note
handleStateChanges is used when…​FIXME

shutdown Method

shutdown(): Unit

shutdown…​FIXME

Note
shutdown is used when…​FIXME

startup Method

startup(): Unit

startup…​FIXME

Note
startup is used when…​FIXME

getTopicPartitionStatesFromZk Internal Method

getTopicPartitionStatesFromZk(partitions: Seq[TopicPartition])
: (Map[TopicPartition, LeaderAndIsr], Seq[TopicPartition], Map[TopicPartition, Exception])

getTopicPartitionStatesFromZk…​FIXME

Note
getTopicPartitionStatesFromZk is used when…​FIXME

initializeReplicaState Internal Method

initializeReplicaState(): Unit

initializeReplicaState…​FIXME

Note
initializeReplicaState is used when…​FIXME

doHandleStateChanges Internal Method

doHandleStateChanges(
  replicaId: Int,
  partitions: Seq[TopicPartition],
  targetState: ReplicaState,
  callbacks: Callbacks): Unit

doHandleStateChanges…​FIXME

Note
doHandleStateChanges is used when…​FIXME

results matching ""

    No results matching ""