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

ZooKeeperReplicationConfig介绍

[英]ZooKeeper-based replication configuration.
[中]基于ZooKeeper的复制配置。

代码示例

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

@Override
public boolean equals(Object obj) {
  if (!(obj instanceof ZooKeeperReplicationConfig)) {
    return false;
  }
  if (obj == this) {
    return true;
  }
  final ZooKeeperReplicationConfig that = (ZooKeeperReplicationConfig) obj;
  return serverId() == that.serverId() &&
      servers().equals(that.servers()) &&
      additionalProperties().equals(that.additionalProperties()) &&
      timeoutMillis() == that.timeoutMillis() &&
      numWorkers() == that.numWorkers() &&
      maxLogCount() == that.maxLogCount() &&
      minLogAgeMillis() == that.minLogAgeMillis();
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

private static int findServerId(Map<Integer, ZooKeeperAddress> servers, int currentServerId,
                NetworkInterface iface) {
  for (final Enumeration<InetAddress> ea = iface.getInetAddresses(); ea.hasMoreElements();) {
    currentServerId = findServerId(servers, currentServerId, ea.nextElement());
  }
  return currentServerId;
}

代码示例来源：origin: line/centraldogma

private EmbeddedZooKeeper startZooKeeper() throws Exception {
  logger.info("Starting the ZooKeeper peer ({}) ..", cfg.serverId());
  EmbeddedZooKeeper peer = null;
  boolean success = false;
      out.write((cfg.serverId() + "\n").getBytes(StandardCharsets.US_ASCII));
      final StringBuilder buf = new StringBuilder();
      final String newline = System.lineSeparator();
      final String escapedSecret = jaasValueEscaper.escape(cfg.secret());
      ImmutableList.of("Server", EmbeddedZooKeeper.SASL_SERVER_LOGIN_CONTEXT).forEach(name -> {
        buf.append(name).append(" {").append(newline);
    zkProps.setProperty("clientPort", String.valueOf(cfg.serverAddress().clientPort()));
    cfg.servers().forEach((id, addr) -> {
      zkProps.setProperty(
          "server." + id,

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

private void deleteLogs() throws Exception {
  final List<String> children = curator.getChildren().forPath(absolutePath(LOG_PATH));
  if (children.size() <= cfg.maxLogCount()) {
    return;
  final long minAllowedTimestamp = System.currentTimeMillis() - cfg.minLogAgeMillis();
  final int targetCount = children.size() - cfg.maxLogCount();
  final List<String> deleted = new ArrayList<>(targetCount);
  children.sort(Comparator.comparingLong(Long::parseLong));

代码示例来源：origin: line/centraldogma

"127.0.0.1:" + quorumPeer.getClientPort(), cfg.timeoutMillis(), cfg.timeoutMillis(),
(retryCount, elapsedTimeMs, sleeper) -> {
  return retryPolicy.allowRetry(retryCount, elapsedTimeMs, sleeper);
cfg.numWorkers(), cfg.numWorkers(),
60, TimeUnit.SECONDS, new LinkedTransferQueue<>(),
new DefaultThreadFactory("zookeeper-command-executor", true));

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

@Override
public int replicaId() {
  return cfg.serverId();
}

代码示例来源：origin: line/centraldogma

private void copyZkProperty(Properties zkProps, String key, String defaultValue) {
  zkProps.setProperty(key, cfg.additionalProperties().getOrDefault(key, defaultValue));
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

private EmbeddedZooKeeper startZooKeeper() throws Exception {
  logger.info("Starting the ZooKeeper peer ({}) ..", cfg.serverId());
  EmbeddedZooKeeper peer = null;
  boolean success = false;
      out.write((cfg.serverId() + "\n").getBytes(StandardCharsets.US_ASCII));
      final StringBuilder buf = new StringBuilder();
      final String newline = System.lineSeparator();
      final String escapedSecret = jaasValueEscaper.escape(cfg.secret());
      ImmutableList.of("Server", EmbeddedZooKeeper.SASL_SERVER_LOGIN_CONTEXT).forEach(name -> {
        buf.append(name).append(" {").append(newline);
    zkProps.setProperty("clientPort", String.valueOf(cfg.serverAddress().clientPort()));
    cfg.servers().forEach((id, addr) -> {
      zkProps.setProperty(
          "server." + id,

代码示例来源：origin: line/centraldogma

private void deleteLogs() throws Exception {
  final List<String> children = curator.getChildren().forPath(absolutePath(LOG_PATH));
  if (children.size() <= cfg.maxLogCount()) {
    return;
  final long minAllowedTimestamp = System.currentTimeMillis() - cfg.minLogAgeMillis();
  final int targetCount = children.size() - cfg.maxLogCount();
  final List<String> deleted = new ArrayList<>(targetCount);
  children.sort(Comparator.comparingLong(Long::parseLong));

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

"127.0.0.1:" + quorumPeer.getClientPort(), cfg.timeoutMillis(), cfg.timeoutMillis(),
(retryCount, elapsedTimeMs, sleeper) -> {
  return retryPolicy.allowRetry(retryCount, elapsedTimeMs, sleeper);
cfg.numWorkers(), cfg.numWorkers(),
60, TimeUnit.SECONDS, new LinkedTransferQueue<>(),
new DefaultThreadFactory("zookeeper-command-executor", true));

代码示例来源：origin: line/centraldogma

@Override
public int replicaId() {
  return cfg.serverId();
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

private void copyZkProperty(Properties zkProps, String key, String defaultValue) {
  zkProps.setProperty(key, cfg.additionalProperties().getOrDefault(key, defaultValue));
}

代码示例来源：origin: line/centraldogma

@Override
public boolean equals(Object obj) {
  if (!(obj instanceof ZooKeeperReplicationConfig)) {
    return false;
  }
  if (obj == this) {
    return true;
  }
  final ZooKeeperReplicationConfig that = (ZooKeeperReplicationConfig) obj;
  return serverId() == that.serverId() &&
      servers().equals(that.servers()) &&
      additionalProperties().equals(that.additionalProperties()) &&
      timeoutMillis() == that.timeoutMillis() &&
      numWorkers() == that.numWorkers() &&
      maxLogCount() == that.maxLogCount() &&
      minLogAgeMillis() == that.minLogAgeMillis();
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

private EmbeddedZooKeeper startZooKeeper() throws Exception {
  logger.info("Starting the ZooKeeper peer ({}) ..", cfg.serverId());
  EmbeddedZooKeeper peer = null;
  boolean success = false;
      out.write((cfg.serverId() + "\n").getBytes(StandardCharsets.US_ASCII));
      final StringBuilder buf = new StringBuilder();
      final String newline = System.lineSeparator();
      final String escapedSecret = jaasValueEscaper.escape(cfg.secret());
      ImmutableList.of("Server", EmbeddedZooKeeper.SASL_SERVER_LOGIN_CONTEXT).forEach(name -> {
        buf.append(name).append(" {").append(newline);
    zkProps.setProperty("clientPort", String.valueOf(cfg.serverAddress().clientPort()));
    cfg.servers().forEach((id, addr) -> {
      zkProps.setProperty(
          "server." + id,

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

private void deleteLogs() throws Exception {
  final List<String> children = curator.getChildren().forPath(absolutePath(LOG_PATH));
  if (children.size() <= cfg.maxLogCount()) {
    return;
  final long minAllowedTimestamp = System.currentTimeMillis() - cfg.minLogAgeMillis();
  final int targetCount = children.size() - cfg.maxLogCount();
  final List<String> deleted = new ArrayList<>(targetCount);
  children.sort(Comparator.comparingLong(Long::parseLong));

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

"127.0.0.1:" + quorumPeer.getClientPort(), cfg.timeoutMillis(), cfg.timeoutMillis(),
(retryCount, elapsedTimeMs, sleeper) -> {
  return retryPolicy.allowRetry(retryCount, elapsedTimeMs, sleeper);
cfg.numWorkers(), cfg.numWorkers(),
60, TimeUnit.SECONDS, new LinkedTransferQueue<>(),
new DefaultThreadFactory("zookeeper-command-executor", true));

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server

private static int findServerId(Map<Integer, ZooKeeperAddress> servers, int currentServerId,
                NetworkInterface iface) {
  for (final Enumeration<InetAddress> ea = iface.getInetAddresses(); ea.hasMoreElements();) {
    currentServerId = findServerId(servers, currentServerId, ea.nextElement());
  }
  return currentServerId;
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

@Override
public int replicaId() {
  return cfg.serverId();
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

private void copyZkProperty(Properties zkProps, String key, String defaultValue) {
  zkProps.setProperty(key, cfg.additionalProperties().getOrDefault(key, defaultValue));
}

代码示例来源：origin: com.linecorp.centraldogma/centraldogma-server-shaded

@Override
public boolean equals(Object obj) {
  if (!(obj instanceof ZooKeeperReplicationConfig)) {
    return false;
  }
  if (obj == this) {
    return true;
  }
  final ZooKeeperReplicationConfig that = (ZooKeeperReplicationConfig) obj;
  return serverId() == that.serverId() &&
      servers().equals(that.servers()) &&
      additionalProperties().equals(that.additionalProperties()) &&
      timeoutMillis() == that.timeoutMillis() &&
      numWorkers() == that.numWorkers() &&
      maxLogCount() == that.maxLogCount() &&
      minLogAgeMillis() == that.minLogAgeMillis();
}