cache

Nov 21, 2022

Changes in this version

type Database

+ Ping func() error

type MongoDB

+ func (m MongoDB) Ping() error

type NoDatabase

+ func (NoDatabase) Ping() error

type Redis

+ func (r *Redis) Ping() error

type SQLDatabase

+ func (db *SQLDatabase) Ping() error

Oct 11, 2022

Changes in this version

+ func ParseRedisClusterURL(redisURL string) (*redis.ClusterOptions, error)

Sep 13, 2022

Changes in this version

type Database

+ Purge func() error

type MongoDB

+ func (m MongoDB) Purge() error

type NoDatabase

+ func (NoDatabase) Purge() error

type Redis

+ func (r *Redis) Purge() error

type SQLDatabase

+ func (db *SQLDatabase) Purge() error

Jul 9, 2022

Changes in this version

type SQLDriver

+ const Oracle

Jun 11, 2022

Changes in this version

type SQLDriver

+ const SQLite

+ type SQLSet struct

+ Member string

+ Name string

+ func (*SQLSet) TableName() string

+ type SQLSortedSet struct

+ Member string

+ Name string

+ Score float64

+ func (*SQLSortedSet) TableName() string

+ type SQLValue struct

+ Name string

+ Value string

+ func (*SQLValue) TableName() string

May 14, 2022

Changes in this version

+ const Measurements

May 1, 2022

Changes in this version

+ const HiddenItemsV2

+ const ItemNeighborsDigest

+ const OfflineRecommendDigest

+ const UserNeighborsDigest

type Database

+ Scan func(work func(string) error) error

type MongoDB

+ func (m MongoDB) Scan(work func(string) error) error

type NoDatabase

+ func (NoDatabase) Scan(_ func(string) error) error

type Redis

+ func (r *Redis) Scan(work func(string) error) error

type SQLDatabase

+ func (db *SQLDatabase) Scan(work func(string) error) error

Apr 10, 2022

Changes in this version

+ func BatchKey(prefix string, keys ...string) []string

type Database

+ Get func(name string) *ReturnValue

+ GetSortedScores func(members ...SetMember) ([]float64, error)

+ Init func() error

+ Set func(values ...Value) error

+ type MongoDB struct

+ func (m MongoDB) AddSet(name string, members ...string) error

+ func (m MongoDB) AddSorted(sortedSets ...SortedSet) error

+ func (m MongoDB) Close() error

+ func (m MongoDB) Delete(name string) error

+ func (m MongoDB) Exists(names ...string) ([]int, error)

+ func (m MongoDB) Get(name string) *ReturnValue

+ func (m MongoDB) GetSet(name string) ([]string, error)

+ func (m MongoDB) GetSorted(name string, begin, end int) ([]Scored, error)

+ func (m MongoDB) GetSortedByScore(name string, begin, end float64) ([]Scored, error)

+ func (m MongoDB) GetSortedScores(members ...SetMember) ([]float64, error)

+ func (m MongoDB) Init() error

+ func (m MongoDB) RemSet(name string, members ...string) error

+ func (m MongoDB) RemSorted(name, member string) error

+ func (m MongoDB) RemSortedByScore(name string, begin, end float64) error

+ func (m MongoDB) Set(values ...Value) error

+ func (m MongoDB) SetSet(name string, members ...string) error

+ func (m MongoDB) SetSorted(name string, scores []Scored) error

type NoDatabase

+ func (NoDatabase) Get(_ string) *ReturnValue

+ func (NoDatabase) GetSortedScores(_ ...SetMember) ([]float64, error)

+ func (NoDatabase) Init() error

+ func (NoDatabase) Set(_ ...Value) error

type Redis

+ func (r *Redis) Get(key string) *ReturnValue

+ func (r *Redis) GetSortedScores(members ...SetMember) ([]float64, error)

+ func (r *Redis) Init() error

+ func (r *Redis) Set(values ...Value) error

+ type ReturnValue struct

+ func (r *ReturnValue) Integer() (int, error)

