data

Jun 13, 2026

Changes in this version

type Database

+ Reconcile func(config.SearchConfig) error

+ SearchItems func(ctx context.Context, query string, n int) ([]ScoredItem, error)

type MongoDB

+ func (db *MongoDB) Reconcile(searchConfig config.SearchConfig) error

+ func (db *MongoDB) SearchItems(ctx context.Context, query string, n int) ([]ScoredItem, error)

type NoDatabase

+ func (NoDatabase) Reconcile(_ config.SearchConfig) error

+ func (NoDatabase) SearchItems(_ context.Context, _ string, _ int) ([]ScoredItem, error)

type ProxyClient

+ func (p *ProxyClient) Reconcile(searchConfig config.SearchConfig) error

+ func (p ProxyClient) SearchItems(ctx context.Context, query string, n int) ([]ScoredItem, error)

type ProxyServer

+ func (p *ProxyServer) Reconcile(_ context.Context, in *protocol.ReconcileRequest) (*protocol.ReconcileResponse, error)

+ func (p *ProxyServer) SearchItems(ctx context.Context, in *protocol.SearchItemsRequest) (*protocol.SearchItemsResponse, error)

type SQLDatabase

+ func (d *SQLDatabase) Reconcile(searchConfig config.SearchConfig) error

+ func (d *SQLDatabase) SearchItems(ctx context.Context, query string, n int) ([]ScoredItem, error)

+ type ScoredItem struct

+ Score float64

Apr 15, 2026

Changes in this version

+ type GetOptions struct

+ After *time.Time

+ Categories []string

+ ReturnId bool

+ SkipHidden bool

Dec 15, 2025

Changes in this version

+ var ErrItemNotExist = errors.NotFoundf("item")

+ var ErrNoDatabase = errors.NotAssignedf("database")

+ var ErrUserNotExist = errors.NotFoundf("user")

+ func FeedbackTypeExpressionToMongo(e expression.FeedbackTypeExpression) bson.M

+ func FeedbackTypeExpressionToSQL(db *gorm.DB, e expression.FeedbackTypeExpression) *gorm.DB

+ func Register(prefixes []string, creator Creator)

+ func SortFeedbacks(feedback []Feedback)

+ func ValidateLabels(o any) error

+ type ClickHouseItem struct

+ Version time.Time

+ func NewClickHouseItem(item Item) (clickHouseItem ClickHouseItem)

+ type ClickhouseUser struct

+ Version time.Time

+ func NewClickhouseUser(user User) (clickhouseUser ClickhouseUser)

+ type Creator func(path, tablePrefix string, opts ...storage.Option) (Database, error)

+ type Database interface

+ BatchGetItems func(ctx context.Context, itemIds []string) ([]Item, error)

+ BatchInsertFeedback func(ctx context.Context, feedback []Feedback, ...) error

+ BatchInsertItems func(ctx context.Context, items []Item) error

+ BatchInsertUsers func(ctx context.Context, users []User) error

+ Close func() error

+ CountFeedback func(ctx context.Context) (int, error)

+ CountItems func(ctx context.Context) (int, error)

+ CountUsers func(ctx context.Context) (int, error)

+ DeleteItem func(ctx context.Context, itemId string) error

+ DeleteUser func(ctx context.Context, userId string) error

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

+ GetFeedback func(ctx context.Context, cursor string, n int, beginTime, endTime *time.Time, ...) (string, []Feedback, error)

+ GetFeedbackStream func(ctx context.Context, batchSize int, options ...ScanOption) (chan []Feedback, chan error)

+ GetItem func(ctx context.Context, itemId string) (Item, error)

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

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

+ GetItems func(ctx context.Context, cursor string, n int, beginTime *time.Time) (string, []Item, error)

+ GetLatestItems func(ctx context.Context, n int, categories []string) ([]Item, error)

+ GetUser func(ctx context.Context, userId string) (User, error)

+ GetUserFeedback func(ctx context.Context, userId string, endTime *time.Time, ...) ([]Feedback, error)

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

+ GetUserStream func(ctx context.Context, batchSize int) (chan []User, chan error)

