database

Documentation

Index

• Variables
• type DB
  • func New(db *database.DB, cache cache.Cache) *DB
  • func (db *DB) Add(m model.Stat) error
  • func (db *DB) BytesBucket(userID int64) []byte
  • func (db *DB) FetchByuserID(userID int64) ([]model.Stat, error)
  • func (db *DB) FetchProfileStat(userID int64) (model.AggregationStat, error)
  • func (db *DB) FetchRateStat(userID int64) (model.RateStat, error)
  • func (db *DB) SerialBucket(userID int64) string

Variables

var (
	ErrNotFound = fmt.Errorf("not found")
)

Types

type DB

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

func New

func New(db *database.DB, cache cache.Cache) *DB

func (*DB) Add

func (db *DB) Add(m model.Stat) error

func (*DB) BytesBucket

func (db *DB) BytesBucket(userID int64) []byte

func (*DB) FetchByuserID

func (db *DB) FetchByuserID(userID int64) ([]model.Stat, error)

func (*DB) FetchProfileStat

func (db *DB) FetchProfileStat(userID int64) (model.AggregationStat, error)

func (*DB) FetchRateStat

func (db *DB) FetchRateStat(userID int64) (model.RateStat, error)

func (*DB) SerialBucket

func (db *DB) SerialBucket(userID int64) string