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

ZooKeeperHostDiscovery.<init>介绍

暂无

代码示例

代码示例来源：origin: com.bazaarvoice.emodb/emodb-sor-hadoop

private static HostDiscovery createZooKeeperHostDiscovery(CuratorFramework curator, String serviceName, MetricRegistry metricRegistry) {
  return new ZooKeeperHostDiscovery(curator, serviceName, metricRegistry);
}

代码示例来源：origin: bazaarvoice/emodb

private static HostDiscovery createZooKeeperHostDiscovery(CuratorFramework curator, String serviceName, MetricRegistry metricRegistry) {
  return new ZooKeeperHostDiscovery(curator, serviceName, metricRegistry);
}

代码示例来源：origin: bazaarvoice/emodb

@Override
public void start() throws Exception {
  _hostDiscovery = new ZooKeeperHostDiscovery(_curator, _endPointAdapter.getServiceName(), _metricRegistry);
  _hostDiscovery.addListener(new HostDiscovery.EndPointListener() {
    @Override
    public void onEndPointAdded(final ServiceEndPoint host) {
      rebuildEndpoints();
    }
    @Override
    public void onEndPointRemoved(ServiceEndPoint endPoint) {
      rebuildEndpoints();
    }
  });
  if (_delayedInvalidationService == null) {
    _delayedInvalidationService = Executors.newSingleThreadExecutor(
        new ThreadFactoryBuilder().setNameFormat("local-dc-invalidation-%d").build());
    _shutdownDelayedInvalidationService = true;
  }
  _delayedInvalidationService.execute(this::pollForDelayedEndPoints);
  // Initialize endpoints by rebuilding
  rebuildEndpoints();
}

代码示例来源：origin: com.bazaarvoice.emodb/emodb-cachemgr

@Override
public void start() throws Exception {
  _hostDiscovery = new ZooKeeperHostDiscovery(_curator, _endPointAdapter.getServiceName(), _metricRegistry);
  _hostDiscovery.addListener(new HostDiscovery.EndPointListener() {
    @Override
    public void onEndPointAdded(final ServiceEndPoint host) {
      rebuildEndpoints();
    }
    @Override
    public void onEndPointRemoved(ServiceEndPoint endPoint) {
      rebuildEndpoints();
    }
  });
  if (_delayedInvalidationService == null) {
    _delayedInvalidationService = Executors.newSingleThreadExecutor(
        new ThreadFactoryBuilder().setNameFormat("local-dc-invalidation-%d").build());
    _shutdownDelayedInvalidationService = true;
  }
  _delayedInvalidationService.execute(this::pollForDelayedEndPoints);
  // Initialize endpoints by rebuilding
  rebuildEndpoints();
}

代码示例来源：origin: bazaarvoice/emodb

@Provides @Singleton @DedupQueueHostDiscovery
HostDiscovery provideDedupQueueHostDiscovery(MultiThreadedServiceFactory<AuthDedupQueueService> serviceFactory,
                       @Global CuratorFramework curator, LifeCycleRegistry lifeCycle) {
  return lifeCycle.manage(new ZooKeeperHostDiscovery(curator, serviceFactory.getServiceName(), _environment.metrics()));
}

代码示例来源：origin: bazaarvoice/emodb

