test_class.declarator: consul
test_class.modifier: private static
test_class.original_string: private static ConsulProcess consul;
test_class.type: ConsulProcess
test_class.var_name: consul
test_class.declarator: consulRegistry
test_class.modifier: private
test_class.original_string: private ConsulRegistry consulRegistry;
test_class.type: ConsulRegistry
test_class.var_name: consulRegistry
test_class.declarator: service = "org.apache.dubbo.test.injvmServie"
test_class.modifier: private
test_class.original_string: private String service = "org.apache.dubbo.test.injvmServie";
test_class.type: String
test_class.var_name: service
test_class.declarator: serviceUrl = URL.valueOf("consul://127.0.0.1:" + NetUtils.getAvailablePort() + "/" + service + "?notify=false&methods=test1,test2")
test_class.modifier: private
test_class.original_string: private URL serviceUrl = URL.valueOf("consul://127.0.0.1:" + NetUtils.getAvailablePort() + "/" + service + "?notify=false&methods=test1,test2");
test_class.type: URL
test_class.var_name: serviceUrl
test_class.declarator: registryUrl
test_class.modifier: private
test_class.original_string: private URL registryUrl;
test_class.type: URL
test_class.var_name: registryUrl
test_class.declarator: consulRegistryFactory
test_class.modifier: private
test_class.original_string: private ConsulRegistryFactory consulRegistryFactory;
test_class.type: ConsulRegistryFactory
test_class.var_name: consulRegistryFactory
test_class.file: dubbo-registry/dubbo-registry-consul/src/test/java/org/apache/dubbo/registry/consul/ConsulRegistryTest.java
test_class.identifier: ConsulRegistryTest
test_case.body: @Test
      public void testStatusChecker() {
          RegistryStatusChecker registryStatusChecker = new RegistryStatusChecker();
          Status status = registryStatusChecker.check();
          assertThat(status.getLevel(), is(Status.Level.UNKNOWN));
  
          Registry registry = consulRegistryFactory.getRegistry(registryUrl);
          assertThat(registry, not(nullValue()));
  
          status = registryStatusChecker.check();
          assertThat(status.getLevel(), is(Status.Level.OK));
  
          registry.register(serviceUrl);
          status = registryStatusChecker.check();
          assertThat(status.getLevel(), is(Status.Level.OK));
      }
