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

Group介绍

暂无

代码示例

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

public void useCurator(CuratorFramework curator) {
  Group<T> group = this.group;
  if (group != null) {
    closeQuietly(group);
  }
  if (curator != null) {
    group = createGroup(curator, path, clazz);
    group.update(state);
    for (GroupListener<T> listener : listeners) {
      group.add(listener);
    }
    if (started.get()) {
      group.start();
    }
    this.group = group;
  }
}

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

@Override
  public void groupEvent(Group<QueryNodeState> group, GroupEvent event) {
    try {
      state.lock.update(new QueryNodeState(queryName, containerName,
          state.lock.isMaster() ? new String[]{"stat"} : null));
    } catch (IllegalStateException e) {
      // not joined ? ignore
    }
  }
});

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

public void close() {
    future.cancel(false);
    if (lock != null) {
      try {
        lock.close();
      } catch (IOException e) {
        // Ignore
      }
    }
  }
}

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

public void start() {
  group.add(this);
  repository.addListener(this);
  group.start();
}

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

private void updateCluster() {
  try {
    singleton.update(new ESNode(clusterName.value(), localNode, singleton.isMaster()));
  } catch (Exception e) {
  if (singleton.isMaster()) {
    if (logger.isDebugEnabled()) {
      String master = singleton.master() != null ? singleton.master().node.name() : null;
      List<String> slaves = new ArrayList<String>();
      for (ESNode s : singleton.slaves()) {
        slaves.add(s.node.name());
  } else if (singleton.master() != null) {
    DiscoveryNode masterNode = singleton.master().getNode();
    try {

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

@Override
public void add(GroupListener<T> listener) {
  listeners.add(listener);
  Group<T> group = this.group;
  if (group != null) {
    group.add(listener);
  }
}

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

protected void doStart() {
  if (group != null) {
    group.start();
  }
}

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

@Override
public boolean isMaster() {
  Group<T> group = this.group;
  if (group != null) {
    return group.isMaster();
  } else {
    return false;
  }
}

代码示例来源：origin: io.fabric8.insight/insight-elasticsearch-discovery

@Override
public void onNewClusterState(final ClusterState newState, final NewStateProcessed newStateProcessed) {
  if (singleton.isMaster()) {
    logger.warn("master should not receive new cluster state from [{}]", newState.nodes().masterNode());
  } else {
    } else {
      if (logger.isDebugEnabled()) {
        String master = singleton.master() != null ? singleton.master().node.name() : null;
        List<String> slaves = new ArrayList<String>();
        for (ESNode s : singleton.slaves()) {
          slaves.add(s.node.name());

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

@Override
protected void doStart() throws Exception {
  super.doStart();
  singleton.start();
  LOG.debug("Attempting to become master for endpoint: " + endpoint + " in " + endpoint.getCamelContext() + " with singletonID: " + endpoint.getSingletonId());
  singleton.update(createNodeState());
}

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

@Override
public void update(T state) {
  this.state = state;
  Group<T> group = this.group;
  if (group != null) {
    group.update(state);
  }
}

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

@Override
public void groupEvent(Group group, GroupEvent event) {
  switch (event) {
    case CONNECTED:
      break;
    case CHANGED:
      if (singleton.isConnected()) {
        if (singleton.isMaster()) {
          if (LOG.isDebugEnabled()) {
            LOG.debug("Master/Standby endpoint is Master for:  " + endpoint + " in " + endpoint.getCamelContext());
          }
          onLockOwned();
        } else {
          if (LOG.isDebugEnabled()) {
            LOG.debug("Master/Standby endpoint is Standby for: " + endpoint + " in " + endpoint.getCamelContext());
          }
        }
      }
      break;
    case DISCONNECTED:
      try {
        stopConsumer();
      } catch (Exception e) {
        LOG.error("Failed to stop master consumer for: " + endpoint + ". Reason: " + e, e);
      }
      break;
  }
}

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

@Override
public Map<String, T> members() {
  Group<T> group = this.group;
  if (group != null) {
    return group.members();
  } else {
    return Collections.emptyMap();
  }
}

代码示例来源：origin: io.fabric8.insight/insight-elasticsearch-discovery

@Override
public ClusterState execute(ClusterState currentState) {
  // Rebuild state
  ClusterState.Builder stateBuilder = ClusterState.builder(currentState);
  // Rebuild nodes
  DiscoveryNodes.Builder nodesBuilder = DiscoveryNodes.builder()
      .localNodeId(localNode.id())
      .masterNodeId(singleton.master().getNode().id())
      .put(singleton.master().getNode());
  for (ESNode node : singleton.slaves()) {
    nodesBuilder.put(node.getNode());
  }
  latestDiscoNodes = nodesBuilder.build();
  stateBuilder.nodes(latestDiscoNodes);
  for (DiscoveryNode node : latestDiscoNodes) {
    if (!currentState.nodes().nodeExists(node.id())) {
      transportService.connectToNode(node);
    }
  }
  // update the fact that we are the master...
  if (!localNode().id().equals(currentState.nodes().masterNodeId())) {
    ClusterBlocks clusterBlocks = ClusterBlocks.builder().blocks(currentState.blocks()).removeGlobalBlock(NO_MASTER_BLOCK).build();
    stateBuilder.blocks(clusterBlocks);
  }
  return stateBuilder.build();
}

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

@Override
public T master() {
  Group<T> group = this.group;
  if (group != null) {
    return group.master();
  } else {
    return null;
  }
}

代码示例来源：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: io.fabric8.insight/insight-elasticsearch-discovery

private void updateCluster() {
  try {
    singleton.update(new ESNode(clusterName.value(), localNode, singleton.isMaster()));
  } catch (Exception e) {
  if (singleton.isMaster()) {
    if (logger.isDebugEnabled()) {
      String master = singleton.master() != null ? singleton.master().node.name() : null;
      List<String> slaves = new ArrayList<>();
      for (ESNode s : singleton.slaves()) {
        slaves.add(s.node.name());
  } else if (singleton.master() != null) {
    DiscoveryNode masterNode = singleton.master().getNode();
    try {

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

@Override
public void add(GroupListener<T> listener) {
  listeners.add(listener);
  Group<T> group = this.group;
  if (group != null) {
    group.add(listener);
  }
}

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

protected void doStart() {
  if (group != null) {
    group.start();
  }
}

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

@Override
public boolean isMaster() {
  Group<T> group = this.group;
  if (group != null) {
    return group.isMaster();
  } else {
    return false;
  }
}