mysql

Documentation

Index

• type Storage
  • func New(dsn string) (s Storage, err error)
  • func (s Storage) CreateAuthToken(authToken models.AuthToken) *errors.Error
  • func (s Storage) CreateRewardIncome(income models.Income, now time.Time) *errors.Error
  • func (s Storage) CreateUser(u models.User) *errors.Error
  • func (s Storage) CreateWithdrawal(withdrawal models.Withdrawal) *errors.Error
  • func (s Storage) DeleteAuthToken(authToken string) *errors.Error
  • func (s Storage) GetAuthToken(authTokenString string) (models.AuthToken, *errors.Error)
  • func (s Storage) GetLatestConfig() (models.Config, *errors.Error)
  • func (s Storage) GetLatestTotalReward() (models.TotalReward, *errors.Error)
  • func (s Storage) GetRefereesSince(userID, id, limit int64) ([]models.User, *errors.Error)
  • func (s Storage) GetRefereesUntil(userID, id, limit int64) ([]models.User, *errors.Error)
  • func (s Storage) GetRewardIncomesSince(userID int64, since time.Time, limit int64) ([]models.Income, *errors.Error)
  • func (s Storage) GetRewardIncomesUntil(userID int64, until time.Time, limit int64) ([]models.Income, *errors.Error)
  • func (s Storage) GetRewardRatesByType(rewardRateType string) ([]models.RewardRate, *errors.Error)
  • func (s Storage) GetSessionByToken(token string) (models.Session, *errors.Error)
  • func (s Storage) GetUserByEmail(email string) (models.User, *errors.Error)
  • func (s Storage) GetUserByID(id int64) (models.User, *errors.Error)
  • func (s Storage) GetWithdrawableUsers() ([]models.User, *errors.Error)
  • func (s Storage) GetWithdrawalsSince(userID int64, since time.Time, limit int64) ([]models.Withdrawal, *errors.Error)
  • func (s Storage) GetWithdrawalsUntil(userID int64, until time.Time, limit int64) ([]models.Withdrawal, *errors.Error)
  • func (s Storage) IncrementTotalReward(now time.Time, delta int64) *errors.Error
  • func (s *Storage) SetMaxIdleConns(n int)
  • func (s *Storage) SetMaxOpenConns(n int)
  • func (s Storage) UpdateUserStatus(id int64, status string) *errors.Error
  • func (s Storage) UpsertSession(session models.Session) *errors.Error

Types

type Storage

type Storage struct {
	// contains filtered or unexported fields
}

Storage implements Storage interface for data storage

func New

func New(dsn string) (s Storage, err error)

New returns a Storage with data source name

func (Storage) CreateAuthToken

func (s Storage) CreateAuthToken(authToken models.AuthToken) *errors.Error

CreateAuthToken creates a new auth token

func (Storage) CreateRewardIncome

func (s Storage) CreateRewardIncome(income models.Income, now time.Time) *errors.Error

CreateRewardIncome creates a new reward type income

func (Storage) CreateUser

func (s Storage) CreateUser(u models.User) *errors.Error

CreateUser creates a new user

func (Storage) CreateWithdrawal

func (s Storage) CreateWithdrawal(withdrawal models.Withdrawal) *errors.Error

CreateWithdrawal creates a new withdrawal

func (Storage) DeleteAuthToken

func (s Storage) DeleteAuthToken(authToken string) *errors.Error

DeleteAuthToken deletes auth_token from storage

func (Storage) GetAuthToken

func (s Storage) GetAuthToken(authTokenString string) (models.AuthToken, *errors.Error)

GetAuthToken gets models.AuthToken with auth_token given

func (Storage) GetLatestConfig

func (s Storage) GetLatestConfig() (models.Config, *errors.Error)

GetLatestConfig get latest system config

func (Storage) GetLatestTotalReward

func (s Storage) GetLatestTotalReward() (models.TotalReward, *errors.Error)

GetLatestTotalReward get all total rewards order by time desc

func (Storage) GetRefereesSince

func (s Storage) GetRefereesSince(userID, id, limit int64) ([]models.User, *errors.Error)

GetRefereesSince gets user's referees since, id >= since

func (Storage) GetRefereesUntil

func (s Storage) GetRefereesUntil(userID, id, limit int64) ([]models.User, *errors.Error)

GetRefereesUntil gets user's referees since, id < until

func (Storage) GetRewardIncomesSince

func (s Storage) GetRewardIncomesSince(userID int64, since time.Time, limit int64) ([]models.Income, *errors.Error)

GetRewardIncomesSince get user's reward income records since, created_at >= since pagination design, previous https://developers.facebook.com/blog/post/478/

func (Storage) GetRewardIncomesUntil

func (s Storage) GetRewardIncomesUntil(userID int64, until time.Time, limit int64) ([]models.Income, *errors.Error)

GetRewardIncomesUntil get user's reward income records until, created_at < until pagination design, next

func (Storage) GetRewardRatesByType

func (s Storage) GetRewardRatesByType(rewardRateType string) ([]models.RewardRate, *errors.Error)

GetRewardRatesByType get all reward rates by type

func (Storage) GetSessionByToken

func (s Storage) GetSessionByToken(token string) (models.Session, *errors.Error)

GetSessionByToken gets models.Session with token given

func (Storage) GetUserByEmail

func (s Storage) GetUserByEmail(email string) (models.User, *errors.Error)

GetUserByEmail gets a user with email given

func (Storage) GetUserByID

func (s Storage) GetUserByID(id int64) (models.User, *errors.Error)

GetUserByID gets a user with id given

func (Storage) GetWithdrawableUsers

func (s Storage) GetWithdrawableUsers() ([]models.User, *errors.Error)

GetWithdrawableUsers gets users who are able to withdraw

func (Storage) GetWithdrawalsSince

func (s Storage) GetWithdrawalsSince(userID int64, since time.Time, limit int64) ([]models.Withdrawal, *errors.Error)

GetWithdrawalsSince get user's withdrawal since, created_at >= since

func (Storage) GetWithdrawalsUntil

func (s Storage) GetWithdrawalsUntil(userID int64, until time.Time, limit int64) ([]models.Withdrawal, *errors.Error)

GetWithdrawalsUntil get user's withdrawal until, created_at < until

func (Storage) IncrementTotalReward

func (s Storage) IncrementTotalReward(now time.Time, delta int64) *errors.Error

IncrementTotalReward increments total reward by delta for now

func (*Storage) SetMaxIdleConns

func (s *Storage) SetMaxIdleConns(n int)

SetMaxIdleConns alias sql.DB.SetMaxIdleConns

func (*Storage) SetMaxOpenConns

func (s *Storage) SetMaxOpenConns(n int)

SetMaxOpenConns alias sql.DB.SetMaxOpenConns

func (Storage) UpdateUserStatus

func (s Storage) UpdateUserStatus(id int64, status string) *errors.Error

UpdateUserStatus updates a user's status

func (Storage) UpsertSession

func (s Storage) UpsertSession(session models.Session) *errors.Error

UpsertSession creates a new session