"ZooKeeper host discovery is configured but withZooKeeperHostDiscovery() was not called.");
try (HostDiscovery hostDiscovery = new ZooKeeperHostDiscovery(_curator, _zooKeeperServiceName, metricRegistry)) {
  List<String> hostList = Lists.newArrayList();
  for (ServiceEndPoint endPoint : hostDiscovery.getHosts()) {

代码示例来源：origin: bazaarvoice/emodb

@Provides @Singleton @DatabusHostDiscovery
HostDiscovery provideSubjectDatabusHostDiscovery(MultiThreadedServiceFactory<SubjectDatabus> serviceFactory,
                     @Global CuratorFramework curator, LifeCycleRegistry lifeCycle) {
  return lifeCycle.manage(new ZooKeeperHostDiscovery(curator, serviceFactory.getServiceName(), _environment.metrics()));
}

代码示例来源：origin: com.bazaarvoice.emodb/emodb-common-astyanax

"ZooKeeper host discovery is configured but withZooKeeperHostDiscovery() was not called.");
try (HostDiscovery hostDiscovery = new ZooKeeperHostDiscovery(_curator, _zooKeeperServiceName, metricRegistry)) {
  List<String> hostList = Lists.newArrayList();
  for (ServiceEndPoint endPoint : hostDiscovery.getHosts()) {

代码示例来源：origin: bazaarvoice/emodb

@Override
  protected void run(Bootstrap<EmoConfiguration> bootstrap, Namespace namespace, EmoConfiguration configuration)
      throws Exception {
    String serviceName = namespace.getString("service");

    CuratorFramework curator = configuration.getZooKeeperConfiguration().newCurator();
    curator.start();

    ZooKeeperHostDiscovery hostDiscovery = new ZooKeeperHostDiscovery(curator, serviceName, bootstrap.getMetricRegistry());

    for (ServiceEndPoint endPoint : hostDiscovery.getHosts()) {
      System.out.println(endPoint.getId());
    }

    hostDiscovery.close();
    curator.close();
  }
}

代码示例来源：origin: bazaarvoice/emodb

/** Create an SOA QueueService client for forwarding non-partition-aware clients to the right server. */
@Provides @Singleton @PartitionAwareClient
QueueServiceAuthenticator provideQueueClient(QueueService queueService, Client jerseyClient,
                       @SelfHostAndPort HostAndPort self, @Global CuratorFramework curator,
                       MetricRegistry metricRegistry, HealthCheckRegistry healthCheckRegistry) {
  MultiThreadedServiceFactory<AuthQueueService> serviceFactory = new PartitionAwareServiceFactory<>(
      AuthQueueService.class,
      QueueClientFactory.forClusterAndHttpClient(_configuration.getCluster(), jerseyClient),
      new TrustedQueueService(queueService), self, healthCheckRegistry, metricRegistry);
  AuthQueueService client = ServicePoolBuilder.create(AuthQueueService.class)
      .withHostDiscovery(new ZooKeeperHostDiscovery(curator, serviceFactory.getServiceName(), metricRegistry))
      .withServiceFactory(serviceFactory)
      .withMetricRegistry(metricRegistry)
      .withCachingPolicy(ServiceCachingPolicyBuilder.getMultiThreadedClientPolicy())
      .buildProxy(new ExponentialBackoffRetry(5, 50, 1000, TimeUnit.MILLISECONDS));
  _environment.lifecycle().manage(new ManagedServicePoolProxy(client));
  return QueueServiceAuthenticator.proxied(client);
}

代码示例来源：origin: bazaarvoice/ostrich

ServicePool<CalculatorService> pool = ServicePoolBuilder.create(CalculatorService.class)
    .withServiceFactory(serviceFactory)
    .withHostDiscovery(new ZooKeeperHostDiscovery(curator, serviceFactory.getServiceName(), metrics))
    .withMetricRegistry(metrics)
    .withCachingPolicy(cachingPolicy)

代码示例来源：origin: bazaarvoice/emodb

@Override
  public ScanWorkflow get() {
    QueueClientFactory factory = QueueClientFactory.forClusterAndHttpClient(_cluster, _client);
    // Don't use the local queue service; create a client to call out to the live EmoDB application.
    AuthQueueService authService = ServicePoolBuilder.create(AuthQueueService.class)
        .withServiceFactory(factory)
        .withHostDiscovery(new ZooKeeperHostDiscovery(_curator, factory.getServiceName(), _metricRegistry))
        .withMetricRegistry(_metricRegistry)
        .buildProxy(new ExponentialBackoffRetry(5, 50, 1000, TimeUnit.MILLISECONDS));
    _environment.lifecycle().manage(new ManagedServicePoolProxy(authService));
    QueueService service = QueueServiceAuthenticator.proxied(authService)
        .usingCredentials(_apiKey);
    return new QueueScanWorkflow(service, _pendingScanRangeQueueName, _completeScanRangeQueueName);
  }
}

代码示例来源：origin: bazaarvoice/ostrich

DictionaryService service = ServicePoolBuilder.create(DictionaryService.class)
    .withServiceFactory(serviceFactory)
    .withHostDiscovery(new ZooKeeperHostDiscovery(curator, serviceFactory.getServiceName(), metrics))
    .withMetricRegistry(metrics)
    .withCachingPolicy(cachingPolicy)

代码示例来源：origin: bazaarvoice/emodb

@Override
  public ScanWorkflow get() {
    QueueClientFactory factory = QueueClientFactory.forClusterAndHttpClient(_cluster, _client);
    // Don't use the local queue service; create a client to call out to the live EmoDB application.
    AuthQueueService authService = ServicePoolBuilder.create(AuthQueueService.class)
        .withServiceFactory(factory)
        .withHostDiscovery(new ZooKeeperHostDiscovery(_curator, factory.getServiceName(), _metricRegistry))
        .withMetricRegistry(_metricRegistry)
        .buildProxy(new ExponentialBackoffRetry(5, 50, 1000, TimeUnit.MILLISECONDS));
    _environment.lifecycle().manage(new ManagedServicePoolProxy(authService));
    QueueService service = QueueServiceAuthenticator.proxied(authService)
        .usingCredentials(_apiKey);
    return new QueueScanWorkflow(service, _pendingScanRangeQueueName, _completeScanRangeQueueName);
  }
}

代码示例来源：origin: bazaarvoice/ostrich

CalculatorService service = ServicePoolBuilder.create(CalculatorService.class)
    .withServiceFactory(serviceFactory)
    .withHostDiscovery(new ZooKeeperHostDiscovery(curator, serviceFactory.getServiceName(), metrics))
    .withMetricRegistry(metrics)
    .withCachingPolicy(cachingPolicy)