Java AgentClient类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.orbitz.consul.AgentClient类的典型用法代码示例。如果您正苦于以下问题：Java AgentClient类的具体用法？Java AgentClient怎么用？Java AgentClient使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

AgentClient类属于com.orbitz.consul包，在下文中一共展示了AgentClient类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: register

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
@Override
public void register() throws SysException {

    AgentClient agentClient = buildConsul().agentClient();

    try {
        String check = config.getConsul("check");
        String serviceId = config.getConsul("serviceId");
        String serviceName = config.getConsul("serviceName");
        int port = Integer.parseInt(config.getConsul("port"));
        long ttl = Long.parseLong(config.getConsul("ttl"));
        agentClient.register(port, URI.create(check).toURL(), ttl, serviceName, serviceId);
    } catch (Exception e) {
        throw new SysException(e);
    }
}

开发者ID:speedyproject，项目名称:dcmp，代码行数:17，代码来源:ConsulServiceImpl.java

示例2: advertise

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
public void advertise(Registration registration) {
    if (this.advertisements.contains(registration)) {
        return;
    }

    AgentClient client = this.agentClientInjector.getValue();

    com.orbitz.consul.model.agent.Registration consulReg = ImmutableRegistration.builder()
            .address(registration.getAddress())
            .port(registration.getPort())
            .id(serviceId(registration))
            .name(registration.getName())
            .addTags(registration.getTags().toArray(new String[]{}))
            .check(com.orbitz.consul.model.agent.Registration.RegCheck.ttl(3L))
            .build();
    client.register(consulReg);

    this.advertisements.add(registration);

    log.info("Registered service " + consulReg.getId());
}

开发者ID:wildfly-swarm-archive，项目名称:wildfly-swarm-topology-consul，代码行数:22，代码来源:Advertiser.java

示例3: deregister

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
/**
 * Deregister a service from Consul
 */
public void deregister() {
    final AgentClient agent = consul.agentClient();
    if (!agent.isRegistered(serviceId)) {
        LOGGER.info("No service registered with ID \"{}\"", serviceId);
        return;
    }

    LOGGER.info("Deregistering service ID \"{}\"", serviceId);

    try {
        consul.agentClient().deregister(serviceId);
    } catch (ConsulException e) {
        LOGGER.error("Failed to deregister service from Consul", e);
    }
}

开发者ID:smoketurner，项目名称:dropwizard-consul，代码行数:19，代码来源:ConsulAdvertiser.java

示例4: advertise

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
public void advertise(Registration registration) {
    if (this.advertisements.contains(registration)) {
        return;
    }

    AgentClient client = this.agentClientInjector.getValue();

    com.orbitz.consul.model.agent.Registration consulReg = ImmutableRegistration.builder()
            .address(registration.getAddress())
            .port(registration.getPort())
            .id(serviceId(registration))
            .name(registration.getName())
            .addTags(registration.getTags().toArray(new String[]{}))
            .check(com.orbitz.consul.model.agent.Registration.RegCheck.ttl(3L))
            .build();
    client.register(consulReg);

    this.advertisements.add(registration);
}

开发者ID:wildfly-swarm-archive，项目名称:ARCHIVE-wildfly-swarm，代码行数:20，代码来源:Advertiser.java

示例5: registerMyself

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
private void registerMyself() throws NotRegisteredException, IOException {
    AgentClient agentClient = getConsul().agentClient();

    if (!agentClient.isRegistered(consulProperties.getServiceId())) {
        registerHeartbeat();
    }

    log.info("writing service access properties");
    KeyValueClient kvClient = getConsul().keyValueClient();
    Map<String, String> accessProperties = new HashMap<>();
    String serverName = InetAddress.getLocalHost().getHostName();
    accessProperties.put("hostname", serverName);
    accessProperties.put("ip", dnsResolver.readNonLoopbackLocalAddress());
    String port = String.valueOf(serverProperties.getPort());
    accessProperties.put("port", port);
    accessProperties.put("username", securityProperties.getUser().getName());
    accessProperties.put("password", securityProperties.getUser().getPassword());

    // read current access values and add ourselves
    String accessKey = consulProperties.getServiceName() + "/access/" + serverName + ":" + port;
    kvClient.putValue(accessKey, mapper.writeValueAsString(accessProperties));
}

