dao

Documentation

Index

• type MysqlManagerImpl
  • func NewMysqlManager(db *gorm.DB) *MysqlManagerImpl
  • func (m *MysqlManagerImpl) CreateQuizChoice(quizChoice *model.QuizChoice) error
  • func (m *MysqlManagerImpl) CreateQuizJudge(quizJudge *model.QuizJudge) error
• type RedisManagerImpl
  • func NewRedisManager(client *redis.Client) *RedisManagerImpl
  • func (r *RedisManagerImpl) CheckRoomExists(ctx context.Context, roomId int64) (bool, error)
  • func (r *RedisManagerImpl) CheckUserHasSubmittedAnswer(ctx context.Context, request *quiz.SubmitAnswerRequest) (bool, error)
  • func (r *RedisManagerImpl) GetAnswer(ctx context.Context, questionId int64) (*quiz.AnswerPayload, error)
  • func (r *RedisManagerImpl) GetQuizStatus(ctx context.Context, QuestionId int64, RoomId int64) (*model.QuizStatus, error)
  • func (r *RedisManagerImpl) QuizLock(ctx context.Context, userId int64) error
  • func (r *RedisManagerImpl) QuizUnlock(ctx context.Context, userId int64) error
  • func (r *RedisManagerImpl) RecordAcceptAnswer(ctx context.Context, request *quiz.SubmitAnswerRequest) error
  • func (r *RedisManagerImpl) RecordWrongAnswer(ctx context.Context, request *quiz.SubmitAnswerRequest) error
  • func (r *RedisManagerImpl) SendQuestion(ctx context.Context, req *quiz.SubmitQuestionRequest, questionId int64) error
  • func (r *RedisManagerImpl) SendQuizStatus(ctx context.Context, status *model.QuizStatus) error
  • func (r *RedisManagerImpl) StoreAnswer(ctx context.Context, question *quiz.SubmitQuestionRequest, questionId int64) error

Types

type MysqlManagerImpl

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

func NewMysqlManager

func NewMysqlManager(db *gorm.DB) *MysqlManagerImpl

func (*MysqlManagerImpl) CreateQuizChoice

func (m *MysqlManagerImpl) CreateQuizChoice(quizChoice *model.QuizChoice) error

func (*MysqlManagerImpl) CreateQuizJudge

func (m *MysqlManagerImpl) CreateQuizJudge(quizJudge *model.QuizJudge) error

type RedisManagerImpl

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

func NewRedisManager

func NewRedisManager(client *redis.Client) *RedisManagerImpl

func (*RedisManagerImpl) CheckRoomExists

func (r *RedisManagerImpl) CheckRoomExists(ctx context.Context, roomId int64) (bool, error)

func (*RedisManagerImpl) CheckUserHasSubmittedAnswer

func (r *RedisManagerImpl) CheckUserHasSubmittedAnswer(ctx context.Context, request *quiz.SubmitAnswerRequest) (bool, error)

func (*RedisManagerImpl) GetAnswer

func (r *RedisManagerImpl) GetAnswer(ctx context.Context, questionId int64) (*quiz.AnswerPayload, error)

func (*RedisManagerImpl) GetQuizStatus

func (r *RedisManagerImpl) GetQuizStatus(ctx context.Context, QuestionId int64, RoomId int64) (*model.QuizStatus, error)

这里是获取并统计对于特定题目做题的状态。

func (*RedisManagerImpl) QuizLock

func (r *RedisManagerImpl) QuizLock(ctx context.Context, userId int64) error

func (*RedisManagerImpl) QuizUnlock

func (r *RedisManagerImpl) QuizUnlock(ctx context.Context, userId int64) error

func (*RedisManagerImpl) RecordAcceptAnswer

func (r *RedisManagerImpl) RecordAcceptAnswer(ctx context.Context, request *quiz.SubmitAnswerRequest) error

func (*RedisManagerImpl) RecordWrongAnswer

func (r *RedisManagerImpl) RecordWrongAnswer(ctx context.Context, request *quiz.SubmitAnswerRequest) error

func (*RedisManagerImpl) SendQuestion

func (r *RedisManagerImpl) SendQuestion(ctx context.Context, req *quiz.SubmitQuestionRequest, questionId int64) error

func (*RedisManagerImpl) SendQuizStatus

func (r *RedisManagerImpl) SendQuizStatus(ctx context.Context, status *model.QuizStatus) error

向 redis 中发送当前的 quiz 状态，push 服务从 redis 中接受然后推送给客户端。

func (*RedisManagerImpl) StoreAnswer

func (r *RedisManagerImpl) StoreAnswer(ctx context.Context, question *quiz.SubmitQuestionRequest, questionId int64) error