- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.uri()
方法的一些代码示例,展示了ZooKeeperClientBuilder.uri()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperClientBuilder.uri()
方法的具体详情如下:
包路径:com.twitter.distributedlog.ZooKeeperClientBuilder
类名称:ZooKeeperClientBuilder
方法名:uri
[英]Set DistributedLog URI.
[中]
代码示例来源:origin: twitter/distributedlog
@Test(timeout = 60000)
public void testAclPermsZkAccessNoConflict() throws Exception {
String namespace = "/" + runtime.getMethodName();
initDlogMeta(namespace, "test-un", "test-stream");
URI uri = createDLMURI(namespace);
ZooKeeperClient zkc = TestZooKeeperClientBuilder.newBuilder()
.name("unpriv")
.uri(uri)
.build();
zkc.get().getChildren(uri.getPath() + "/test-stream", false, new Stat());
zkc.get().getData(uri.getPath() + "/test-stream", false, new Stat());
}
代码示例来源:origin: twitter/distributedlog
public static void unbind(URI uri) throws IOException {
DistributedLogConfiguration conf = new DistributedLogConfiguration();
ZooKeeperClient zkc = ZooKeeperClientBuilder.newBuilder()
.sessionTimeoutMs(conf.getZKSessionTimeoutMilliseconds())
.retryThreadCount(conf.getZKClientNumberRetryThreads())
.requestRateLimit(conf.getZKRequestRateLimit())
.zkAclId(conf.getZkAclId())
.uri(uri)
.build();
byte[] data = new byte[0];
try {
zkc.get().setData(uri.getPath(), data, -1);
} catch (KeeperException ke) {
throw new IOException("Fail to unbound dl metadata on uri " + uri, ke);
} catch (InterruptedException ie) {
throw new IOException("Interrupted when unbinding dl metadata on uri " + uri, ie);
} finally {
zkc.close();
}
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
executorService = Executors.newSingleThreadScheduledExecutor();
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createURI("/"))
.build();
conf = new DistributedLogConfiguration();
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createURI("/"))
.build();
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zooKeeperClient =
TestZooKeeperClientBuilder.newBuilder()
.uri(createDLMURI("/"))
.build();
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder
.newBuilder()
.uri(createDLMURI("/"))
.build();
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zooKeeperClient = TestZooKeeperClientBuilder
.newBuilder()
.uri(createDLMURI("/"))
.build();
conf.setTraceReadAheadMetadataChanges(true);
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createURI("/"))
.sessionTimeoutMs(10000)
.build();
resolver = new ZkMetadataResolver(zkc);
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.name("zkc")
.uri(DLMTestUtil.createDLMURI(zkPort, "/"))
.sessionTimeoutMs(sessionTimeoutMs)
.build();
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.name("zkc")
.uri(DLMTestUtil.createDLMURI(zkPort, "/"))
.sessionTimeoutMs(sessionTimeoutMs)
.build();
}
代码示例来源:origin: twitter/distributedlog
private ZooKeeperClientBuilder clientBuilder(int sessionTimeoutMs)
throws Exception {
return ZooKeeperClientBuilder.newBuilder()
.name("zkc")
.uri(DLMTestUtil.createDLMURI(zkPort, "/"))
.sessionTimeoutMs(sessionTimeoutMs)
.zkServers(zkServers)
.retryPolicy(new BoundExponentialBackoffRetryPolicy(100, 200, 2));
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createURI("/"))
.build();
bkc = BookKeeperClientBuilder.newBuilder().name("bkc")
.dlConfig(dlConf).ledgersPath(ledgersPath).zkc(zkc).build();
allocationExecutor = Executors.newSingleThreadScheduledExecutor();
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createDLMURI("/"))
.sessionTimeoutMs(zkSessionTimeoutMs)
.build();
scheduler = OrderedScheduler.newBuilder()
.name("test-zk-namespace-watcher")
.corePoolSize(1)
.build();
}
代码示例来源:origin: twitter/distributedlog
public SimpleBookKeeperClient(DistributedLogConfiguration conf, URI uri) {
try {
zkc = ZooKeeperClientBuilder.newBuilder()
.sessionTimeoutMs(conf.getZKSessionTimeoutMilliseconds())
.zkAclId(conf.getZkAclId())
.uri(uri)
.build();
BKDLConfig bkdlConfig = BKDLConfig.resolveDLConfig(zkc, uri);
BKDLConfig.propagateConfiguration(bkdlConfig, conf);
bkc = BookKeeperClientBuilder.newBuilder()
.zkc(zkc)
.dlConfig(conf)
.ledgersPath(bkdlConfig.getBkLedgersPath())
.name("dlog")
.build();
} catch (Exception e) {
close();
}
}
public BookKeeperClient client() {
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
scheduler = OrderedScheduler.newBuilder()
.name("test-logsegment-metadata-store-updater")
.corePoolSize(1)
.build();
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createURI("/"))
.sessionTimeoutMs(10000)
.build();
metadataStore = new ZKLogSegmentMetadataStore(conf, zkc, scheduler);
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = ZooKeeperClientBuilder.newBuilder()
.name("zkc")
.uri(createDLMURI("/"))
.sessionTimeoutMs(sessionTimeoutMs)
.zkAclId(null)
.build();
zkc0 = ZooKeeperClientBuilder.newBuilder()
.name("zkc0")
.uri(createDLMURI("/"))
.sessionTimeoutMs(sessionTimeoutMs)
.zkAclId(null)
.build();
lockStateExecutor = OrderedScheduler.newBuilder()
.name("test-scheduer")
.corePoolSize(1)
.build();
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createURI("/"))
.zkServers(zkServers)
.build();
bkc = BookKeeperClientBuilder.newBuilder().name("bkc")
.dlConfig(dlConf).ledgersPath(ledgersPath).zkc(zkc).build();
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = ZooKeeperClientBuilder.newBuilder()
.name("zkc")
.uri(DLMTestUtil.createDLMURI(zkPort, "/"))
.sessionTimeoutMs(sessionTimeoutMs)
.zkServers(zkServers)
.zkAclId(null)
.build();
zkc0 = ZooKeeperClientBuilder.newBuilder()
.name("zkc0")
.uri(DLMTestUtil.createDLMURI(zkPort, "/"))
.sessionTimeoutMs(sessionTimeoutMs)
.zkServers(zkServers)
.zkAclId(null)
.build();
lockStateExecutor = OrderedScheduler.newBuilder()
.corePoolSize(1)
.build();
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createDLMURI("/"))
.sessionTimeoutMs(zkSessionTimeoutMs)
.build();
scheduler = OrderedScheduler.newBuilder()
.name("test-zk-logmetadata-store")
.corePoolSize(1)
.build();
DistributedLogConfiguration conf = new DistributedLogConfiguration();
conf.addConfiguration(baseConf);
this.uri = createDLMURI("/" + runtime.getMethodName());
metadataStore = new ZKLogMetadataStore(conf, uri, zkc, scheduler);
}
代码示例来源:origin: twitter/distributedlog
@Before
public void setup() throws Exception {
zkc = TestZooKeeperClientBuilder.newBuilder()
.uri(createDLMURI("/"))
.sessionTimeoutMs(zkSessionTimeoutMs)
.build();
scheduler = OrderedScheduler.newBuilder()
.name("test-zk-logmetadata-store")
.corePoolSize(2)
.build();
DistributedLogConfiguration conf = new DistributedLogConfiguration();
conf.addConfiguration(baseConf);
this.uri = createDLMURI("/" + runtime.getMethodName());
FederatedZKLogMetadataStore.createFederatedNamespace(uri, zkc);
metadataStore = new FederatedZKLogMetadataStore(conf, uri, zkc, scheduler);
}
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.retryPolicy()方法的一些代码示例,展示了ZooKeeperClien
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.retryThreadCount()方法的一些代码示例,展示了ZooKeeper
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.statsLogger()方法的一些代码示例,展示了ZooKeeperClien
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.zkServers()方法的一些代码示例,展示了ZooKeeperClientB
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.uri()方法的一些代码示例,展示了ZooKeeperClientBuilder
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.build()方法的一些代码示例,展示了ZooKeeperClientBuild
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.name()方法的一些代码示例,展示了ZooKeeperClientBuilde
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.zkAclId()方法的一些代码示例,展示了ZooKeeperClientBui
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.requestRateLimit()方法的一些代码示例,展示了ZooKeeper
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.newBuilder()方法的一些代码示例,展示了ZooKeeperClient
本文整理了Java中com.twitter.distributedlog.ZooKeeperClientBuilder.sessionTimeoutMs()方法的一些代码示例,展示了ZooKeeper
我是一名优秀的程序员,十分优秀!