Documentation
¶
Index ¶
- type BalanceRepository
- func (r BalanceRepository) ClearBalance(ctx context.Context, uid user.ID) error
- func (r BalanceRepository) GetBalance(ctx context.Context, uid user.ID) ([]loan.Balance, error)
- func (r BalanceRepository) HasBalance(ctx context.Context, uid user.ID) (bool, error)
- func (r BalanceRepository) SetBalance(ctx context.Context, uid user.ID, balance ...loan.Balance) error
- func (r BalanceRepository) UpdateBalance(ctx context.Context, uid user.ID, deltas ...loan.Balance) error
- type GroupRepository
- func (r GroupRepository) AddGroup(ctx context.Context, name string, owner user.ID) (*user.GroupID, error)
- func (r GroupRepository) AddGroupUsers(ctx context.Context, gid user.GroupID, uids []user.ID) error
- func (r GroupRepository) DeleteGroup(ctx context.Context, gid user.GroupID) error
- func (r GroupRepository) DeleteGroupUser(ctx context.Context, gid user.GroupID, uid user.ID) error
- func (r GroupRepository) GetGroupMembers(ctx context.Context, gid user.GroupID) (user.Users, error)
- func (r GroupRepository) GetGroupOwner(ctx context.Context, gid user.GroupID) (*user.ID, error)
- func (r GroupRepository) GroupByID(ctx context.Context, gid user.ID) (*user.Group, error)
- func (r GroupRepository) GroupMemberIDs(ctx context.Context, gid user.GroupID) ([]user.ID, error)
- func (r GroupRepository) GroupsByAuthor(ctx context.Context, uid user.ID) (user.Groups, error)
- func (r GroupRepository) GroupsByUser(ctx context.Context, uid user.ID) (user.Groups, error)
- type LoansRepository
- type SessionRepository
- type UserRepository
- func (r UserRepository) AddUser(ctx context.Context, u user.User) (*user.ID, error)
- func (r UserRepository) AllUsers(ctx context.Context) (user.Users, error)
- func (r UserRepository) Exists(email string) (bool, error)
- func (r UserRepository) UserByEmail(ctx context.Context, email string) (*user.User, error)
- func (r UserRepository) UserByID(ctx context.Context, uid user.ID) (*user.User, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BalanceRepository ¶
type BalanceRepository struct {
// contains filtered or unexported fields
}
BalanceRepository keeps user balance in Redis cache.
func NewBalanceRepository ¶
func NewBalanceRepository(log *zap.Logger, r redis.Cmdable) *BalanceRepository
NewBalanceRepository is BalanceRepository constructor
func (BalanceRepository) ClearBalance ¶
ClearBalance implements service.BalanceStore
func (BalanceRepository) GetBalance ¶
GetBalance implements service.BalanceStore
func (BalanceRepository) HasBalance ¶
HasBalance implements service.BalanceStore
func (BalanceRepository) SetBalance ¶
func (r BalanceRepository) SetBalance(ctx context.Context, uid user.ID, balance ...loan.Balance) error
SetBalance implements service.BalanceStore
func (BalanceRepository) UpdateBalance ¶
func (r BalanceRepository) UpdateBalance(ctx context.Context, uid user.ID, deltas ...loan.Balance) error
UpdateBalance implements service.BalanceStore
type GroupRepository ¶
type GroupRepository struct {
// contains filtered or unexported fields
}
func NewGroupRepository ¶
func NewGroupRepository(db *sqlx.DB) *GroupRepository
NewGroupRepository is GroupRepository constructor
func (GroupRepository) AddGroup ¶
func (r GroupRepository) AddGroup(ctx context.Context, name string, owner user.ID) (*user.GroupID, error)
AddGroup implements service.GroupStore
func (GroupRepository) AddGroupUsers ¶
AddGroupUsers implements service.GroupManager
func (GroupRepository) DeleteGroup ¶
DeleteGroup implements service.GroupStore
func (GroupRepository) DeleteGroupUser ¶
DeleteGroupUser implements service.GroupManager
func (GroupRepository) GetGroupMembers ¶
GetGroupMembers implements service.GroupManager
func (GroupRepository) GetGroupOwner ¶
GetGroupOwner implements service.GroupStore
func (GroupRepository) GroupMemberIDs ¶
func (GroupRepository) GroupsByAuthor ¶
GroupsByAuthor implements service.GroupManager
func (GroupRepository) GroupsByUser ¶
GroupsByUser implements service.GroupManager
type LoansRepository ¶
type LoansRepository struct {
// contains filtered or unexported fields
}
LoansRepository stores loan log in database
func NewLoansRepository ¶
func NewLoansRepository(db *sqlx.DB) *LoansRepository
NewLoansRepository is LoansRepository constructor
func (LoansRepository) GetUserBalance ¶
GetUserBalance implements service.LoansStorage
type SessionRepository ¶
type SessionRepository struct {
// contains filtered or unexported fields
}
func NewSessionRepository ¶
func NewSessionRepository(r redis.Cmdable) *SessionRepository
func (SessionRepository) CreateSession ¶
func (r SessionRepository) CreateSession(ctx context.Context, uid user.ID, ttl time.Duration) (*auth.Session, error)
CreateSession implements service.SessionStore
func (SessionRepository) GetSession ¶
GetSession implements service.SessionStore
func (SessionRepository) RemoveSession ¶
RemoveSession implements service.SessionStore
type UserRepository ¶
type UserRepository struct {
// contains filtered or unexported fields
}
func NewUserRepository ¶
func NewUserRepository(db *sqlx.DB) *UserRepository
NewUserRepository is UserRepository constructor
Source Files