+ GetUsers func(ctx context.Context, cursor string, n int) (string, []User, error)

+ Init func() error

+ ModifyItem func(ctx context.Context, itemId string, patch ItemPatch) error

+ ModifyUser func(ctx context.Context, userId string, patch UserPatch) error

+ Optimize func() error

+ Ping func() error

+ Purge func() error

+ func Open(path, tablePrefix string, opts ...storage.Option) (Database, error)

+ type Feedback struct

+ Comment string

+ Timestamp time.Time

+ Updated time.Time

+ Value float64

+ type FeedbackKey struct

+ FeedbackType string

+ ItemId string

+ UserId string

+ type Item struct

+ Categories []string

+ Comment string

+ IsHidden bool

+ ItemId string

+ Labels any

+ Timestamp time.Time

+ type ItemFeedback Feedback

+ type ItemPatch struct

+ Categories []string

+ Comment *string

+ IsHidden *bool

+ Labels any

+ Timestamp *time.Time

+ type MongoDB struct

+ func (db *MongoDB) BatchGetItems(ctx context.Context, itemIds []string) ([]Item, error)

+ func (db *MongoDB) BatchInsertFeedback(ctx context.Context, feedback []Feedback, ...) error

+ func (db *MongoDB) BatchInsertItems(ctx context.Context, items []Item) error

+ func (db *MongoDB) BatchInsertUsers(ctx context.Context, users []User) error

+ func (db *MongoDB) Close() error

+ func (db *MongoDB) CountFeedback(ctx context.Context) (int, error)

+ func (db *MongoDB) CountItems(ctx context.Context) (int, error)

+ func (db *MongoDB) CountUsers(ctx context.Context) (int, error)

+ func (db *MongoDB) DeleteItem(ctx context.Context, itemId string) error

+ func (db *MongoDB) DeleteUser(ctx context.Context, userId string) error

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

+ func (db *MongoDB) GetFeedback(ctx context.Context, cursor string, n int, beginTime, endTime *time.Time, ...) (string, []Feedback, error)

+ func (db *MongoDB) GetFeedbackStream(ctx context.Context, batchSize int, scanOptions ...ScanOption) (chan []Feedback, chan error)

+ func (db *MongoDB) GetItem(ctx context.Context, itemId string) (item Item, err error)

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

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

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

+ func (db *MongoDB) GetLatestItems(ctx context.Context, n int, categories []string) ([]Item, error)

+ func (db *MongoDB) GetUser(ctx context.Context, userId string) (user User, err error)

+ func (db *MongoDB) GetUserFeedback(ctx context.Context, userId string, endTime *time.Time, ...) ([]Feedback, error)

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

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

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

+ func (db *MongoDB) Init() error

+ func (db *MongoDB) ModifyItem(ctx context.Context, itemId string, patch ItemPatch) error

+ func (db *MongoDB) ModifyUser(ctx context.Context, userId string, patch UserPatch) error

+ func (db *MongoDB) Optimize() error

+ func (db *MongoDB) Ping() error

+ func (db *MongoDB) Purge() error

+ type NoDatabase struct

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

+ func (NoDatabase) BatchInsertFeedback(_ context.Context, _ []Feedback, _, _, _ bool) error

+ func (NoDatabase) BatchInsertItems(_ context.Context, _ []Item) error

+ func (NoDatabase) BatchInsertUsers(_ context.Context, _ []User) error

+ func (NoDatabase) Close() error

+ func (NoDatabase) DeleteItem(_ context.Context, _ string) error

+ func (NoDatabase) DeleteUser(_ context.Context, _ string) error

+ func (NoDatabase) DeleteUserItemFeedback(_ context.Context, _, _ string, _ ...string) (int, error)

+ func (NoDatabase) GetFeedback(_ context.Context, _ string, _ int, _, _ *time.Time, _ ...string) (string, []Feedback, error)

+ func (NoDatabase) GetFeedbackStream(_ context.Context, _ int, _ ...ScanOption) (chan []Feedback, chan error)

+ func (NoDatabase) GetItem(_ context.Context, _ string) (Item, error)

