Versions in this module Expand all Collapse all v1 v1.1.0 May 5, 2026 v1.0.0 May 3, 2026 Changes in this version + const FetchIGDBGamesTaskName + const ProcessModerationTaskName + const UpdateGameInfoTaskName + const UpdateTrendingIndexTaskName + type GameFacade interface + CreateCompany func(ctx context.Context, company model.Company) (int32, error) + UpdateGameTrendingIndex func(ctx context.Context, gameID int32) error + type IGDBAPIClient interface + GetGameInfoForUpdate func(ctx context.Context, igdbID int64) (igdbapi.GameInfoForUpdate, error) + GetImageByURL func(ctx context.Context, imageURL, imageType string) (igdbapi.GetImageResp, error) + GetTopRatedGames func(ctx context.Context, platformsIDs []int64, releasedAfter time.Time, ...) ([]igdbapi.TopRatedGames, error) + type ModerationFacade interface + ProcessModeration func(ctx context.Context, gameID int32) error + type S3Client interface + Upload func(ctx context.Context, data io.ReadSeeker, contentType string, ...) (s3.UploadResult, error) + type Storage interface + CreateGame func(ctx context.Context, cgd model.CreateGameData) (id int32, err error) + CreateGenre func(ctx context.Context, g model.Genre) (int32, error) + GetCompanies func(ctx context.Context) ([]model.Company, error) + GetGameByID func(ctx context.Context, id int32) (game model.Game, err error) + GetGameIDByIGDBID func(ctx context.Context, igdbID int64) (id int32, err error) + GetGamesIDsAfterID func(ctx context.Context, lastID int32, batchSize int) ([]int32, error) + GetGenres func(ctx context.Context) ([]model.Genre, error) + GetPendingModerationGameIDs func(ctx context.Context, limit int) ([]model.ModerationIDGameID, error) + GetPlatforms func(ctx context.Context) ([]model.Platform, error) + GetTask func(ctx context.Context, name string) (model.Task, error) + RunWithTx func(ctx context.Context, f func(context.Context) error) error + SetModerationRecordsStatus func(ctx context.Context, gameIDs []int32, status model.ModerationStatus) error + UpdateGameIGDBInfo func(ctx context.Context, id int32, ug model.UpdateGameIGDBData) error + UpdateTask func(ctx context.Context, task model.Task) error + type TaskProvider struct + func New(log *zap.Logger, storage Storage, igdbClient IGDBAPIClient, s3Client S3Client, ...) *TaskProvider + func (tp *TaskProvider) DoTask(name string, ...) error + func (tp *TaskProvider) StartFetchIGDBGames() error + func (tp *TaskProvider) StartProcessModeration() error + func (tp *TaskProvider) StartUpdateGameInfo() error + func (tp *TaskProvider) StartUpdateTrendingIndex() error
Go to main page