This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git.
from b8abd1a SCB-1386 Added some comments on the SagaEnd annotation.
new 601f6f4 SCB-1369 Add Elasticsearch Persistence Repository
new a70fded SCB-1369 Resolve conflicts with Netty when initializing the
number of client processors
new 9d5a712 SCB-1369 Save transaction data to Elasticsearch after
SagaActor stopped
new a9cb93b SCB-1369 Rename Benchmark.md to benchmark_zh.md
new 5e997a4 SCB-1369 Add how_to_use_fsm_zh.md
new 19d7bb5 SCB-1369 Merge cucumber feature
new b8c1f65 SCB-1369 Merge cucumber feature & Redefine the byteman port
number for booking, car, hotel
new b7f4cb0 SCB-1369 Delete unused method & class
new 06aa103 SCB-1369 Modified to finally call the stopSagaData method
new 690ebe1 SCB-1369 Use synchronization methods to avoid conflicts
between thread refreshTimer and batch writes
new f3c76dd SCB-1369 Default non-persistent transaction data
new 640c20a SCB-1369 Modify counter error
new 4e6b3ab SCB-1369 Define Elasticsearch Document Object for Query
new c4cbc24 SCB-1369 Define Paging Query Object for APIs
new 3ca8812 SCB-1369 Attribute events type changed to Map for deserialize
the JSON
new a888641 SCB-1369 Add paging query event list method and single event
query method for APIs
new b54421e SCB-1369 Clean up memory data after persisting data to ES
new 4d2d9e0 SCB-1369 Event object built-in toMap method
new a5156f6 SCB-1369 Modify the test case to get transaction data
new 37b44cd SCB-1369 Change @Autowired TransactionRepository required is
false for Unit Tests
new 7b7e1d3 SCB-1369 rebase
new e7a43a4 SCB-1369 Test APIs adds prefix /test
new 1fe0bd2 SCB-1369 Save transaction data to Elasticsearch after
SagaActor stopped
new c79846e SCB-1369 Delete unused method & class
new 15956e1 SCB-1369 Default non-persistent transaction data
new 3980564 SCB-1369 Fixed typo Global
new ceec64b SCB-1369 Fixed conflict
new 8a55243 SCB-1369 Fixed typo
new c19ef0c SCB-1369 Add license header
new 6b18f4e SCB-1369 Update document
new b78efa7 SCB-1369 Add unit test cases for APIControllerV1
new 4207b65 SCB-1369 Fixed typo
new c9651fc SCB-1369 Modify APIs to return JSON date format to long
new 166e696 SCB-1369 Fixed typo
new 131eb83 SCB-1369 Fixed transaction typo
new 4130d60 SCB-1369 Fixed global typo
new 5ab27e8 SCB-1369 Add License header
new 958e597 SCB-1369 Modify warning message
The 38 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:
.../acceptance-pack-akka-spring-demo/pom.xml | 27 ++
.../org/apache/servicecomb/pack/PackStepdefs.java | 6 +-
.../alpha_records_transaction_events.feature | 169 +++++++
...ion_after_post_car_compensated_scenario.feature | 42 --
...n_after_post_hotel_compensated_scenario.feature | 46 --
...pack_booking_timeout_suspended_scenario.feature | 44 --
.../pack_car_fail_compensated_scenario.feature | 37 --
.../pack_hotel_fail_compensated_scenario.feature | 41 --
.../test/resources/pack_success_scenario.feature | 41 --
.../pack/alpha/core/fsm/PackSagaEvent.java | 150 -------
alpha/alpha-fsm/pom.xml | 12 +
.../pack/alpha/fsm/FsmAutoConfiguration.java | 84 +++-
.../servicecomb/pack/alpha/fsm/SagaActor.java | 10 +-
.../pack/alpha/fsm}/TransactionType.java | 4 +-
.../pack/alpha/fsm/event/base/BaseEvent.java | 12 +-
.../pack/alpha/fsm/metrics/MetricsBean.java | 46 ++
.../servicecomb/pack/alpha/fsm/model/SagaData.java | 18 -
.../servicecomb/pack/alpha/fsm/model/TxEntity.java | 17 +-
.../AbstractTransactionRepositoryChannel.java} | 30 +-
.../fsm/repository/NoneTransactionRepository.java | 29 +-
.../fsm/repository/TransactionRepository.java} | 17 +-
.../TransactionRepositoryChannel.java} | 8 +-
.../MemoryTransactionRepositoryChannel.java} | 34 +-
.../ElasticsearchTransactionRepository.java | 204 +++++++++
.../elasticsearch/GlobalTransactionDocument.java | 12 +-
.../fsm/repository/model/GlobalTransaction.java | 181 ++++++++
.../repository/model/PagingGlobalTransactions.java | 100 +++++
.../fsm/repository/model/SagaSubTransaction.java | 109 +++++
.../spring/integration/akka/SagaDataExtension.java | 106 ++---
.../eventbus/EventSubscribeBeanPostProcessor.java | 62 ---
.../servicecomb/pack/alpha/fsm/SagaActorTest.java | 55 ++-
.../pack/alpha/fsm/SagaIntegrationTest.java | 73 +--
.../ElasticsearchTransactionRepositoryTest.java | 139 ++++++
.../servicecomb/pack/alpha/server/AlphaConfig.java | 2 +
.../pack/alpha/server/api/APIControllerV1.java | 24 +
.../alpha/server/fsm/FsmSagaDataController.java | 3 +-
.../src/main/resources/application.yaml | 2 +
.../alpha/server/api/APIControllerV1Tests.java | 310 +++++++++++++
.../alpha/server/fsm/AlphaIntegrationFsmTest.java | 83 ++--
docs/fsm/{Benchmark.md => benchmark_zh.md} | 0
docs/fsm/how_to_use_fsm.md | 491 ++++++++++++++++++++
docs/fsm/how_to_use_fsm_zh.md | 496 +++++++++++++++++++++
docs/user_guide.md | 7 +-
docs/user_guide_zh.md | 6 +-
44 files changed, 2656 insertions(+), 733 deletions(-)
create mode 100644
acceptance-tests/acceptance-pack-akka-spring-demo/src/test/resources/alpha_records_transaction_events.feature
delete mode 100644
acceptance-tests/acceptance-pack-akka-spring-demo/src/test/resources/pack_booking_exception_after_post_car_compensated_scenario.feature
delete mode 100644
acceptance-tests/acceptance-pack-akka-spring-demo/src/test/resources/pack_booking_exception_after_post_hotel_compensated_scenario.feature
delete mode 100644
acceptance-tests/acceptance-pack-akka-spring-demo/src/test/resources/pack_booking_timeout_suspended_scenario.feature
delete mode 100644
acceptance-tests/acceptance-pack-akka-spring-demo/src/test/resources/pack_car_fail_compensated_scenario.feature
delete mode 100644
acceptance-tests/acceptance-pack-akka-spring-demo/src/test/resources/pack_hotel_fail_compensated_scenario.feature
delete mode 100644
acceptance-tests/acceptance-pack-akka-spring-demo/src/test/resources/pack_success_scenario.feature
delete mode 100644
alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/fsm/PackSagaEvent.java
copy
{omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/core
=>
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm}/TransactionType.java
(91%)
copy
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/{channel/KafkaActorEventChannel.java
=> repository/AbstractTransactionRepositoryChannel.java} (55%)
copy
omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/pack/omega/connector/grpc/core/ReconnectStreamObserver.java
=>
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/NoneTransactionRepository.java
(57%)
copy
alpha/{alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/CommandRepository.java
=>
alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/TransactionRepository.java}
(61%)
copy
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/{channel/ActorEventChannel.java
=> repository/TransactionRepositoryChannel.java} (77%)
copy
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/{channel/MemoryActorEventChannel.java
=> repository/channel/MemoryTransactionRepositoryChannel.java} (58%)
create mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/elasticsearch/ElasticsearchTransactionRepository.java
copy
demo/tcc-spring-demo/inventory/src/main/java/org/apache/servicecomb/pack/demo/inventory/ProductDao.java
=>
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/elasticsearch/GlobalTransactionDocument.java
(66%)
create mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/model/GlobalTransaction.java
create mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/model/PagingGlobalTransactions.java
create mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/model/SagaSubTransaction.java
delete mode 100644
alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/spring/integration/eventbus/EventSubscribeBeanPostProcessor.java
create mode 100644
alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/repository/ElasticsearchTransactionRepositoryTest.java
create mode 100644
alpha/alpha-server/src/test/java/org/apache/servicecomb/pack/alpha/server/api/APIControllerV1Tests.java
rename docs/fsm/{Benchmark.md => benchmark_zh.md} (100%)
create mode 100644 docs/fsm/how_to_use_fsm.md
create mode 100644 docs/fsm/how_to_use_fsm_zh.md