+ func (r *ReturnValue) String() (string, error)

+ func (r *ReturnValue) Time() (time.Time, error)

+ type SQLDatabase struct

+ func (db *SQLDatabase) AddSet(key string, members ...string) error

+ func (db *SQLDatabase) AddSorted(sortedSets ...SortedSet) error

+ func (db *SQLDatabase) Close() error

+ func (db *SQLDatabase) Delete(name string) error

+ func (db *SQLDatabase) Exists(names ...string) ([]int, error)

+ func (db *SQLDatabase) Get(name string) *ReturnValue

+ func (db *SQLDatabase) GetSet(key string) ([]string, error)

+ func (db *SQLDatabase) GetSorted(key string, begin, end int) ([]Scored, error)

+ func (db *SQLDatabase) GetSortedByScore(key string, begin, end float64) ([]Scored, error)

+ func (db *SQLDatabase) GetSortedScores(members ...SetMember) ([]float64, error)

+ func (db *SQLDatabase) Init() error

+ func (db *SQLDatabase) RemSet(key string, members ...string) error

+ func (db *SQLDatabase) RemSorted(key, member string) error

+ func (db *SQLDatabase) RemSortedByScore(key string, begin, end float64) error

+ func (db *SQLDatabase) Set(values ...Value) error

+ func (db *SQLDatabase) SetSet(key string, members ...string) error

+ func (db *SQLDatabase) SetSorted(key string, scores []Scored) error

+ type SQLDriver int

+ const MySQL

+ const Postgres

+ type SetMember struct

+ func Member(name, member string) SetMember

+ type SortedSet struct

+ func Sorted(name string, scores []Scored) SortedSet

+ type Value struct

+ func Integer(name string, value int) Value

+ func String(name, value string) Value

+ func Time(name string, value time.Time) Value

Mar 13, 2022

Changes in this version

+ func GetScores(s []Scored) []float64

type Database

+ RemSortedByScore func(key string, begin, end float64) error

type NoDatabase

+ func (NoDatabase) RemSortedByScore(_ string, _, _ float64) error

type Redis

+ func (r *Redis) RemSortedByScore(key string, begin, end float64) error

Feb 14, 2022

Changes in this version

type Database

+ GetSortedByScore func(key string, begin, end float32) ([]Scored, error)

type NoDatabase

+ func (NoDatabase) GetSortedByScore(_ string, _, _ float32) ([]Scored, error)

type Redis

+ func (r *Redis) GetSortedByScore(key string, begin, end float32) ([]Scored, error)

Feb 1, 2022

Changes in this version

+ const ItemNeighborIndexRecall

+ const LastFitMatchingModelTime

+ const MatchingIndexRecall

+ const NumItemLabels

+ const NumTotalPosFeedbacks

+ const NumUserLabels

+ const NumValidNegFeedbacks

+ const NumValidPosFeedbacks

+ const UserNeighborIndexRecall

type Database

+ AddSorted func(key string, scores []Scored) error

type NoDatabase

+ func (NoDatabase) AddSorted(_ string, _ []Scored) error

type Redis

+ func (r *Redis) AddSorted(key string, scores []Scored) error

Dec 28, 2021

Changes in this version

+ func Key(keys ...string) string

+ func SortScores(scores []Scored)

type Database

+ AddSet func(key string, members ...string) error

+ Delete func(prefix, name string) error

+ Exists func(prefix string, names ...string) ([]int, error)

+ GetSet func(key string) ([]string, error)

+ GetSorted func(key string, begin, end int) ([]Scored, error)

+ GetSortedScore func(key, member string) (float32, error)

+ IncrSorted func(key, member string) error

+ RemSet func(key string, members ...string) error

+ RemSorted func(key, member string) error

+ SetSet func(key string, members ...string) error

+ SetSorted func(key string, scores []Scored) error

type NoDatabase

+ func (NoDatabase) AddSet(_ string, _ ...string) error