test_case.class_method_signature: ConsulRegistryTest.testStatusChecker()
test_case.full_signature: @Test public void testStatusChecker()
test_case.identifier: testStatusChecker
test_case.invocations: check assertThat getLevel is getRegistry assertThat not nullValue check assertThat getLevel is register check assertThat getLevel is
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testStatusChecker()
focal_class.declarator: logger = LoggerFactory.getLogger(ConsulRegistry.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger logger = LoggerFactory.getLogger(ConsulRegistry.class);
focal_class.type: Logger
focal_class.var_name: logger
focal_class.declarator: client
focal_class.modifier: private
focal_class.original_string: private ConsulClient client;
focal_class.type: ConsulClient
focal_class.var_name: client
focal_class.declarator: checkPassInterval
focal_class.modifier: private
focal_class.original_string: private long checkPassInterval;
focal_class.type: long
focal_class.var_name: checkPassInterval
focal_class.declarator: notifierExecutor = newCachedThreadPool(
              new NamedThreadFactory("dubbo-consul-notifier", true))
focal_class.modifier: private
focal_class.original_string: private ExecutorService notifierExecutor = newCachedThreadPool(
              new NamedThreadFactory("dubbo-consul-notifier", true));
focal_class.type: ExecutorService
focal_class.var_name: notifierExecutor
focal_class.declarator: notifiers = new ConcurrentHashMap<>()
focal_class.modifier: private
focal_class.original_string: private ConcurrentMap<URL, ConsulNotifier> notifiers = new ConcurrentHashMap<>();
focal_class.type: ConcurrentMap<URL, ConsulNotifier>
focal_class.var_name: notifiers
focal_class.declarator: ttlConsulCheckExecutor
focal_class.modifier: private
focal_class.original_string: private ScheduledExecutorService ttlConsulCheckExecutor;
focal_class.type: ScheduledExecutorService
focal_class.var_name: ttlConsulCheckExecutor
focal_class.declarator: token
focal_class.modifier: private
focal_class.original_string: private String token;
focal_class.type: String
focal_class.var_name: token
focal_class.file: dubbo-registry/dubbo-registry-consul/src/main/java/org/apache/dubbo/registry/consul/ConsulRegistry.java
focal_class.identifier: ConsulRegistry
focal_class.class_method_signature: ConsulRegistry.ConsulRegistry(URL url)
focal_class.full_signature: public  ConsulRegistry(URL url)
focal_class.identifier: ConsulRegistry
focal_class.modifiers: public
focal_class.parameters: (URL url)
focal_class.signature:  ConsulRegistry(URL url)
focal_class.class_method_signature: ConsulRegistry.register(URL url)
focal_class.full_signature: @Override public void register(URL url)
focal_class.identifier: register
focal_class.modifiers: @Override public
focal_class.parameters: (URL url)
focal_class.return: void
focal_class.signature: void register(URL url)
focal_class.class_method_signature: ConsulRegistry.doRegister(URL url)
focal_class.full_signature: @Override public void doRegister(URL url)
focal_class.identifier: doRegister
focal_class.modifiers: @Override public
focal_class.parameters: (URL url)
focal_class.return: void
focal_class.signature: void doRegister(URL url)
focal_class.class_method_signature: ConsulRegistry.unregister(URL url)
focal_class.full_signature: @Override public void unregister(URL url)
focal_class.identifier: unregister
focal_class.modifiers: @Override public
focal_class.parameters: (URL url)
focal_class.return: void
focal_class.signature: void unregister(URL url)
focal_class.class_method_signature: ConsulRegistry.doUnregister(URL url)
focal_class.full_signature: @Override public void doUnregister(URL url)
focal_class.identifier: doUnregister
focal_class.modifiers: @Override public
focal_class.parameters: (URL url)
focal_class.return: void
focal_class.signature: void doUnregister(URL url)
focal_class.class_method_signature: ConsulRegistry.subscribe(URL url, NotifyListener listener)
focal_class.full_signature: @Override public void subscribe(URL url, NotifyListener listener)
focal_class.identifier: subscribe
focal_class.modifiers: @Override public
focal_class.parameters: (URL url, NotifyListener listener)
focal_class.return: void
focal_class.signature: void subscribe(URL url, NotifyListener listener)
focal_class.class_method_signature: ConsulRegistry.doSubscribe(URL url, NotifyListener listener)
focal_class.full_signature: @Override public void doSubscribe(URL url, NotifyListener listener)
focal_class.identifier: doSubscribe
focal_class.modifiers: @Override public
focal_class.parameters: (URL url, NotifyListener listener)
focal_class.return: void
focal_class.signature: void doSubscribe(URL url, NotifyListener listener)
focal_class.class_method_signature: ConsulRegistry.unsubscribe(URL url, NotifyListener listener)
focal_class.full_signature: @Override public void unsubscribe(URL url, NotifyListener listener)
focal_class.identifier: unsubscribe
focal_class.modifiers: @Override public
focal_class.parameters: (URL url, NotifyListener listener)
focal_class.return: void
focal_class.signature: void unsubscribe(URL url, NotifyListener listener)
focal_class.class_method_signature: ConsulRegistry.doUnsubscribe(URL url, NotifyListener listener)
focal_class.full_signature: @Override public void doUnsubscribe(URL url, NotifyListener listener)
focal_class.identifier: doUnsubscribe
focal_class.modifiers: @Override public
focal_class.parameters: (URL url, NotifyListener listener)
focal_class.return: void
focal_class.signature: void doUnsubscribe(URL url, NotifyListener listener)
focal_class.class_method_signature: ConsulRegistry.lookup(URL url)
focal_class.full_signature: @Override public List<URL> lookup(URL url)
focal_class.identifier: lookup
focal_class.modifiers: @Override public
focal_class.parameters: (URL url)
focal_class.return: List<URL>
focal_class.signature: List<URL> lookup(URL url)
focal_class.class_method_signature: ConsulRegistry.isAvailable()
focal_class.full_signature: @Override public boolean isAvailable()
focal_class.identifier: isAvailable
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isAvailable()
focal_class.class_method_signature: ConsulRegistry.destroy()
focal_class.full_signature: @Override public void destroy()
focal_class.identifier: destroy
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void destroy()
focal_class.class_method_signature: ConsulRegistry.checkPass()
focal_class.full_signature: private void checkPass()
focal_class.identifier: checkPass
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void checkPass()
focal_class.class_method_signature: ConsulRegistry.getHealthServices(String service, long index, int watchTimeout)
focal_class.full_signature: private Response<List<HealthService>> getHealthServices(String service, long index, int watchTimeout)
focal_class.identifier: getHealthServices
focal_class.modifiers: private
focal_class.parameters: (String service, long index, int watchTimeout)
focal_class.return: Response<List<HealthService>>
focal_class.signature: Response<List<HealthService>> getHealthServices(String service, long index, int watchTimeout)
focal_class.class_method_signature: ConsulRegistry.getAllServices(long index, int watchTimeout)
focal_class.full_signature: private Response<Map<String, List<String>>> getAllServices(long index, int watchTimeout)
focal_class.identifier: getAllServices
focal_class.modifiers: private
focal_class.parameters: (long index, int watchTimeout)
focal_class.return: Response<Map<String, List<String>>>
focal_class.signature: Response<Map<String, List<String>>> getAllServices(long index, int watchTimeout)
focal_class.class_method_signature: ConsulRegistry.getHealthServices(Map<String, List<String>> services)
focal_class.full_signature: private List<HealthService> getHealthServices(Map<String, List<String>> services)
focal_class.identifier: getHealthServices
focal_class.modifiers: private
focal_class.parameters: (Map<String, List<String>> services)
focal_class.return: List<HealthService>
focal_class.signature: List<HealthService> getHealthServices(Map<String, List<String>> services)
focal_class.class_method_signature: ConsulRegistry.isConsumerSide(URL url)
focal_class.full_signature: private boolean isConsumerSide(URL url)
focal_class.identifier: isConsumerSide
focal_class.modifiers: private
focal_class.parameters: (URL url)
focal_class.return: boolean
focal_class.signature: boolean isConsumerSide(URL url)
focal_class.class_method_signature: ConsulRegistry.isProviderSide(URL url)
focal_class.full_signature: private boolean isProviderSide(URL url)
focal_class.identifier: isProviderSide
focal_class.modifiers: private
focal_class.parameters: (URL url)
focal_class.return: boolean
focal_class.signature: boolean isProviderSide(URL url)
focal_class.class_method_signature: ConsulRegistry.convert(List<HealthService> services, URL consumerURL)
focal_class.full_signature: private List<URL> convert(List<HealthService> services, URL consumerURL)
focal_class.identifier: convert
focal_class.modifiers: private
focal_class.parameters: (List<HealthService> services, URL consumerURL)
focal_class.return: List<URL>
focal_class.signature: List<URL> convert(List<HealthService> services, URL consumerURL)
focal_class.class_method_signature: ConsulRegistry.emptyURL(URL consumerURL)
focal_class.full_signature: private List<URL> emptyURL(URL consumerURL)
focal_class.identifier: emptyURL
focal_class.modifiers: private
focal_class.parameters: (URL consumerURL)
focal_class.return: List<URL>
focal_class.signature: List<URL> emptyURL(URL consumerURL)
focal_class.class_method_signature: ConsulRegistry.buildService(URL url)
focal_class.full_signature: private NewService buildService(URL url)
focal_class.identifier: buildService
focal_class.modifiers: private
focal_class.parameters: (URL url)
focal_class.return: NewService
focal_class.signature: NewService buildService(URL url)
focal_class.class_method_signature: ConsulRegistry.buildTags(URL url)
focal_class.full_signature: private List<String> buildTags(URL url)
focal_class.identifier: buildTags
focal_class.modifiers: private
focal_class.parameters: (URL url)
focal_class.return: List<String>
focal_class.signature: List<String> buildTags(URL url)
focal_class.class_method_signature: ConsulRegistry.buildId(URL url)
focal_class.full_signature: private String buildId(URL url)
focal_class.identifier: buildId
focal_class.modifiers: private
focal_class.parameters: (URL url)
focal_class.return: String
focal_class.signature: String buildId(URL url)
focal_class.class_method_signature: ConsulRegistry.buildCheck(URL url)
focal_class.full_signature: private NewService.Check buildCheck(URL url)
focal_class.identifier: buildCheck
focal_class.modifiers: private
focal_class.parameters: (URL url)
focal_class.return: NewService.Check
focal_class.signature: NewService.Check buildCheck(URL url)
focal_class.class_method_signature: ConsulRegistry.buildWatchTimeout(URL url)
focal_class.full_signature: private int buildWatchTimeout(URL url)
focal_class.identifier: buildWatchTimeout
focal_class.modifiers: private
focal_class.parameters: (URL url)
focal_class.return: int
focal_class.signature: int buildWatchTimeout(URL url)
focal_class.superclass: extends FailbackRegistry
focal_method.body: @Override
      public void register(URL url) {
          if (isConsumerSide(url)) {
              return;
          }
  
          super.register(url);
      }
focal_method.class_method_signature: ConsulRegistry.register(URL url)
focal_method.full_signature: @Override public void register(URL url)
focal_method.identifier: register
focal_method.invocations: isConsumerSide register
focal_method.modifiers: @Override public
focal_method.parameters: (URL url)
focal_method.return: void
focal_method.signature: void register(URL url)