-
Notifications
You must be signed in to change notification settings - Fork 278
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
(WIP) Feat transaction at datasource #127
(WIP) Feat transaction at datasource #127
Conversation
realize branchReport
add processor unittest
change the format of the log
remove the duplicate code same with sample/local
feature append action context for tcc
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
@@ -64,6 +64,18 @@ func (RMRemoting) BranchRegister(branchType branch.BranchType, resourceId, clien | |||
|
|||
// Branch report | |||
func (RMRemoting) BranchReport(branchType branch.BranchType, xid string, branchId int64, status branch.BranchStatus, applicationData string) error { | |||
request := message.BranchReportRequest{ | |||
Xid: xid, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
这里的RMRemoting类相当于seata-java当中的AbstractResourceManager 作为ResourceManager的代理管理分支分支事务?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
类似
是不是需要rebase一下master分支呢? |
我应该 pull master 修复了下问题 |
import ( | ||
_ "github.com/seata/seata-go-datasource/sql/exec/hook" | ||
|
||
// mysql 相关插件 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
do not use chinese
* realize branchReport * feat: add datasource proxy * add processor unittest * remove blank and annotation * branchReport return value judgment * feat: none * feat: refactor datasource design * docs: add code comment * refactor: rename SQLHook to SQLInterceptor * refactor: none * optimize-zap-log * update changed the format of log * remove the duplicate code same with sample/local * feat: add rm * feat: none * refactor: refactor undo log * optimize format of logging * optimize format of logging * optimize format of logging * Update logging.go * refactor: refactor db resource proxy * refactor: refactot data proxy * feature add action context for tcc * add err check for unmarshal json * feat: query use Executor * refactor: refactor code and fix bug * refactor: refactor datasource AT mode Co-authored-by: lichen <[email protected]> Co-authored-by: springliao <[email protected]> Co-authored-by: cgDeepLearn <[email protected]> Co-authored-by: liiibpm <[email protected]> Co-authored-by: juzimao <[email protected]> Co-authored-by: Xin.Zh <[email protected]>
* realize branchReport * feat: add datasource proxy * add processor unittest * remove blank and annotation * branchReport return value judgment * feat: none * feat: refactor datasource design * docs: add code comment * refactor: rename SQLHook to SQLInterceptor * refactor: none * optimize-zap-log * update changed the format of log * remove the duplicate code same with sample/local * feat: add rm * feat: none * refactor: refactor undo log * optimize format of logging * optimize format of logging * optimize format of logging * Update logging.go * refactor: refactor db resource proxy * refactor: refactot data proxy * feature add action context for tcc * add err check for unmarshal json * feat: query use Executor * refactor: refactor code and fix bug * refactor: refactor datasource AT mode Co-authored-by: lichen <[email protected]> Co-authored-by: springliao <[email protected]> Co-authored-by: cgDeepLearn <[email protected]> Co-authored-by: liiibpm <[email protected]> Co-authored-by: juzimao <[email protected]> Co-authored-by: Xin.Zh <[email protected]>
No description provided.