rm

package
v1.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 30, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TwoPhaseActionTag            = "seataTwoPhaseAction"
	TwoPhaseActionNameTag        = "seataTwoPhaseServiceName"
	TwoPhaseActionPrepareTagVal  = "prepare"
	TwoPhaseActionCommitTagVal   = "commit"
	TwoPhaseActionRollbackTagVal = "rollback"
)

Variables

View Source 
var ErrBranchReportResponseFault = errors.New("branch report response fault")
View Source 
var (
	TypBusinessContextInterface = reflect.Zero(reflect.TypeOf((*tm.BusinessActionContext)(nil))).Type()
)

Functions

func InitRm 

func InitRm(cfg RmConfig)

InitRmClient init seata rm client

func IsTwoPhaseAction 

func IsTwoPhaseAction(v interface{}) bool

Types

type BranchRegisterParam 

type BranchRegisterParam struct {
	BranchType      branch.BranchType
	ResourceId      string
	ClientId        string
	Xid             string
	ApplicationData string
	LockKeys        string
}

BranchRegisterParam Branch register function param for ResourceManager

type BranchReportParam 

type BranchReportParam struct {
	BranchType      branch.BranchType
	Xid             string
	BranchId        int64
	Status          branch.BranchStatus
	ApplicationData string
}

BranchReportParam Branch report function param for ResourceManager

type BranchResource 

type BranchResource struct {
	BranchType      branch.BranchType
	Xid             string
	BranchId        int64
	ResourceId      string
	ApplicationData []byte
}

BranchResource contains branch to commit or rollback

type Config 

type Config struct {
	AsyncCommitBufferLimit          int        `yaml:"async-commit-buffer-limit" json:"async-commit-buffer-limit,omitempty" koanf:"async-commit-buffer-limit"`
	ReportRetryCount                int        `yaml:"report-retry-count" json:"report-retry-count,omitempty" koanf:"report-retry-count"`
	TableMetaCheckEnable            bool       `yaml:"table-meta-check-enable" json:"table-meta-check-enable" koanf:"table-meta-check-enable"`
	ReportSuccessEnable             bool       `yaml:"report-success-enable" json:"report-success-enable,omitempty" koanf:"report-success-enable"`
	SagaBranchRegisterEnable        bool       `yaml:"saga-branch-register-enable" json:"saga-branch-register-enable,omitempty" koanf:"saga-branch-register-enable"`
	SagaJsonParser                  string     `yaml:"saga-json-parser" json:"saga-json-parser,omitempty" koanf:"saga-json-parser"`
	SagaRetryPersistModeUpdate      bool       `yaml:"saga-retry-persist-mode-update" json:"saga-retry-persist-mode-update,omitempty" koanf:"saga-retry-persist-mode-update"`
	SagaCompensatePersistModeUpdate bool       `` /* 139-byte string literal not displayed */
	TccActionInterceptorOrder       int        `yaml:"tcc-action-interceptor-order" json:"tcc-action-interceptor-order,omitempty" koanf:"tcc-action-interceptor-order"`
	SqlParserType                   string     `yaml:"sql-parser-type" json:"sql-parser-type,omitempty" koanf:"sql-parser-type"`
	LockConfig                      LockConfig `yaml:"lock" json:"lock,omitempty" koanf:"lock"`
}

func (*Config) RegisterFlagsWithPrefix 

func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

type LockConfig 

type LockConfig struct {
	RetryInterval                       time.Duration `yaml:"retry-interval" json:"retry-interval,omitempty" koanf:"retry-interval"`
	RetryTimes                          int           `yaml:"retry-times" json:"retry-times,omitempty" koanf:"retry-times"`
	RetryPolicyBranchRollbackOnConflict bool          `` /* 154-byte string literal not displayed */
}

func (*LockConfig) RegisterFlagsWithPrefix 

