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

ZooKeeperCommandExecutor.<init>介绍

暂无

代码示例

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

private CommandExecutor newZooKeeperCommandExecutor(ProjectManager pm, Executor repositoryWorker,
                          @Nullable SessionManager sessionManager,
                          @Nullable Consumer<CommandExecutor> onTakeLeadership,
                          @Nullable Runnable onReleaseLeadership) {
  final ZooKeeperReplicationConfig zkCfg = (ZooKeeperReplicationConfig) cfg.replicationConfig();
  // Delete the old UUID replica ID which is not used anymore.
  new File(cfg.dataDir(), "replica_id").delete();
  // TODO(trustin): Provide a way to restart/reload the replicator
  //                so that we can recover from ZooKeeper maintenance automatically.
  return new ZooKeeperCommandExecutor(zkCfg, cfg.dataDir(),
                    new StandaloneCommandExecutor(pm,
                                   repositoryWorker,
                                   sessionManager,
                                   null, null),
                    onTakeLeadership, onReleaseLeadership);
}

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

private CommandExecutor newZooKeeperCommandExecutor(ProjectManager pm, Executor repositoryWorker,
                          @Nullable SessionManager sessionManager,
                          @Nullable Consumer<CommandExecutor> onTakeLeadership,
                          @Nullable Runnable onReleaseLeadership) {
  final ZooKeeperReplicationConfig zkCfg = (ZooKeeperReplicationConfig) cfg.replicationConfig();
  // Delete the old UUID replica ID which is not used anymore.
  new File(cfg.dataDir(), "replica_id").delete();
  // TODO(trustin): Provide a way to restart/reload the replicator
  //                so that we can recover from ZooKeeper maintenance automatically.
  return new ZooKeeperCommandExecutor(zkCfg, cfg.dataDir(),
                    new StandaloneCommandExecutor(pm,
                                   repositoryWorker,
                                   sessionManager,
                                   null, null),
                    onTakeLeadership, onReleaseLeadership);
}

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

private CommandExecutor newZooKeeperCommandExecutor(ProjectManager pm, Executor repositoryWorker,
                          @Nullable CentralDogmaSecurityManager securityManager,
                          @Nullable Consumer<CommandExecutor> onTakeLeadership,
                          @Nullable Runnable onReleaseLeadership) {
  final ZooKeeperReplicationConfig zkCfg = (ZooKeeperReplicationConfig) cfg.replicationConfig();
  // Delete the old UUID replica ID which is not used anymore.
  new File(cfg.dataDir(), "replica_id").delete();
  // TODO(trustin): Provide a way to restart/reload the replicator
  //                so that we can recover from ZooKeeper maintenance automatically.
  return new ZooKeeperCommandExecutor(zkCfg, cfg.dataDir(),
                    new StandaloneCommandExecutor(pm,
                                   securityManager,
                                   repositoryWorker,
                                   null, null),
                    onTakeLeadership, onReleaseLeadership);
}

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

Replica(InstanceSpec spec, Map<Integer, ZooKeeperAddress> servers,
    Function<Command<?>, CompletableFuture<?>> delegate, boolean start) throws Exception {
  this.delegate = delegate;
  dataDir = spec.getDataDirectory();
  final int id = spec.getServerId();
  final ZooKeeperReplicationConfig zkCfg = new ZooKeeperReplicationConfig(id, servers);
  rm = new ZooKeeperCommandExecutor(zkCfg, dataDir, new AbstractCommandExecutor(null, null) {
    @Override
    public int replicaId() {
      return id;
    }
    @Override
    protected void doStart(@Nullable Runnable onTakeLeadership,
                @Nullable Runnable onReleaseLeadership) {}
    @Override
    protected void doStop(@Nullable Runnable onReleaseLeadership) {}
    @Override
    @SuppressWarnings("unchecked")
    protected <T> CompletableFuture<T> doExecute(Command<T> command) {
      return (CompletableFuture<T>) delegate.apply(command);
    }
  }, null, null);
  startFuture = start ? rm.start() : null;
}