Package | Description |
---|---|
org.apache.zookeeper.server |
ZooKeeper server theory of operation
|
org.apache.zookeeper.server.admin | |
org.apache.zookeeper.server.command | |
org.apache.zookeeper.server.quorum |
Modifier and Type | Field and Description |
---|---|
protected ZooKeeperServer |
ZooKeeperServerBean.zks |
protected ZooKeeperServer |
ServerCnxnFactory.zkServer |
Modifier and Type | Method and Description |
---|---|
ZooKeeperServer |
ServerCnxnFactory.getZooKeeperServer() |
Modifier and Type | Method and Description |
---|---|
void |
ServerCnxnFactory.setZooKeeperServer(ZooKeeperServer zks) |
void |
ServerCnxnFactory.startup(ZooKeeperServer zkServer) |
abstract void |
ServerCnxnFactory.startup(ZooKeeperServer zkServer,
boolean startServer) |
void |
NettyServerCnxnFactory.startup(ZooKeeperServer zks,
boolean startServer) |
void |
NIOServerCnxnFactory.startup(ZooKeeperServer zks,
boolean startServer) |
Constructor and Description |
---|
ConnectionBean(ServerCnxn connection,
ZooKeeperServer zk) |
FinalRequestProcessor(ZooKeeperServer zks) |
NIOServerCnxn(ZooKeeperServer zk,
SocketChannel sock,
SelectionKey sk,
NIOServerCnxnFactory factory,
org.apache.zookeeper.server.NIOServerCnxnFactory.SelectorThread selectorThread) |
ObserverBean(Observer observer,
ZooKeeperServer zks) |
PrepRequestProcessor(ZooKeeperServer zks,
RequestProcessor nextProcessor) |
SyncRequestProcessor(ZooKeeperServer zks,
RequestProcessor nextProcessor) |
ZooKeeperServerBean(ZooKeeperServer zks) |
Modifier and Type | Method and Description |
---|---|
CommandResponse |
Commands.CnxnStatResetCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.ConfCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.ConsCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.DirsCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.DumpCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.EnvCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.GetTraceMaskCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.IsroCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.MonitorCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.RuokCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.SetTraceMaskCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.SrvrCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.StatCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.StatResetCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.WatchCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.WatchesByPathCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.WatchSummaryCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Command.run(ZooKeeperServer zkServer,
Map<String,String> kwargs)
Run this command.
|
static CommandResponse |
Commands.runCommand(String cmdName,
ZooKeeperServer zkServer,
Map<String,String> kwargs)
Run the registered command with name cmdName.
|
void |
JettyAdminServer.setZooKeeperServer(ZooKeeperServer zkServer)
Set the ZooKeeperServer that will be used to run Commands.
|
void |
DummyAdminServer.setZooKeeperServer(ZooKeeperServer zkServer) |
void |
AdminServer.setZooKeeperServer(ZooKeeperServer zkServer) |
Modifier and Type | Field and Description |
---|---|
protected ZooKeeperServer |
AbstractFourLetterCommand.zkServer |
Modifier and Type | Method and Description |
---|---|
boolean |
CommandExecutor.execute(ServerCnxn serverCnxn,
PrintWriter pwriter,
int commandCode,
ZooKeeperServer zkServer,
ServerCnxnFactory factory)
This class decides which command to be executed and then executes
|
void |
AbstractFourLetterCommand.setZkServer(ZooKeeperServer zkServer) |
Modifier and Type | Class and Description |
---|---|
class |
FollowerZooKeeperServer
Just like the standard ZooKeeperServer.
|
class |
LeaderZooKeeperServer
Just like the standard ZooKeeperServer.
|
class |
LearnerZooKeeperServer
Parent class for all ZooKeeperServers for Learners
|
class |
ObserverZooKeeperServer
A ZooKeeperServer for the Observer node type.
|
class |
QuorumZooKeeperServer
Abstract base class for all ZooKeeperServers that participate in
a quorum.
|
class |
ReadOnlyZooKeeperServer
A ZooKeeperServer which comes into play when peer is partitioned from the
majority.
|
Modifier and Type | Method and Description |
---|---|
ZooKeeperServer |
QuorumPeer.getActiveServer() |
Modifier and Type | Method and Description |
---|---|
void |
QuorumPeer.setZooKeeperServer(ZooKeeperServer zks) |
protected void |
ReadOnlyZooKeeperServer.unregisterJMX(ZooKeeperServer zks) |
Constructor and Description |
---|
FollowerBean(Follower follower,
ZooKeeperServer zks) |
LeaderBean(Leader leader,
ZooKeeperServer zks) |
ReadOnlyBean(ZooKeeperServer zks) |
ReadOnlyRequestProcessor(ZooKeeperServer zks,
RequestProcessor nextProcessor) |
Copyright © 2008–2019 The Apache Software Foundation. All rights reserved.