gpt4 book ai didi

com.twitter.common.zookeeper.testing.ZooKeeperTestServer.createClient()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-13 11:04:15 26 4
gpt4 key购买 nike

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

ZooKeeperTestServer.createClient介绍

[英]Returns a new unauthenticated zookeeper client connected to the in-process zookeeper server with the default session timeout.
[中]返回一个新的未经验证的zookeeper客户端,该客户端连接到进程中的zookeeper服务器,默认会话超时。

代码示例

代码示例来源:origin: com.twitter.common/zookeeper-testing

/**
 * Returns a new unauthenticated zookeeper client connected to the in-process zookeeper server
 * with the default session timeout.
 */
protected final ZooKeeperClient createZkClient() {
 return zkTestServer.createClient();
}

代码示例来源:origin: com.twitter.common/zookeeper-testing

/**
  * Returns a new authenticated zookeeper client connected to the in-process zookeeper server with
  * the default session timeout and the custom chroot path.
  */
 protected final ZooKeeperClient createZkClient(String chrootPath) {
  return zkTestServer.createClient(chrootPath);
 }
}

代码示例来源:origin: com.twitter.common/zookeeper-testing

/**
 * Returns a new authenticated zookeeper client connected to the in-process zookeeper server with
 * the default session timeout.
 */
protected final ZooKeeperClient createZkClient(Credentials credentials) {
 return zkTestServer.createClient(credentials);
}

代码示例来源:origin: com.twitter.common/zookeeper-testing

/**
 * Returns a new unauthenticated zookeeper client connected to the in-process zookeeper server
 * with a custom {@code sessionTimeout}.
 */
protected final ZooKeeperClient createZkClient(Amount<Integer, Time> sessionTimeout) {
 return zkTestServer.createClient(sessionTimeout);
}

代码示例来源:origin: com.twitter.common/zookeeper-testing

/**
 * Returns a new unauthenticated zookeeper client connected to the in-process zookeeper server
 * with the default session timeout.
 */
public final ZooKeeperClient createClient() {
 return createClient(defaultSessionTimeout);
}

代码示例来源:origin: com.twitter.common/zookeeper-testing

/**
 * Returns a new authenticated zookeeper client connected to the in-process zookeeper server with
 * a custom {@code sessionTimeout}.
 */
protected final ZooKeeperClient createZkClient(Amount<Integer, Time> sessionTimeout,
  Credentials credentials) {
 return zkTestServer.createClient(sessionTimeout, credentials);
}

代码示例来源:origin: com.twitter.common/zookeeper-testing

/**
 * Returns a new authenticated zookeeper client connected to the in-process zookeeper server with
 * a custom {@code sessionTimeout}.
 */
public final ZooKeeperClient createClient(Amount<Integer, Time> sessionTimeout,
  Credentials credentials) {
   return createClient(sessionTimeout, credentials, Optional.<String>absent());
  }

代码示例来源:origin: com.twitter.common/zookeeper-testing

/**
 * Returns a new unauthenticated zookeeper client connected to the in-process zookeeper server
 * with the default session timeout and a custom {@code chrootPath}.
 */
public final ZooKeeperClient createClient(String chrootPath) {
 return createClient(defaultSessionTimeout, Credentials.NONE, Optional.of(chrootPath));
}

代码示例来源:origin: com.twitter.common/zookeeper-testing

/**
 * Returns a new authenticated zookeeper client connected to the in-process zookeeper server with
 * the default session timeout.
 */
public final ZooKeeperClient createClient(Credentials credentials) {
 return createClient(defaultSessionTimeout, credentials, Optional.<String>absent());
}

代码示例来源:origin: com.twitter.common/zookeeper-testing

/**
 * Returns a new unauthenticated zookeeper client connected to the in-process zookeeper server
 * with a custom {@code sessionTimeout}.
 */
public final ZooKeeperClient createClient(Amount<Integer, Time> sessionTimeout) {
 return createClient(sessionTimeout, Credentials.NONE, Optional.<String>absent());
}

代码示例来源:origin: com.twitter.common.zookeeper.guice/client

@Override
 public ZooKeeperClient get() {
  ZooKeeperTestServer zooKeeperServer;
  try {
   zooKeeperServer = new ZooKeeperTestServer(0, shutdownRegistry);
   zooKeeperServer.startNetwork();
  } catch (IOException e) {
   throw Throwables.propagate(e);
  } catch (InterruptedException e) {
   throw Throwables.propagate(e);
  }
  LOG.info("Embedded zookeeper cluster started on port " + zooKeeperServer.getPort());
  return zooKeeperServer.createClient(config.sessionTimeout, config.credentials);
 }
}

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com