data

Nov 21, 2022

Changes in this version

type Database

+ Ping func() error

type MongoDB

+ func (db *MongoDB) Ping() error

type NoDatabase

+ func (NoDatabase) Ping() error

type Redis

+ func (r *Redis) Ping() error

type SQLDatabase

+ func (d *SQLDatabase) Ping() error

Sep 13, 2022

Changes in this version

type Database

+ Purge func() error

type MongoDB

+ func (db *MongoDB) Purge() error

type NoDatabase

+ func (NoDatabase) Purge() error

type Redis

+ func (r *Redis) Purge() error

type SQLDatabase

+ func (d *SQLDatabase) Purge() error

Jul 9, 2022

Changes in this version

+ type ClickHouseFeedback struct

+ Version time.Time

+ func (*ClickHouseFeedback) TableName() string

+ type ClickHouseItem struct

+ Version time.Time

+ func NewClickHouseItem(item Item) (clickHouseItem ClickHouseItem)

+ func (*ClickHouseItem) TableName() string

+ type ClickhouseUser struct

+ Version time.Time

+ func NewClickhouseUser(user User) (clickhouseUser ClickhouseUser)

+ func (*ClickhouseUser) TableName() string

type SQLDriver

+ const Oracle

+ type SQLItem struct

+ Categories string

+ Comment string

+ IsHidden bool

+ ItemId string

+ Labels string

+ Timestamp time.Time

+ func NewSQLItem(item Item) (sqlItem SQLItem)

+ func (*SQLItem) TableName() string

+ type SQLUser struct

+ Comment string

+ Labels string

+ Subscribe string

+ UserId string

+ func NewSQLUser(user User) (sqlUser SQLUser)

+ func (*SQLUser) TableName() string

Jun 11, 2022

Changes in this version

type SQLDriver

+ const SQLite

May 25, 2022

Changes in this version

type FeedbackKey

+ func (*FeedbackKey) TableName() string

type Item

+ func (*Item) TableName() string

type User

+ func (*User) TableName() string

Apr 10, 2022

Changes in this version

type Database

+ BatchGetItems func(itemIds []string) ([]Item, error)

type MongoDB

+ func (db *MongoDB) BatchGetItems(itemIds []string) ([]Item, error)

type NoDatabase

+ func (NoDatabase) BatchGetItems(_ []string) ([]Item, error)

type Redis

+ func (r *Redis) BatchGetItems(itemIds []string) ([]Item, error)

type SQLDatabase

+ func (d *SQLDatabase) BatchGetItems(itemIds []string) ([]Item, error)

Dec 28, 2021

Changes in this version

+ func SortFeedbacks(feedback []Feedback)

Dec 11, 2021

Changes in this version

type Item

+ Categories []string

+ IsHidden bool

type ItemPatch

+ Categories []string

+ IsHidden *bool

Nov 6, 2021

Changes in this version

type Database

+ ModifyItem func(itemId string, patch ItemPatch) error

+ ModifyUser func(userId string, patch UserPatch) error

+ type ItemPatch struct

+ Comment *string

+ Labels []string

+ Timestamp *time.Time

type MongoDB

+ func (db *MongoDB) ModifyItem(itemId string, patch ItemPatch) error

+ func (db *MongoDB) ModifyUser(userId string, patch UserPatch) error

type NoDatabase

+ func (d NoDatabase) ModifyItem(_ string, _ ItemPatch) error

+ func (d NoDatabase) ModifyUser(_ string, _ UserPatch) error

type Redis

+ func (r *Redis) ModifyItem(itemId string, patch ItemPatch) error

+ func (r *Redis) ModifyUser(userId string, patch UserPatch) error

type SQLDatabase

+ func (d *SQLDatabase) ModifyItem(itemId string, patch ItemPatch) error

+ func (d *SQLDatabase) ModifyUser(userId string, patch UserPatch) error

+ type UserPatch struct

+ Comment *string

+ Labels []string

+ Subscribe []string

Oct 16, 2021

Changes in this version

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Sep 26, 2021

Changes in this version

type Database

+ BatchInsertItems func(items []Item) error

+ BatchInsertUsers func(users []User) error

+ GetFeedbackStream func(batchSize int, timeLimit *time.Time, feedbackTypes ...string) (chan []Feedback, chan error)

+ GetItemStream func(batchSize int, timeLimit *time.Time) (chan []Item, chan error)

