Documentation ¶
Index ¶
- type Storage
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Storage ¶
type Storage struct {
// contains filtered or unexported fields
}
Storage implements Storage interface for data storage
func (Storage) CreateAuthToken ¶
CreateAuthToken creates a new auth token
func (Storage) CreateRewardIncome ¶
CreateRewardIncome creates a new reward type income
func (Storage) CreateUser ¶
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 ¶
DeleteAuthToken deletes auth_token from storage
func (Storage) GetAuthToken ¶
GetAuthToken gets models.AuthToken with auth_token given
func (Storage) GetLatestConfig ¶
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 ¶
GetRefereesSince gets user's referees since, id >= since
func (Storage) GetRefereesUntil ¶
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 ¶
GetRewardRatesByType get all reward rates by type
func (Storage) GetSessionByToken ¶
GetSessionByToken gets models.Session with token given
func (Storage) GetUserByEmail ¶
GetUserByEmail gets a user with email given
func (Storage) GetUserByID ¶
GetUserByID gets a user with id given
func (Storage) GetWithdrawableUsers ¶
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 ¶
IncrementTotalReward increments total reward by delta for now
func (*Storage) SetMaxIdleConns ¶
SetMaxIdleConns alias sql.DB.SetMaxIdleConns
func (*Storage) SetMaxOpenConns ¶
SetMaxOpenConns alias sql.DB.SetMaxOpenConns
func (Storage) UpdateUserStatus ¶
UpdateUserStatus updates a user's status