index

Documentation

Index

• type CollectRepo
• type IndexCollect
• type IndexRepo
• type Repo
  • func NewMysqlRepo(q *query.Query, log *zap.Logger) (Repo, error)
• type Subject
• type SubjectRepo

Types

type CollectRepo

type CollectRepo interface {
	// GetIndexCollect get and index colelct item if exists
	GetIndexCollect(ctx context.Context, id model.IndexID, uid model.UserID) (*IndexCollect, error)

	// AddIndexCollect add an index collect to given user
	AddIndexCollect(ctx context.Context, id model.IndexID, uid model.UserID) error

	// DeleteIndexCollect remove index collect from given user
	DeleteIndexCollect(ctx context.Context, id model.IndexID, uid model.UserID) error
}

type IndexCollect

type IndexCollect struct {
	ID          uint32
	IndexID     model.IndexID
	UserID      model.UserID
	CreatedTime time.Time
}

type IndexRepo

type IndexRepo interface {
	Get(ctx context.Context, id model.IndexID) (model.Index, error)
	New(ctx context.Context, i *model.Index) error
	Update(ctx context.Context, id model.IndexID, title string, desc string) error
	Delete(ctx context.Context, id model.IndexID) error
}

type Repo

type Repo interface {
	IndexRepo
	SubjectRepo
	CollectRepo
}

func NewMysqlRepo

func NewMysqlRepo(q *query.Query, log *zap.Logger) (Repo, error)

type Subject

type Subject struct {
	Comment string
	AddedAt time.Time
	Subject model.Subject
}

type SubjectRepo

type SubjectRepo interface {
	CountSubjects(ctx context.Context, id model.IndexID, subjectType model.SubjectType) (int64, error)
	ListSubjects(
		ctx context.Context, id model.IndexID, subjectType model.SubjectType, limit, offset int,
	) ([]Subject, error)
	AddOrUpdateIndexSubject(
		ctx context.Context, id model.IndexID, subjectID model.SubjectID, sort uint32, comment string,
	) (*Subject, error)
	DeleteIndexSubject(
		ctx context.Context, id model.IndexID, subjectID model.SubjectID,
	) error
}