+ GetUserStream func(batchSize int) (chan []User, chan error)

type MongoDB

+ func (db *MongoDB) BatchInsertItems(items []Item) error

+ func (db *MongoDB) BatchInsertUsers(users []User) error

+ func (db *MongoDB) GetFeedbackStream(batchSize int, timeLimit *time.Time, feedbackTypes ...string) (chan []Feedback, chan error)

+ func (db *MongoDB) GetItemStream(batchSize int, timeLimit *time.Time) (chan []Item, chan error)

+ func (db *MongoDB) GetUserStream(batchSize int) (chan []User, chan error)

type NoDatabase

+ func (NoDatabase) BatchInsertItems(_ []Item) error

+ func (NoDatabase) BatchInsertUsers(_ []User) error

+ func (NoDatabase) GetFeedbackStream(_ int, _ *time.Time, _ ...string) (chan []Feedback, chan error)

+ func (NoDatabase) GetItemStream(_ int, _ *time.Time) (chan []Item, chan error)

+ func (NoDatabase) GetUserStream(_ int) (chan []User, chan error)

type Redis

+ func (r *Redis) BatchInsertItems(items []Item) error

+ func (r *Redis) BatchInsertUsers(users []User) error

+ func (r *Redis) GetFeedbackStream(batchSize int, timeLimit *time.Time, feedbackTypes ...string) (chan []Feedback, chan error)

+ func (r *Redis) GetItemStream(batchSize int, timeLimit *time.Time) (chan []Item, chan error)

+ func (r *Redis) GetUserStream(batchSize int) (chan []User, chan error)

type SQLDatabase

+ func (d *SQLDatabase) BatchInsertItems(items []Item) error

+ func (d *SQLDatabase) BatchInsertUsers(users []User) error

+ func (d *SQLDatabase) GetFeedbackStream(batchSize int, timeLimit *time.Time, feedbackTypes ...string) (chan []Feedback, chan error)

+ func (d *SQLDatabase) GetItemStream(batchSize int, timeLimit *time.Time) (chan []Item, chan error)

+ func (d *SQLDatabase) GetUserStream(batchSize int) (chan []User, chan error)

Aug 15, 2021

Changes in this version

type Database

+ Optimize func() error

type MongoDB

+ func (db *MongoDB) Optimize() error

type NoDatabase

+ func (NoDatabase) Optimize() error

type Redis

+ func (r *Redis) Optimize() error

type SQLDatabase

+ func (d *SQLDatabase) Optimize() error

+ type SQLDriver int

+ const ClickHouse

+ const MySQL

+ const Postgres

Jun 17, 2021

Changes in this version

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

+ var ErrUnsupported = fmt.Errorf("unsupported interface")

type Database

+ CountActiveUsers func(date time.Time) (int, error)

+ GetClickThroughRate func(date time.Time, positiveTypes []string, readType string) (float64, error)

type MongoDB

+ func (db *MongoDB) CountActiveUsers(date time.Time) (int, error)

+ func (db *MongoDB) GetClickThroughRate(date time.Time, positiveTypes []string, readType string) (float64, error)

type NoDatabase

+ func (NoDatabase) CountActiveUsers(date time.Time) (int, error)

+ func (NoDatabase) GetClickThroughRate(date time.Time, positiveTypes []string, readType string) (float64, error)

type Redis

+ func (r *Redis) CountActiveUsers(date time.Time) (int, error)

+ func (r *Redis) GetClickThroughRate(date time.Time, positiveTypes []string, readType string) (float64, error)

type SQLDatabase

+ func (d *SQLDatabase) CountActiveUsers(date time.Time) (int, error)

+ func (d *SQLDatabase) GetClickThroughRate(date time.Time, positiveTypes []string, readType string) (float64, error)

Jun 5, 2021

Changes in this version

+ var ErrItemNotExist = errors.New("item not exist")

+ var ErrUserNotExist = errors.New("user not exist")

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

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

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

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

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

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

+ var NoDatabaseError = fmt.Errorf("no database specified for datastore")

+ type Database interface

+ BatchInsertFeedback func(feedback []Feedback, insertUser, insertItem bool) error

+ BatchInsertItem func(items []Item) error

+ Close func() error

+ DeleteItem func(itemId string) error

+ DeleteUser func(userId string) error

+ DeleteUserItemFeedback func(userId, itemId string, feedbackTypes ...string) (int, error)

