Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetClientConfig ¶
func SetClientConfig(config *DistributedTransaction)
Types ¶
type ATConfig ¶
type ATConfig struct {
DSN string `yaml:"dsn" json:"dsn,omitempty"`
ReportRetryCount int `default:"5" yaml:"reportRetryCount" json:"reportRetryCount,omitempty"`
ReportSuccessEnable bool `default:"false" yaml:"reportSuccessEnable" json:"reportSuccessEnable,omitempty"`
LockRetryInterval time.Duration `default:"10ms" yaml:"lockRetryInterval" json:"lockRetryInterval,omitempty"`
LockRetryTimes int `default:"30" yaml:"lockRetryTimes" json:"lockRetryTimes,omitempty"`
}
type DistributedTransaction ¶
type DistributedTransaction struct {
ApplicationID string `yaml:"appid" json:"appid"`
RetryDeadThreshold int64 `yaml:"retry_dead_threshold" json:"retry_dead_threshold"`
RollbackRetryTimeoutUnlockEnable bool `yaml:"rollback_retry_timeout_unlock_enable" json:"rollback_retry_timeout_unlock_enable"`
EtcdConfig clientv3.Config `yaml:"etcd_config" json:"etcd_config"`
ATConfig ATConfig `yaml:"at" json:"at,omitempty"`
TMConfig TMConfig `yaml:"tm" json:"tm,omitempty"`
}
func InitDistributedTransaction ¶
func InitDistributedTransaction(configurationPath string) *DistributedTransaction
InitDistributedTransaction init configuration from a file path
Click to show internal directories.
Click to hide internal directories.