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

TransportService.getRemoteClusterService介绍

暂无

代码示例

代码示例来源：origin: floragunncom/search-guard

@Inject
public GuiceHolder(final RepositoriesService repositoriesService,
    final TransportService remoteClusterService) {
  GuiceHolder.repositoriesService = repositoriesService;
  GuiceHolder.remoteClusterService = remoteClusterService.getRemoteClusterService();
}

代码示例来源：origin: org.elasticsearch/elasticsearch

RemoteClusterAwareClient(Settings settings, ThreadPool threadPool, TransportService service, String clusterAlias) {
  super(settings, threadPool);
  this.service = service;
  this.clusterAlias = clusterAlias;
  this.remoteClusterService = service.getRemoteClusterService();
}

代码示例来源：origin: org.elasticsearch/elasticsearch

public RemoteClusterService getRemoteClusterService() {
  return transportService.getRemoteClusterService();
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Inject
public TransportFieldCapabilitiesAction(Settings settings, TransportService transportService,
                    ClusterService clusterService, ThreadPool threadPool,
                    TransportFieldCapabilitiesIndexAction shardAction,
                    ActionFilters actionFilters,
                    IndexNameExpressionResolver
                        indexNameExpressionResolver) {
  super(settings, FieldCapabilitiesAction.NAME, threadPool, transportService,
    actionFilters, indexNameExpressionResolver, FieldCapabilitiesRequest::new);
  this.clusterService = clusterService;
  this.remoteClusterService = transportService.getRemoteClusterService();
  this.shardAction = shardAction;
}

代码示例来源：origin: org.elasticsearch/elasticsearch

/**
 * Returns a client to the remote cluster if the given cluster alias exists.
 * @param threadPool the {@link ThreadPool} for the client
 * @param clusterAlias the cluster alias the remote cluster is registered under
 *
 * @throws IllegalArgumentException if the given clusterAlias doesn't exist
 */
public Client getRemoteClusterClient(ThreadPool threadPool, String clusterAlias) {
  if (transportService.getRemoteClusterService().getRemoteClusterNames().contains(clusterAlias) == false) {
    throw new IllegalArgumentException("unknown cluster alias [" + clusterAlias + "]");
  }
  return new RemoteClusterAwareClient(settings, threadPool, transportService, clusterAlias);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

/**
 * Returns a connection to the given node on the provided cluster. If the cluster alias is <code>null</code> the node will be resolved
 * against the local cluster.
 * @param clusterAlias the cluster alias the node should be resolve against
 * @param node the node to resolve
 * @return a connection to the given node belonging to the cluster with the provided alias.
 */
Transport.Connection getConnection(String clusterAlias, DiscoveryNode node) {
  if (clusterAlias == null) {
    return transportService.getConnection(node);
  } else {
    return transportService.getRemoteClusterService().getConnection(node, clusterAlias);
  }
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

RemoteClusterAwareClient(Settings settings, ThreadPool threadPool, TransportService service, String clusterAlias) {
  super(settings, threadPool);
  this.service = service;
  this.clusterAlias = clusterAlias;
  this.remoteClusterService = service.getRemoteClusterService();
}

代码示例来源：origin: apache/servicemix-bundles

RemoteClusterAwareClient(Settings settings, ThreadPool threadPool, TransportService service, String clusterAlias) {
  super(settings, threadPool);
  this.service = service;
  this.clusterAlias = clusterAlias;
  this.remoteClusterService = service.getRemoteClusterService();
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

public RemoteClusterService getRemoteClusterService() {
  return transportService.getRemoteClusterService();
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

public RemoteClusterService getRemoteClusterService() {
  return transportService.getRemoteClusterService();
}

代码示例来源：origin: apache/servicemix-bundles

public RemoteClusterService getRemoteClusterService() {
  return transportService.getRemoteClusterService();
}

代码示例来源：origin: org.elasticsearch/elasticsearch

this.pluginLifecycleComponents = Collections.unmodifiableList(pluginLifecycleComponents);
client.initialize(injector.getInstance(new Key<Map<GenericAction, TransportAction>>() {}),
    () -> clusterService.localNode().getId(), transportService.getRemoteClusterService());

代码示例来源：origin: com.floragunn/search-guard-6

@Inject
public GuiceHolder(final RepositoriesService repositoriesService,
    final TransportService remoteClusterService) {
  GuiceHolder.repositoriesService = repositoriesService;
  GuiceHolder.remoteClusterService = remoteClusterService.getRemoteClusterService();
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

@Inject
public TransportFieldCapabilitiesAction(Settings settings, TransportService transportService,
                    ClusterService clusterService, ThreadPool threadPool,
                    TransportFieldCapabilitiesIndexAction shardAction,
                    ActionFilters actionFilters,
                    IndexNameExpressionResolver
                        indexNameExpressionResolver) {
  super(settings, FieldCapabilitiesAction.NAME, threadPool, transportService,
    actionFilters, indexNameExpressionResolver, FieldCapabilitiesRequest::new);
  this.clusterService = clusterService;
  this.remoteClusterService = transportService.getRemoteClusterService();
  this.shardAction = shardAction;
}

代码示例来源：origin: apache/servicemix-bundles

@Inject
public TransportFieldCapabilitiesAction(Settings settings, TransportService transportService,
                    ClusterService clusterService, ThreadPool threadPool,
                    TransportFieldCapabilitiesIndexAction shardAction,
                    ActionFilters actionFilters,
                    IndexNameExpressionResolver
                        indexNameExpressionResolver) {
  super(settings, FieldCapabilitiesAction.NAME, threadPool, transportService,
    actionFilters, indexNameExpressionResolver, FieldCapabilitiesRequest::new);
  this.clusterService = clusterService;
  this.remoteClusterService = transportService.getRemoteClusterService();
  this.shardAction = shardAction;
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

@Inject
public TransportFieldCapabilitiesAction(Settings settings, TransportService transportService,
                    ClusterService clusterService, ThreadPool threadPool,
                    TransportFieldCapabilitiesIndexAction shardAction,
                    ActionFilters actionFilters,
                    IndexNameExpressionResolver
                        indexNameExpressionResolver) {
  super(settings, FieldCapabilitiesAction.NAME, threadPool, transportService,
    actionFilters, indexNameExpressionResolver, FieldCapabilitiesRequest::new);
  this.clusterService = clusterService;
  this.remoteClusterService = transportService.getRemoteClusterService();
  this.transportService = transportService;
  this.shardAction = shardAction;
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

/**
 * Returns a client to the remote cluster if the given cluster alias exists.
 * @param threadPool the {@link ThreadPool} for the client
 * @param clusterAlias the cluster alias the remote cluster is registered under
 *
 * @throws IllegalArgumentException if the given clusterAlias doesn't exist
 */
public Client getRemoteClusterClient(ThreadPool threadPool, String clusterAlias) {
  if (transportService.getRemoteClusterService().getRemoteClusterNames().contains(clusterAlias) == false) {
    throw new IllegalArgumentException("unknown cluster alias [" + clusterAlias + "]");
  }
  return new RemoteClusterAwareClient(settings, threadPool, transportService, clusterAlias);
}

代码示例来源：origin: apache/servicemix-bundles

/**
   * Returns a client to the remote cluster if the given cluster alias exists.
   * @param threadPool the {@link ThreadPool} for the client
   * @param clusterAlias the cluster alias the remote cluster is registered under
   *
   * @throws IllegalArgumentException if the given clusterAlias doesn't exist
   */
  public Client getRemoteClusterClient(ThreadPool threadPool, String clusterAlias) {
    if (transportService.getRemoteClusterService().getRemoteClusterNames().contains(clusterAlias) == false) {
      throw new IllegalArgumentException("unknown cluster alias [" + clusterAlias + "]");
    }
    return new RemoteClusterAwareClient(settings, threadPool, transportService, clusterAlias);
  }
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

/**
 * Returns a connection to the given node on the provided cluster. If the cluster alias is <code>null</code> the node will be resolved
 * against the local cluster.
 * @param clusterAlias the cluster alias the node should be resolve against
 * @param node the node to resolve
 * @return a connection to the given node belonging to the cluster with the provided alias.
 */
Transport.Connection getConnection(String clusterAlias, DiscoveryNode node) {
  if (clusterAlias == null) {
    return transportService.getConnection(node);
  } else {
    return transportService.getRemoteClusterService().getConnection(node, clusterAlias);
  }
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

/**
   * Returns a connection to the given node on the provided cluster. If the cluster alias is <code>null</code> the node will be resolved
   * against the local cluster.
   * @param clusterAlias the cluster alias the node should be resolve against
   * @param node the node to resolve
   * @return a connection to the given node belonging to the cluster with the provided alias.
   */
  Transport.Connection getConnection(String clusterAlias, DiscoveryNode node) {
    if (clusterAlias == null) {
      return transportService.getConnection(node);
    } else {
      return transportService.getRemoteClusterService().getConnection(node, clusterAlias);
    }
  }
}