本文整理了Java中io.fabric8.api.ZooKeeperClusterService类的一些代码示例，展示了ZooKeeperClusterService类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZooKeeperClusterService类的具体详情如下：
包路径：io.fabric8.api.ZooKeeperClusterService
类名称：ZooKeeperClusterService

ZooKeeperClusterService介绍

暂无

代码示例

代码示例来源：origin: jboss-fuse/fabric8

@Override
public List<String> getEnsembleContainers() {
  assertValid();
  return clusterService.get().getEnsembleContainers();
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public void addToCluster(List<String> containers) {
  assertValid();
  clusterService.get().addToCluster(containers);
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public void createCluster(List<String> containers) {
  assertValid();
  clusterService.get().createCluster(containers);
}

代码示例来源：origin: io.fabric8/fabric-commands

builder = builder.zookeeperPassword(clusterService.getZookeeperPassword());
} else {
  builder = builder.zookeeperPassword(zookeeperPassword);
clusterService.addToCluster(containers, builder.build());
ServiceProxy<ZooKeeperClusterService> serviceProxy = ServiceProxy.createServiceProxy(bundleContext, ZooKeeperClusterService.class);
try {
  System.out.println("Updated Zookeeper connection string: " + serviceProxy.getService().getZooKeeperUrl());
} finally {
  serviceProxy.close();

代码示例来源：origin: io.fabric8/fabric-commands

builder = builder.zookeeperPassword(clusterService.getZookeeperPassword());
} else {
  builder = builder.zookeeperPassword(zookeeperPassword);
clusterService.removeFromCluster(containers, builder.build());
ServiceProxy<ZooKeeperClusterService> serviceProxy = ServiceProxy.createServiceProxy(bundleContext, ZooKeeperClusterService.class);
try {
  System.out.println("Updated Zookeeper connection string: " + serviceProxy.getService().getZooKeeperUrl());
} finally {
  serviceProxy.close();

代码示例来源：origin: io.fabric8/fabric-commands

private void applyEnsembleConfiguration() throws Exception {
  Map<String, String> currentConfig = clusterService.getEnsembleConfiguration();
  int currentTickTime = Integer.parseInt(currentConfig.get("tickTime"));
  int currentInitLimit = Integer.parseInt(currentConfig.get("initLimit"));
  int currentSyncLimit = Integer.parseInt(currentConfig.get("syncLimit"));
  String currentDataDir = currentConfig.get("dataDir");
  currentDataDir = currentDataDir.substring(0, currentDataDir.lastIndexOf("/"));
  zooKeeperTickTime = zooKeeperTickTime != 0 ? zooKeeperTickTime : currentTickTime;
  zooKeeperInitLimit = zooKeeperInitLimit != 0 ? zooKeeperInitLimit : currentInitLimit;
  zooKeeperSyncLimit = zooKeeperSyncLimit != 0 ? zooKeeperSyncLimit : currentSyncLimit;
  zooKeeperDataDir = !Strings.isNullOrBlank(zooKeeperDataDir) ? zooKeeperDataDir : currentDataDir;
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public void removeFromCluster(List<String> containers, CreateEnsembleOptions options) {
  assertValid();
  clusterService.get().removeFromCluster(containers, options);
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public String getZookeeperPassword() {
  assertValid();
  return clusterService.get().getZookeeperPassword();
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public String getZooKeeperUrl() {
  assertValid();
  return clusterService.get().getZooKeeperUrl();
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public Map<String, String> getEnsembleConfiguration() throws Exception {
  return clusterService.get().getEnsembleConfiguration();
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public void removeFromCluster(List<String> containers) {
  assertValid();
  clusterService.get().removeFromCluster(containers);
}

代码示例来源：origin: io.fabric8/fabric-commands

@Override
protected Object doExecute() throws Exception {
  TablePrinter printer = new TablePrinter();
  printer.column("id");
  List<String> containers = clusterService.getEnsembleContainers();
  if (containers != null) {
    for (String container : containers) {
      printer.row(container);
    }
  }
  printer.print();
  return null;
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public void createCluster(List<String> containers, CreateEnsembleOptions options) {
  assertValid();
  clusterService.get().createCluster(containers, options);
}

代码示例来源：origin: io.fabric8/fabric-commands

private void applyEnsembleConfiguration() throws Exception {
  Map<String, String> currentConfig = clusterService.getEnsembleConfiguration();
  int currentTickTime = Integer.parseInt(currentConfig.get("tickTime"));
  int currentInitLimit = Integer.parseInt(currentConfig.get("initLimit"));
  int currentSyncLimit = Integer.parseInt(currentConfig.get("syncLimit"));
  String currentDataDir = currentConfig.get("dataDir");
  currentDataDir = currentDataDir.substring(0, currentDataDir.lastIndexOf("/"));
  zooKeeperTickTime = zooKeeperTickTime != 0 ? zooKeeperTickTime : currentTickTime;
  zooKeeperInitLimit = zooKeeperInitLimit != 0 ? zooKeeperInitLimit : currentInitLimit;
  zooKeeperSyncLimit = zooKeeperSyncLimit != 0 ? zooKeeperSyncLimit : currentSyncLimit;
  zooKeeperDataDir = !Strings.isNullOrBlank(zooKeeperDataDir) ? zooKeeperDataDir : currentDataDir;
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public void addToCluster(List<String> containers, CreateEnsembleOptions options) {
  assertValid();
  clusterService.get().addToCluster(containers, options);
}

代码示例来源：origin: io.fabric8/fabric-boot-commands

FabricValidations.validateContainerName(name);
if (!isEnsembleServer) {
  if (clusterService.getEnsembleContainers().isEmpty()) {
    if (!isEnsembleServer) {
      throw new IllegalStateException("The use of the --ensemble-server option is mandatory when creating an initial container");

代码示例来源：origin: io.fabric8/fabric-boot-commands

ServiceProxy<ZooKeeperClusterService> serviceProxy = ServiceProxy.createServiceProxy(bundleContext, ZooKeeperClusterService.class);
try {
  serviceProxy.getService().createCluster(containers, options);
} finally {
  serviceProxy.close();

代码示例来源：origin: jboss-fuse/fabric8

FabricValidations.validateContainerName(name);
if (!isEnsembleServer) {
  if (clusterService.getEnsembleContainers().isEmpty()) {
    if (!isEnsembleServer) {
      throw new IllegalStateException("The use of the --ensemble-server option is mandatory when creating an initial container");

代码示例来源：origin: jboss-fuse/fabric8

ServiceProxy<ZooKeeperClusterService> serviceProxy = ServiceProxy.createServiceProxy(bundleContext, ZooKeeperClusterService.class);
try {
  serviceProxy.getService().createCluster(containers, options);
} finally {
  serviceProxy.close();