开发者ID:amirkibbar，项目名称:plum，代码行数:23，代码来源:Consul4Spring.java

示例6: configure

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
@Override
public void configure(final Binder binder) {
    loading();

    cfgs.forEach((id, cfg) -> {
        final Consul consul = build(cfg);
        binder.bind(Consul.class).annotatedWith(Names.named(CONSUL_PREFIX + id)).toInstance(consul);
        binder.bind(AgentClient.class).annotatedWith(Names.named(CONSUL_AGENT_CLIENT_PREFIX + id)).toInstance(consul.agentClient());
        binder.bind(HealthClient.class).annotatedWith(Names.named(CONSUL_HEALTH_CLIENT_PREFIX + id)).toInstance(consul.healthClient());
        binder.bind(KeyValueClient.class).annotatedWith(Names.named(CONSUL_KEY_VALUE_CLIENT_PREFIX + id)).toInstance(consul.keyValueClient());
        binder.bind(CatalogClient.class).annotatedWith(Names.named(CONSUL_CATALOG_CLIENT_PREFIX + id)).toInstance(consul.catalogClient());
        binder.bind(StatusClient.class).annotatedWith(Names.named(CONSUL_STATUS_CLIENT_PREFIX + id)).toInstance(consul.statusClient());
        binder.bind(SessionClient.class).annotatedWith(Names.named(CONSUL_SESSION_CLIENT_PREFIX + id)).toInstance(consul.sessionClient());
        binder.bind(EventClient.class).annotatedWith(Names.named(CONSUL_EVENT_CLIENT_PREFIX + id)).toInstance(consul.eventClient());
        binder.bind(PreparedQueryClient.class).annotatedWith(Names.named(CONSUL_PREPARED_QUERY_CLIENT_PREFIX + id))
                .toInstance(consul.preparedQueryClient());
        binder.bind(CoordinateClient.class).annotatedWith(Names.named(CONSUL_COORDINATE_CLIENT_PREFIX + id))
                .toInstance(consul.coordinateClient());
        binder.bind(OperatorClient.class).annotatedWith(Names.named(CONSUL_OPERATOR_CLIENT + id)).toInstance(consul.operatorClient());
    });

}

开发者ID:nano-projects，项目名称:nano-framework，代码行数:23，代码来源:ConsulModule.java

示例7: deregister

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
@Override
public void deregister() throws SysException {

    AgentClient agentClient = buildConsul().agentClient();

    try {
        agentClient.deregister(config.getConsul("serviceId"));
    } catch (Exception e) {
        throw new SysException(e);
    }
}

开发者ID:speedyproject，项目名称:dcmp，代码行数:12，代码来源:ConsulServiceImpl.java

示例8: register

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
@Override
public void register() throws SysException {
    try {
        AgentClient agentClient = buildConsul().agentClient();
        agentClient.register(Configurer.port, URI.create(Configurer.check).toURL(), Configurer.ttl,
                Configurer.serviceName, Configurer.serviceId);
    } catch (Exception e) {
        throw new SysException(e);
    }
}

开发者ID:speedyproject，项目名称:dcmp，代码行数:11，代码来源:ConsulServiceImpl.java

示例9: deregister

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
@Override
public void deregister() throws SysException {
    try {
        AgentClient agentClient = buildConsul().agentClient();
        agentClient.deregister(Configurer.serviceId);
    } catch (Exception e) {
        throw new SysException(e);
    }
}

开发者ID:speedyproject，项目名称:dcmp，代码行数:10，代码来源:ConsulServiceImpl.java

示例10: register

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
private static void register() {
    AgentClient agentClient = consul.agentClient();

    List<Registration.RegCheck> checks = new ArrayList<Registration.RegCheck>();

    HostAndPort serviceHostAndPort = HostAndPort.fromParts(visibleHost, visiblePort);

    Registration.RegCheck mainCheck = Registration.RegCheck.tcp(serviceHostAndPort.toString(), 30);

    checks.add(mainCheck);

    Registration registration = ImmutableRegistration
            .builder()
            .port(visiblePort)
            .address(visibleHost)
            .checks(checks)
            .name(serviceName)
            .id(serviceId)
            .addTags(tsdMode)
            .build();

    agentClient.register(registration);

    if (agentClient.isRegistered(serviceId)) {
        LOGGER.info("Registered this instance with Consul");
    } else {
        LOGGER.warn("Consul reports that this instance is not registered");
    }
}