+ func (NoDatabase) GetItemFeedback(_ context.Context, _ string, _ ...string) ([]Feedback, error)

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

+ func (NoDatabase) GetItems(_ context.Context, _ string, _ int, _ *time.Time) (string, []Item, error)

+ func (NoDatabase) GetLatestItems(_ context.Context, _ int, _ []string) ([]Item, error)

+ func (NoDatabase) GetUser(_ context.Context, _ string) (User, error)

+ func (NoDatabase) GetUserFeedback(context.Context, string, *time.Time, ...expression.FeedbackTypeExpression) ([]Feedback, error)

+ func (NoDatabase) GetUserItemFeedback(_ context.Context, _, _ string, _ ...string) ([]Feedback, error)

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

+ func (NoDatabase) GetUsers(_ context.Context, _ string, _ int) (string, []User, error)

+ func (NoDatabase) Init() error

+ func (NoDatabase) Optimize() error

+ func (NoDatabase) Ping() error

+ func (NoDatabase) Purge() error

+ func (d NoDatabase) CountFeedback(_ context.Context) (int, error)

+ func (d NoDatabase) CountItems(_ context.Context) (int, error)

+ func (d NoDatabase) CountUsers(_ context.Context) (int, error)

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

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

+ type ProxyClient struct

+ func NewProxyClient(conn *grpc.ClientConn) *ProxyClient

+ func (p ProxyClient) BatchGetItems(ctx context.Context, itemIds []string) ([]Item, error)

+ func (p ProxyClient) BatchInsertFeedback(ctx context.Context, feedback []Feedback, ...) error

+ func (p ProxyClient) BatchInsertItems(ctx context.Context, items []Item) error

+ func (p ProxyClient) BatchInsertUsers(ctx context.Context, users []User) error

+ func (p ProxyClient) Close() error

+ func (p ProxyClient) CountFeedback(ctx context.Context) (int, error)

+ func (p ProxyClient) CountItems(ctx context.Context) (int, error)

+ func (p ProxyClient) CountUsers(ctx context.Context) (int, error)

+ func (p ProxyClient) DeleteItem(ctx context.Context, itemId string) error

+ func (p ProxyClient) DeleteUser(ctx context.Context, userId string) error

+ func (p ProxyClient) DeleteUserItemFeedback(ctx context.Context, userId, itemId string, feedbackTypes ...string) (int, error)

+ func (p ProxyClient) GetFeedback(ctx context.Context, cursor string, n int, beginTime, endTime *time.Time, ...) (string, []Feedback, error)

+ func (p ProxyClient) GetFeedbackStream(ctx context.Context, batchSize int, options ...ScanOption) (chan []Feedback, chan error)

+ func (p ProxyClient) GetItem(ctx context.Context, itemId string) (Item, error)

+ func (p ProxyClient) GetItemFeedback(ctx context.Context, itemId string, feedbackTypes ...string) ([]Feedback, error)

+ func (p ProxyClient) GetItemStream(ctx context.Context, batchSize int, timeLimit *time.Time) (chan []Item, chan error)

+ func (p ProxyClient) GetItems(ctx context.Context, cursor string, n int, beginTime *time.Time) (string, []Item, error)

+ func (p ProxyClient) GetLatestItems(ctx context.Context, n int, categories []string) ([]Item, error)

+ func (p ProxyClient) GetUser(ctx context.Context, userId string) (User, error)

+ func (p ProxyClient) GetUserFeedback(ctx context.Context, userId string, endTime *time.Time, ...) ([]Feedback, error)

+ func (p ProxyClient) GetUserItemFeedback(ctx context.Context, userId, itemId string, feedbackTypes ...string) ([]Feedback, error)

+ func (p ProxyClient) GetUserStream(ctx context.Context, batchSize int) (chan []User, chan error)

+ func (p ProxyClient) GetUsers(ctx context.Context, cursor string, n int) (string, []User, error)

+ func (p ProxyClient) Init() error

+ func (p ProxyClient) ModifyItem(ctx context.Context, itemId string, patch ItemPatch) error

