Versions in this module Expand all Collapse all v1 v1.2.1 May 30, 2024 Changes in this version + func InitTCC() + type Config struct + FenceConfig fence.Config + func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet) + type TCCResource struct + AppName string + ResourceGroupId string + func ParseTCCResource(v interface{}) (*TCCResource, error) + func (t *TCCResource) GetBranchType() branch.BranchType + func (t *TCCResource) GetResourceGroupId() string + func (t *TCCResource) GetResourceId() string + type TCCResourceManager struct + func GetTCCResourceManagerInstance() *TCCResourceManager + func (t *TCCResourceManager) BranchCommit(ctx context.Context, branchResource rm.BranchResource) (branch.BranchStatus, error) + func (t *TCCResourceManager) BranchRegister(ctx context.Context, param rm.BranchRegisterParam) (int64, error) + func (t *TCCResourceManager) BranchReport(ctx context.Context, param rm.BranchReportParam) error + func (t *TCCResourceManager) BranchRollback(ctx context.Context, branchResource rm.BranchResource) (branch.BranchStatus, error) + func (t *TCCResourceManager) GetBranchType() branch.BranchType + func (t *TCCResourceManager) GetCachedResources() *sync.Map + func (t *TCCResourceManager) LockQuery(ctx context.Context, param rm.LockQueryParam) (bool, error) + func (t *TCCResourceManager) RegisterResource(resource rm.Resource) error + func (t *TCCResourceManager) UnregisterResource(resource rm.Resource) error + type TCCServiceProxy struct + func NewTCCServiceProxy(service interface{}) (*TCCServiceProxy, error) + func (t *TCCServiceProxy) GetTransactionInfo() tm.GtxConfig + func (t *TCCServiceProxy) Prepare(ctx context.Context, params interface{}) (interface{}, error) + func (t *TCCServiceProxy) Reference() string + func (t *TCCServiceProxy) RegisterResource() error + func (t *TCCServiceProxy) SetReferenceName(referenceName string)
Go to main page