开发者ID:inst-tech，项目名称:opentsdb-plugins，代码行数:30，代码来源:ConsulPlugin.java

示例11: activate

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
@Override
public void activate(ServiceActivatorContext context) throws ServiceRegistryException {

    ServiceTarget target = context.getServiceTarget();

    ConsulService consul = new ConsulService(this.url);
    target.addService(ConsulService.SERVICE_NAME, consul)
            .install();

    HealthClientService healthClient = new HealthClientService();
    target.addService(HealthClientService.SERIVCE_NAME, healthClient)
            .addDependency(ConsulService.SERVICE_NAME, Consul.class, healthClient.getConsulInjector())
            .install();


    CatalogClientService catalogClient = new CatalogClientService();
    target.addService(CatalogClientService.SERVICE_NAME, catalogClient)
            .addDependency(ConsulService.SERVICE_NAME, Consul.class, catalogClient.getConsulInjector())
            .install();

    AgentClientService agentClient = new AgentClientService();
    target.addService(AgentClientService.SERVICE_NAME, agentClient)
            .addDependency(ConsulService.SERVICE_NAME, Consul.class, agentClient.getConsulInjector())
            .install();

    Advertiser advertiser = new Advertiser();
    target.addService(Advertiser.SERVICE_NAME, advertiser)
            .addDependency(AgentClientService.SERVICE_NAME, AgentClient.class, advertiser.getAgentClientInjector())
            .install();

}

开发者ID:wildfly-swarm-archive，项目名称:wildfly-swarm-topology-consul，代码行数:32，代码来源:AgentActivator.java

示例12: unadvertise

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
public void unadvertise(String name, String address, int port) {

        AgentClient client = this.agentClientInjector.getValue();

        this.advertisements
                .stream()
                .forEach(e -> {
                    String serviceId = serviceId(e);
                    log.info("Deregister service " + serviceId);
                    client.deregister(serviceId);
                });


        this.advertisements.removeIf(e -> e.getName().equals(name) && e.getAddress().equals(address) && e.getPort() == port);


    }

开发者ID:wildfly-swarm-archive，项目名称:wildfly-swarm-topology-consul，代码行数:18，代码来源:Advertiser.java

示例13: activate

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
@Override
public void activate(ServiceActivatorContext context) throws ServiceRegistryException {

    ServiceTarget target = context.getServiceTarget();

    ConsulService consul = new ConsulService(this.fraction.url());
    target.addService(ConsulService.SERVICE_NAME, consul)
            .install();

    HealthClientService healthClient = new HealthClientService();
    target.addService(HealthClientService.SERIVCE_NAME, healthClient)
            .addDependency(ConsulService.SERVICE_NAME, Consul.class, healthClient.getConsulInjector())
            .install();


    CatalogClientService catalogClient = new CatalogClientService();
    target.addService(CatalogClientService.SERVICE_NAME, catalogClient)
            .addDependency(ConsulService.SERVICE_NAME, Consul.class, catalogClient.getConsulInjector())
            .install();

    AgentClientService agentClient = new AgentClientService();
    target.addService(AgentClientService.SERVICE_NAME, agentClient)
            .addDependency(ConsulService.SERVICE_NAME, Consul.class, agentClient.getConsulInjector())
            .install();

    Advertiser advertiser = new Advertiser();
    target.addService(Advertiser.SERVICE_NAME, advertiser)
            .addDependency(AgentClientService.SERVICE_NAME, AgentClient.class, advertiser.getAgentClientInjector())
            .install();

}

开发者ID:wildfly-swarm，项目名称:wildfly-swarm，代码行数:32，代码来源:AgentActivator.java

示例14: unadvertise

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
public void unadvertise(String name, String address, int port) {

        AgentClient client = this.agentClientInjector.getValue();
        Registration r = new Registration("consul", name, address, port, "");

        this.advertisements
                .stream()
                .filter(e -> e.equals(r))
                .forEach(e -> {
                    String serviceId = serviceId(e);
                    log.info("Deregister service " + serviceId);
                    client.deregister(serviceId);
                });
        this.advertisements.removeIf(e -> e.equals(r));
    }