+ func (p ProxyClient) ModifyUser(ctx context.Context, userId string, patch UserPatch) error

+ func (p ProxyClient) Optimize() error

+ func (p ProxyClient) Ping() error

+ func (p ProxyClient) Purge() error

+ type ProxyServer struct

+ func NewProxyServer(database Database) *ProxyServer

+ func (p *ProxyServer) BatchGetItems(ctx context.Context, in *protocol.BatchGetItemsRequest) (*protocol.BatchGetItemsResponse, error)

+ func (p *ProxyServer) BatchInsertFeedback(ctx context.Context, in *protocol.BatchInsertFeedbackRequest) (*protocol.BatchInsertFeedbackResponse, error)

+ func (p *ProxyServer) BatchInsertItems(ctx context.Context, in *protocol.BatchInsertItemsRequest) (*protocol.BatchInsertItemsResponse, error)

+ func (p *ProxyServer) BatchInsertUsers(ctx context.Context, in *protocol.BatchInsertUsersRequest) (*protocol.BatchInsertUsersResponse, error)

+ func (p *ProxyServer) CountFeedback(ctx context.Context, in *protocol.CountFeedbackRequest) (*protocol.CountFeedbackResponse, error)

+ func (p *ProxyServer) CountItems(ctx context.Context, in *protocol.CountItemsRequest) (*protocol.CountItemsResponse, error)

+ func (p *ProxyServer) CountUsers(ctx context.Context, in *protocol.CountUsersRequest) (*protocol.CountUsersResponse, error)

+ func (p *ProxyServer) DeleteItem(ctx context.Context, in *protocol.DeleteItemRequest) (*protocol.DeleteItemResponse, error)

+ func (p *ProxyServer) DeleteUser(ctx context.Context, in *protocol.DeleteUserRequest) (*protocol.DeleteUserResponse, error)

+ func (p *ProxyServer) DeleteUserItemFeedback(ctx context.Context, in *protocol.DeleteUserItemFeedbackRequest) (*protocol.DeleteUserItemFeedbackResponse, error)

+ func (p *ProxyServer) GetFeedback(ctx context.Context, in *protocol.GetFeedbackRequest) (*protocol.GetFeedbackResponse, error)

+ func (p *ProxyServer) GetFeedbackStream(in *protocol.GetFeedbackStreamRequest, ...) error

+ func (p *ProxyServer) GetItem(ctx context.Context, in *protocol.GetItemRequest) (*protocol.GetItemResponse, error)

+ func (p *ProxyServer) GetItemFeedback(ctx context.Context, in *protocol.GetItemFeedbackRequest) (*protocol.GetFeedbackResponse, error)

+ func (p *ProxyServer) GetItemStream(in *protocol.GetItemStreamRequest, ...) error

+ func (p *ProxyServer) GetItems(ctx context.Context, in *protocol.GetItemsRequest) (*protocol.GetItemsResponse, error)

+ func (p *ProxyServer) GetLatestItems(ctx context.Context, in *protocol.GetLatestItemsRequest) (*protocol.GetLatestItemsResponse, error)

+ func (p *ProxyServer) GetUser(ctx context.Context, in *protocol.GetUserRequest) (*protocol.GetUserResponse, error)

+ func (p *ProxyServer) GetUserFeedback(ctx context.Context, in *protocol.GetUserFeedbackRequest) (*protocol.GetFeedbackResponse, error)

+ func (p *ProxyServer) GetUserItemFeedback(ctx context.Context, in *protocol.GetUserItemFeedbackRequest) (*protocol.GetFeedbackResponse, error)

+ func (p *ProxyServer) GetUserStream(in *protocol.GetUserStreamRequest, ...) error

+ func (p *ProxyServer) GetUsers(ctx context.Context, in *protocol.GetUsersRequest) (*protocol.GetUsersResponse, error)

+ func (p *ProxyServer) ModifyItem(ctx context.Context, in *protocol.ModifyItemRequest) (*protocol.ModifyItemResponse, error)

