boltdb

Documentation

Index

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

Types

type BoltdbStore

type BoltdbStore struct {
}

func (*BoltdbStore) ChangeGlobalStatus

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

func (*BoltdbStore) FindBranches

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

func (*BoltdbStore) FindTransGlobalStore

func (s *BoltdbStore) FindTransGlobalStore(gid string) (trans *storage.TransGlobalStore)

func (*BoltdbStore) LockGlobalSaveBranches

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

func (*BoltdbStore) LockOneGlobalTrans

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

func (*BoltdbStore) MaySaveNewTrans

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

func (*BoltdbStore) Ping

func (s *BoltdbStore) Ping() error

func (*BoltdbStore) PopulateData

func (s *BoltdbStore) PopulateData(skipDrop bool)

func (*BoltdbStore) ScanTransGlobalStores

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

func (*BoltdbStore) TouchCronTime

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

func (*BoltdbStore) UpdateBranches

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