+ GetFeedback func(cursor string, n int, timeLimit *time.Time, feedbackTypes ...string) (string, []Feedback, error)

+ GetItem func(itemId string) (Item, error)

+ GetItemFeedback func(itemId string, feedbackTypes ...string) ([]Feedback, error)

+ GetItems func(cursor string, n int, timeLimit *time.Time) (string, []Item, error)

+ GetMeasurements func(name string, n int) ([]Measurement, error)

+ GetUser func(userId string) (User, error)

+ GetUserFeedback func(userId string, feedbackTypes ...string) ([]Feedback, error)

+ GetUserItemFeedback func(userId, itemId string, feedbackTypes ...string) ([]Feedback, error)

+ GetUsers func(cursor string, n int) (string, []User, error)

+ Init func() error

+ InsertFeedback func(feedback Feedback, insertUser, insertItem bool) error

+ InsertItem func(item Item) error

+ InsertMeasurement func(measurement Measurement) error

+ InsertUser func(user User) error

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

+ type Feedback struct

+ Comment string

+ Timestamp time.Time

+ type FeedbackKey struct

+ FeedbackType string

+ ItemId string

+ UserId string

+ type Item struct

+ Comment string

+ ItemId string

+ Labels []string

+ Timestamp time.Time

+ type Measurement struct

+ Comment string

+ Name string

+ Timestamp time.Time

+ Value float32

+ type MongoDB struct

+ func (db *MongoDB) BatchInsertFeedback(feedback []Feedback, insertUser, insertItem bool) error

+ func (db *MongoDB) BatchInsertItem(items []Item) error

+ func (db *MongoDB) Close() error

+ func (db *MongoDB) DeleteItem(itemId string) error

+ func (db *MongoDB) DeleteUser(userId string) error

+ func (db *MongoDB) DeleteUserItemFeedback(userId, itemId string, feedbackTypes ...string) (int, error)

+ func (db *MongoDB) GetFeedback(cursor string, n int, timeLimit *time.Time, feedbackTypes ...string) (string, []Feedback, error)

+ func (db *MongoDB) GetItem(itemId string) (item Item, err error)

+ func (db *MongoDB) GetItemFeedback(itemId string, feedbackTypes ...string) ([]Feedback, error)

+ func (db *MongoDB) GetItems(cursor string, n int, timeLimit *time.Time) (string, []Item, error)

+ func (db *MongoDB) GetMeasurements(name string, n int) ([]Measurement, error)

+ func (db *MongoDB) GetUser(userId string) (user User, err error)

+ func (db *MongoDB) GetUserFeedback(userId string, feedbackTypes ...string) ([]Feedback, error)

+ func (db *MongoDB) GetUserItemFeedback(userId, itemId string, feedbackTypes ...string) ([]Feedback, error)

+ func (db *MongoDB) GetUsers(cursor string, n int) (string, []User, error)

+ func (db *MongoDB) Init() error

+ func (db *MongoDB) InsertFeedback(feedback Feedback, insertUser, insertItem bool) error

+ func (db *MongoDB) InsertItem(item Item) error

+ func (db *MongoDB) InsertMeasurement(measurement Measurement) error

+ func (db *MongoDB) InsertUser(user User) error

+ type NoDatabase struct

+ func (NoDatabase) BatchInsertFeedback(feedback []Feedback, insertUser, insertItem bool) error

+ func (NoDatabase) BatchInsertItem(items []Item) error

+ func (NoDatabase) Close() error

+ func (NoDatabase) DeleteItem(itemId string) error

+ func (NoDatabase) DeleteUser(userId string) error

+ func (NoDatabase) DeleteUserItemFeedback(userId, itemId string, feedbackTypes ...string) (int, error)

+ func (NoDatabase) GetFeedback(cursor string, n int, time *time.Time, feedbackTypes ...string) (string, []Feedback, error)

+ func (NoDatabase) GetItem(itemId string) (Item, error)

+ func (NoDatabase) GetItemFeedback(itemId string, feedbackTypes ...string) ([]Feedback, error)

+ func (NoDatabase) GetItems(cursor string, n int, time *time.Time) (string, []Item, error)

+ func (NoDatabase) GetMeasurements(name string, n int) ([]Measurement, error)

+ func (NoDatabase) GetUser(userId string) (User, error)

+ func (NoDatabase) GetUserFeedback(userId string, feedbackTypes ...string) ([]Feedback, error)

