redis

Documentation

Index

• type RedisStore
  • func (s *RedisStore) ChangeGlobalStatus(global *storage.TransGlobalStore, newStatus string, updates []string, ...)
  • func (s *RedisStore) FindBranches(gid string) []storage.TransBranchStore
  • func (s *RedisStore) FindTransGlobalStore(gid string) *storage.TransGlobalStore
  • func (s *RedisStore) LockGlobalSaveBranches(gid string, status string, branches []storage.TransBranchStore, ...)
  • func (s *RedisStore) LockOneGlobalTrans(expireIn time.Duration) *storage.TransGlobalStore
  • func (s *RedisStore) MaySaveNewTrans(global *storage.TransGlobalStore, branches []storage.TransBranchStore) error
  • func (s *RedisStore) Ping() error
  • func (s *RedisStore) PopulateData(skipDrop bool)
  • func (s *RedisStore) ScanTransGlobalStores(position *string, limit int64) []storage.TransGlobalStore
  • func (s *RedisStore) TouchCronTime(global *storage.TransGlobalStore, nextCronInterval int64)
  • func (s *RedisStore) UpdateBranches(branches []storage.TransBranchStore, updates []string) (int, error)

Types

type RedisStore

type RedisStore struct {
}

RedisStore is the storage with redis, all transaction information will bachend with redis

func (*RedisStore) ChangeGlobalStatus

func (s *RedisStore) ChangeGlobalStatus(global *storage.TransGlobalStore, newStatus string, updates []string, finished bool)

func (*RedisStore) FindBranches

func (s *RedisStore) FindBranches(gid string) []storage.TransBranchStore

func (*RedisStore) FindTransGlobalStore

func (s *RedisStore) FindTransGlobalStore(gid string) *storage.TransGlobalStore

func (*RedisStore) LockGlobalSaveBranches

func (s *RedisStore) LockGlobalSaveBranches(gid string, status string, branches []storage.TransBranchStore, branchStart int)

func (*RedisStore) LockOneGlobalTrans

func (s *RedisStore) LockOneGlobalTrans(expireIn time.Duration) *storage.TransGlobalStore

func (*RedisStore) MaySaveNewTrans

func (s *RedisStore) MaySaveNewTrans(global *storage.TransGlobalStore, branches []storage.TransBranchStore) error

func (*RedisStore) Ping

func (s *RedisStore) Ping() error

func (*RedisStore) PopulateData

func (s *RedisStore) PopulateData(skipDrop bool)

func (*RedisStore) ScanTransGlobalStores

func (s *RedisStore) ScanTransGlobalStores(position *string, limit int64) []storage.TransGlobalStore

func (*RedisStore) TouchCronTime

func (s *RedisStore) TouchCronTime(global *storage.TransGlobalStore, nextCronInterval int64)

func (*RedisStore) UpdateBranches

func (s *RedisStore) UpdateBranches(branches []storage.TransBranchStore, updates []string) (int, error)