Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

master

package

Go to main page

Versions in this module

v0

v0.5.4

Feb 2, 2026

v0.5.3

Jan 31, 2026

v0.5.2

Jan 17, 2026

v0.5.1

Dec 20, 2025

v0.5.0

Dec 15, 2025

Changes in this version

+ const EOF

+ const FeedbackStream

+ const ItemStream

+ const LabelData

+ const LabelFeedbackType

+ const LabelStep

+ const UserStream

+ var ActiveItemsTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var ActiveUsersTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var CacheReclaimedTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var CacheScannedSeconds = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var CacheScannedTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var CollaborativeFilteringFitSeconds = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var CollaborativeFilteringNDCG10 = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var CollaborativeFilteringPrecision10 = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var CollaborativeFilteringRecall10 = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var CollaborativeFilteringSearchPrecision10 = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var CollaborativeFilteringSearchSeconds = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var FeedbacksTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var FindItemNeighborsSecondsVec = promauto.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ var FindItemNeighborsTotalSeconds = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var FindUserNeighborsSecondsVec = promauto.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ var FindUserNeighborsTotalSeconds = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var ImplicitFeedbacksTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var InactiveItemsTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var InactiveUsersTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var ItemLabelsTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var ItemsTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var LoadDatasetStepSecondsVec = promauto.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ var LoadDatasetTotalSeconds = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var MemoryInUseBytesVec = promauto.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ var NegativeFeedbackTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var PositiveFeedbacksTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var RankingAUC = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var RankingFitSeconds = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var RankingPrecision = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var RankingRecall = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var RankingSearchPrecision = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var RankingSearchSeconds = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var UpdateItemNeighborsTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var UpdateUserNeighborsTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var UserLabelsTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ var UsersTotal = promauto.NewGauge(prometheus.GaugeOpts{ ... })

+ type Datasets struct

+ type DetailedFeedback struct

+ Comment string

+ FeedbackType string

+ Item data.Item

+ Timestamp time.Time

+ UserId string

+ Value float64

+ type DumpStats struct

+ Duration time.Duration

+ Feedback int

+ Items int

+ Users int

+ type Master struct

+ func NewMaster(cfg *config.Config, cacheFolder string, standalone bool) *Master

+ func (m *Master) CreateWebService()

+ func (m *Master) GetItem(score cache.Score) (any, error)

+ func (m *Master) GetMeta(ctx context.Context, nodeInfo *protocol.NodeInfo) (*protocol.Meta, error)

+ func (m *Master) GetUser(score cache.Score) (any, error)

+ func (m *Master) LoadDataFromDatabase(ctx context.Context, database data.Database, ...) (ctrDataset *ctr.Dataset, dataSet *dataset.Dataset, err error)

+ func (m *Master) LoginFilter(req *restful.Request, resp *restful.Response, chain *restful.FilterChain)

+ func (m *Master) PushProgress(_ context.Context, in *protocol.PushProgressRequest) (*protocol.PushProgressResponse, error)

+ func (m *Master) Restore(r io.ReadCloser) (stats DumpStats, err error)

+ func (m *Master) RunTasksLoop()

+ func (m *Master) Serve()

+ func (m *Master) Shutdown()

+ func (m *Master) StartHttpServer()

+ type OnlineEvaluator struct

+ PositiveFeedback map[string]map[int32]mapset.Set[int32]

+ PositiveTypes []expression.FeedbackTypeExpression

+ ReadFeedback []map[int32]mapset.Set[int32]

+ ReadTypes []expression.FeedbackTypeExpression

+ WindowEnd time.Time

+ WindowSize int

+ func NewOnlineEvaluator(positiveTypes, readTypes []expression.FeedbackTypeExpression) *OnlineEvaluator

+ func (evaluator *OnlineEvaluator) Add(feedbackType string, value float64, userIndex int32, itemIndex int32, ...)

+ func (evaluator *OnlineEvaluator) Evaluate() []cache.TimeSeriesPoint

+ type ScoreUser struct

+ Score float64

+ type ScoredItem struct

+ Score float64

+ type SinglePageAppFileSystem struct

+ func (fs *SinglePageAppFileSystem) Open(name string) (http.File, error)

+ type Status struct

+ BinaryVersion string

+ LatestItemsUpdateTime time.Time

+ MatchingModelFitTime time.Time

+ MatchingModelScore cf.Score

+ NumItemLabels int

+ NumItems int

+ NumServers int

+ NumTotalPosFeedback int

+ NumUserLabels int

+ NumUsers int

+ NumValidNegFeedback int

+ NumValidPosFeedback int

+ NumWorkers int

+ PopularItemsUpdateTime time.Time

+ RankingModelFitTime time.Time

+ RankingModelScore ctr.Score

+ type User struct

+ LastActiveTime time.Time

+ LastUpdateTime time.Time

+ type UserInfo struct

+ AuthType string

+ Email string

+ FamilyName string

+ GivenName string

+ MiddleName string

+ Name string

+ NickName string

+ Picture string

+ UpdatedAt string

+ Verified bool

+ type UserIterator struct

+ Cursor string

+ Users []User

v0.5.0-rc

Nov 22, 2025

v0.5.0-alpha.8

Nov 15, 2025

v0.5.0-alpha.7

Nov 2, 2025

v0.5.0-alpha.6

Sep 21, 2025

v0.5.0-alpha.5

Aug 25, 2025

v0.5.0-alpha.4

Aug 15, 2025