func (cfg *LockConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

type LockQueryParam 

type LockQueryParam struct {
	BranchType branch.BranchType
	ResourceId string
	Xid        string
	LockKeys   string
}

LockQueryParam Lock query function param for ResourceManager

type RMRemoting 

type RMRemoting struct{}

func GetRMRemotingInstance 

func GetRMRemotingInstance() *RMRemoting

func (*RMRemoting) BranchRegister 

func (r *RMRemoting) BranchRegister(param BranchRegisterParam) (int64, error)

BranchRegister Register branch of global transaction

func (*RMRemoting) BranchReport 

func (r *RMRemoting) BranchReport(param BranchReportParam) error

BranchReport Report status of transaction branch

func (*RMRemoting) LockQuery 

func (r *RMRemoting) LockQuery(param LockQueryParam) (bool, error)

LockQuery Query lock status of transaction branch

func (*RMRemoting) RegisterResource 

func (r *RMRemoting) RegisterResource(resource Resource) error

type Resource 

type Resource interface {
	GetResourceGroupId() string
	GetResourceId() string
	GetBranchType() branch.BranchType
}

Resource that can be managed by Resource Manager and involved into global transaction

type ResourceManager 

type ResourceManager interface {
	ResourceManagerInbound
	ResourceManagerOutbound

	// RegisterResource register a resource to be managed by resource manager
	RegisterResource(resource Resource) error
	// UnregisterResource unregister a resource from the Resource Manager
	UnregisterResource(resource Resource) error
	// GetCachedResources get all resources managed by this manager
	GetCachedResources() *sync.Map
	// GetBranchType get the branch type
	GetBranchType() branch.BranchType
}

ResourceManager Resource Manager: common behaviors

type ResourceManagerCache 

type ResourceManagerCache struct {
	// contains filtered or unexported fields
}

func GetRmCacheInstance 

func GetRmCacheInstance() *ResourceManagerCache

func (*ResourceManagerCache) GetResourceManager 

func (d *ResourceManagerCache) GetResourceManager(branchType branch.BranchType) ResourceManager

func (*ResourceManagerCache) RegisterResourceManager 

func (d *ResourceManagerCache) RegisterResourceManager(resourceManager ResourceManager)

type ResourceManagerGetter 

type ResourceManagerGetter interface {
	GetResourceManager(branchType branch.BranchType) ResourceManager
}

type ResourceManagerInbound 

type ResourceManagerInbound interface {
	// BranchCommit commit a branch transaction
	BranchCommit(ctx context.Context, resource BranchResource) (branch.BranchStatus, error)
	// BranchRollback rollback a branch transaction
	BranchRollback(ctx context.Context, resource BranchResource) (branch.BranchStatus, error)
}

ResourceManagerInbound Control a branch transaction commit or rollback

type ResourceManagerOutbound 

type ResourceManagerOutbound interface {
	// BranchRegister rm register the branch transaction
	BranchRegister(ctx context.Context, param BranchRegisterParam) (int64, error)
	// BranchReport branch transaction report the status
	BranchReport(ctx context.Context, param BranchReportParam) error
	// LockQuery lock query boolean
	LockQuery(ctx context.Context, param LockQueryParam) (bool, error)
}

ResourceManagerOutbound Resource Manager: send outbound request to TC

type RmConfig 

type RmConfig struct {
	Config

	ApplicationID  string
	TxServiceGroup string
}

type TwoPhaseAction 

type TwoPhaseAction struct {
	// contains filtered or unexported fields
}

func ParseTwoPhaseAction 

func ParseTwoPhaseAction(v interface{}) (*TwoPhaseAction, error)

func ParseTwoPhaseActionByInterface 

func ParseTwoPhaseActionByInterface(v interface{}) (*TwoPhaseAction, error)

func (*TwoPhaseAction) Commit 

func (t *TwoPhaseAction) Commit(ctx context.Context, businessActionContext *tm.BusinessActionContext) (bool, error)

func (*TwoPhaseAction) GetActionName 

func (t *TwoPhaseAction) GetActionName() string

func (*TwoPhaseAction) GetCommitMethodName 

func (t *TwoPhaseAction) GetCommitMethodName() string

func (*TwoPhaseAction) GetPrepareMethodName 

func (t *TwoPhaseAction) GetPrepareMethodName() string

func (*TwoPhaseAction) GetRollbackMethodName 

func (t *TwoPhaseAction) GetRollbackMethodName() string

func (*TwoPhaseAction) GetTwoPhaseService 

func (t *TwoPhaseAction) GetTwoPhaseService() interface{}

func (*TwoPhaseAction) Prepare 

func (t *TwoPhaseAction) Prepare(ctx context.Context, params interface{}) (bool, error)

func (*TwoPhaseAction) Rollback 

func (t *TwoPhaseAction) Rollback(ctx context.Context, businessActionContext *tm.BusinessActionContext) (bool, error)

type TwoPhaseInterface 

type TwoPhaseInterface interface {
	Prepare(ctx context.Context, params interface{}) (bool, error)
	Commit(ctx context.Context, businessActionContext *tm.BusinessActionContext) (bool, error)
	Rollback(ctx context.Context, businessActionContext *tm.BusinessActionContext) (bool, error)
	GetActionName() string
}

Source Files

View all Source files

Directories

Path Synopsis
tcc
fence
fence/config
fence/enum
fence/handler
fence/store/db/dao
fence/store/db/model
fence/store/db/sql

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.