Package | Description |
---|---|
org.apache.zookeeper.server |
ZooKeeper server theory of operation
ZooKeeperServer is designed to work in standalone mode and also
be extensible so that it can be used to implement the quorum based
version of ZooKeeper.
|
org.apache.zookeeper.server.admin | |
org.apache.zookeeper.server.auth | |
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) |
RequestThrottler(ZooKeeperServer zks) |
ServerCnxn(ZooKeeperServer zkServer) |
SyncRequestProcessor(ZooKeeperServer zks,
RequestProcessor nextProcessor) |
ZooKeeperServerBean(ZooKeeperServer zks) |
Modifier and Type | Method and Description |
---|---|
CommandResponse |
Command.run(ZooKeeperServer zkServer,
Map<String,String> kwargs)
Run this command.
|
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.DigestCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.GetTraceMaskCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.InitialConfigurationCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.IsroCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.LastSnapshotCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.LeaderCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.MonitorCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.ObserverCnxnStatResetCommand.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.SyncedObserverConsCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.SystemPropertiesCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
CommandResponse |
Commands.VotingViewCommand.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 |
Commands.ZabStateCommand.run(ZooKeeperServer zkServer,
Map<String,String> kwargs) |
static CommandResponse |
Commands.runCommand(String cmdName,
ZooKeeperServer zkServer,
Map<String,String> kwargs)
Run the registered command with name cmdName.
|
void |
DummyAdminServer.setZooKeeperServer(ZooKeeperServer zkServer) |
void |
JettyAdminServer.setZooKeeperServer(ZooKeeperServer zkServer)
Set the ZooKeeperServer that will be used to run Commands.
|
void |
AdminServer.setZooKeeperServer(ZooKeeperServer zkServer) |
Modifier and Type | Method and Description |
---|---|
ZooKeeperServer |
ServerAuthenticationProvider.ServerObjs.getZks() |
Constructor and Description |
---|
ServerObjs(ZooKeeperServer zks,
ServerCnxn cnxn) |
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–2020 The Apache Software Foundation. All rights reserved.