Skip to content

Commit

Permalink
release 0.8.0
Browse files Browse the repository at this point in the history
release 0.8.0
  • Loading branch information
slievrly authored Aug 16, 2019
2 parents 39e4d89 + 543b0da commit 0945681
Show file tree
Hide file tree
Showing 200 changed files with 7,532 additions and 1,629 deletions.
6 changes: 3 additions & 3 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,10 @@
[![maven](https://img.shields.io/maven-central/v/io.seata/seata-parent.svg)](https://search.maven.org/search?q=io.seata)
[![](https://img.shields.io/twitter/follow/seataio.svg?label=Follow&style=social&logoWidth=0)](https://twitter.com/intent/follow?screen_name=seataio)


## What is Seata?

A **distributed transaction solution** with high performance and ease of use for **microservices** architecture.

### Distributed Transaction Problem in Microservices

Let's imagine a traditional monolithic application. Its business is built up with 3 modules. They use a single local data source.
Expand Down Expand Up @@ -75,13 +75,13 @@ For more details about principle and design, please go to [Seata wiki page](http

##### Seata Community

- **Seata** :Simple Extensible Autonomous Transaction Architecture. Ant Financial joins Fescar, which make it to be a more neutral and open community for distributed transaction,and Fescar be rename to Seata.
- **Seata** :Simple Extensible Autonomous Transaction Architecture. Ant Financial joins Fescar, which make it to be a more neutral and open community for distributed transaction,and Fescar be renamed to Seata.



## Maven dependency
```xml
<seata.version>0.7.1</seata.version>
<seata.version>0.8.0</seata.version>

<dependency>
<groupId>io.seata</groupId>
Expand Down
2 changes: 1 addition & 1 deletion all/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@

<groupId>io.seata</groupId>
<artifactId>seata-all</artifactId>
<version>0.7.1</version>
<version>0.8.0</version>

<name>Seata All-in-one ${project.version}</name>
<url>http://seata.io</url>
Expand Down
28 changes: 26 additions & 2 deletions bom/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@

<groupId>io.seata</groupId>
<artifactId>seata-bom</artifactId>
<version>0.7.1</version>
<version>0.8.0</version>

<modelVersion>4.0.0</modelVersion>
<packaging>pom</packaging>
Expand Down Expand Up @@ -65,7 +65,7 @@

<properties>
<spring.version>4.3.23.RELEASE</spring.version>
<netty4.version>4.1.24.Final</netty4.version>
<netty4.version>4.1.30.Final</netty4.version>
<dubbo.version>2.7.0</dubbo.version>
<dubbo.alibaba.version>2.6.5</dubbo.alibaba.version>
<sofa.rpc.version>5.5.3</sofa.rpc.version>
Expand Down Expand Up @@ -234,6 +234,12 @@
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>${apache-zookeeper.version}</version>
<exclusions>
<exclusion>
<artifactId>io.netty</artifactId>
<groupId>netty</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
Expand Down Expand Up @@ -307,6 +313,24 @@
<groupId>io.etcd</groupId>
<artifactId>jetcd-core</artifactId>
<version>${etcd-client-v3.version}</version>
<exclusions>
<exclusion>
<groupId>io.netty</groupId>
<artifactId>netty-codec-http</artifactId>
</exclusion>
<exclusion>
<groupId>io.netty</groupId>
<artifactId>netty-codec-http2</artifactId>
</exclusion>
<exclusion>
<groupId>io.netty</groupId>
<artifactId>netty-handler-proxy</artifactId>
</exclusion>
<exclusion>
<groupId>io.netty</groupId>
<artifactId>netty-handler</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,12 +15,12 @@
*/
package io.seata.codec.protobuf.convertor;

import io.seata.core.model.BranchType;
import io.seata.codec.protobuf.generated.AbstractMessageProto;
import io.seata.codec.protobuf.generated.AbstractTransactionRequestProto;
import io.seata.codec.protobuf.generated.BranchRegisterRequestProto;
import io.seata.codec.protobuf.generated.BranchTypeProto;
import io.seata.codec.protobuf.generated.MessageTypeProto;
import io.seata.core.model.BranchType;
import io.seata.core.protocol.transaction.BranchRegisterRequest;

/**
Expand All @@ -40,11 +40,12 @@ public BranchRegisterRequestProto convert2Proto(BranchRegisterRequest branchRegi

final String applicationData = branchRegisterRequest.getApplicationData();
final String resourceId = branchRegisterRequest.getResourceId();
final String lockKey = branchRegisterRequest.getLockKey();
BranchRegisterRequestProto result = BranchRegisterRequestProto.newBuilder()
.setAbstractTransactionRequest(abstractTransactionRequestProto)
.setApplicationData(applicationData==null?"":applicationData)
.setApplicationData(applicationData == null ? "" : applicationData)
.setBranchType(BranchTypeProto.valueOf(branchRegisterRequest.getBranchType().name()))
.setLockKey(branchRegisterRequest.getLockKey())
.setLockKey(lockKey == null ? "" : lockKey)
.setResourceId(resourceId == null ? "" : resourceId)
.setXid(branchRegisterRequest.getXid())
.build();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,13 +15,13 @@
*/
package io.seata.codec.protobuf.convertor;

import io.seata.core.model.BranchType;
import io.seata.codec.protobuf.generated.AbstractMessageProto;
import io.seata.codec.protobuf.generated.AbstractTransactionRequestProto;
import io.seata.codec.protobuf.generated.BranchRegisterRequestProto;
import io.seata.codec.protobuf.generated.BranchTypeProto;
import io.seata.codec.protobuf.generated.GlobalLockQueryRequestProto;
import io.seata.codec.protobuf.generated.MessageTypeProto;
import io.seata.core.model.BranchType;
import io.seata.core.protocol.transaction.GlobalLockQueryRequest;

/**
Expand All @@ -41,11 +41,12 @@ public GlobalLockQueryRequestProto convert2Proto(GlobalLockQueryRequest globalLo
abstractMessage).build();

final String applicationData = globalLockQueryRequest.getApplicationData();
final String lockKey = globalLockQueryRequest.getLockKey();
BranchRegisterRequestProto branchRegisterRequestProto = BranchRegisterRequestProto.newBuilder()
.setAbstractTransactionRequest(abstractTransactionRequestProto)
.setApplicationData(applicationData==null?"":applicationData)
.setApplicationData(applicationData == null ? "" : applicationData)
.setBranchType(BranchTypeProto.valueOf(globalLockQueryRequest.getBranchType().name()))
.setLockKey(globalLockQueryRequest.getLockKey())
.setLockKey(lockKey == null ? "" : lockKey)
.setResourceId(globalLockQueryRequest.getResourceId())
.setXid(globalLockQueryRequest.getXid())
.build();
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,61 @@
/*
* Copyright 1999-2019 Seata.io Group.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.seata.codec.protobuf.convertor;

import io.seata.codec.protobuf.generated.AbstractMessageProto;
import io.seata.codec.protobuf.generated.AbstractTransactionRequestProto;
import io.seata.codec.protobuf.generated.BranchTypeProto;
import io.seata.codec.protobuf.generated.MessageTypeProto;
import io.seata.codec.protobuf.generated.UndoLogDeleteRequestProto;
import io.seata.core.model.BranchType;
import io.seata.core.protocol.transaction.UndoLogDeleteRequest;

/**
* @author yuanguoyao
*/
public class UndoLogDeleteRequestConvertor implements PbConvertor<UndoLogDeleteRequest, UndoLogDeleteRequestProto> {
@Override
public UndoLogDeleteRequestProto convert2Proto(UndoLogDeleteRequest undoLogDeleteRequest) {
final short typeCode = undoLogDeleteRequest.getTypeCode();

final AbstractMessageProto abstractMessage = AbstractMessageProto.newBuilder().setMessageType(
MessageTypeProto.forNumber(typeCode)).build();

final AbstractTransactionRequestProto abstractTransactionRequestProto = AbstractTransactionRequestProto
.newBuilder().setAbstractMessage(
abstractMessage).build();

final UndoLogDeleteRequestProto undoLogDeleteRequestProto = UndoLogDeleteRequestProto
.newBuilder()
.setAbstractTransactionRequest(abstractTransactionRequestProto)
.setSaveDays(undoLogDeleteRequest.getSaveDays())
.setBranchType(BranchTypeProto.valueOf(undoLogDeleteRequest.getBranchType().name()))
.setResourceId(undoLogDeleteRequest.getResourceId())
.build();

return undoLogDeleteRequestProto;
}

@Override
public UndoLogDeleteRequest convert2Model(UndoLogDeleteRequestProto undoLogDeleteRequestProto) {
UndoLogDeleteRequest undoLogDeleteRequest = new UndoLogDeleteRequest();
undoLogDeleteRequest.setSaveDays((short)undoLogDeleteRequestProto.getSaveDays());
undoLogDeleteRequest.setResourceId(undoLogDeleteRequestProto.getResourceId());
undoLogDeleteRequest.setBranchType(BranchType.valueOf(undoLogDeleteRequestProto.getBranchType().name()));

return undoLogDeleteRequest;
}
}

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading

0 comments on commit 0945681

Please sign in to comment.