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

ZKWatcherManager介绍

[英]Watcher Manager to manage watchers.

Metrics

• total_watches: total number of watches that managed by this watcher manager.
• num_child_watches: number of paths that are watched for children changes by this watcher manager.
  [中]监视者管理器，用于管理监视者。
  ####指标
  *'total_watches'：此观察管理器管理的手表总数。
  *'num_child_watches'：此监视程序管理器监视子项更改的路径数。

代码示例

代码示例来源：origin: twitter/distributedlog

public ZKWatcherManager build() {
    return new ZKWatcherManager(_name, _statsLogger);
  }
}

代码示例来源：origin: twitter/distributedlog

@Override
public void process(WatchedEvent event) {
  switch (event.getType()) {
    case None:
      handleKeeperStateEvent(event);
      break;
    case NodeChildrenChanged:
      handleChildWatchEvent(event);
      break;
    default:
      break;
  }
}

代码示例来源：origin: twitter/distributedlog

@Test(timeout = 60000)
public void testRegisterUnregisterWatcher() throws Exception {
  ZKWatcherManager watcherManager = ZKWatcherManager.newBuilder()
      .name("test-register-unregister-watcher")
      .statsLogger(NullStatsLogger.INSTANCE)
  watcherManager.registerChildWatcher(path, watcher);
  watcherManager.unregisterChildWatcher(path, watcher);

代码示例来源：origin: twitter/distributedlog

@Override
public Future<Void> asyncClose() {
  // No-op
  this.zooKeeperClient.getWatcherManager().unregisterChildWatcher(logMetadata.getLogSegmentsPath(), this);
  return Future.Void();
}

代码示例来源：origin: twitter/distributedlog

.registerChildWatcher(logMetadata.getLogSegmentsPath(), this);

代码示例来源：origin: twitter/distributedlog

ZooKeeperClient(String name,
        int sessionTimeoutMs,
        int connectionTimeoutMs,
        String zooKeeperServers,
        RetryPolicy retryPolicy,
        StatsLogger statsLogger,
        int retryThreadCount,
        double requestRateLimit,
        Credentials credentials) {
  this.name = name;
  this.sessionTimeoutMs = sessionTimeoutMs;
  this.zooKeeperServers = zooKeeperServers;
  this.defaultConnectionTimeoutMs = connectionTimeoutMs;
  this.retryPolicy = retryPolicy;
  this.statsLogger = statsLogger;
  this.retryThreadCount = retryThreadCount;
  this.requestRateLimit = requestRateLimit;
  this.credentials = credentials;
  this.watcherManager = ZKWatcherManager.newBuilder()
      .name(name)
      .statsLogger(statsLogger.scope("watcher_manager"))
      .build();
}

代码示例来源：origin: twitter/distributedlog

@Override
public Future<Void> asyncClose() {
  LOG.info("Stopping Readahead worker for {}", fullyQualifiedName);
  running = false;
  this.zkc.getWatcherManager()
      .unregisterChildWatcher(this.logMetadata.getLogSegmentsPath(), this);
  // Aside from unfortunate naming of variables, this allows
  // the currently active long poll to be interrupted and completed
  AsyncNotification notification;
  synchronized (notificationLock) {
    notification = metadataNotification;
    metadataNotification = null;
  }
  if (null != notification) {
    notification.notifyOnOperationComplete();
  }
  if (null == stopPromise) {
    return Future.Void();
  }
  return FutureUtils.ignore(FutureUtils.within(
      stopPromise,
      2 * conf.getReadAheadWaitTime(),
      TimeUnit.MILLISECONDS,
      new TimeoutException("Timeout on waiting for ReadAhead worker to stop " + fullyQualifiedName),
      scheduler,
      fullyQualifiedName));
}

代码示例来源：origin: twitter/distributedlog

.registerChildWatcher(logMetadata.getLogSegmentsPath(), this);