This is an automated email from the ASF dual-hosted git repository.
flypiggy pushed a change to branch feature/support-namingserver
in repository https://gitbox.apache.org/repos/asf/incubator-seata-go.git
from 169cfd13 OSPP 2025 Go&Java Version alignment /support-namingserver
(#924)
add 19c5e306 update go version (#880) (#931)
add 7d32bd30 optimize: add missing VERSION file and version support (#895)
add 190b3b95 optimize: correct time format (#902)
add cc5edf7a test: improve test coverage for pkg/datasource/sql/mock (#976)
add df6a5a9b test: improve test coverage for pkg/datasource/sql/types
(#975)
add ad92ad81 test: improve test coverage for pkg/datasource/sql/hook (#978)
add 075cb83c test: improve test coverage for pkg/integration/grpc (#970)
add 4420143b test: Improve test coverage for
pkg/datasource/sql/undo/factor (#972)
add c26ad1cf test: improve test coverage for pkg/integration/gin (#969)
add da8fbf5e Improve test coverage for pkg/datasource/sql/undo/base (#967)
add e56d368b test: Improve test coverage for
pkg/datasource/sql/exec/config (#966)
add 205f8d91 test: improve test coverage for pkg/util/convert (#963)
add 1de80ee8 test: improve test coverage for pkg/util/errors (#962)
add 0747d09d test: improve test coverage for pkg/util/log (#964)
add 7f181b6a test: improve test coverage for pkg/discovery/mock (#984)
add 9ca5bd82 test: improve test coverage for pkg/protocol/branch (#982)
add b74a0be4 test: improve test coverage for pkg/remoting/config (#981)
add eaf4b270 test: improve test coverage for pkg/datasource/sql/util (#974)
add 4dd7de66 test: improve test coverage for pkg/datasource (#973)
add 51094928 test: improve test coverage for discovery/mock and
integration (#985)
add faa32f07 test: add some test (#979)
add 4d2e765b optimize: fix git status issue (#894)
add 85417fd3 test: improve test coverage for pkg/remoting/mock (#980)
add be1ad86e test: improve test coverage for pkg/integration/dubbo (#968)
add c0a7ab09 bugfix: error image when use null value as image query
condition in insert on duplicate #704 (#725) (#884)
add d76ac395 test: Improve test coverage for
pkg/datasource/sql/datasource/mysql (#965)
add b15d9d36 bugfix: close *sql.Rows returned by QueryContext to prevent
resource leak (#989)
add 72f847e4 test: add unit tests for pkg/constant, pkg/client, and pkg/tm
(#988)
add 34dfa822 test: Improve test coverage (#983)
add 174d2f85 test: improve test coverage for pkg/datasource/sql/undo (#971)
add 8632371d fix: Data Race in ConsistentHash LoadBalance (#998)
add afb86509 test: Improve test coverage for pkg/datasource/sql/exec (#999)
add 6437e520 Connections leaks in resource manager (#1011)
add b818a65c Fix: Unable to return the correct type for Zip compression
(#1013)
add 774046b2 optimize: optimize parsePkValues to reduce nested loops
(#1018)
add c39fcc63 Feature/saga (#1030)
add 4bdc7fff feat: Support snappy compression type (#1027)
add b90d3ae0 optimize: enhance RoundRobinLoadBalance performance (#995)
add 623c02ef bugfix: fix connection leaks and potential nil pointer
panic(#991) (#997)
add efdd88af optimize: add contribution intention check box to issue
template (#1025)
add f73b6684 test: add unit test for pkg/rm/tcc/config (#1007)
add 4ea34705 test: add unit test for pkg/rm/config (#1006)
add e2e18563 test: add unit test for pkg/util/flagext/register (#1005)
add b18bcb01 test: add unit test for pkg/rm/init (#1004)
add f5d4da7a push v2.1.0 changes logs (#1047)
add 3ba877c7 fix intergrate test error (#1048)
add 66e77770 fix: modified version to v2 (#1041)
new 94e6c1e0 Merge remote-tracking branch 'upstream/master' into
feature/support-namingserver
The 1 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:
.github/ISSUE_TEMPLATE/#0_bug_report_zh.yml | 4 +-
.github/ISSUE_TEMPLATE/#1_feature_request_zh.yml | 4 +-
.github/ISSUE_TEMPLATE/0_bug_report.yml | 4 +-
.github/ISSUE_TEMPLATE/1_feature_request.yml | 2 +
.github/PULL_REQUEST_TEMPLATE.md | 11 +-
.github/workflows/golangci-lint.yml | 1 -
.github/workflows/integrate-test.yml | 2 +-
.github/workflows/{labeler.yml => issue-robot.yml} | 29 +-
.github/workflows/unit-test.yml | 79 ++
.gitignore | 1 +
.licenserc.yaml | 1 +
.pre-commit-config.yaml => VERSION | 9 +-
changes/2.1.0.md | 125 ++
changes/2.1.0_zh.md | 125 ++
changes/dev.md | 7 +-
cmd/start.go | 61 +
go.mod | 29 +-
go.sum | 36 +-
goimports.sh | 2 +-
integrate_test.sh | 5 +-
makefile | 4 +-
pkg/client/client.go | 28 +-
pkg/client/client_test.go | 161 +++
pkg/client/config.go | 21 +-
pkg/compressor/compressor_type.go | 3 +
pkg/compressor/deflate_compress.go | 2 +-
.../stringmap.go => compressor/snappy_compress.go} | 26 +-
...ip_compress_test.go => snappy_compress_test.go} | 11 +-
pkg/compressor/zip_compress.go | 2 +-
pkg/compressor/zip_compress_test.go | 2 +
pkg/constant/context_test.go | 146 ++
pkg/datasource/init.go | 2 +-
pkg/datasource/init_test.go | 55 +
pkg/datasource/sql/async_worker.go | 13 +-
pkg/datasource/sql/at_resource_manager.go | 12 +-
pkg/datasource/sql/conn.go | 6 +-
pkg/datasource/sql/conn_at.go | 8 +-
pkg/datasource/sql/conn_at_test.go | 10 +-
pkg/datasource/sql/conn_xa.go | 9 +-
pkg/datasource/sql/conn_xa_test.go | 10 +-
pkg/datasource/sql/connector.go | 2 +-
pkg/datasource/sql/connector_test.go | 8 +-
pkg/datasource/sql/datasource/base/meta_cache.go | 10 +-
.../sql/datasource/base/meta_cache_test.go | 106 +-
.../sql/datasource/datasource_manager.go | 6 +-
pkg/datasource/sql/datasource/mysql/meta_cache.go | 4 +-
.../sql/datasource/mysql/meta_cache_test.go | 367 +++++
pkg/datasource/sql/datasource/mysql/trigger.go | 14 +-
.../sql/datasource/mysql/trigger_test.go | 547 +++++++-
pkg/datasource/sql/db.go | 16 +-
pkg/datasource/sql/driver.go | 12 +-
pkg/datasource/sql/driver_test.go | 8 +-
pkg/datasource/sql/exec/at/at_executor.go | 10 +-
pkg/datasource/sql/exec/at/at_executor_test.go | 422 ++++++
pkg/datasource/sql/exec/at/base_executor.go | 12 +-
pkg/datasource/sql/exec/at/base_executor_test.go | 6 +-
pkg/datasource/sql/exec/at/config.go | 2 +-
pkg/datasource/sql/exec/at/delete_executor.go | 14 +-
pkg/datasource/sql/exec/at/delete_executor_test.go | 8 +-
pkg/datasource/sql/exec/at/escape.go | 4 +-
pkg/datasource/sql/exec/at/escape_test.go | 2 +-
pkg/datasource/sql/exec/at/insert_executor.go | 10 +-
pkg/datasource/sql/exec/at/insert_executor_test.go | 12 +-
.../sql/exec/at/insert_on_update_executor.go | 10 +-
.../sql/exec/at/insert_on_update_executor_test.go | 6 +-
.../sql/exec/at/multi_delete_executor.go | 10 +-
.../sql/exec/at/multi_delete_executor_test.go | 10 +-
pkg/datasource/sql/exec/at/multi_executor.go | 6 +-
pkg/datasource/sql/exec/at/multi_update_excutor.go | 14 +-
.../sql/exec/at/multi_update_excutor_test.go | 14 +-
pkg/datasource/sql/exec/at/plain_executor.go | 4 +-
pkg/datasource/sql/exec/at/plain_executor_test.go | 6 +-
.../sql/exec/at/select_for_update_executor.go | 20 +-
.../sql/exec/at/select_for_update_executor_test.go | 4 +-
pkg/datasource/sql/exec/at/update_executor.go | 18 +-
pkg/datasource/sql/exec/at/update_executor_test.go | 16 +-
pkg/datasource/sql/exec/at/update_join_executor.go | 12 +-
.../sql/exec/at/update_join_executor_test.go | 13 +-
pkg/datasource/sql/exec/config/config.go | 4 +-
pkg/datasource/sql/exec/config/config_test.go | 112 ++
pkg/datasource/sql/exec/executor.go | 4 +-
pkg/datasource/sql/exec/executor_test.go | 471 +++++++
pkg/datasource/sql/exec/hook.go | 2 +-
pkg/datasource/sql/exec/hook_test.go | 460 +++++++
.../sql/exec/select_for_update_executor.go | 16 +-
pkg/datasource/sql/hook/logger_hook.go | 6 +-
pkg/datasource/sql/hook/logger_hook_test.go | 188 +++
pkg/datasource/sql/hook/undo_log_hook.go | 10 +-
pkg/datasource/sql/hook/undo_log_hook_test.go | 555 ++++++++
pkg/datasource/sql/mock/mock_datasource_manager.go | 8 +-
.../sql/mock/mock_datasource_manager_test.go | 209 +++
.../sql/mock/mock_driver_components_test.go | 203 +++
pkg/datasource/sql/mock/mock_driver_test.go | 262 ++++
.../sql/mock/mock_table_meta_cache_test.go | 91 ++
pkg/datasource/sql/parser/parse_factory_test.go | 4 +-
pkg/datasource/sql/parser/parser_factory.go | 2 +-
pkg/datasource/sql/plugin.go | 14 +-
pkg/datasource/sql/stmt.go | 6 +-
pkg/datasource/sql/tx.go | 12 +-
pkg/datasource/sql/tx_at.go | 2 +-
pkg/datasource/sql/types/const_test.go | 195 +++
pkg/datasource/sql/types/dbtype_string_test.go | 57 +
pkg/datasource/sql/types/executor.go | 2 +-
pkg/datasource/sql/types/executor_test.go | 206 +++
pkg/datasource/sql/types/image.go | 11 +-
pkg/datasource/sql/types/image_test.go | 150 +++
pkg/datasource/sql/types/key_type_test.go | 77 ++
pkg/datasource/sql/types/meta_test.go | 94 ++
...ketword_checker.go => mysql_keyword_checker.go} | 0
.../sql/types/mysql_keyword_checker_test.go | 263 ++++
pkg/datasource/sql/types/sql_data_type_test.go | 193 +++
pkg/datasource/sql/types/sql_test.go | 216 +++
pkg/datasource/sql/types/types.go | 2 +-
pkg/datasource/sql/types/types_test.go | 387 ++++++
pkg/datasource/sql/undo/base/undo.go | 33 +-
pkg/datasource/sql/undo/base/undo_test.go | 1411 ++++++++++++++++++++
.../sql/undo/builder/basic_undo_log_builder.go | 10 +-
.../undo/builder/basic_undo_log_builder_test.go | 20 +-
.../undo/builder/mysql_delete_undo_log_builder.go | 10 +-
.../builder/mysql_delete_undo_log_builder_test.go | 65 +-
.../undo/builder/mysql_insert_undo_log_builder.go | 8 +-
.../builder/mysql_insert_undo_log_builder_test.go | 47 +-
...ql_insertonduplicate_update_undo_log_builder.go | 228 +++-
...sertonduplicate_update_undo_log_builder_test.go | 116 +-
.../builder/mysql_multi_delete_undo_log_builder.go | 8 +-
.../undo/builder/mysql_multi_undo_log_builder.go | 4 +-
.../builder/mysql_multi_undo_log_builder_test.go | 208 +++
.../builder/mysql_multi_update_undo_log_builder.go | 8 +-
.../mysql_multi_update_undo_log_builder_test.go | 4 +-
.../undo/builder/mysql_update_undo_log_builder.go | 10 +-
.../builder/mysql_update_undo_log_builder_test.go | 10 +-
pkg/datasource/sql/undo/config.go | 2 +-
pkg/datasource/sql/undo/config_test.go | 201 +++
pkg/datasource/sql/undo/executor/executor.go | 35 +-
pkg/datasource/sql/undo/executor/executor_test.go | 361 ++++-
.../undo/executor/mysql_undo_delete_executor.go | 4 +-
.../executor/mysql_undo_delete_executor_test.go | 316 +++++
.../undo/executor/mysql_undo_executor_holder.go | 2 +-
.../executor/mysql_undo_executor_holder_test.go | 92 ++
.../undo/executor/mysql_undo_insert_executor.go | 4 +-
.../executor/mysql_undo_insert_executor_test.go | 357 +++++
.../undo/executor/mysql_undo_update_executor.go | 4 +-
.../executor/mysql_undo_update_executor_test.go | 310 +++++
pkg/datasource/sql/undo/executor/sql.go | 4 +-
pkg/datasource/sql/undo/executor/sql_test.go | 262 +++-
pkg/datasource/sql/undo/executor/utils.go | 6 +-
pkg/datasource/sql/undo/executor/utils_test.go | 518 +++++++
.../sql/undo/factor/undo_executor_factory.go | 6 +-
.../sql/undo/factor/undo_executor_factory_test.go | 163 +++
.../sql/undo/factor/undo_executor_holder_factor.go | 6 +-
.../factor/undo_executor_holder_factor_test.go | 130 ++
pkg/datasource/sql/undo/mysql/default.go | 4 +-
.../sql/undo/mysql/default_test.go} | 39 +-
pkg/datasource/sql/undo/mysql/undo.go | 6 +-
pkg/datasource/sql/undo/mysql/undo_test.go | 151 +++
.../sql/undo/parser/branch_undo_log.pb.go | 5 +-
.../sql/undo/parser/const_test.go} | 26 +-
pkg/datasource/sql/undo/parser/parser_api.go | 2 +-
pkg/datasource/sql/undo/parser/parser_api_test.go | 187 +++
.../sql/undo/parser/parser_cache_test.go | 73 +
pkg/datasource/sql/undo/parser/parser_json.go | 2 +-
pkg/datasource/sql/undo/parser/parser_json_test.go | 42 +-
pkg/datasource/sql/undo/parser/parser_protobuf.go | 11 +-
.../sql/undo/parser/parser_protobuf_test.go | 35 +-
.../sql/undo/parser/protobuf_conversion_test.go | 422 ++++++
.../sql/undo/parser/protobuf_generated_test.go | 362 +++++
pkg/datasource/sql/undo/undo.go | 12 +-
pkg/datasource/sql/undo/undo_executor.go | 2 +-
.../sql/undo/undo_executor_holder_test.go | 117 ++
.../sql/undo/undo_executor_test.go} | 37 +-
pkg/datasource/sql/undo/undo_test.go | 367 +++++
pkg/datasource/sql/undo_test.go | 4 +-
pkg/datasource/sql/util/convert_test.go | 473 +++++++
pkg/datasource/sql/util/ctxutil_test.go | 505 +++++++
pkg/datasource/sql/util/lockkey.go | 3 +-
pkg/datasource/sql/util/lockkey_test.go | 543 ++++++++
pkg/datasource/sql/util/params_test.go | 172 +++
pkg/datasource/sql/util/sql_test.go | 570 ++++++++
pkg/datasource/sql/xa/mysql_xa_connection.go | 2 +-
pkg/datasource/sql/xa/mysql_xa_connection_test.go | 2 +-
pkg/datasource/sql/xa/xa_resource_factory.go | 4 +-
pkg/datasource/sql/xa_resource_manager.go | 12 +-
pkg/discovery/config.go | 2 +-
pkg/discovery/etcd3.go | 4 +-
pkg/discovery/etcd3_test.go | 12 +-
pkg/discovery/file.go | 4 +-
pkg/discovery/mock/mock_etcd_client_test.go | 160 +++
pkg/discovery/mock/test_etcd_client.go | 2 +-
pkg/integration/dubbo/dubbo_transaction_filter.go | 6 +-
.../dubbo/dubbo_transaction_filter_test.go | 420 +++++-
pkg/integration/gin/gin_transaction_middleware.go | 6 +-
.../gin/gin_transaction_middleware_test.go | 172 +++
.../grpc/grpc_transaction_interceptor.go | 8 +-
.../grpc/grpc_transaction_interceptor_test.go | 353 +++++
pkg/integration/integration.go | 2 +-
pkg/integration/integration_test.go | 205 +++
pkg/protocol/branch/branch_test.go | 66 +
pkg/protocol/codec/branch_commit_req_codec.go | 6 +-
pkg/protocol/codec/branch_commit_req_codec_test.go | 4 +-
pkg/protocol/codec/branch_commit_response_codec.go | 8 +-
.../codec/branch_commit_response_codec_test.go | 6 +-
pkg/protocol/codec/branch_register_req_codec.go | 6 +-
.../codec/branch_register_req_codec_test.go | 4 +-
.../codec/branch_register_response_codec.go | 6 +-
.../codec/branch_register_response_codec_test.go | 4 +-
pkg/protocol/codec/branch_report_req_codec.go | 6 +-
pkg/protocol/codec/branch_report_req_codec_test.go | 4 +-
pkg/protocol/codec/branch_rollback_req_codec.go | 6 +-
.../codec/branch_rollback_req_codec_test.go | 4 +-
.../codec/branch_rollback_response_codec.go | 8 +-
.../codec/branch_rollback_response_codec_test.go | 6 +-
.../codec/branch_statue_report_response_codec.go | 6 +-
.../branch_statue_report_response_codec_test.go | 4 +-
pkg/protocol/codec/codec.go | 5 +-
.../codec/common_global_end_request_codec.go | 4 +-
.../codec/common_global_end_response_codec.go | 6 +-
.../codec/common_identify_request_codec.go | 4 +-
.../codec/common_identify_response_codec.go | 4 +-
pkg/protocol/codec/global_begin_request_codec.go | 4 +-
.../codec/global_begin_request_codec_test.go | 2 +-
pkg/protocol/codec/global_begin_response_codec.go | 6 +-
.../codec/global_begin_response_codec_test.go | 4 +-
pkg/protocol/codec/global_commit_req_codec.go | 2 +-
pkg/protocol/codec/global_commit_req_codec_test.go | 2 +-
pkg/protocol/codec/global_commit_response_codec.go | 2 +-
.../codec/global_commit_response_codec_test.go | 2 +-
pkg/protocol/codec/global_lock_query_req_codec.go | 6 +-
.../codec/global_lock_query_req_codec_test.go | 4 +-
pkg/protocol/codec/global_lock_query_resp_codec.go | 6 +-
.../codec/global_lock_query_resp_codec_test.go | 4 +-
pkg/protocol/codec/global_report_request_codec.go | 7 +-
.../codec/global_report_request_codec_test.go | 2 +-
pkg/protocol/codec/global_report_response_codec.go | 2 +-
.../codec/global_report_response_codec_test.go | 2 +-
pkg/protocol/codec/global_rollback_req_codec.go | 2 +-
.../codec/global_rollback_req_codec_test.go | 2 +-
.../codec/global_rollback_response_codec.go | 2 +-
.../codec/global_rollback_response_codec_test.go | 2 +-
pkg/protocol/codec/global_status_req_codec.go | 2 +-
pkg/protocol/codec/global_status_req_codec_test.go | 2 +-
pkg/protocol/codec/global_status_response_codec.go | 2 +-
.../codec/global_status_response_codec_test.go | 2 +-
pkg/protocol/codec/register_rm_request_codec.go | 4 +-
.../codec/register_rm_request_codec_test.go | 2 +-
pkg/protocol/codec/register_rm_response_codec.go | 2 +-
.../codec/register_rm_response_codec_test.go | 2 +-
pkg/protocol/codec/register_tm_request_codec.go | 2 +-
.../codec/register_tm_request_codec_test.go | 2 +-
pkg/protocol/codec/register_tm_response_codec.go | 2 +-
.../codec/register_tm_response_codec_test.go | 2 +-
pkg/protocol/message/request_message.go | 2 +-
pkg/protocol/message/response_message.go | 4 +-
pkg/remoting/config/config.go | 2 +-
pkg/remoting/config/config_test.go | 224 ++++
pkg/remoting/config/session_config_test.go | 244 ++++
pkg/remoting/getty/getty_client.go | 6 +-
pkg/remoting/getty/getty_client_test.go | 6 +-
pkg/remoting/getty/getty_init.go | 4 +-
pkg/remoting/getty/getty_remoting.go | 6 +-
pkg/remoting/getty/getty_remoting_test.go | 2 +-
pkg/remoting/getty/listener.go | 12 +-
pkg/remoting/getty/readwriter.go | 6 +-
pkg/remoting/getty/readwriter_test.go | 4 +-
pkg/remoting/getty/session_manager.go | 10 +-
.../loadbalance/consistent_hash_loadbalance.go | 2 +
.../consistent_hash_loadbalance_test.go | 2 +-
.../loadbalance/least_active_loadbalance.go | 2 +-
.../loadbalance/least_active_loadbalance_test.go | 5 +-
pkg/remoting/loadbalance/loadbalance.go | 4 -
.../loadbalance/random_loadbalance_test.go | 2 +-
.../loadbalance/round_robin_loadbalance.go | 167 ++-
.../loadbalance/round_robin_loadbalance_test.go | 102 +-
pkg/remoting/loadbalance/xid_loadbalance.go | 4 +-
pkg/remoting/loadbalance/xid_loadbalance_test.go | 2 +-
pkg/remoting/mock/mock_getty_session_test.go | 722 ++++++++++
.../client/client_heart_beat_processon.go | 6 +-
.../client/client_heart_beat_processor_test.go | 6 +-
.../client/client_on_response_processor.go | 6 +-
.../client/client_on_response_processor_test.go | 4 +-
.../processor/client/rm_branch_commit_processor.go | 8 +-
.../client/rm_branch_commit_processor_test.go | 10 +-
.../client/rm_branch_rollback_processor.go | 8 +-
.../client/rm_branch_rollback_processor_test.go | 10 +-
pkg/remoting/processor/remoting_processor.go | 2 +-
pkg/rm/config_test.go | 269 ++++
pkg/rm/init.go | 5 +
pkg/rm/init_test.go | 220 +++
pkg/rm/rm_api.go | 2 +-
pkg/rm/rm_api_test.go | 2 +-
pkg/rm/rm_cache.go | 2 +-
pkg/rm/rm_cache_test.go | 2 +-
pkg/rm/rm_remoting.go | 6 +-
pkg/rm/tcc/config.go | 2 +-
pkg/rm/tcc/config_test.go | 182 +++
pkg/rm/tcc/fence/config/tcc_fence_config.go | 2 +-
...cc_fence_config.go => tcc_fence_config_test.go} | 25 +-
pkg/rm/tcc/fence/fence.go | 7 +-
pkg/rm/tcc/fence/fence_api.go | 6 +-
pkg/rm/tcc/fence/fence_api_test.go | 6 +-
pkg/rm/tcc/fence/fence_driver.go | 2 +-
pkg/rm/tcc/fence/fence_driver_conn.go | 4 +-
pkg/rm/tcc/fence/fence_driver_conn_test.go | 562 ++++++++
pkg/rm/tcc/fence/fence_driver_tx.go | 2 +-
pkg/rm/tcc/fence/fence_test.go | 792 +++++++++++
.../tcc/fence/handler/tcc_fence_wrapper_handler.go | 14 +-
.../handler/tcc_fence_wrapper_handler_test.go | 1043 +++++++++++++++
pkg/rm/tcc/fence/store/db/dao/store_api.go | 4 +-
pkg/rm/tcc/fence/store/db/dao/tcc_fence_db.go | 9 +-
pkg/rm/tcc/fence/store/db/dao/tcc_fence_db_test.go | 6 +-
pkg/rm/tcc/fence/store/db/model/tcc_fence_do.go | 2 +-
.../tcc/fence/store/db/sql/tcc_fence_store_sql.go | 2 +-
.../fence/store/db/sql/tcc_fence_store_sql_test.go | 409 ++++++
pkg/rm/tcc/tcc_resource.go | 15 +-
pkg/rm/tcc/tcc_resource_test.go | 8 +-
pkg/rm/tcc/tcc_service.go | 14 +-
pkg/rm/tcc/tcc_service_test.go | 10 +-
pkg/rm/two_phase.go | 2 +-
pkg/rm/two_phase_test.go | 4 +-
pkg/{rm/tcc => saga}/config.go | 11 +-
pkg/saga/readme.md | 47 +
.../rm/handler_saga.go} | 22 +-
.../lz4_compress.go => saga/rm/saga_resource.go} | 44 +-
pkg/saga/rm/saga_resource_manager.go | 159 +++
.../rm/saga_resource_manager_test.go} | 28 +-
.../rm/state_machine_engine_holder.go} | 22 +-
.../rand.go => saga/runtime/engine_registry.go} | 34 +-
pkg/saga/statemachine/constant/constant.go | 104 ++
pkg/saga/statemachine/engine/config/bootstrap.go | 62 +
.../engine/config/default_statemachine_config.go | 824 ++++++++++++
.../config/default_statemachine_config_test.go | 325 +++++
pkg/saga/statemachine/engine/config/noop_store.go | 87 ++
.../statemachine/engine/config/store_bootstrap.go | 71 +
.../engine/config/testdata/invalid.json | 3 +
.../engine/config/testdata/invalid.yaml | 13 +-
.../engine/config/testdata/order_saga.json | 274 ++++
.../engine/config/testdata/order_saga.yaml | 204 +++
.../engine/config/testdata/order_saga_v2.json | 322 +++++
.../engine/config/testdata/order_saga_v2.yaml | 228 ++++
.../engine/config/testdata/saga_config.json | 13 +
.../engine/config/testdata/saga_config.yaml | 19 +-
.../engine/config/testdata/saga_config_v2.json | 13 +
.../engine/config/testdata/saga_config_v2.yaml | 19 +-
.../core/process_ctrl_statemachine_engine.go | 747 +++++++++++
.../process_ctrl_statemachine_engine_async_test.go | 345 +++++
.../statemachine/engine/exception/exception.go | 84 ++
.../engine/exception/exception_test.go | 68 +
.../engine/exception/forward_invalid_exception.go} | 27 +-
.../exception/forward_invalid_exception_test.go | 68 +
.../statemachine/engine/expr/cel_expression.go | 96 ++
.../engine/expr/cel_expression_factory.go} | 32 +-
.../engine/expr/cel_expression_factory_test.go} | 11 +-
.../engine/expr/cel_expression_test.go} | 36 +-
.../statemachine/engine/expr/error_expression.go} | 35 +-
.../statemachine/engine/expr/expression.go} | 17 +-
.../engine/expr/expression_factory.go} | 8 +-
.../engine/expr/expression_factory_manager.go | 51 +
.../engine/expr/expression_resolver.go | 105 ++
.../engine/expr/expression_resolver_test.go | 70 +
.../engine/expr/sequence_expression.go | 64 +
.../engine/expr/sequence_expression_factory.go | 56 +
.../statemachine/engine/invoker/func_invoker.go | 225 ++++
.../engine/invoker/func_invoker_test.go | 168 +++
.../statemachine/engine/invoker/grpc_invoker.go | 263 ++++
.../engine/invoker/grpc_invoker_test.go | 187 +++
.../statemachine/engine/invoker/http_invoker.go | 220 +++
.../engine/invoker/http_invoker_test.go | 179 +++
pkg/saga/statemachine/engine/invoker/invoker.go | 101 ++
.../engine/invoker/javascript_script_invoker.go | 162 +++
.../invoker/javascript_script_invoker_test.go | 262 ++++
.../statemachine/engine/invoker/json_parser.go} | 22 +-
.../statemachine/engine/invoker/local_invoker.go | 200 +++
.../engine/invoker/local_invoker_test.go | 212 +++
.../engine/pcext/compensation_holder.go | 92 ++
pkg/saga/statemachine/engine/pcext/engine_utils.go | 236 ++++
pkg/saga/statemachine/engine/pcext/instruction.go | 113 ++
.../engine/pcext/loop_context_holder.go | 111 ++
.../statemachine/engine/pcext/loop_task_utils.go | 78 ++
.../statemachine/engine/pcext/parameter_utils.go | 143 ++
.../statemachine/engine/pcext/process_handler.go | 197 +++
.../statemachine/engine/pcext/process_router.go | 139 ++
.../statemachine/engine/pcext/state_router_impl.go | 355 +++++
.../engine/pcext/state_router_impl_test.go | 152 +++
.../engine/repo/repository/state_log_repository.go | 139 ++
.../repo/repository/state_machine_repository.go | 255 ++++
.../repository/state_machine_repository_test.go | 162 +++
.../statemachine/engine/repo/statemachine_store.go | 48 +
.../statemachine/engine/sequence/sequence.go} | 8 +-
pkg/saga/statemachine/engine/sequence/snowflake.go | 133 ++
.../engine/sequence/snowflake_test.go} | 32 +-
.../statemachine/engine/sequence/uuid.go} | 19 +-
.../statemachine/engine/serializer/serializer.go} | 64 +-
.../engine/serializer/serializer_test.go} | 17 +-
.../statemachine/engine/statemachine_config.go | 81 ++
.../statemachine/engine/statemachine_engine.go | 60 +
.../engine/statemachine_engine_test.go | 49 +
pkg/saga/statemachine/engine/strategy.go | 37 +
.../engine/strategy/status_decision.go | 274 ++++
.../engine/utils/process_context_utils.go | 113 ++
.../process_ctrl/bussiness_processor.go | 111 ++
.../process_ctrl/default_process_handler.go} | 10 +-
.../statemachine/process_ctrl/event.go} | 5 +-
pkg/saga/statemachine/process_ctrl/event_bus.go | 157 +++
.../statemachine/process_ctrl/event_consumer.go} | 44 +-
.../statemachine/process_ctrl/event_publisher.go} | 19 +-
.../handlers/service_task_state_handler.go | 266 ++++
.../saga/statemachine/process_ctrl/instruction.go | 5 +-
.../process_ctrl/process/process_type.go} | 6 +-
.../statemachine/process_ctrl/process_context.go | 225 ++++
.../process_ctrl/process_controller.go} | 38 +-
.../statemachine/process_ctrl/process_router.go | 112 ++
.../statelang/parser/choice_state_json_parser.go | 93 ++
.../parser/compensation_trigger_state_parser.go} | 50 +-
.../statelang/parser/end_state_parser.go | 83 ++
.../statelang/parser/statemachine_config_parser.go | 140 ++
.../parser/statemachine_config_parser_test.go | 884 ++++++++++++
.../statelang/parser/statemachine_json_parser.go | 131 ++
.../parser/statemachine_json_parser_test.go | 127 ++
.../statelang/parser/statemachine_parser.go | 262 ++++
.../statelang/parser/sub_state_machine_parser.go | 103 ++
.../statelang/parser/task_state_json_parser.go | 351 +++++
pkg/saga/statemachine/statelang/state.go | 92 ++
.../statemachine/statelang/state/choice_state.go | 92 ++
.../statelang/state/compensation_trigger_state.go} | 33 +-
pkg/saga/statemachine/statelang/state/end_state.go | 81 ++
.../statelang/state/loop_start_state.go} | 25 +-
.../statelang/state/sub_state_machine.go | 87 ++
.../statemachine/statelang/state/task_state.go | 478 +++++++
pkg/saga/statemachine/statelang/state_instance.go | 360 +++++
pkg/saga/statemachine/statelang/statemachine.go | 278 ++++
.../statelang/statemachine_instance.go | 351 +++++
pkg/saga/statemachine/statemachine.go | 47 +
pkg/saga/statemachine/store/db/db.go | 121 ++
pkg/saga/statemachine/store/db/db_test.go | 64 +
pkg/saga/statemachine/store/db/statelang.go | 133 ++
pkg/saga/statemachine/store/db/statelang_test.go | 92 ++
pkg/saga/statemachine/store/db/statelog.go | 1360 +++++++++++++++++++
pkg/saga/statemachine/store/db/statelog_test.go | 823 ++++++++++++
pkg/saga/statemachine/store/store.go | 57 +
pkg/saga/tm/default_saga_transactional_template.go | 175 +++
pkg/saga/tm/saga_transactional_template.go | 44 +
pkg/tm/config_test.go | 175 +++
pkg/tm/constant.go | 2 +-
pkg/tm/constant_test.go | 135 ++
pkg/tm/context.go | 5 +-
pkg/tm/context_test.go | 4 +-
pkg/tm/global_transaction.go | 33 +-
pkg/tm/global_transaction_test.go | 6 +-
pkg/tm/init_test.go | 170 +++
pkg/tm/transaction_executor.go | 4 +-
pkg/tm/transaction_executor_test.go | 5 +-
pkg/tm/{init.go => transaction_hook.go} | 16 +-
.../rm_cache.go => tm/transaction_hook_manager.go} | 48 +-
pkg/util/collection/collection.go | 44 +-
pkg/util/collection/collection_test.go | 23 +
pkg/util/convert/convert_test.go | 676 ++++++++++
pkg/util/errors/code.go | 15 +
pkg/util/errors/error_test.go | 504 +++++++
pkg/util/flagext/deprecated.go | 2 +-
pkg/util/flagext/register_test.go | 77 ++
pkg/util/log/logging_test.go | 583 ++++++++
pkg/util/reflectx/unmarkshaler.go | 165 +++
testdata/context.go | 4 +-
testdata/meta_cache.go | 2 +-
testdata/mock_tcc.go | 2 +-
.../saga/engine/invoker/grpc/product.go | 51 +-
testdata/saga/engine/invoker/grpc/product.pb.go | 237 ++++
testdata/saga/engine/invoker/grpc/product.proto | 35 +
.../saga/engine/invoker/grpc/product_grpc.pb.go | 168 +++
.../statelang/simple_statelang_with_choice.json | 38 +
.../statelang/simple_statelang_with_choice.yaml | 40 +-
testdata/saga/statelang/simple_statemachine.json | 138 ++
testdata/saga/statelang/simple_statemachine.yaml | 105 ++
.../saga/statelang/state_machine_new_designer.json | 424 ++++++
.../saga/statelang/state_machine_new_designer.yaml | 301 +++++
testdata/sql/saga/sqlite_init.sql | 81 ++
475 files changed, 44487 insertions(+), 1396 deletions(-)
copy .github/workflows/{labeler.yml => issue-robot.yml} (60%)
create mode 100644 .github/workflows/unit-test.yml
copy .pre-commit-config.yaml => VERSION (78%)
create mode 100644 changes/2.1.0.md
create mode 100644 changes/2.1.0_zh.md
create mode 100644 pkg/client/client_test.go
copy pkg/{util/flagext/stringmap.go => compressor/snappy_compress.go} (66%)
copy pkg/compressor/{zip_compress_test.go => snappy_compress_test.go} (83%)
create mode 100644 pkg/constant/context_test.go
create mode 100644 pkg/datasource/init_test.go
create mode 100644 pkg/datasource/sql/datasource/mysql/meta_cache_test.go
create mode 100644 pkg/datasource/sql/exec/at/at_executor_test.go
create mode 100644 pkg/datasource/sql/exec/config/config_test.go
create mode 100644 pkg/datasource/sql/exec/executor_test.go
create mode 100644 pkg/datasource/sql/exec/hook_test.go
create mode 100644 pkg/datasource/sql/hook/logger_hook_test.go
create mode 100644 pkg/datasource/sql/hook/undo_log_hook_test.go
create mode 100644 pkg/datasource/sql/mock/mock_datasource_manager_test.go
create mode 100644 pkg/datasource/sql/mock/mock_driver_components_test.go
create mode 100644 pkg/datasource/sql/mock/mock_driver_test.go
create mode 100644 pkg/datasource/sql/mock/mock_table_meta_cache_test.go
create mode 100644 pkg/datasource/sql/types/const_test.go
create mode 100644 pkg/datasource/sql/types/dbtype_string_test.go
create mode 100644 pkg/datasource/sql/types/executor_test.go
create mode 100644 pkg/datasource/sql/types/key_type_test.go
rename pkg/datasource/sql/types/{mysql_ketword_checker.go =>
mysql_keyword_checker.go} (100%)
create mode 100644 pkg/datasource/sql/types/mysql_keyword_checker_test.go
create mode 100644 pkg/datasource/sql/types/sql_data_type_test.go
create mode 100644 pkg/datasource/sql/types/sql_test.go
create mode 100644 pkg/datasource/sql/types/types_test.go
create mode 100644 pkg/datasource/sql/undo/base/undo_test.go
create mode 100644 pkg/datasource/sql/undo/config_test.go
create mode 100644
pkg/datasource/sql/undo/executor/mysql_undo_delete_executor_test.go
create mode 100644
pkg/datasource/sql/undo/executor/mysql_undo_executor_holder_test.go
create mode 100644
pkg/datasource/sql/undo/executor/mysql_undo_insert_executor_test.go
create mode 100644
pkg/datasource/sql/undo/executor/mysql_undo_update_executor_test.go
create mode 100644 pkg/datasource/sql/undo/executor/utils_test.go
create mode 100644 pkg/datasource/sql/undo/factor/undo_executor_factory_test.go
create mode 100644
pkg/datasource/sql/undo/factor/undo_executor_holder_factor_test.go
copy pkg/{compressor/zip_compress_test.go =>
datasource/sql/undo/mysql/default_test.go} (52%)
create mode 100644 pkg/datasource/sql/undo/mysql/undo_test.go
copy pkg/{compressor/bzip2_compress_test.go =>
datasource/sql/undo/parser/const_test.go} (63%)
create mode 100644 pkg/datasource/sql/undo/parser/parser_api_test.go
create mode 100644 pkg/datasource/sql/undo/parser/protobuf_conversion_test.go
create mode 100644 pkg/datasource/sql/undo/parser/protobuf_generated_test.go
create mode 100644 pkg/datasource/sql/undo/undo_executor_holder_test.go
copy pkg/{compressor/zip_compress_test.go =>
datasource/sql/undo/undo_executor_test.go} (53%)
create mode 100644 pkg/datasource/sql/undo/undo_test.go
create mode 100644 pkg/datasource/sql/util/ctxutil_test.go
create mode 100644 pkg/datasource/sql/util/lockkey_test.go
create mode 100644 pkg/datasource/sql/util/params_test.go
create mode 100644 pkg/datasource/sql/util/sql_test.go
create mode 100644 pkg/discovery/mock/mock_etcd_client_test.go
create mode 100644 pkg/integration/gin/gin_transaction_middleware_test.go
create mode 100644 pkg/integration/grpc/grpc_transaction_interceptor_test.go
create mode 100644 pkg/integration/integration_test.go
create mode 100644 pkg/protocol/branch/branch_test.go
create mode 100644 pkg/remoting/config/config_test.go
create mode 100644 pkg/remoting/config/session_config_test.go
create mode 100644 pkg/remoting/mock/mock_getty_session_test.go
create mode 100644 pkg/rm/config_test.go
create mode 100644 pkg/rm/init_test.go
create mode 100644 pkg/rm/tcc/config_test.go
copy pkg/rm/tcc/fence/config/{tcc_fence_config.go => tcc_fence_config_test.go}
(54%)
create mode 100644 pkg/rm/tcc/fence/fence_test.go
create mode 100644 pkg/rm/tcc/fence/handler/tcc_fence_wrapper_handler_test.go
create mode 100644 pkg/rm/tcc/fence/store/db/sql/tcc_fence_store_sql_test.go
copy pkg/{rm/tcc => saga}/config.go (76%)
create mode 100644 pkg/saga/readme.md
copy pkg/{rm/rm_remoting_test.go => saga/rm/handler_saga.go} (65%)
copy pkg/{compressor/lz4_compress.go => saga/rm/saga_resource.go} (54%)
create mode 100644 pkg/saga/rm/saga_resource_manager.go
copy pkg/{rm/rm_remoting_test.go => saga/rm/saga_resource_manager_test.go}
(65%)
copy pkg/{rm/rm_remoting_test.go => saga/rm/state_machine_engine_holder.go}
(68%)
copy pkg/{util/rand/rand.go => saga/runtime/engine_registry.go} (52%)
create mode 100644 pkg/saga/statemachine/constant/constant.go
create mode 100644 pkg/saga/statemachine/engine/config/bootstrap.go
create mode 100644
pkg/saga/statemachine/engine/config/default_statemachine_config.go
create mode 100644
pkg/saga/statemachine/engine/config/default_statemachine_config_test.go
create mode 100644 pkg/saga/statemachine/engine/config/noop_store.go
create mode 100644 pkg/saga/statemachine/engine/config/store_bootstrap.go
create mode 100644 pkg/saga/statemachine/engine/config/testdata/invalid.json
copy .pre-commit-config.yaml =>
pkg/saga/statemachine/engine/config/testdata/invalid.yaml (77%)
create mode 100644 pkg/saga/statemachine/engine/config/testdata/order_saga.json
create mode 100644 pkg/saga/statemachine/engine/config/testdata/order_saga.yaml
create mode 100644
pkg/saga/statemachine/engine/config/testdata/order_saga_v2.json
create mode 100644
pkg/saga/statemachine/engine/config/testdata/order_saga_v2.yaml
create mode 100644
pkg/saga/statemachine/engine/config/testdata/saga_config.json
copy .pre-commit-config.yaml =>
pkg/saga/statemachine/engine/config/testdata/saga_config.yaml (71%)
create mode 100644
pkg/saga/statemachine/engine/config/testdata/saga_config_v2.json
copy .pre-commit-config.yaml =>
pkg/saga/statemachine/engine/config/testdata/saga_config_v2.yaml (71%)
create mode 100644
pkg/saga/statemachine/engine/core/process_ctrl_statemachine_engine.go
create mode 100644
pkg/saga/statemachine/engine/core/process_ctrl_statemachine_engine_async_test.go
create mode 100644 pkg/saga/statemachine/engine/exception/exception.go
create mode 100644 pkg/saga/statemachine/engine/exception/exception_test.go
copy pkg/{datasource/sql/types/key_type.go =>
saga/statemachine/engine/exception/forward_invalid_exception.go} (74%)
create mode 100644
pkg/saga/statemachine/engine/exception/forward_invalid_exception_test.go
create mode 100644 pkg/saga/statemachine/engine/expr/cel_expression.go
copy pkg/{discovery/base.go =>
saga/statemachine/engine/expr/cel_expression_factory.go} (60%)
copy pkg/{rm/tcc/fence/fence_driver_conn_test.go =>
saga/statemachine/engine/expr/cel_expression_factory_test.go} (77%)
copy pkg/{compressor/zstd_compress_test.go =>
saga/statemachine/engine/expr/cel_expression_test.go} (61%)
copy pkg/{datasource/sql/undo/parser/parser_cache_test.go =>
saga/statemachine/engine/expr/error_expression.go} (58%)
copy pkg/{datasource/sql/undo/undo_executor.go =>
saga/statemachine/engine/expr/expression.go} (76%)
copy pkg/{tm/init.go => saga/statemachine/engine/expr/expression_factory.go}
(89%)
create mode 100644
pkg/saga/statemachine/engine/expr/expression_factory_manager.go
create mode 100644 pkg/saga/statemachine/engine/expr/expression_resolver.go
create mode 100644
pkg/saga/statemachine/engine/expr/expression_resolver_test.go
create mode 100644 pkg/saga/statemachine/engine/expr/sequence_expression.go
create mode 100644
pkg/saga/statemachine/engine/expr/sequence_expression_factory.go
create mode 100644 pkg/saga/statemachine/engine/invoker/func_invoker.go
create mode 100644 pkg/saga/statemachine/engine/invoker/func_invoker_test.go
create mode 100644 pkg/saga/statemachine/engine/invoker/grpc_invoker.go
create mode 100644 pkg/saga/statemachine/engine/invoker/grpc_invoker_test.go
create mode 100644 pkg/saga/statemachine/engine/invoker/http_invoker.go
create mode 100644 pkg/saga/statemachine/engine/invoker/http_invoker_test.go
create mode 100644 pkg/saga/statemachine/engine/invoker/invoker.go
create mode 100644
pkg/saga/statemachine/engine/invoker/javascript_script_invoker.go
create mode 100644
pkg/saga/statemachine/engine/invoker/javascript_script_invoker_test.go
copy pkg/{compressor/none_compressor.go =>
saga/statemachine/engine/invoker/json_parser.go} (61%)
create mode 100644 pkg/saga/statemachine/engine/invoker/local_invoker.go
create mode 100644 pkg/saga/statemachine/engine/invoker/local_invoker_test.go
create mode 100644 pkg/saga/statemachine/engine/pcext/compensation_holder.go
create mode 100644 pkg/saga/statemachine/engine/pcext/engine_utils.go
create mode 100644 pkg/saga/statemachine/engine/pcext/instruction.go
create mode 100644 pkg/saga/statemachine/engine/pcext/loop_context_holder.go
create mode 100644 pkg/saga/statemachine/engine/pcext/loop_task_utils.go
create mode 100644 pkg/saga/statemachine/engine/pcext/parameter_utils.go
create mode 100644 pkg/saga/statemachine/engine/pcext/process_handler.go
create mode 100644 pkg/saga/statemachine/engine/pcext/process_router.go
create mode 100644 pkg/saga/statemachine/engine/pcext/state_router_impl.go
create mode 100644 pkg/saga/statemachine/engine/pcext/state_router_impl_test.go
create mode 100644
pkg/saga/statemachine/engine/repo/repository/state_log_repository.go
create mode 100644
pkg/saga/statemachine/engine/repo/repository/state_machine_repository.go
create mode 100644
pkg/saga/statemachine/engine/repo/repository/state_machine_repository_test.go
create mode 100644 pkg/saga/statemachine/engine/repo/statemachine_store.go
copy pkg/{datasource/sql/xa_xid.go =>
saga/statemachine/engine/sequence/sequence.go} (89%)
create mode 100644 pkg/saga/statemachine/engine/sequence/snowflake.go
copy pkg/{util/flagext/stringmap.go =>
saga/statemachine/engine/sequence/snowflake_test.go} (64%)
copy pkg/{rm/tcc/fence/config/tcc_fence_config.go =>
saga/statemachine/engine/sequence/uuid.go} (75%)
copy pkg/{compressor/gzip_compress.go =>
saga/statemachine/engine/serializer/serializer.go} (50%)
copy pkg/{protocol/message/message_apis_test.go =>
saga/statemachine/engine/serializer/serializer_test.go} (70%)
create mode 100644 pkg/saga/statemachine/engine/statemachine_config.go
create mode 100644 pkg/saga/statemachine/engine/statemachine_engine.go
create mode 100644 pkg/saga/statemachine/engine/statemachine_engine_test.go
create mode 100644 pkg/saga/statemachine/engine/strategy.go
create mode 100644 pkg/saga/statemachine/engine/strategy/status_decision.go
create mode 100644 pkg/saga/statemachine/engine/utils/process_context_utils.go
create mode 100644 pkg/saga/statemachine/process_ctrl/bussiness_processor.go
copy pkg/{integration/integration.go =>
saga/statemachine/process_ctrl/default_process_handler.go} (85%)
copy pkg/{datasource/sql/handler/rm_handler_xa.go =>
saga/statemachine/process_ctrl/event.go} (94%)
create mode 100644 pkg/saga/statemachine/process_ctrl/event_bus.go
copy pkg/{rm/tcc/fence/fence_driver_tx.go =>
saga/statemachine/process_ctrl/event_consumer.go} (51%)
copy pkg/{compressor/none_compressor.go =>
saga/statemachine/process_ctrl/event_publisher.go} (64%)
create mode 100644
pkg/saga/statemachine/process_ctrl/handlers/service_task_state_handler.go
copy cmd/start.go => pkg/saga/statemachine/process_ctrl/instruction.go (94%)
copy pkg/{datasource/sql/undo/parser/const.go =>
saga/statemachine/process_ctrl/process/process_type.go} (88%)
create mode 100644 pkg/saga/statemachine/process_ctrl/process_context.go
copy pkg/{rm/tcc/fence/fence_driver_tx.go =>
saga/statemachine/process_ctrl/process_controller.go} (56%)
create mode 100644 pkg/saga/statemachine/process_ctrl/process_router.go
create mode 100644
pkg/saga/statemachine/statelang/parser/choice_state_json_parser.go
copy pkg/{compressor/gzip_compress.go =>
saga/statemachine/statelang/parser/compensation_trigger_state_parser.go} (50%)
create mode 100644 pkg/saga/statemachine/statelang/parser/end_state_parser.go
create mode 100644
pkg/saga/statemachine/statelang/parser/statemachine_config_parser.go
create mode 100644
pkg/saga/statemachine/statelang/parser/statemachine_config_parser_test.go
create mode 100644
pkg/saga/statemachine/statelang/parser/statemachine_json_parser.go
create mode 100644
pkg/saga/statemachine/statelang/parser/statemachine_json_parser_test.go
create mode 100644
pkg/saga/statemachine/statelang/parser/statemachine_parser.go
create mode 100644
pkg/saga/statemachine/statelang/parser/sub_state_machine_parser.go
create mode 100644
pkg/saga/statemachine/statelang/parser/task_state_json_parser.go
create mode 100644 pkg/saga/statemachine/statelang/state.go
create mode 100644 pkg/saga/statemachine/statelang/state/choice_state.go
copy pkg/{discovery/base.go =>
saga/statemachine/statelang/state/compensation_trigger_state.go} (64%)
create mode 100644 pkg/saga/statemachine/statelang/state/end_state.go
copy pkg/{util/errors/error.go =>
saga/statemachine/statelang/state/loop_start_state.go} (65%)
create mode 100644 pkg/saga/statemachine/statelang/state/sub_state_machine.go
create mode 100644 pkg/saga/statemachine/statelang/state/task_state.go
create mode 100644 pkg/saga/statemachine/statelang/state_instance.go
create mode 100644 pkg/saga/statemachine/statelang/statemachine.go
create mode 100644 pkg/saga/statemachine/statelang/statemachine_instance.go
create mode 100644 pkg/saga/statemachine/statemachine.go
create mode 100644 pkg/saga/statemachine/store/db/db.go
create mode 100644 pkg/saga/statemachine/store/db/db_test.go
create mode 100644 pkg/saga/statemachine/store/db/statelang.go
create mode 100644 pkg/saga/statemachine/store/db/statelang_test.go
create mode 100644 pkg/saga/statemachine/store/db/statelog.go
create mode 100644 pkg/saga/statemachine/store/db/statelog_test.go
create mode 100644 pkg/saga/statemachine/store/store.go
create mode 100644 pkg/saga/tm/default_saga_transactional_template.go
create mode 100644 pkg/saga/tm/saga_transactional_template.go
create mode 100644 pkg/tm/config_test.go
create mode 100644 pkg/tm/constant_test.go
create mode 100644 pkg/tm/init_test.go
copy pkg/tm/{init.go => transaction_hook.go} (80%)
copy pkg/{rm/rm_cache.go => tm/transaction_hook_manager.go} (50%)
create mode 100644 pkg/util/errors/error_test.go
create mode 100644 pkg/util/flagext/register_test.go
create mode 100644 pkg/util/log/logging_test.go
create mode 100644 pkg/util/reflectx/unmarkshaler.go
copy pkg/compressor/lz4_compress.go =>
testdata/saga/engine/invoker/grpc/product.go (54%)
create mode 100644 testdata/saga/engine/invoker/grpc/product.pb.go
create mode 100644 testdata/saga/engine/invoker/grpc/product.proto
create mode 100644 testdata/saga/engine/invoker/grpc/product_grpc.pb.go
create mode 100644 testdata/saga/statelang/simple_statelang_with_choice.json
copy goimports.sh => testdata/saga/statelang/simple_statelang_with_choice.yaml
(56%)
mode change 100755 => 100644
create mode 100644 testdata/saga/statelang/simple_statemachine.json
create mode 100644 testdata/saga/statelang/simple_statemachine.yaml
create mode 100644 testdata/saga/statelang/state_machine_new_designer.json
create mode 100644 testdata/saga/statelang/state_machine_new_designer.yaml
create mode 100644 testdata/sql/saga/sqlite_init.sql
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