+ func (NoDatabase) Delete(_, _ string) error

+ func (NoDatabase) Exists(_ string, _ ...string) ([]int, error)

+ func (NoDatabase) GetSet(_ string) ([]string, error)

+ func (NoDatabase) GetSorted(_ string, _, _ int) ([]Scored, error)

+ func (NoDatabase) GetSortedScore(_, _ string) (float32, error)

+ func (NoDatabase) IncrSorted(_, _ string) error

+ func (NoDatabase) RemSet(_ string, _ ...string) error

+ func (NoDatabase) RemSorted(_, _ string) error

+ func (NoDatabase) SetSet(_ string, _ ...string) error

+ func (NoDatabase) SetSorted(_ string, _ []Scored) error

type Redis

+ func (r *Redis) AddSet(key string, members ...string) error

+ func (r *Redis) Delete(prefix, name string) error

+ func (r *Redis) Exists(prefix string, names ...string) ([]int, error)

+ func (r *Redis) GetSet(key string) ([]string, error)

+ func (r *Redis) GetSorted(key string, begin, end int) ([]Scored, error)

+ func (r *Redis) GetSortedScore(key, member string) (float32, error)

+ func (r *Redis) IncrSorted(key, member string) error

+ func (r *Redis) RemSet(key string, members ...string) error

+ func (r *Redis) RemSorted(key, member string) error

+ func (r *Redis) SetSet(key string, members ...string) error

+ func (r *Redis) SetSorted(key string, scores []Scored) error

Dec 11, 2021

Changes in this version

+ const HiddenItems

+ const ItemCategories

+ const LastUpdateLatestItemsTime

+ const LastUpdatePopularItemsTime

type Database

+ GetCategoryScores func(prefix, name, category string, begin, end int) ([]Scored, error)

+ PopScores func(prefix, name string, n int) error

+ SetCategoryScores func(prefix, name, category string, items []Scored) error

type NoDatabase

+ func (NoDatabase) GetCategoryScores(_, _, _ string, _, _ int) ([]Scored, error)

+ func (NoDatabase) PopScores(_, _ string, _ int) error

+ func (NoDatabase) SetCategoryScores(_, _, _ string, _ []Scored) error

type Redis

+ func (r *Redis) GetCategoryScores(prefix, name, category string, begin, end int) ([]Scored, error)

+ func (r *Redis) PopScores(prefix, name string, n int) error

+ func (r *Redis) SetCategoryScores(prefix, name, category string, items []Scored) error

Nov 6, 2021

Changes in this version

+ const OfflineRecommend

Oct 16, 2021

Changes in this version

+ var AppendScoresSeconds = promauto.NewHistogram(prometheus.HistogramOpts{ ... })

+ var AppendScoresTimes = promauto.NewCounter(prometheus.CounterOpts{ ... })

+ var ClearScoresSeconds = promauto.NewHistogram(prometheus.HistogramOpts{ ... })

+ var ClearScoresTimes = promauto.NewCounter(prometheus.CounterOpts{ ... })

+ var GetScoresSeconds = promauto.NewHistogram(prometheus.HistogramOpts{ ... })

+ var GetScoresTimes = promauto.NewCounter(prometheus.CounterOpts{ ... })

+ var SetScoresSeconds = promauto.NewHistogram(prometheus.HistogramOpts{ ... })

+ var SetScoresTimes = promauto.NewCounter(prometheus.CounterOpts{ ... })

type Database

+ AppendScores func(prefix, name string, items ...Scored) error

+ ClearScores func(prefix, name string) error

type NoDatabase

+ func (NoDatabase) AppendScores(_, _ string, _ ...Scored) error

+ func (NoDatabase) ClearScores(_, _ string) error

type Redis

+ func (r *Redis) AppendScores(prefix, name string, items ...Scored) error

+ func (r *Redis) ClearScores(prefix, name string) error

Sep 26, 2021

Changes in this version

+ const DataImported

+ const LastModifyItemTime

+ const LastModifyUserTime

