repository

Documentation

Index

• Variables
• type ArticleRepository
  • func NewArticleRepository(dao article.ArticleDao, cache cache.ArticleCache, logger *zap.Logger) ArticleRepository
• type ArticleRepositoryImpl
  • func (repo *ArticleRepositoryImpl) Create(ctx context.Context, article *domain.Article) (int64, error)
  • func (repo *ArticleRepositoryImpl) List(ctx context.Context, offset int, limit int) ([]domain.Article, error)
  • func (repo *ArticleRepositoryImpl) Sync(ctx context.Context, article *domain.Article) (int64, error)
  • func (repo *ArticleRepositoryImpl) Update(ctx context.Context, article *domain.Article) error
• type CodeRepository
  • func NewCodeRepository(c *cache.CodeCache, l *zap.Logger) CodeRepository
• type CodeRepositoryImpl
  • func (repo *CodeRepositoryImpl) Store(ctx context.Context, biz, phone, code string) error
  • func (repo *CodeRepositoryImpl) Verify(ctx context.Context, biz, phone, inputCode string) (bool, error)
• type InteractiveRepository
• type InteractiveRepositoryImpl
  • func NewInteractiveRepositoryImpl() *InteractiveRepositoryImpl
  • func (repo *InteractiveRepositoryImpl) IncreaseLikeCount(ctx context.Context, biz string, id int64, uid int64) error
  • func (repo *InteractiveRepositoryImpl) IncreaseReadCount(ctx context.Context, biz string, bizId int64) error
• type UserRepository
  • func NewUserRepository(d dao.UserDao, c cache.UserCache, l *zap.Logger) UserRepository
• type UserRepositoryImpl
  • func (r *UserRepositoryImpl) Create(ctx context.Context, u domain.User) error
  • func (r *UserRepositoryImpl) Domain2Entity(u domain.User) dao.User
  • func (r *UserRepositoryImpl) Entity2Domain(u dao.User) domain.User
  • func (r *UserRepositoryImpl) FindByEmail(ctx context.Context, email string) (domain.User, error)
  • func (r *UserRepositoryImpl) FindById(ctx context.Context, id int64) (domain.User, error)
  • func (r *UserRepositoryImpl) FindByPhone(ctx context.Context, phone string) (domain.User, error)

Variables

var (
	ErrCodeSendToMany         = cache.ErrSetCodeTooMany
	ErrCodeVerifyTooManyTimes = cache.ErrCodeVerifyTooManyTimes
)

var (
	ErrUserDuplicateEmail = dao.ErrUserDuplicateEmail
	ErrUserNotFound       = dao.ErrUserNotFound
)

Types

type ArticleRepository

type ArticleRepository interface {
	Create(ctx context.Context, article *domain.Article) (int64, error)
	Update(ctx context.Context, article *domain.Article) error
	Sync(ctx context.Context, article *domain.Article) (int64, error)
	List(ctx context.Context, offset int, limit int) ([]domain.Article, error)
}

func NewArticleRepository

func NewArticleRepository(dao article.ArticleDao, cache cache.ArticleCache, logger *zap.Logger) ArticleRepository

type ArticleRepositoryImpl

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

func (*ArticleRepositoryImpl) Create

func (repo *ArticleRepositoryImpl) Create(ctx context.Context, article *domain.Article) (int64, error)

func (*ArticleRepositoryImpl) List

func (repo *ArticleRepositoryImpl) List(ctx context.Context, offset int, limit int) ([]domain.Article, error)

func (*ArticleRepositoryImpl) Sync

func (repo *ArticleRepositoryImpl) Sync(ctx context.Context, article *domain.Article) (int64, error)

func (*ArticleRepositoryImpl) Update

func (repo *ArticleRepositoryImpl) Update(ctx context.Context, article *domain.Article) 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(c *cache.CodeCache, l *zap.Logger) CodeRepository

type CodeRepositoryImpl

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

func (*CodeRepositoryImpl) Store

func (repo *CodeRepositoryImpl) Store(ctx context.Context, biz, phone, code string) error

func (*CodeRepositoryImpl) Verify

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

type InteractiveRepository

type InteractiveRepository interface {
	IncreaseReadCount(ctx context.Context, biz string, bizId int64) error
	IncreaseLikeCount(ctx context.Context, biz string, id int64, uid int64) error
}

type InteractiveRepositoryImpl

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

func NewInteractiveRepositoryImpl

func NewInteractiveRepositoryImpl() *InteractiveRepositoryImpl

func (*InteractiveRepositoryImpl) IncreaseLikeCount

func (repo *InteractiveRepositoryImpl) IncreaseLikeCount(ctx context.Context, biz string, id int64, uid int64) error

func (*InteractiveRepositoryImpl) IncreaseReadCount

func (repo *InteractiveRepositoryImpl) IncreaseReadCount(ctx context.Context, biz string, bizId int64) error

type UserRepository

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

func NewUserRepository

func NewUserRepository(d dao.UserDao, c cache.UserCache, l *zap.Logger) UserRepository

type UserRepositoryImpl

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

func (*UserRepositoryImpl) Create

func (r *UserRepositoryImpl) Create(ctx context.Context, u domain.User) error

func (*UserRepositoryImpl) Domain2Entity

func (r *UserRepositoryImpl) Domain2Entity(u domain.User) dao.User

func (*UserRepositoryImpl) Entity2Domain

func (r *UserRepositoryImpl) Entity2Domain(u dao.User) domain.User

func (*UserRepositoryImpl) FindByEmail

func (r *UserRepositoryImpl) FindByEmail(ctx context.Context, email string) (domain.User, error)

func (*UserRepositoryImpl) FindById

func (r *UserRepositoryImpl) FindById(ctx context.Context, id int64) (domain.User, error)

FindById 缺点：只要缓存返回了 error，就直接取数据库查询。

回写缓存的时候，忽略掉了错误

func (*UserRepositoryImpl) FindByPhone

func (r *UserRepositoryImpl) FindByPhone(ctx context.Context, phone string) (domain.User, error)