sql

Documentation

Index

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

Functions

func SetDBConn

func SetDBConn(db *gorm.DB)

Types

type SqlStore

type SqlStore struct {
}

func (*SqlStore) ChangeGlobalStatus

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

func (*SqlStore) FindBranches

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

func (*SqlStore) FindTransGlobalStore

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

func (*SqlStore) LockGlobalSaveBranches

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

func (*SqlStore) LockOneGlobalTrans

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

func (*SqlStore) MaySaveNewTrans

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

func (*SqlStore) Ping

func (s *SqlStore) Ping() error

func (*SqlStore) PopulateData

func (s *SqlStore) PopulateData(skipDrop bool)

func (*SqlStore) ScanTransGlobalStores

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

func (*SqlStore) TouchCronTime

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

func (*SqlStore) UpdateBranches

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