+ const LastUpdateUserRecommendTime

Sep 4, 2021

Changes in this version

+ const CTRRecommend

+ const CollaborativeRecommend

+ const ItemNeighbors

+ const LastUpdateItemNeighborsTime

+ const LastUpdateUserNeighborsTime

+ const UserNeighbors

+ type Scored struct

+ Id string

+ Score float32

Jun 5, 2021

Changes in this version

+ const GlobalMeta

+ const IgnoreItems

+ const LastActiveTime

+ const LastFitRankingModelTime

+ const LastRankingModelVersion

+ const LastUpdateLatestTime

+ const LastUpdateNeighborTime

+ const LastUpdatePopularTime

+ const LastUpdateRecommendTime

+ const LatestItems

+ const NumInserted

+ const NumItems

+ const NumPositiveFeedback

+ const NumUsers

+ const PopularItems

+ const RecommendItems

+ const SimilarItems

+ const SubscribeItems

+ var ErrNoDatabase = fmt.Errorf("no database specified")

+ var ErrObjectNotExist = fmt.Errorf("object not exists")

+ func RemoveScores(items []ScoredItem) []string

+ type Database interface

+ AppendList func(prefix, name string, items ...string) error

+ ClearList func(prefix, name string) error

+ Close func() error

+ GetInt func(prefix, name string) (int, error)

+ GetList func(prefix, name string) ([]string, error)

+ GetScores func(prefix, name string, begin int, end int) ([]ScoredItem, error)

+ GetString func(prefix, name string) (string, error)

+ GetTime func(prefix, name string) (time.Time, error)

+ IncrInt func(prefix, name string) error

+ SetInt func(prefix, name string, val int) error

+ SetScores func(prefix, name string, items []ScoredItem) error

+ SetString func(prefix, name string, val string) error

+ SetTime func(prefix, name string, val time.Time) error

+ func Open(path string) (Database, error)

+ type NoDatabase struct

+ func (NoDatabase) AppendList(prefix, name string, items ...string) error

+ func (NoDatabase) ClearList(prefix, name string) error

+ func (NoDatabase) Close() error

+ func (NoDatabase) GetInt(prefix, name string) (int, error)

+ func (NoDatabase) GetList(prefix, name string) ([]string, error)

+ func (NoDatabase) GetScores(prefix, name string, begin int, end int) ([]ScoredItem, error)

+ func (NoDatabase) GetString(prefix, name string) (string, error)

+ func (NoDatabase) GetTime(prefix, name string) (time.Time, error)

+ func (NoDatabase) IncrInt(prefix, name string) error

+ func (NoDatabase) SetInt(prefix, name string, val int) error

+ func (NoDatabase) SetScores(prefix, name string, items []ScoredItem) error

+ func (NoDatabase) SetString(prefix, name string, val string) error

+ func (NoDatabase) SetTime(prefix, name string, val time.Time) error

+ type Redis struct

+ func (r *Redis) AppendList(prefix, name string, items ...string) error

+ func (r *Redis) ClearList(prefix, name string) error

+ func (r *Redis) Close() error

+ func (r *Redis) GetInt(prefix, name string) (int, error)

+ func (r *Redis) GetList(prefix, name string) ([]string, error)

+ func (r *Redis) GetScores(prefix, name string, begin, end int) ([]ScoredItem, error)

+ func (r *Redis) GetString(prefix, name string) (string, error)

+ func (r *Redis) GetTime(prefix, name string) (time.Time, error)

+ func (r *Redis) IncrInt(prefix, name string) error

+ func (r *Redis) SetInt(prefix, name string, val int) error

+ func (r *Redis) SetScores(prefix, name string, items []ScoredItem) error

+ func (r *Redis) SetString(prefix, name string, val string) error

+ func (r *Redis) SetTime(prefix, name string, val time.Time) error

+ type ScoredItem struct

+ ItemId string

+ Score float32

+ func CreateScoredItems(itemIds []string, scores []float32) []ScoredItem