gpt4 book ai didi

com.palominolabs.benchpress.config.ZookeeperConfig.getBasePath()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-17 12:09:31 28 4
gpt4 key购买 nike

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

ZookeeperConfig.getBasePath介绍

暂无

代码示例

代码示例来源:origin: palominolabs/benchpress

@Provides
@Singleton
public ServiceDiscovery<WorkerMetadata> getServiceDiscovery(ZookeeperConfig zookeeperConfig,
    CuratorFramework curatorFramework, InstanceSerializerFactory instanceSerializerFactory) {
  return ServiceDiscoveryBuilder.builder(WorkerMetadata.class)
      .basePath(zookeeperConfig.getBasePath())
      .client(curatorFramework)
      .serializer(instanceSerializerFactory
          .getInstanceSerializer(new TypeReference<ServiceInstance<WorkerMetadata>>() {}))
      .build();
}

代码示例来源:origin: palominolabs/benchpress

@Before
public void setUp() throws Exception {
  testingServer = new TestingServer();
  Injector injector = Guice.createInjector(new AbstractModule() {
    @Override
    protected void configure() {
      binder().requireExplicitBindings();
      install(new TestConfigModule(testingServer.getPort()));
      bind(WorkerAdvertiser.class);
      install(new CuratorModule());
      bind(SliceRunner.class);
      bind(TaskProgressClient.class).to(NoOpTaskProgressClient.class);
      install(new TaskPluginRegistryModule());
      install(new IpcJsonModule());
    }
  });
  injector.injectMembers(this);
  curatorLifecycleHook.start();
  // TODO make ZookeeperConfig not use config-magic so we don't duplicate ServiceDiscovery setup
  serviceDiscovery = ServiceDiscoveryBuilder.builder(WorkerMetadata.class)
    .basePath(zookeeperConfig.getBasePath())
    .client(curatorFramework)
    .serializer(injector.getInstance(InstanceSerializerFactory.class)
      .getInstanceSerializer(new TypeReference<ServiceInstance<WorkerMetadata>>() {}))
    .build();
  serviceDiscovery.start();
}

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