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

ZooKeeperGroup.<init>介绍

暂无

代码示例

代码示例来源：origin: io.fabric8/fabric-groups

@Override
public <T extends NodeState> Group<T> createGroup(String path, Class<T> clazz) {
  return new ZooKeeperGroup<T>(curator, path, clazz);
}

代码示例来源：origin: io.fabric8/fabric-groups

@Override
public <T extends NodeState> Group<T> createGroup(String path, Class<T> clazz) {
  return new ZooKeeperGroup<T>(curator, path, clazz);
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public <T extends NodeState> Group<T> createGroup(String path, Class<T> clazz) {
  return new ZooKeeperGroup<T>(curator, path, clazz);
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public <T extends NodeState> Group<T> createGroup(String path, Class<T> clazz) {
  return new ZooKeeperGroup<T>(curator, path, clazz);
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public <T extends NodeState> Group<T> createGroup(String path, Class<T> clazz, ThreadFactory threadFactory) {
  return new ZooKeeperGroup<T>(curator, path, clazz, threadFactory);
}

代码示例来源：origin: jboss-fuse/fabric8

protected Group<T> createGroup(CuratorFramework client, String path, Class<T> clazz) {
  return new ZooKeeperGroup<T>(client, path, clazz);
}

代码示例来源：origin: io.fabric8/fabric-groups

protected Group<T> createGroup(CuratorFramework client, String path, Class<T> clazz) {
  return new ZooKeeperGroup<T>(client, path, clazz);
}

代码示例来源：origin: jboss-fuse/fabric8

@Override
public <T extends NodeState> Group<T> createGroup(String path, Class<T> clazz, ThreadFactory threadFactory) {
  return new ZooKeeperGroup<T>(curator, path, clazz, threadFactory);
}

代码示例来源：origin: io.fabric8/fabric-partition

public TaskCoordinator(TaskContext context, WorkItemRepository repository, BalancingPolicy balancingPolicy, CuratorFramework curator) {
  this.context = context;
  this.repository = repository;
  this.balancingPolicy = balancingPolicy;
  this.curator = curator;
  this.group = new ZooKeeperGroup<WorkerNode>(curator, ZkPath.TASK.getPath(context.getId()), WorkerNode.class);
}

代码示例来源：origin: io.fabric8.insight/insight-influxdb-metrics

private void activateInternal() {
  group = new ZooKeeperGroup<InfluxDBNode>(curator.get(), INFLUXDB_CLUSTER_PATH, InfluxDBNode.class);
  group.add(this);
  group.start();
}

代码示例来源：origin: jboss-fuse/fabric8

private void activateInternal() {
  group = new ZooKeeperGroup<InfluxDBNode>(curator.get(), INFLUXDB_CLUSTER_PATH, InfluxDBNode.class);
  group.add(this);
  group.start();
}

代码示例来源：origin: io.fabric8/fabric-git

@Activate
void activate() throws IOException {
  activateComponent();
  group = new ZooKeeperGroup<GitNode>(curator.get(), ZkPath.GIT.getPath(), GitNode.class);
  group.add(this);
  group.start();
}

代码示例来源：origin: jboss-fuse/fabric8

public synchronized Group getGroup() throws Exception {
   if (group == null) {
     group = new ZooKeeperGroup<CxfNodeState>(getCurator(), zkRoot + fabricPath, CxfNodeState.class, new NamedThreadFactory("zkgroup-lb-feature"));
     group.start();
   }
  return group;
}

代码示例来源：origin: fabric8io/jube

@Inject
public Replicator(CuratorFramework curator,
         ApiMasterKubernetesModel model,
         ProcessManager processManager,
         @ConfigProperty(name = "REPLICATOR_POLL_TIME", defaultValue = "2000")
         long pollTime) {
  this.curator = curator;
  this.model = model;
  this.processManager = processManager;
  this.pollTime = pollTime;
  System.out.println("Starting the replicator with poll time: " + pollTime);
  group = new ZooKeeperGroup<ReplicatorNode>(curator, KUBERNETES_REPLICATOR, ReplicatorNode.class);
  groupListener = new GroupListener<ReplicatorNode>() {
    @Override
    public void groupEvent(Group<ReplicatorNode> group, GroupEvent event) {
      onGroupEvent(group, event);
    }
  };
  group.add(groupListener);
  group.update(createState());
  group.start();
  enableTimer();
}

代码示例来源：origin: io.fabric8/fabric-openshift

@Activate
void activate(Map<String, ?> configuration) {
  //this.realm =  properties != null && properties.containsKey(REALM_PROPERTY_NAME) ? properties.get(REALM_PROPERTY_NAME) : DEFAULT_REALM;
  //this.role =  properties != null && properties.containsKey(ROLE_PROPERTY_NAME) ? properties.get(ROLE_PROPERTY_NAME) : DEFAULT_ROLE;
  group = new ZooKeeperGroup(curator.get(), ZkPath.OPENSHIFT.getPath(), ControllerNode.class);
  group.add(this);
  group.update(createState());
  group.start();
  activateComponent();
}

代码示例来源：origin: jboss-fuse/fabric8

@Activate
void activate() throws IOException {
  activateComponent();
  group = new ZooKeeperGroup<GitNode>(curator.get(), ZkPath.GIT.getPath(), GitNode.class, new NamedThreadFactory("zkgroup-gml"));
  group.add(this);
  group.start();
}

代码示例来源：origin: jboss-fuse/fabric8

@Activate
void activate() {
  CuratorFramework curator = this.curator.get();
  enableMasterZkCache(curator);
  group = new ZooKeeperGroup<AutoScalerNode>(curator, ZkPath.AUTO_SCALE_CLUSTER.getPath(), AutoScalerNode.class);
  group.add(this);
  group.update(createState());
  group.start();
  activateComponent();
}

代码示例来源：origin: io.fabric8/fabric-git-server

@Activate
void activate(Map<String, ?> configuration) throws Exception {
  RuntimeProperties sysprops = runtimeProperties.get();
  realm = getConfiguredRealm(sysprops, configuration);
  role = getConfiguredRole(sysprops, configuration);
  dataPath = sysprops.getDataPath();
  activateComponent();
  group = new ZooKeeperGroup<GitNode>(curator.get(), ZkPath.GIT.getPath(), GitNode.class);
  group.add(this);
  group.update(createState());
  group.start();
}

代码示例来源：origin: jboss-fuse/fabric8

@Activate
void activate(Map<String, ?> configuration) throws Exception {
  RuntimeProperties sysprops = runtimeProperties.get();
  realm = getConfiguredRealm(sysprops, configuration);
  roles = getConfiguredRoles(sysprops, configuration);
  dataPath = sysprops.getDataPath();
  activateComponent();
  group = new ZooKeeperGroup<GitNode>(curator.get(), ZkPath.GIT.getPath(), GitNode.class, new NamedThreadFactory("zkgroup-git-httpreg"));
  //if anything went wrong in a previous deactivation we still have to clean up the registry
  zkCleanUp(group);
  group.add(this);
  group.update(createState());
  group.start();
}