repository

package
v0.3.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 13, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CachedExamineRepository added in v0.1.8 

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

func (*CachedExamineRepository) GetResultByUidAndQid added in v0.1.8 

func (repo *CachedExamineRepository) GetResultByUidAndQid(ctx context.Context, uid int64, qid int64) (domain.Result, error)

func (*CachedExamineRepository) GetResultsByIds added in v0.1.8 

func (repo *CachedExamineRepository) GetResultsByIds(ctx context.Context, uid int64, ids []int64) ([]domain.ExamineResult, error)

func (*CachedExamineRepository) SaveResult added in v0.1.8 

func (repo *CachedExamineRepository) SaveResult(ctx context.Context, uid, qid int64, result domain.ExamineResult) error

func (*CachedExamineRepository) UpdateQuestionResult added in v0.3.0 

func (repo *CachedExamineRepository) UpdateQuestionResult(ctx context.Context, uid int64, qid int64, result domain.Result) error

type CachedRepository 

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

CachedRepository 支持缓存的 repository 实现 虽然在 Save 的时候，理论上也需要更新缓存，但是没有必要

func (*CachedRepository) Create 

func (c *CachedRepository) Create(ctx context.Context, question *domain.Question) (int64, error)

func (*CachedRepository) Delete added in v0.1.0 

func (c *CachedRepository) Delete(ctx context.Context, qid int64) error

func (*CachedRepository) ExcludeQuestions added in v0.2.1 

func (c *CachedRepository) ExcludeQuestions(ctx context.Context, ids []int64, offset int, limit int) ([]domain.Question, int64, error)

func (*CachedRepository) GetById 

func (c *CachedRepository) GetById(ctx context.Context, qid int64) (domain.Question, error)

func (*CachedRepository) GetPubByID 

func (c *CachedRepository) GetPubByID(ctx context.Context, qid int64) (domain.Question, error)

func (*CachedRepository) GetPubByIDs added in v0.0.2 

func (c *CachedRepository) GetPubByIDs(ctx context.Context, qids []int64) ([]domain.Question, error)

func (*CachedRepository) List 

func (c *CachedRepository) List(ctx context.Context, offset int, limit int) ([]domain.Question, error)

func (*CachedRepository) PubCount added in v0.3.3 

func (c *CachedRepository) PubCount(ctx context.Context, biz string) (int64, error)

func (*CachedRepository) PubList 

func (c *CachedRepository) PubList(ctx context.Context, offset int, limit int, biz string) ([]domain.Question, error)

func (*CachedRepository) QuestionIds added in v0.3.3 

func (c *CachedRepository) QuestionIds(ctx context.Context) ([]int64, error)

func (*CachedRepository) Sync 

func (c *CachedRepository) Sync(ctx context.Context, que *domain.Question) (int64, error)

func (*CachedRepository) Total 

func (c *CachedRepository) Total(ctx context.Context) (int64, error)

func (*CachedRepository) Update 

func (c *CachedRepository) Update(ctx context.Context, question *domain.Question) error

type ExamineRepository added in v0.1.8 

type ExamineRepository interface {
	SaveResult(ctx context.Context, uid, qid int64, result domain.ExamineResult) error
	GetResultByUidAndQid(ctx context.Context, uid int64, qid int64) (domain.Result, error)
	GetResultsByIds(ctx context.Context, uid int64, ids []int64) ([]domain.ExamineResult, error)
	UpdateQuestionResult(ctx context.Context, uid int64, qid int64, result domain.Result) error
}

func NewCachedExamineRepository added in v0.1.8 

func NewCachedExamineRepository(dao dao.ExamineDAO) ExamineRepository

type QuestionSetRepository 

type QuestionSetRepository interface {
	Create(ctx context.Context, set domain.QuestionSet) (int64, error)
	UpdateQuestions(ctx context.Context, set domain.QuestionSet) error

	GetByID(ctx context.Context, id int64) (domain.QuestionSet, error)
	PubGetByID(ctx context.Context, id int64) (domain.QuestionSet, error)

	Total(ctx context.Context) (int64, error)
	List(ctx context.Context, offset int, limit int) ([]domain.QuestionSet, error)
	UpdateNonZero(ctx context.Context, set domain.QuestionSet) error
	GetByIDs(ctx context.Context, ids []int64) ([]domain.QuestionSet, error)
	GetByIDsWithQuestion(ctx context.Context, ids []int64) ([]domain.QuestionSet, error)
	ListByBiz(ctx context.Context, offset, limit int, biz string) ([]domain.QuestionSet, error)
	GetByBiz(ctx context.Context, biz string, bizId int64) (domain.QuestionSet, error)
	CountByBiz(ctx context.Context, biz string) (int64, error)
}

func NewQuestionSetRepository 

func NewQuestionSetRepository(d dao.QuestionSetDAO) QuestionSetRepository

type Repository 

type Repository interface {
	PubList(ctx context.Context, offset int, limit int, biz string) ([]domain.Question, error)
	// Sync 保存到制作库，而后同步到线上库
	Sync(ctx context.Context, que *domain.Question) (int64, error)
	PubCount(ctx context.Context, biz string) (int64, error)
	List(ctx context.Context, offset int, limit int) ([]domain.Question, error)
	Total(ctx context.Context) (int64, error)
	Update(ctx context.Context, question *domain.Question) error
	Create(ctx context.Context, question *domain.Question) (int64, error)
	// QuestionIds 获取全量问题id列表，用于ai同步
	QuestionIds(ctx context.Context) ([]int64, error)

	// Delete 会直接删除制作库和线上库的数据
	Delete(ctx context.Context, qid int64) error

	GetById(ctx context.Context, qid int64) (domain.Question, error)
	GetPubByID(ctx context.Context, qid int64) (domain.Question, error)
	GetPubByIDs(ctx context.Context, ids []int64) ([]domain.Question, error)
	// ExcludeQuestions 分页接口，不含这些 id 的问题
	ExcludeQuestions(ctx context.Context, ids []int64, offset int, limit int) ([]domain.Question, int64, error)
}

func NewCacheRepository 

func NewCacheRepository(d dao.QuestionDAO, c cache.QuestionCache) Repository

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.