开发者ID:wildfly-swarm，项目名称:wildfly-swarm，代码行数:16，代码来源:Advertiser.java

示例15: getValue

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
@Override
public AgentClient getValue() throws IllegalStateException, IllegalArgumentException {
    return this.client;
}

开发者ID:wildfly-swarm，项目名称:wildfly-swarm，代码行数:5，代码来源:AgentClientService.java

示例16: start

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
@Override
public void start(StartContext startContext) throws StartException {
    ServiceTarget target = startContext.getChildTarget();

    ConsulService consul = new ConsulService(this.url);
    target.addService(ConsulService.SERVICE_NAME, consul)
            .install();

    HealthClientService healthClient = new HealthClientService();
    target.addService(HealthClientService.SERIVCE_NAME, healthClient)
            .addDependency(ConsulService.SERVICE_NAME, Consul.class, healthClient.getConsulInjector())
            .install();

    AgentClientService agentClient = new AgentClientService();
    target.addService(AgentClientService.SERVICE_NAME, agentClient)
            .addDependency(ConsulService.SERVICE_NAME, Consul.class, agentClient.getConsulInjector())
            .install();

    CatalogClientService catalogClient = new CatalogClientService();
    target.addService(CatalogClientService.SERVICE_NAME, catalogClient)
            .addDependency(ConsulService.SERVICE_NAME, Consul.class, catalogClient.getConsulInjector())
            .install();


    this.advertiser = new Advertiser();
    target.addService(Advertiser.SERVICE_NAME, advertiser)
            .addDependency(AgentClientService.SERVICE_NAME, AgentClient.class, advertiser.getAgentClientInjector())
            .install();

    CatalogWatcher watcher = new CatalogWatcher();
    target.addService(CatalogWatcher.SERVICE_NAME, watcher)
            .addDependency(CatalogClientService.SERVICE_NAME, CatalogClient.class, watcher.getCatalogClientInjector())
            .addDependency(HealthClientService.SERIVCE_NAME, HealthClient.class, watcher.getHealthClientInjector())
            .addDependency(TopologyManager.SERVICE_NAME, TopologyManager.class, watcher.getTopologyManagerInjector())
            .install();
}

开发者ID:wildfly-swarm-archive，项目名称:ARCHIVE-wildfly-swarm，代码行数:37，代码来源:ConsulTopologyConnector.java

示例17: registerHeartbeat

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
private void registerHeartbeat() {
    log.info("registering heartbeat");
    AgentClient agentClient = getConsul().agentClient();
    Registration registration = new Registration();
    registration.setPort(serverProperties.getPort());
    registration.setAddress(dnsResolver.readNonLoopbackLocalAddress());
    registration.setId(toUniqueName("heartbeat"));
    registration.setName(consulProperties.getServiceName());
    registration.setTags(consulProperties.getTags());
    Registration.Check check = new Registration.Check();
    check.setTtl(format("%ss", 2 * (consulProperties.getHeartbeatRate() == null ? DEFAULT_HEARTBEAT_RATE : consulProperties.getHeartbeatRate())));
    registration.setCheck(check);
    agentClient.register(registration);
}

开发者ID:amirkibbar，项目名称:plum，代码行数:15，代码来源:Consul4Spring.java

示例18: keepAlive

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
/**
 * changes the heartbeat check to PASS in a configurable rate. The default rate is 15 minutes. The heartbeat check
 * is defined with a grace period of 2 heartbeats before it sets itself to FAIL.
 */
@Override
public void keepAlive() {
    try {
        AgentClient agentClient = getConsul().agentClient();
        // the heartbeat is the service itself, not a check - that's why we "pass" it and not "check" it
        agentClient.pass(toUniqueName("heartbeat"));
        log.info("[check heartbeat]: PASS");
    } catch (NotRegisteredException e) {
        log.error("[check heartbeat]: FAIL " + e.getMessage());
        log.error("can't mark heartbeat as PASS", e);
        registerHeartbeat();
    }
}

开发者ID:amirkibbar，项目名称:plum，代码行数:18，代码来源:Consul4Spring.java