+ func (NoDatabase) GetUserItemFeedback(userId, itemId string, feedbackTypes ...string) ([]Feedback, error)

+ func (NoDatabase) GetUsers(cursor string, n int) (string, []User, error)

+ func (NoDatabase) Init() error

+ func (NoDatabase) InsertFeedback(feedback Feedback, insertUser, insertItem bool) error

+ func (NoDatabase) InsertItem(item Item) error

+ func (NoDatabase) InsertMeasurement(measurement Measurement) error

+ func (NoDatabase) InsertUser(user User) error

+ type Redis struct

+ func (r *Redis) BatchInsertFeedback(feedback []Feedback, insertUser, insertItem bool) error

+ func (r *Redis) BatchInsertItem(items []Item) error

+ func (r *Redis) Close() error

+ func (r *Redis) DeleteItem(itemId string) error

+ func (r *Redis) DeleteUser(userId string) error

+ func (r *Redis) DeleteUserItemFeedback(userId, itemId string, feedbackTypes ...string) (int, error)

+ func (r *Redis) ForFeedback(ctx context.Context, ...) error

+ func (r *Redis) GetFeedback(cursor string, n int, timeLimit *time.Time, feedbackTypes ...string) (string, []Feedback, error)

+ func (r *Redis) GetItem(itemId string) (Item, error)

+ func (r *Redis) GetItemFeedback(itemId string, feedbackTypes ...string) ([]Feedback, error)

+ func (r *Redis) GetItems(cursor string, n int, timeLimit *time.Time) (string, []Item, error)

+ func (r *Redis) GetMeasurements(name string, n int) ([]Measurement, error)

+ func (r *Redis) GetUser(userId string) (User, error)

+ func (r *Redis) GetUserFeedback(userId string, feedbackTypes ...string) ([]Feedback, error)

+ func (r *Redis) GetUserItemFeedback(userId, itemId string, feedbackTypes ...string) ([]Feedback, error)

+ func (r *Redis) GetUsers(cursor string, n int) (string, []User, error)

+ func (r *Redis) Init() error

+ func (r *Redis) InsertFeedback(feedback Feedback, insertUser, insertItem bool) error

+ func (r *Redis) InsertItem(item Item) error

+ func (r *Redis) InsertMeasurement(measurement Measurement) error

+ func (r *Redis) InsertUser(user User) error

+ type SQLDatabase struct

+ func (d *SQLDatabase) BatchInsertFeedback(feedback []Feedback, insertUser, insertItem bool) error

+ func (d *SQLDatabase) BatchInsertItem(items []Item) error

+ func (d *SQLDatabase) Close() error

+ func (d *SQLDatabase) DeleteItem(itemId string) error

+ func (d *SQLDatabase) DeleteUser(userId string) error

+ func (d *SQLDatabase) DeleteUserItemFeedback(userId, itemId string, feedbackTypes ...string) (int, error)

+ func (d *SQLDatabase) GetFeedback(cursor string, n int, timeLimit *time.Time, feedbackTypes ...string) (string, []Feedback, error)

+ func (d *SQLDatabase) GetItem(itemId string) (Item, error)

+ func (d *SQLDatabase) GetItemFeedback(itemId string, feedbackTypes ...string) ([]Feedback, error)

+ func (d *SQLDatabase) GetItems(cursor string, n int, timeLimit *time.Time) (string, []Item, error)

+ func (d *SQLDatabase) GetMeasurements(name string, n int) ([]Measurement, error)

+ func (d *SQLDatabase) GetUser(userId string) (User, error)

+ func (d *SQLDatabase) GetUserFeedback(userId string, feedbackTypes ...string) ([]Feedback, error)

+ func (d *SQLDatabase) GetUserItemFeedback(userId, itemId string, feedbackTypes ...string) ([]Feedback, error)

+ func (d *SQLDatabase) GetUsers(cursor string, n int) (string, []User, error)

+ func (d *SQLDatabase) Init() error

+ func (d *SQLDatabase) InsertFeedback(feedback Feedback, insertUser, insertItem bool) error

+ func (d *SQLDatabase) InsertItem(item Item) error

+ func (d *SQLDatabase) InsertMeasurement(measurement Measurement) error

+ func (d *SQLDatabase) InsertUser(user User) error

+ type User struct

+ Comment string

+ Labels []string

+ Subscribe []string

+ UserId string