public abstract class ZkClientConnectionStrategy extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
ZkClientConnectionStrategy.ConnectedListener |
static interface |
ZkClientConnectionStrategy.DisconnectedListener |
static interface |
ZkClientConnectionStrategy.ZkUpdate |
Constructor and Description |
---|
ZkClientConnectionStrategy() |
Modifier and Type | Method and Description |
---|---|
void |
addConnectedListener(ZkClientConnectionStrategy.ConnectedListener listener) |
void |
addDisconnectedListener(ZkClientConnectionStrategy.DisconnectedListener listener) |
abstract void |
connect(String zkServerAddress,
int zkClientTimeout,
org.apache.zookeeper.Watcher watcher,
ZkClientConnectionStrategy.ZkUpdate updater) |
void |
connected() |
protected SolrZooKeeper |
createSolrZooKeeper(String serverAddress,
int zkClientTimeout,
org.apache.zookeeper.Watcher watcher) |
void |
disconnected() |
ZkCredentialsProvider |
getZkCredentialsToAddAutomatically() |
boolean |
hasZkCredentialsToAddAutomatically() |
abstract void |
reconnect(String serverAddress,
int zkClientTimeout,
org.apache.zookeeper.Watcher watcher,
ZkClientConnectionStrategy.ZkUpdate updater) |
void |
setZkCredentialsToAddAutomatically(ZkCredentialsProvider zkCredentialsToAddAutomatically) |
public abstract void connect(String zkServerAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher, ZkClientConnectionStrategy.ZkUpdate updater) throws IOException, InterruptedException, TimeoutException
public abstract void reconnect(String serverAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher, ZkClientConnectionStrategy.ZkUpdate updater) throws IOException, InterruptedException, TimeoutException
public void disconnected()
public void connected()
public void addDisconnectedListener(ZkClientConnectionStrategy.DisconnectedListener listener)
public void addConnectedListener(ZkClientConnectionStrategy.ConnectedListener listener)
public void setZkCredentialsToAddAutomatically(ZkCredentialsProvider zkCredentialsToAddAutomatically)
public boolean hasZkCredentialsToAddAutomatically()
public ZkCredentialsProvider getZkCredentialsToAddAutomatically()
protected SolrZooKeeper createSolrZooKeeper(String serverAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher) throws IOException
IOException
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.