This is an automated email from the ASF dual-hosted git repository.
yaohaishi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/servicecomb-java-chassis.git.
from 908e20f [SCB-1737] support ISO 8601 data and time (part2: HIGHWAY)
new 0b507b4 [SCB-1691] modify instance status change interface
new d6cbf86 [SCB-1691] Decouple the ServiceRegistry and other modules
new bf3292b [SCB-1691] add name for ServiceRegistry
new 8e1f6bf [SCB-1691] ServiceRegistryConfig just carries config value
new a407a98 [SCB-1691] ClientPool can be instantiated
new 096a43b [SCB-1691] add RestClientUtil for multiple
ServiceRegistryClient instance situation
new 32cf126 [SCB-1691] add WebsocketClientPool for multiple
ServiceRegistryClient instance situation
new 1a920eb [SCB-1691] replace RestUtils and WebsocketUtils in
ServiceRegistryClientImpl
new e5d89b5 [SCB-1691] add ServiceRegistryCache
new d4e8db6 [SCB-1691] ServiceRegistry use serviceRegistryCache
new 7828f7f [SCB-1691] RegistryUtils manage multiple ServiceRegistry
instances
new c79d5e1 [SCB-1691] Each ServiceRegistry uses an isolated EventBus
new b24a037 [SCB-1691] code improve
new 4abbc6d [SCB-1691] Each registry client use isolated IpPortManager
new d2126d3 [SCB-1691] add schema and endpoint into all ServiceRegistry
instances
new bbd7702 [SCB-1691] support multiple TLS enabled sc clusters
new be1660f [SCB-1691] turn instance status to DOWN and wait for a period
when shutdown
new 369c578 [SCB-1691] fix CI error
new 15cb6a7 [SCB-1691] fix according to review opinion
The 19 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/servicecomb/core/SCBEngine.java | 63 ++-
.../handler/impl/ProducerOperationHandler.java | 1 -
.../consumer/MicroserviceReferenceConfig.java | 2 +-
.../provider/producer/ProducerBootListener.java | 9 +-
.../core/transport/TransportManager.java | 7 +-
.../handler/impl/TestSimpleLoadBalanceHandler.java | 5 +-
.../servicecomb/demo/edge/consumer/Consumer.java | 2 +-
.../jaxrs/client/MultiErrorCodeServiceClient.java | 2 +-
.../foundation/common/event/SimpleSubscriber.java | 2 +-
.../loadbalance/TestLoadBalanceHandler2.java | 39 +-
.../loadbalance/TestLoadbalanceHandler.java | 3 +-
.../java/org/apache/servicecomb/it/ITUtils.java | 4 +-
.../servicecomb/it/deploy/MicroserviceDeploy.java | 2 +-
.../it/extend/engine/GateRestTemplate.java | 2 +-
.../it/extend/engine/ITSCBAsyncRestTemplate.java | 4 +-
.../it/extend/engine/ITSCBRestTemplate.java | 2 +-
.../servicecomb/it/edge/PreLoadBootListener.java | 2 +-
.../async/CseAsyncClientHttpRequestTest.java | 7 +-
.../servicecomb/serviceregistry/RegistryUtils.java | 229 +++++++++-
.../serviceregistry/ServiceRegistry.java | 35 +-
.../cache/MicroserviceInstanceCache.java | 8 +-
.../serviceregistry/client/IpPortManager.java | 8 +-
.../client/LocalServiceRegistryClientImpl.java | 30 +-
.../client/ServiceRegistryClient.java | 23 +-
.../client/http/AbstractClientPool.java | 40 +-
.../serviceregistry/client/http/ClientPool.java | 6 +-
.../client/http/HttpClientPool.java | 36 +-
.../http/{RestUtils.java => RestClientUtil.java} | 57 +--
.../serviceregistry/client/http/RestUtils.java | 5 +
.../client/http/ServiceRegistryClientImpl.java | 94 ++--
.../client/http/WebsocketClientPool.java | 25 +-
.../client/http/WebsocketClientUtil.java | 126 ++++++
.../client/http/WebsocketUtils.java | 4 +-
.../config/ServiceRegistryConfig.java | 473 +++++++++++++--------
...nfig.java => ServiceRegistryConfigBuilder.java} | 194 ++++-----
.../serviceregistry/consumer/AppManager.java | 14 +-
.../consumer/MicroserviceVersion.java | 6 +-
.../consumer/MicroserviceVersions.java | 7 +-
.../consumer/StaticMicroserviceVersions.java | 5 +-
.../diagnosis/instance/InstanceCacheCheckTask.java | 3 +-
.../serviceregistry/discovery/DiscoveryTree.java | 1 -
.../registry/AbstractServiceRegistry.java | 132 +++---
.../registry/RemoteServiceRegistry.java | 20 +-
.../registry/ServiceRegistryFactory.java | 28 +-
.../registry/cache/AggregateMicroserviceCache.java | 139 ++++++
.../cache/AggregateServiceRegistryCache.java | 99 +++++
.../registry/cache/MicroserviceCache.java | 68 +++
.../registry/cache/MicroserviceCacheKey.java | 122 ++++++
.../cache/MicroserviceCacheRefreshedEvent.java | 65 ++-
.../cache/RefreshableMicroserviceCache.java | 248 +++++++++++
.../cache/RefreshableServiceRegistryCache.java | 175 ++++++++
.../registry/cache/ServiceRegistryCache.java | 63 ++-
.../serviceregistry/swagger/SwaggerLoader.java | 17 +-
.../serviceregistry/MockMicroserviceVersions.java | 17 +-
.../serviceregistry/RegistryUtilsTest.java | 77 ++++
.../serviceregistry/ServiceRegistryTest.java | 68 +++
.../servicecomb/serviceregistry/TestConsumers.java | 21 +-
.../servicecomb/serviceregistry/TestRegistry.java | 10 +-
.../serviceregistry/TestRegistryBase.java | 30 +-
.../cache/TestMicroserviceInstanceCache.java | 35 +-
.../client/LocalServiceRegistryClientImplTest.java | 66 +++
.../serviceregistry/client/TestIpPortManager.java | 7 +-
.../serviceregistry/client/http/RestUtilsTest.java | 1 +
.../client/http/TestClientHttp.java | 78 ++--
.../client/http/TestHttpClientPool.java | 28 +-
.../client/http/TestServiceRegistryClientImpl.java | 162 ++++---
.../client/http/TestWebsocketClientPool.java | 15 +-
.../config/TestServiceRegistryConfig.java | 12 +-
.../instance/TestInstanceCacheChecker.java | 20 +-
.../discovery/TestDiscoveryTree.java | 17 +-
.../registry/EmptyMockServiceRegistry.java | 139 ++++++
.../registry/TestRemoteServiceRegistry.java | 10 +-
.../registry/TestServiceRegistryFactory.java | 8 +-
.../cache/AggregateMicroserviceCacheTest.java | 159 +++++++
.../cache/AggregateServiceRegistryCacheTest.java | 212 +++++++++
.../registry/cache/MicroserviceCacheKeyTest.java | 88 ++++
.../registry/cache/MockedMicroserviceCache.java} | 48 +--
.../cache/RefreshableMicroserviceCacheTest.java | 367 ++++++++++++++++
.../cache/RefreshableServiceRegistryCacheTest.java | 205 +++++++++
.../serviceregistry/swagger/TestSwaggerLoader.java | 35 +-
.../springboot/common/AbstractDiscoveryClient.java | 26 +-
81 files changed, 3781 insertions(+), 943 deletions(-)
copy
service-registry/src/main/java/org/apache/servicecomb/serviceregistry/client/http/{RestUtils.java
=> RestClientUtil.java} (79%)
create mode 100644
service-registry/src/main/java/org/apache/servicecomb/serviceregistry/client/http/WebsocketClientUtil.java
copy
service-registry/src/main/java/org/apache/servicecomb/serviceregistry/config/{ServiceRegistryConfig.java
=> ServiceRegistryConfigBuilder.java} (61%)
create mode 100644
service-registry/src/main/java/org/apache/servicecomb/serviceregistry/registry/cache/AggregateMicroserviceCache.java
create mode 100644
service-registry/src/main/java/org/apache/servicecomb/serviceregistry/registry/cache/AggregateServiceRegistryCache.java
create mode 100644
service-registry/src/main/java/org/apache/servicecomb/serviceregistry/registry/cache/MicroserviceCache.java
create mode 100644
service-registry/src/main/java/org/apache/servicecomb/serviceregistry/registry/cache/MicroserviceCacheKey.java
copy
clients/service-center-client/src/main/java/org/apache/servicecomb/service/center/client/model/MicroservicesResponse.java
=>
service-registry/src/main/java/org/apache/servicecomb/serviceregistry/registry/cache/MicroserviceCacheRefreshedEvent.java
(67%)
mode change 100755 => 100644
create mode 100644
service-registry/src/main/java/org/apache/servicecomb/serviceregistry/registry/cache/RefreshableMicroserviceCache.java
create mode 100644
service-registry/src/main/java/org/apache/servicecomb/serviceregistry/registry/cache/RefreshableServiceRegistryCache.java
copy
clients/service-center-client/src/main/java/org/apache/servicecomb/service/center/client/model/MicroserviceInstancesResponse.java
=>
service-registry/src/main/java/org/apache/servicecomb/serviceregistry/registry/cache/ServiceRegistryCache.java
(66%)
mode change 100755 => 100644
create mode 100644
service-registry/src/test/java/org/apache/servicecomb/serviceregistry/RegistryUtilsTest.java
create mode 100644
service-registry/src/test/java/org/apache/servicecomb/serviceregistry/ServiceRegistryTest.java
create mode 100644
service-registry/src/test/java/org/apache/servicecomb/serviceregistry/registry/EmptyMockServiceRegistry.java
create mode 100644
service-registry/src/test/java/org/apache/servicecomb/serviceregistry/registry/cache/AggregateMicroserviceCacheTest.java
create mode 100644
service-registry/src/test/java/org/apache/servicecomb/serviceregistry/registry/cache/AggregateServiceRegistryCacheTest.java
create mode 100644
service-registry/src/test/java/org/apache/servicecomb/serviceregistry/registry/cache/MicroserviceCacheKeyTest.java
copy
service-registry/src/{main/java/org/apache/servicecomb/serviceregistry/client/Endpoints.java
=>
test/java/org/apache/servicecomb/serviceregistry/registry/cache/MockedMicroserviceCache.java}
(56%)
create mode 100644
service-registry/src/test/java/org/apache/servicecomb/serviceregistry/registry/cache/RefreshableMicroserviceCacheTest.java
create mode 100644
service-registry/src/test/java/org/apache/servicecomb/serviceregistry/registry/cache/RefreshableServiceRegistryCacheTest.java