sql

Documentation

Index

• func SetDBConn(db *gorm.DB)
• type Store
  • func (s *Store) ChangeGlobalStatus(global *storage.TransGlobalStore, newStatus string, updates []string, ...)
  • func (s *Store) FindBranches(gid string) []storage.TransBranchStore
  • 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(timeout time.Duration, limit int64) (succeedCount int64, hasRemaining bool, err error)
  • func (s *Store) ScanTransGlobalStores(position *string, limit int64) []storage.TransGlobalStore
  • func (s *Store) TouchCronTime(global *storage.TransGlobalStore, nextCronInterval int64, ...)
  • func (s *Store) UpdateBranches(branches []storage.TransBranchStore, updates []string) (int, error)

Functions

func SetDBConn

func SetDBConn(db *gorm.DB)

SetDBConn sets db conn pool

Types

type Store

type Store struct {
}

Store implements storage.Store, and storage with db

func (*Store) ChangeGlobalStatus

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

ChangeGlobalStatus changes global trans status

func (*Store) FindBranches

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

FindBranches finds Branch data by gid

func (*Store) FindTransGlobalStore

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

FindTransGlobalStore finds GlobalTrans data by gid

func (*Store) LockGlobalSaveBranches

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

LockGlobalSaveBranches creates branches

func (*Store) LockOneGlobalTrans

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

LockOneGlobalTrans finds GlobalTrans

func (*Store) MaySaveNewTrans

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

MaySaveNewTrans creates a new trans

func (*Store) Ping

func (s *Store) Ping() error

Ping execs ping cmd to db

func (*Store) PopulateData

func (s *Store) PopulateData(skipDrop bool)

PopulateData populates data to db

func (*Store) ResetCronTime

func (s *Store) ResetCronTime(timeout time.Duration, limit int64) (succeedCount int64, hasRemaining bool, err error)

ResetCronTime rest nextCronTime Prevent multiple backoff from causing NextCronTime to be too long

func (*Store) ScanTransGlobalStores

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

ScanTransGlobalStores lists GlobalTrans data

func (*Store) TouchCronTime

func (s *Store) TouchCronTime(global *storage.TransGlobalStore, nextCronInterval int64, nextCronTime *time.Time)

TouchCronTime updates cronTime

func (*Store) UpdateBranches

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

UpdateBranches update branches info