co.cask.tigon.guice.ZKClientModule类的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 12:45:33 27 4

@Override
protected void configure() {
 /**
  * ZKClientService is provided by the provider method
  * {@link #provideZKClientService(co.cask.tigon.conf.CConfiguration)}.
  */
 bind(ZKClient.class).to(ZKClientService.class);
}

static Injector createGuiceInjector(CConfiguration cConf, Configuration hConf) {
 return Guice.createInjector(
  new ConfigModule(cConf, hConf),
  new IOModule(),
  new ZKClientModule(),
  createDataFabricModule(),
  new LocationRuntimeModule().getDistributedModules(),
  new DiscoveryRuntimeModule().getDistributedModules(),
  new MetricsClientRuntimeModule().getDistributedModules()
 );
}

private static List<Module> createModules(CConfiguration cConf, Configuration hConf) {
 return ImmutableList.of(
  new DataFabricDistributedModule(),
  new ConfigModule(cConf, hConf),
  new IOModule(),
  new ZKClientModule(),
  new TwillModule(),
  new LocationRuntimeModule().getDistributedModules(),
  new DiscoveryRuntimeModule().getDistributedModules(),
  new ProgramRunnerRuntimeModule().getDistributedModules(),
  new MetricsClientModule(),
  new AbstractModule() {
   @Override
   protected void configure() {
    bind(FlowOperations.class).to(DistributedFlowOperations.class);
   }
  }
 );
}

protected Module createModule(final TwillContext context) {
 return Modules.combine(
  new ConfigModule(cConf, hConf),
  new IOModule(),
  new ZKClientModule(),
  new MetricsClientRuntimeModule().getDistributedModules(),
  new LocationRuntimeModule().getDistributedModules(),
  new DiscoveryRuntimeModule().getDistributedModules(),
  new DataFabricModules().getDistributedModules(),
  new AbstractModule() {
   @Override
   protected void configure() {
    // For Binding queue stuff
    bind(QueueReaderFactory.class).in(Scopes.SINGLETON);
    // For program loading
    install(createProgramFactoryModule());
    // For binding DataSet transaction stuff
    install(new DataFabricFacadeModule());
    bind(ServiceAnnouncer.class).toInstance(new ServiceAnnouncer() {
     @Override
     public Cancellable announce(String serviceName, int port) {
      return context.announce(serviceName, port);
     }
    });
   }
  }
 );
}

27 4 0

• homebrew - 错误 : Cask 'java7' is unavailable: No Cask with this name exists

  由于其中一个项目使用的是 Java 1.7，我希望该版本能够手动运行 mrunit 测试用例。我在我的机器上安装了 java8，还想要 java7。当我运行 brew cask install jav

• homebrew - 由于 Cask 错误，无法运行 `brew doctor` 或 `brew list --cask`

  我刚刚安装了一个新的 Cask，然后运行了 brew doctor，它返回了 Error: Cask 'java' is unreadable: undefined method undent' fo

• macos - 当我命令 "brew cask install virtualbox"或 "brew cask search google-chrome"时发生 Homebrew 错误

  我正在尝试使用brew-cask安装virtual box，但这会返回这种错误，并且我无法安装virtualbox。我使用 MacOSX Lion 10.7.5 和 homebrew 0.9.5，ru

• 自酿: cask 'java'定义无效

  最近更新 cask 时，我开始出现以下错误: Error: Cask 'java' definition is invalid: Token '{:v1=>"java"}' in header lin

• ansible - 如何使用ansible安装特定版本的brew cask formula？

  如何使用 ansible 安装特定版本的自制 cask 配方？例如，vagrant 2.2.6 而最新可用的是 2.2.7。 最佳答案 使用较新版本的 Homebrew cask命令已被删除并导致错误

• homebrew - 如何卸载 Homebrew Cask

  我按照 http://caskroom.io/ 中的描述安装了 Homebrew Cask 用于踢球.它归结为以下命令: $ brew install caskroom/cask/brew-cask

• co.cask.tephra.runtime.ZKModule类的使用及代码示例

  本文整理了Java中co.cask.tephra.runtime.ZKModule类的一些代码示例，展示了ZKModule类的具体用法。这些代码示例主要来源于Github/Stackoverflow/

• co.cask.tigon.guice.ZKClientModule类的使用及代码示例

  本文整理了Java中co.cask.tigon.guice.ZKClientModule类的一些代码示例，展示了ZKClientModule类的具体用法。这些代码示例主要来源于Github/Stack

• homebrew - 从终端启动 brew cask 应用程序

  我使用 brew cask 安装了信号(brew cask install signal) 我希望能够通过键入 signal 从终端启动 GUI 应用程序(例如:要运行 emacs 的 GUI [使用

• homebrew - 更改 homebrew-cask 安装目录

  我最近安装了 homebrew-cask，我看到的一件事是它默认将应用程序安装到以下目录中: 版本包下载 => /opt/homebrew-cask/Caskroom/ 示例:/opt/homebre

• macos - 列出可使用 brew-cask 安装的应用程序

  我想知道我的哪些应用程序可以使用 brew cask 安装命令。 我该怎么做？ 规范 我想要做的是从 /Applications 中的所有应用程序中提取 brew-cask 上也可用的应用程序并列出他

• homebrew-cask - 如何手动卸载 Homebrew 桶？

  我安装了一个 Homebrew 桶，当我尝试卸载它时，它给了我一个错误: $ brew cask uninstall julia Error: Cask 'julia' definition is i

• macos - 升级所有通过 Homebrew Cask 安装的木桶

  我使用Homebrew Cask在 OS X 上安装应用程序。如何升级所有已安装的 casks？ 最佳答案 现在 Homebrew Cask 终于有了官方升级机制(具体实现请参见Issue 3396)

• homebrew - 我尝试安装的任何木桶均出现 "No available cask"错误

  嗯，我刚刚更新了我的 brew 并在执行 brew tap phinze/cask 命令后在我的机器上安装了 brew-cask 公式。然后我用brew cask install vagrant来安装

• macos - `brew cask install` 使用的真实位置是哪个目录？

  哪个目录是brew cask install使用的真实位置？ 我想找到应用程序的真实位置，而不是/Application中的符号链接(symbolic link) 最佳答案 您可以在可用的 Casks

• co.cask.cdap.api.workflow.WorkflowToken类的使用及代码示例

  本文整理了Java中co.cask.cdap.api.workflow.WorkflowToken类的一些代码示例，展示了WorkflowToken类的具体用法。这些代码示例主要来源于Github/S

• co.cask.cdap.api.workflow.WorkflowSpecification类的使用及代码示例

  本文整理了Java中co.cask.cdap.api.workflow.WorkflowSpecification类的一些代码示例，展示了WorkflowSpecification类的具体用法。这些代

• co.cask.cdap.common.guice.ZKClientModule类的使用及代码示例

  本文整理了Java中co.cask.cdap.common.guice.ZKClientModule类的一些代码示例，展示了ZKClientModule类的具体用法。这些代码示例主要来源于Github

• co.cask.cdap.common.guice.ZKDiscoveryModule类的使用及代码示例

  本文整理了Java中co.cask.cdap.common.guice.ZKDiscoveryModule类的一些代码示例，展示了ZKDiscoveryModule类的具体用法。这些代码示例主要来源于

• co.cask.cdap.common.zookeeper.ZKExtOperations类的使用及代码示例

  本文整理了Java中co.cask.cdap.common.zookeeper.ZKExtOperations类的一些代码示例，展示了ZKExtOperations类的具体用法。这些代码示例主要来源于