Documentation
¶
Overview ¶
package reds implement the storage for reds
Index ¶
- type Store
- func (s *Store) ChangeGlobalStatus(global *storage.TransGlobalStore, newStatus string, updates []string, ...)
- func (s *Store) CreateKV(cat, key, value string) error
- func (s *Store) DeleteKV(cat, key string) error
- func (s *Store) FindBranches(gid string) []storage.TransBranchStore
- func (s *Store) FindKV(cat, key string) []storage.KVStore
- func (s *Store) FindTransGlobalStore(gid string) *storage.TransGlobalStore
- func (s *Store) LockGlobalSaveBranches(gid string, status string, branches []storage.TransBranchStore, ...)
- func (s *Store) LockOneGlobalTrans(expireIn time.Duration) *storage.TransGlobalStore
- func (s *Store) MaySaveNewTrans(global *storage.TransGlobalStore, branches []storage.TransBranchStore) error
- func (s *Store) Ping() error
- func (s *Store) PopulateData(skipDrop bool)
- func (s *Store) ResetCronTime(after time.Duration, limit int64) (succeedCount int64, hasRemaining bool, err error)
- func (s *Store) ResetTransGlobalCronTime(global *storage.TransGlobalStore) error
- func (s *Store) ScanKV(cat string, position *string, limit int64) []storage.KVStore
- func (s *Store) ScanTransGlobalStores(position *string, limit int64, condition storage.TransGlobalScanCondition) []storage.TransGlobalStore
- func (s *Store) TouchCronTime(global *storage.TransGlobalStore, nextCronInterval int64, ...)
- func (s *Store) UpdateBranches(branches []storage.TransBranchStore, updates []string) (int, error)
- func (s *Store) UpdateKV(kv *storage.KVStore) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶ added in v1.9.1
type Store struct {
}
Store is the storage with redis, all transaction information will bachend with redis
func (*Store) ChangeGlobalStatus ¶ added in v1.9.1
func (s *Store) ChangeGlobalStatus(global *storage.TransGlobalStore, newStatus string, updates []string, finished bool)
ChangeGlobalStatus changes global trans status
func (*Store) FindBranches ¶ added in v1.9.1
func (s *Store) FindBranches(gid string) []storage.TransBranchStore
FindBranches finds Branch data by gid
func (*Store) FindTransGlobalStore ¶ added in v1.9.1
func (s *Store) FindTransGlobalStore(gid string) *storage.TransGlobalStore
FindTransGlobalStore finds GlobalTrans data by gid
func (*Store) LockGlobalSaveBranches ¶ added in v1.9.1
func (s *Store) LockGlobalSaveBranches(gid string, status string, branches []storage.TransBranchStore, branchStart int)
LockGlobalSaveBranches creates branches
func (*Store) LockOneGlobalTrans ¶ added in v1.9.1
func (s *Store) LockOneGlobalTrans(expireIn time.Duration) *storage.TransGlobalStore
LockOneGlobalTrans finds GlobalTrans
func (*Store) MaySaveNewTrans ¶ added in v1.9.1
func (s *Store) MaySaveNewTrans(global *storage.TransGlobalStore, branches []storage.TransBranchStore) error
MaySaveNewTrans creates a new trans
func (*Store) PopulateData ¶ added in v1.9.1
PopulateData populates data to redis
func (*Store) ResetCronTime ¶ added in v1.13.1
func (s *Store) ResetCronTime(after time.Duration, limit int64) (succeedCount int64, hasRemaining bool, err error)
ResetCronTime reset nextCronTime unfinished transactions need to be retried as soon as possible after business downtime is recovered
func (*Store) ResetTransGlobalCronTime ¶ added in v1.17.4
func (s *Store) ResetTransGlobalCronTime(global *storage.TransGlobalStore) error
ResetTransGlobalCronTime reset nextCronTime of one global trans.
func (*Store) ScanTransGlobalStores ¶ added in v1.9.1
func (s *Store) ScanTransGlobalStores(position *string, limit int64, condition storage.TransGlobalScanCondition) []storage.TransGlobalStore
ScanTransGlobalStores lists GlobalTrans data
func (*Store) TouchCronTime ¶ added in v1.9.1
func (s *Store) TouchCronTime(global *storage.TransGlobalStore, nextCronInterval int64, nextCronTime *time.Time)
TouchCronTime updates cronTime
func (*Store) UpdateBranches ¶ added in v1.9.1
UpdateBranches updates branches info
Source Files
Click to show internal directories.
Click to hide internal directories.