示例19: serviceIsRegistered

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
@SuppressWarnings("unused")
private MockUnit.Block serviceIsRegistered(String name, Config config) {
  return unit -> {

    AgentClient agentClient = unit.mock(AgentClient.class);

    Consul consul = unit.get(Consul.class);
    expect(consul.agentClient()).andReturn(agentClient);

    Env env = unit.get(Env.class);
    expect(env.onStarted(isA(Throwing.Runnable.class))).andReturn(env);
    expect(env.onStop(isA(Throwing.Runnable.class))).andReturn(env);
  };
}

开发者ID:jooby-project，项目名称:jooby，代码行数:15，代码来源:ConsulbyTest.java

示例20: fullPluginLifecycleWithDefaultConfiguration

import com.orbitz.consul.AgentClient; //导入依赖的package包/类
@Test
public void fullPluginLifecycleWithDefaultConfiguration() throws ExecutionException, InterruptedException {

    // dummy consul client
    Consul consul = mock(Consul.class);
    AgentClient agentClient = mock(AgentClient.class);
    when(consul.agentClient()).thenReturn(agentClient);

    // empty config
    ConfigurationReader configurationReader = mock(ConfigurationReader.class);
    Properties properties = new Properties();
    when(configurationReader.getProperties()).thenReturn(properties);
    Configuration configuration = new Configuration(configurationReader);

    PluginExecutorService pluginExecutorService = mock(PluginExecutorService.class);

    ConsulDiscoveryCallback callback = new ConsulDiscoveryCallback(consul, configuration, pluginExecutorService);
    callback.init("clusternode1", new ClusterNodeAddress("clusternode1-hostname", 1234));

    // check if registration job gets scheduled
    ArgumentCaptor<Runnable> runnableArgument = ArgumentCaptor.forClass(Runnable.class);
    verify(pluginExecutorService, times(2)).scheduleAtFixedRate(runnableArgument.capture(), anyLong(), eq(60l), eq(TimeUnit.SECONDS));

    // run registration job
    Runnable registrationRunnable = runnableArgument.getAllValues().get(0);
    Runnable updateRunnable = runnableArgument.getAllValues().get(1);

    registrationRunnable.run();

    // verify service registration
    ArgumentCaptor<Registration> argument = ArgumentCaptor.forClass(Registration.class);
    verify(agentClient).register(argument.capture(), any());


    Registration registration = argument.getValue();
    assertEquals("cluster-discovery-hivemq", registration.getName());
    assertEquals("clusternode1-hostname", registration.getAddress().get());
    assertEquals(Integer.valueOf(1234), registration.getPort().get());
    assertEquals("cluster-discovery-hivemq", registration.getName());

    String registrationId = registration.getId();
    assertThat(registrationId).containsOnlyDigits();
    assertEquals(1, registration.getChecks().size());

    Registration.RegCheck regCheck = registration.getChecks().get(0);
    assertEquals("120s", regCheck.getTtl().get());

     // run updater job and check consul service pass call
    updateRunnable.run();
    try {
        verify(agentClient).pass(eq(registrationId));
    } catch (NotRegisteredException e) {
        throw new RuntimeException(e);
    }

    HealthClient healthClient = mock(HealthClient.class);
    List<ServiceHealth> nodes = new ArrayList<>();

    Service service = ImmutableService.builder()
            .address("host1")
            .id("not important")
            .service("doesnt matter")
            .port(5678).build();

    Node node = ImmutableNode.builder().node("node1").address("address1").build();
    ServiceHealth serviceHealth = ImmutableServiceHealth.builder().service(service).node(node).build();

    nodes.add(serviceHealth);
    ConsulResponse response = new ConsulResponse(nodes, 0, true, BigInteger.ZERO);
    when(healthClient.getHealthyServiceInstances(anyString(), ArgumentMatchers.<ImmutableQueryOptions>any())).thenReturn(response);
    when(consul.healthClient()).thenReturn(healthClient);

    List<ClusterNodeAddress> addresses = callback.getNodeAddresses().get();
    assertEquals(1, addresses.size());
    assertEquals("host1", addresses.get(0).getHost());
    assertEquals(5678, addresses.get(0).getPort());

    callback.destroy();
    verify(agentClient).deregister(eq(registrationId));
}

开发者ID:pellepelster，项目名称:hivemq-consul-cluster-discovery，代码行数:81，代码来源:ConsulDiscoveryCallbackTest.java

注：本文中的com.orbitz.consul.AgentClient类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。