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/incubator-servicecomb-saga.git.
from 8ff04bd Update the k8s base/ folder description. Add the intro of
jmeter-collector and the load test ref.
new 819f19a SCB-856 Implement alpha TCC workflow based on local memory.
new 46f0f3b SCB-856 Add junit test framework code for alpha TCC workflow.
new 2064d86 SCB-856 Revise GrpcTccCordinateCommand =>
GrpcTccCoordinateCommand.
new 4781bc1 SCB-856 Revise ParticipateEvent => ParticipatedEvent.
new a7d2b08 SCB-856 Remove author info from class header.
new e9455e0 SCB-856 Integrate alpha saga and tcc within same boot which
are different with port.
new b8a691b SCB-856 Refactor alpha tcc test framework with integrated
server.
new 3f73776 SCB-856 Add junit test case & resolve related bugs.
new 428f877 SCB-856 Refactor TCC alpha server using the same grpc port of
saga.
new 91ddb85 SCB-856 Refactor TCC alpha server with TccCallbackEngine.
new 96d09dc SCB-856 Refactor TCC alpha server package.
new 3126512 SCB-856 Add exception junit test case for TCC alpha server.
new 3875184 SCB-856 Add info log for alpha GrpcTccEventService.
new 697dcc3 SCB-856 Revise alpha TCC server test case.
The 14 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:
.../servicecomb/saga/alpha/server/AlphaConfig.java | 35 ++-
.../saga/alpha/server/GrpcServerConfig.java | 2 +-
.../saga/alpha/server/GrpcStartable.java | 4 +-
.../saga/alpha/server/ServerStartable.java | 2 +-
.../saga/alpha/server/tcc/GrpcTccEventService.java | 92 +++++++
.../alpha/server/tcc/callback/CallbackEngine.java | 25 ++
.../server/tcc/callback/GrpcOmegaTccCallback.java | 53 +++++
.../alpha/server/tcc/callback/OmegaCallback.java | 29 +++
.../server/tcc/callback/OmegaCallbackWrapper.java | 36 +++
.../server/tcc/callback/TccCallbackEngine.java | 62 +++++
.../server/tcc/event/ParticipateEventFactory.java | 38 ++-
.../alpha/server/tcc/event}/ParticipatedEvent.java | 31 ++-
.../tcc/registry/OmegaCallbacksRegistry.java | 96 ++++++++
.../tcc/registry/TransactionEventRegistry.java | 64 +++++
.../saga/alpha/server/AlphaIntegrationTest.java | 16 +-
.../saga/alpha/tcc/server/AlphaTccServerTest.java | 263 +++++++++++++++++++++
.../server/TccCoordinateCommandStreamObserver.java | 56 +++++
17 files changed, 836 insertions(+), 68 deletions(-)
create mode 100644
alpha/alpha-server/src/main/java/org/apache/servicecomb/saga/alpha/server/tcc/GrpcTccEventService.java
create mode 100644
alpha/alpha-server/src/main/java/org/apache/servicecomb/saga/alpha/server/tcc/callback/CallbackEngine.java
create mode 100644
alpha/alpha-server/src/main/java/org/apache/servicecomb/saga/alpha/server/tcc/callback/GrpcOmegaTccCallback.java
create mode 100644
alpha/alpha-server/src/main/java/org/apache/servicecomb/saga/alpha/server/tcc/callback/OmegaCallback.java
create mode 100644
alpha/alpha-server/src/main/java/org/apache/servicecomb/saga/alpha/server/tcc/callback/OmegaCallbackWrapper.java
create mode 100644
alpha/alpha-server/src/main/java/org/apache/servicecomb/saga/alpha/server/tcc/callback/TccCallbackEngine.java
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/tcc/events/TccEndedEvent.java
=>
alpha/alpha-server/src/main/java/org/apache/servicecomb/saga/alpha/server/tcc/event/ParticipateEventFactory.java
(59%)
copy
{omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/tcc/events
=>
alpha/alpha-server/src/main/java/org/apache/servicecomb/saga/alpha/server/tcc/event}/ParticipatedEvent.java
(71%)
create mode 100644
alpha/alpha-server/src/main/java/org/apache/servicecomb/saga/alpha/server/tcc/registry/OmegaCallbacksRegistry.java
create mode 100644
alpha/alpha-server/src/main/java/org/apache/servicecomb/saga/alpha/server/tcc/registry/TransactionEventRegistry.java
create mode 100644
alpha/alpha-server/src/test/java/org/apache/servicecomb/saga/alpha/tcc/server/AlphaTccServerTest.java
create mode 100644
alpha/alpha-server/src/test/java/org/apache/servicecomb/saga/alpha/tcc/server/TccCoordinateCommandStreamObserver.java
