class
ControllerContext
extends AnyRef
Instance Constructors
-
new
ControllerContext
(zkClient: ZkClient, zkSessionTimeout: Int)
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
-
var
allTopics
: Set[String]
-
def
asInstanceOf
[T0]
: T0
-
val
brokerShutdownLock
: AnyRef
-
def
clone
(): AnyRef
-
-
val
controllerLock
: ReentrantLock
-
val
correlationId
: AtomicInteger
-
var
epoch
: Int
-
var
epochZkVersion
: Int
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
finalize
(): Unit
-
def
getClass
(): java.lang.Class[_]
-
def
hashCode
(): Int
-
def
isInstanceOf
[T0]
: Boolean
-
def
liveBrokerIds
: Set[Int]
-
def
liveBrokers
: Set[Broker]
-
def
liveBrokers_=
(brokers: Set[Broker]): Unit
-
def
liveOrShuttingDownBrokerIds
: Set[Int]
-
def
liveOrShuttingDownBrokers
: Set[Broker]
-
def
ne
(arg0: AnyRef): Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
-
var
partitionReplicaAssignment
: Map[TopicAndPartition, Seq[Int]]
-
-
def
partitionsForTopic
(topic: String): Set[TopicAndPartition]
-
def
partitionsOnBroker
(brokerId: Int): Set[TopicAndPartition]
-
var
partitionsUndergoingPreferredReplicaElection
: Set[TopicAndPartition]
-
def
removeTopic
(topic: String): Unit
-
-
def
replicasForTopic
(topic: String): Set[PartitionAndReplica]
-
def
replicasOnBrokers
(brokerIds: Set[Int]): Set[PartitionAndReplica]
-
var
shuttingDownBrokerIds
: Set[Int]
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
def
toString
(): String
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
-
val
zkClient
: ZkClient
-
val
zkSessionTimeout
: Int
Inherited from AnyRef
Inherited from Any