+ func (p *ProxyServer) ModifyUser(ctx context.Context, in *protocol.ModifyUserRequest) (*protocol.ModifyUserResponse, error)

+ func (p *ProxyServer) Ping(_ context.Context, _ *protocol.PingRequest) (*protocol.PingResponse, error)

+ func (p *ProxyServer) Serve(lis net.Listener) error

+ func (p *ProxyServer) Stop()

+ type SQLDatabase struct

+ func (d *SQLDatabase) BatchGetItems(ctx context.Context, itemIds []string) ([]Item, error)

+ func (d *SQLDatabase) BatchInsertFeedback(ctx context.Context, feedback []Feedback, ...) error

+ func (d *SQLDatabase) BatchInsertItems(ctx context.Context, items []Item) error

+ func (d *SQLDatabase) BatchInsertUsers(ctx context.Context, users []User) error

+ func (d *SQLDatabase) Close() error

+ func (d *SQLDatabase) CountFeedback(ctx context.Context) (int, error)

+ func (d *SQLDatabase) CountItems(ctx context.Context) (int, error)

+ func (d *SQLDatabase) CountUsers(ctx context.Context) (int, error)

+ func (d *SQLDatabase) DeleteItem(ctx context.Context, itemId string) error

+ func (d *SQLDatabase) DeleteUser(ctx context.Context, userId string) error

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

+ func (d *SQLDatabase) GetFeedback(ctx context.Context, cursor string, n int, beginTime, endTime *time.Time, ...) (string, []Feedback, error)

+ func (d *SQLDatabase) GetFeedbackStream(ctx context.Context, batchSize int, scanOptions ...ScanOption) (chan []Feedback, chan error)

+ func (d *SQLDatabase) GetItem(ctx context.Context, itemId string) (Item, error)

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

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

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

+ func (d *SQLDatabase) GetLatestItems(ctx context.Context, n int, categories []string) ([]Item, error)

+ func (d *SQLDatabase) GetUser(ctx context.Context, userId string) (User, error)

+ func (d *SQLDatabase) GetUserFeedback(ctx context.Context, userId string, endTime *time.Time, ...) ([]Feedback, error)

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

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

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

+ func (d *SQLDatabase) Init() error

+ func (d *SQLDatabase) ModifyItem(ctx context.Context, itemId string, patch ItemPatch) error

+ func (d *SQLDatabase) ModifyUser(ctx context.Context, userId string, patch UserPatch) error

+ func (d *SQLDatabase) Optimize() error

+ func (d *SQLDatabase) Ping() error

+ func (d *SQLDatabase) Purge() error

+ type SQLDriver int

+ const ClickHouse

+ const MySQL

+ const Postgres

+ const SQLite

+ type SQLItem struct

+ Categories string

+ Comment string

+ IsHidden bool

+ ItemId string

+ Labels string

+ Timestamp time.Time

+ func NewSQLItem(item Item) (sqlItem SQLItem)

+ type SQLUser struct

+ Comment string

+ Labels string

+ UserId string

+ func NewSQLUser(user User) (sqlUser SQLUser)

+ type ScanOption func(options *ScanOptions)

+ func WithBeginItemId(itemId string) ScanOption

+ func WithBeginTime(t time.Time) ScanOption

+ func WithBeginUserId(userId string) ScanOption

+ func WithEndItemId(itemId string) ScanOption

+ func WithEndTime(t time.Time) ScanOption

+ func WithEndUserId(userId string) ScanOption

+ func WithFeedbackTypes(feedbackTypes ...expression.FeedbackTypeExpression) ScanOption

+ func WithOrderByItemId() ScanOption

+ type ScanOptions struct

+ BeginItemId *string

+ BeginTime *time.Time

+ BeginUserId *string

+ EndItemId *string

+ EndTime *time.Time

+ EndUserId *string

+ FeedbackTypes []expression.FeedbackTypeExpression

+ OrderByItemId bool

+ func NewScanOptions(opts ...ScanOption) ScanOptions

+ type User struct

+ Comment string

+ Labels any

+ UserId string

+ type UserFeedback Feedback

+ type UserPatch struct

+ Comment *string

+ Labels any