dao

Documentation

Index

• type BgmApiAccessor
  • func NewBgmApiAccessor() *BgmApiAccessor
  • func (apiClient *BgmApiAccessor) GetCollectionCount(uid string, ctype model.CollectionType, stype model.SubjectType) (int, error)
  • func (apiClient *BgmApiAccessor) GetCollectionTime(uid string, offset int, ctype model.CollectionType, stype model.SubjectType) (time.Time, error)
  • func (apiClient *BgmApiAccessor) GetCollections(uid string, ctype model.CollectionType, stype model.SubjectType, ...) ([]model.Collection, error)
  • func (apiClient *BgmApiAccessor) GetRecentCollections(uid string, ctype model.CollectionType, stype model.SubjectType, ...) ([]model.Collection, error)
  • func (apiClient *BgmApiAccessor) GetSubjects(tags []string, types []model.SubjectType, airDateRange [2]time.Time, ...) ([]model.Subject, error)
  • func (apiClient *BgmApiAccessor) GetUser(uid string) (model.User, error)
• type KonomiAccessor
• type KonomiCRAccessor
  • func NewCRKonomiAccessor() *KonomiCRAccessor
  • func (accessor *KonomiCRAccessor) BatchInsertCollection(collections []model.Collection, batchSize int) error
  • func (accessor *KonomiCRAccessor) BatchInsertUser(users []model.User, batchSize int) error
  • func (accessor *KonomiCRAccessor) DeleteCollectionByUid(uid string) error
  • func (accessor *KonomiCRAccessor) DeleteUser(uid string) error
  • func (accessor *KonomiCRAccessor) Disconnect()
  • func (accessor *KonomiCRAccessor) GetRatings(sid string) ([]int, error)
  • func (accessor *KonomiCRAccessor) GetRowCount(table Table) (int, error)
  • func (accessor *KonomiCRAccessor) GetSubjectIds() ([]string, error)
  • func (accessor *KonomiCRAccessor) GetSubjectIdsPaginated(offset, limit int) ([]string, error)
  • func (accessor *KonomiCRAccessor) GetUser(uid string) (model.User, error)
  • func (accessor *KonomiCRAccessor) GetUserIdsPaginated(offset, limit int) ([]string, error)
  • func (accessor *KonomiCRAccessor) InsertCollection(collection model.Collection) error
  • func (accessor *KonomiCRAccessor) InsertUser(user model.User) error
• type KonomiMongoAccessor
  • func NewMongoKonomiAccessor() *KonomiMongoAccessor
  • func (accessor *KonomiMongoAccessor) Disconnect()
  • func (accessor *KonomiMongoAccessor) InsertCollection(collection model.Collection) error
  • func (accessor *KonomiMongoAccessor) InsertUser(user model.User) error

Types

type BgmApiAccessor

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

func NewBgmApiAccessor

func NewBgmApiAccessor() *BgmApiAccessor

func (*BgmApiAccessor) GetCollectionCount

func (apiClient *BgmApiAccessor) GetCollectionCount(uid string, ctype model.CollectionType, stype model.SubjectType) (int, error)

func (*BgmApiAccessor) GetCollectionTime

func (apiClient *BgmApiAccessor) GetCollectionTime(uid string, offset int, ctype model.CollectionType, stype model.SubjectType) (time.Time, error)

func (*BgmApiAccessor) GetCollections

func (apiClient *BgmApiAccessor) GetCollections(uid string, ctype model.CollectionType, stype model.SubjectType, collectionAcceptor func(gjson.Result) bool) ([]model.Collection, error)

func (*BgmApiAccessor) GetRecentCollections

func (apiClient *BgmApiAccessor) GetRecentCollections(uid string,
	ctype model.CollectionType,
	stype model.SubjectType,
	collectionAcceptor func(gjson.Result) bool,
	recentWindowInDays int) ([]model.Collection, error)

func (*BgmApiAccessor) GetSubjects

func (apiClient *BgmApiAccessor) GetSubjects(tags []string, types []model.SubjectType, airDateRange [2]time.Time, ratingRange [2]float32) ([]model.Subject, error)

func (*BgmApiAccessor) GetUser

func (apiClient *BgmApiAccessor) GetUser(uid string) (model.User, error)

type KonomiAccessor

type KonomiAccessor interface {
	GetRowCount(table jet.Table) (int, error)
	GetUser(uid string) (model.User, error)
	GetUserIdsPaginated(offset, limit int) ([]string, error)
	InsertUser(user model.User) error
	BatchInsertUser(user []model.User, size int) error
	DeleteUser(uid string) error
	GetSubjectIdsPaginated(offset, limit int) ([]string, error)
	GetSubjectIds() ([]string, error)
	GetRatings(sid string) ([]int, error)
	InsertCollection(collection model.Collection) error
	BatchInsertCollection(collections []model.Collection, size int) error
	DeleteCollectionByUid(uid string) error
	Disconnect()
}

type KonomiCRAccessor

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

func NewCRKonomiAccessor

func NewCRKonomiAccessor() *KonomiCRAccessor

func (*KonomiCRAccessor) BatchInsertCollection

func (accessor *KonomiCRAccessor) BatchInsertCollection(collections []model.Collection, batchSize int) error

func (*KonomiCRAccessor) BatchInsertUser

func (accessor *KonomiCRAccessor) BatchInsertUser(users []model.User, batchSize int) error

func (*KonomiCRAccessor) DeleteCollectionByUid

func (accessor *KonomiCRAccessor) DeleteCollectionByUid(uid string) error

func (*KonomiCRAccessor) DeleteUser

func (accessor *KonomiCRAccessor) DeleteUser(uid string) error

func (*KonomiCRAccessor) Disconnect

func (accessor *KonomiCRAccessor) Disconnect()

func (*KonomiCRAccessor) GetRatings

func (accessor *KonomiCRAccessor) GetRatings(sid string) ([]int, error)

func (*KonomiCRAccessor) GetRowCount

func (accessor *KonomiCRAccessor) GetRowCount(table Table) (int, error)

func (*KonomiCRAccessor) GetSubjectIds

func (accessor *KonomiCRAccessor) GetSubjectIds() ([]string, error)

func (*KonomiCRAccessor) GetSubjectIdsPaginated

func (accessor *KonomiCRAccessor) GetSubjectIdsPaginated(offset, limit int) ([]string, error)

func (*KonomiCRAccessor) GetUser

func (accessor *KonomiCRAccessor) GetUser(uid string) (model.User, error)

func (*KonomiCRAccessor) GetUserIdsPaginated

func (accessor *KonomiCRAccessor) GetUserIdsPaginated(offset, limit int) ([]string, error)

func (*KonomiCRAccessor) InsertCollection

func (accessor *KonomiCRAccessor) InsertCollection(collection model.Collection) error

func (*KonomiCRAccessor) InsertUser

func (accessor *KonomiCRAccessor) InsertUser(user model.User) error

type KonomiMongoAccessor

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

func NewMongoKonomiAccessor

func NewMongoKonomiAccessor() *KonomiMongoAccessor

func (*KonomiMongoAccessor) Disconnect

func (accessor *KonomiMongoAccessor) Disconnect()

func (*KonomiMongoAccessor) InsertCollection

func (accessor *KonomiMongoAccessor) InsertCollection(collection model.Collection) error

func (*KonomiMongoAccessor) InsertUser

func (accessor *KonomiMongoAccessor) InsertUser(user model.User) error