Browse Source

SuccessDataExpire => FinishedDataExpire

topic v1.13.1
yedf2 5 years ago
parent
commit
c076b3a68b
  1. 2
      conf.sample.yml
  2. 6
      dtmsvr/config/config.go
  3. 2
      dtmsvr/storage/redis/redis.go

2
conf.sample.yml

@ -35,7 +35,7 @@
### flollowing config is only for some Driver
# DataExpire: 604800 # Trans data will expire in 7 days. only for redis/boltdb.
# SuccessDataExpire: 86400 # successful Trans data will expire in 1 days. only for redis.
# FinishedDataExpire: 86400 # finished Trans data will expire in 1 days. only for redis.
# RedisPrefix: '{a}' # default value is '{a}'. Redis storage prefix. store data to only one slot in cluster
# MicroService:

6
dtmsvr/config/config.go

@ -46,9 +46,9 @@ type Store struct {
MaxOpenConns int64 `yaml:"MaxOpenConns" default:"500"`
MaxIdleConns int64 `yaml:"MaxIdleConns" default:"500"`
ConnMaxLifeTime int64 `yaml:"ConnMaxLifeTime" default:"5"`
DataExpire int64 `yaml:"DataExpire" default:"604800"` // Trans data will expire in 7 days. only for redis/boltdb.
SuccessDataExpire int64 `yaml:"SuccessDataExpire" default:"86400"` // successful Trans data will expire in 1 days. only for redis.
RedisPrefix string `yaml:"RedisPrefix" default:"{a}"` // Redis storage prefix. store data to only one slot in cluster
DataExpire int64 `yaml:"DataExpire" default:"604800"` // Trans data will expire in 7 days. only for redis/boltdb.
FinishedDataExpire int64 `yaml:"FinishedDataExpire" default:"86400"` // finished Trans data will expire in 1 days. only for redis.
RedisPrefix string `yaml:"RedisPrefix" default:"{a}"` // Redis storage prefix. store data to only one slot in cluster
TransGlobalTable string `yaml:"TransGlobalTable" default:"dtm.trans_global"`
TransBranchOpTable string `yaml:"TransBranchOpTable" default:"dtm.trans_branch_op"`
}

2
dtmsvr/storage/redis/redis.go

@ -221,7 +221,7 @@ func (s *Store) ChangeGlobalStatus(global *storage.TransGlobalStore, newStatus s
AppendRaw(finished).
AppendRaw(global.Gid).
AppendRaw(newStatus).
AppendObject(conf.Store.SuccessDataExpire)
AppendObject(conf.Store.FinishedDataExpire)
_, err := callLua(args, `-- ChangeGlobalStatus
local old = redis.call('GET', KEYS[4])
if old ~= ARGV[4] then

Loading…
Cancel
Save