repository

Documentation

Index

• Variables
• type CachedCodeRepository
  • func (cr *CachedCodeRepository) Store(ctx context.Context, biz, phone, code string) error
  • func (cr *CachedCodeRepository) Verify(ctx context.Context, biz, phone, inputCode string) (bool, error)
• type CachedUserRepository
  • func (ur *CachedUserRepository) Create(ctx context.Context, user domain.User) error
  • func (ur *CachedUserRepository) FindByEmail(ctx context.Context, email string) (domain.User, error)
  • func (ur *CachedUserRepository) FindById(ctx context.Context, id int64) (domain.User, error)
  • func (ur *CachedUserRepository) FindByIdV1(ctx context.Context, id int64) (domain.User, error)
  • func (ur *CachedUserRepository) FindByPhone(ctx context.Context, phone string) (domain.User, error)
• type CodeRepository
  • func NewCodeRepository(cache cache.CodeCache) CodeRepository
• type UserRepository
  • func NewUserRepository(dao dao.UserDAO, cache cache.UserCache) UserRepository

Variables

var (
	ErrCodeVerifyTooManyTimes = cache.ErrCodeVerifyTooManyTimes
	ErrCodeSendTooMany        = cache.ErrCodeSendTooMany
)

复用 cache 包中的错误

var (
	ErrUserDuplicateUser = dao.ErrUserDuplicate
	ErrUserNotFound      = dao.ErrDataNotFound
)

Types

type CachedCodeRepository

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

func (*CachedCodeRepository) Store

func (cr *CachedCodeRepository) Store(ctx context.Context, biz, phone, code string) error

func (*CachedCodeRepository) Verify

func (cr *CachedCodeRepository) Verify(ctx context.Context, biz, phone, inputCode string) (bool, error)

type CachedUserRepository

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

func (*CachedUserRepository) Create

func (ur *CachedUserRepository) Create(ctx context.Context, user domain.User) error

func (*CachedUserRepository) FindByEmail

func (ur *CachedUserRepository) FindByEmail(ctx context.Context, email string) (domain.User, error)

func (*CachedUserRepository) FindById

func (ur *CachedUserRepository) FindById(ctx context.Context, id int64) (domain.User, error)

func (*CachedUserRepository) FindByIdV1

func (ur *CachedUserRepository) FindByIdV1(ctx context.Context, id int64) (domain.User, error)

func (*CachedUserRepository) FindByPhone

func (ur *CachedUserRepository) FindByPhone(ctx context.Context, phone string) (domain.User, error)

type CodeRepository

type CodeRepository interface {
	Store(ctx context.Context, biz, phone, code string) error
	Verify(ctx context.Context, biz, phone, inputCode string) (bool, error)
}

func NewCodeRepository

func NewCodeRepository(cache cache.CodeCache) CodeRepository

type UserRepository

type UserRepository interface {
	Create(ctx context.Context, user domain.User) error
	FindById(ctx context.Context, id int64) (domain.User, error)
	FindByEmail(ctx context.Context, email string) (domain.User, error)
	FindByPhone(ctx context.Context, phone string) (domain.User, error)
}

func NewUserRepository

func NewUserRepository(dao dao.UserDAO, cache cache.UserCache) UserRepository