This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a change to branch SCB-817
in repository
https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git.
omit 5e5aade SCB-817 Added the unit tests of TCC related Aspect
add 6dee598 SCB-817 Added the unit tests of TCC related Aspect
add 22082fe SCB-866 extend SQLTransport type
add e38d1b7 SCB-867 Add SQL type Jackson format
add 95be096 SCB-867 Add test for SQL Jackson format
add 9487ac2 [SCB-865] Refactoring the Omega Interceptors 1.Remove the
inheritance hierarchy between SagaStartAnnotationProcessor and
EventAwareInterceptor. 2.Remove the NO_OP_INTERCEPTOR from the interface
EventAwareInterceptor. Turning the NoOp Implementation into a class of static
singleton pattern.
add 0f3ab0a [SCB-865] Refactoring the Omega Interceptors 1. Removing
parentId when dealing with error.
add 314e0cc SCB-865 Added the license header to NoOpEventAwareInterceptor
add 4e3bb69 Expose alpha's gRPC port(8090)
add 5f55399 Add the load test guide.
add 8ff04bd Update the k8s base/ folder description. Add the intro of
jmeter-collector and the load test ref.
new 588059d SCB-817 Updated the TCC protocol for CoordinatedEvent
new dbb7441 SCB-817 Update the omega transactions code
new 20e9afd SCB-818 Implements the TccEventServie of grpc
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (5e5aade)
\
N -- N -- N refs/heads/SCB-817 (20e9afd)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 3 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:
docs/load_test.md | 49 ++++
omega/omega-connector/omega-connector-grpc/pom.xml | 6 +-
.../grpc/GrpcCompensateStreamObserver.java | 3 +-
...rver.java => GrpcCoordinateStreamObserver.java} | 37 +--
.../omega/connector/grpc/GrpcTccEventService.java | 156 +++++++++++++
.../connector/grpc/GrpcTccEventServiceTest.java | 260 +++++++++++++++++++++
.../omega/transaction/EventAwareInterceptor.java | 18 +-
...Factory.java => NoOpEventAwareInterceptor.java} | 27 ++-
.../transaction/SagaStartAnnotationProcessor.java | 23 +-
.../saga/omega/transaction/SagaStartAspect.java | 7 +-
...tService.java => CoordinateMessageHandler.java} | 30 +--
.../transaction/{ => tcc}/MessageHandler.java | 4 +-
.../omega/transaction/tcc/TccEventService.java | 8 +-
.../tcc/TccStartAnnotationProcessor.java | 6 +-
.../{TccEndedEvent.java => CoordinatedEvent.java} | 28 ++-
.../SagaStartAnnotationProcessorTest.java | 17 +-
.../tcc/CoordinateMessageHandlerTest.java | 109 +++++++++
.../transaction/tcc/TccParticipatorAspectTest.java | 11 +-
.../tcc/TccStartAnnotationProcessorTest.java | 10 +-
.../omega/transaction/tcc/TccStartAspectTest.java | 9 +-
.../src/main/proto/GrpcTccEvent.proto | 12 +
pom.xml | 5 +
.../apache/servicecomb/saga/core/Operation.java | 1 +
...ccessfulSagaResponse.java => SQLOperation.java} | 39 +++-
.../{RestTransport.java => SQLTransport.java} | 8 +-
saga-demo/saga-k8s-resources/README.md | 2 +-
saga-demo/saga-k8s-resources/base/alpha.yaml | 4 +-
...mpensation.java => JacksonSQLCompensation.java} | 28 +--
...onSagaRequest.java => JacksonSQLOperation.java} | 43 ++--
...Transaction.java => JacksonSQLTransaction.java} | 17 +-
...estSagaRequest.java => JsonSQLSagaRequest.java} | 28 +--
.../servicecomb/saga/format/JsonSagaRequest.java | 3 +-
.../format/JacksonFromJsonFormatForSQLTest.java | 212 +++++++++++++++++
...equestTest.java => JsonSQLSagaRequestTest.java} | 43 +---
34 files changed, 1031 insertions(+), 232 deletions(-)
create mode 100644 docs/load_test.md
copy
omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/saga/omega/connector/grpc/{GrpcCompensateStreamObserver.java
=> GrpcCoordinateStreamObserver.java} (54%)
create mode 100644
omega/omega-connector/omega-connector-grpc/src/main/java/org/apache/servicecomb/saga/omega/connector/grpc/GrpcTccEventService.java
create mode 100644
omega/omega-connector/omega-connector-grpc/src/test/java/org/apache/servicecomb/saga/omega/connector/grpc/GrpcTccEventServiceTest.java
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/{RecoveryPolicyFactory.java
=> NoOpEventAwareInterceptor.java} (58%)
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/tcc/{TccEventService.java
=> CoordinateMessageHandler.java} (59%)
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/{
=> tcc}/MessageHandler.java (88%)
copy
omega/omega-transaction/src/main/java/org/apache/servicecomb/saga/omega/transaction/tcc/events/{TccEndedEvent.java
=> CoordinatedEvent.java} (77%)
create mode 100644
omega/omega-transaction/src/test/java/org/apache/servicecomb/saga/omega/transaction/tcc/CoordinateMessageHandlerTest.java
copy
saga-core/src/main/java/org/apache/servicecomb/saga/core/{SuccessfulSagaResponse.java
=> SQLOperation.java} (57%)
copy
saga-core/src/main/java/org/apache/servicecomb/saga/transports/{RestTransport.java
=> SQLTransport.java} (84%)
copy
saga-format/src/main/java/org/apache/servicecomb/saga/format/{JacksonRestCompensation.java
=> JacksonSQLCompensation.java} (67%)
copy
saga-format/src/main/java/org/apache/servicecomb/saga/format/{JsonSagaRequest.java
=> JacksonSQLOperation.java} (56%)
copy
saga-format/src/main/java/org/apache/servicecomb/saga/format/{JacksonRestTransaction.java
=> JacksonSQLTransaction.java} (75%)
copy
saga-format/src/main/java/org/apache/servicecomb/saga/format/{JsonRestSagaRequest.java
=> JsonSQLSagaRequest.java} (73%)
create mode 100644
saga-format/src/test/java/org/apache/servicecomb/saga/format/JacksonFromJsonFormatForSQLTest.java
copy
saga-format/src/test/java/org/apache/servicecomb/saga/format/{JsonRestSagaRequestTest.java
=> JsonSQLSagaRequestTest.java} (59%)
