consumers

package
v0.0.0-...-a97d171 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 5, 2021 License: GPL-3.0 Imports: 54 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Apps
	QueueApps                   rabbit.QueueName = "GDB_Apps"
	QueueAppsAchievements       rabbit.QueueName = "GDB_Apps.Achievements"
	QueueAppsItems              rabbit.QueueName = "GDB_Apps.Items"
	QueueAppsArticlesSearch     rabbit.QueueName = "GDB_Apps.Articles.Search"
	QueueAppsAchievementsSearch rabbit.QueueName = "GDB_Apps.Achievements.Search"
	QueueAppsYoutube            rabbit.QueueName = "GDB_Apps.Youtube"
	QueueAppsWishlists          rabbit.QueueName = "GDB_Apps.Wishlists"
	QueueAppsInflux             rabbit.QueueName = "GDB_Apps.Influx"
	QueueAppsDLC                rabbit.QueueName = "GDB_Apps.DLC"
	QueueAppsSameowners         rabbit.QueueName = "GDB_Apps.Sameowners"
	QueueAppsNews               rabbit.QueueName = "GDB_Apps.News"
	QueueAppsFindGroup          rabbit.QueueName = "GDB_Apps.FindGroup"
	QueueAppsReviews            rabbit.QueueName = "GDB_Apps.Reviews"
	QueueAppsTwitch             rabbit.QueueName = "GDB_Apps.Twitch"
	QueueAppsMorelike           rabbit.QueueName = "GDB_Apps.Morelike"
	QueueAppsSteamspy           rabbit.QueueName = "GDB_Apps.Steamspy"
	QueueAppsSearch             rabbit.QueueName = "GDB_Apps.Search"

	// Bundles
	QueueBundles       rabbit.QueueName = "GDB_Bundles"
	QueueBundlesSearch rabbit.QueueName = "GDB_Bundles.Search"

	// Packages
	QueuePackages       rabbit.QueueName = "GDB_Packages"
	QueuePackagesPrices rabbit.QueueName = "GDB_Packages.Prices"

	// Players
	QueuePlayers             rabbit.QueueName = "GDB_Players"
	QueuePlayersAchievements rabbit.QueueName = "GDB_Players.Achievements"
	QueuePlayersAwards       rabbit.QueueName = "GDB_Players.Awards"
	QueuePlayersBadges       rabbit.QueueName = "GDB_Players.Badges"
	QueuePlayersSearch       rabbit.QueueName = "GDB_Players.Search"
	QueuePlayersGames        rabbit.QueueName = "GDB_Players.Games"
	QueuePlayersAliases      rabbit.QueueName = "GDB_Players.Aliases"
	QueuePlayersGroups       rabbit.QueueName = "GDB_Players.Groups"
	QueuePlayersWishlist     rabbit.QueueName = "GDB_Players.Wishlist"

	// Group
	QueueGroups          rabbit.QueueName = "GDB_Groups"
	QueueGroupsSearch    rabbit.QueueName = "GDB_Groups.Search"
	QueueGroupsPrimaries rabbit.QueueName = "GDB_Groups.Primaries"

	// App players
	QueueAppPlayers    rabbit.QueueName = "GDB_App_Players"
	QueueAppPlayersTop rabbit.QueueName = "GDB_App_Players_Top"

	// Other
	QueueChanges     rabbit.QueueName = "GDB_Changes"
	QueueDelay       rabbit.QueueName = "GDB_Delay"
	QueueFailed      rabbit.QueueName = "GDB_Failed"
	QueuePlayerRanks rabbit.QueueName = "GDB_Player_Ranks"
	QueueStats       rabbit.QueueName = "GDB_Stats"
	QueueSteam       rabbit.QueueName = "GDB_Steam"
	QueueTest        rabbit.QueueName = "GDB_Test"
	QueueWebsockets  rabbit.QueueName = "GDB_Websockets"
)
View Source 
const ConsumersPerProcess = 2
View Source 
const (
	MaxDelay = time.Hour * 6
)

Variables

View Source 
var (
	ProducerChannels = map[rabbit.QueueName]*rabbit.Channel{}

	AllProducerDefinitions = []QueueDefinition{
		{Name: QueueAppPlayersTop},
		{Name: QueueAppPlayers},
		{Name: QueueAppsAchievementsSearch, /* contains filtered or unexported fields */},
		{Name: QueueAppsAchievements},
		{Name: QueueAppsArticlesSearch, /* contains filtered or unexported fields */},
		{Name: QueueAppsDLC},
		{Name: QueueAppsFindGroup},
		{Name: QueueAppsInflux},
		{Name: QueueAppsItems},
		{Name: QueueAppsMorelike},
		{Name: QueueAppsNews},
		{Name: QueueAppsReviews},
		{Name: QueueAppsSameowners},
		{Name: QueueAppsSearch, /* contains filtered or unexported fields */},
		{Name: QueueBundlesSearch, /* contains filtered or unexported fields */},
		{Name: QueueAppsSteamspy},
		{Name: QueueAppsTwitch},
		{Name: QueueAppsWishlists, /* contains filtered or unexported fields */},
		{Name: QueueAppsYoutube},
		{Name: QueueApps},
		{Name: QueueBundles},
		{Name: QueueChanges},
		{Name: QueueDelay, /* contains filtered or unexported fields */},
		{Name: QueueFailed, /* contains filtered or unexported fields */},
		{Name: QueueGroupsPrimaries, /* contains filtered or unexported fields */},
		{Name: QueueGroupsSearch, /* contains filtered or unexported fields */},
		{Name: QueueGroups},
		{Name: QueuePackagesPrices},
		{Name: QueuePackages},
		{Name: QueuePlayerRanks},
		{Name: QueuePlayersAwards},
		{Name: QueuePlayersAchievements},
		{Name: QueuePlayersAliases},
		{Name: QueuePlayersBadges},
		{Name: QueuePlayersGames},
		{Name: QueuePlayersGroups},
		{Name: QueuePlayersSearch, /* contains filtered or unexported fields */},
		{Name: QueuePlayersWishlist},
		{Name: QueuePlayers},
		{Name: QueueStats},
		{Name: QueueSteam},
		{Name: QueueTest},
		{Name: QueueWebsockets},
	}

	ConsumersDefinitions = []QueueDefinition{
		{Name: QueueAppPlayers, /* contains filtered or unexported fields */},
		{Name: QueueAppPlayersTop, /* contains filtered or unexported fields */},
		{Name: QueueApps, /* contains filtered or unexported fields */},
		{Name: QueueAppsAchievements, /* contains filtered or unexported fields */},
		{Name: QueueAppsAchievementsSearch, /* contains filtered or unexported fields */},
		{Name: QueueAppsArticlesSearch, /* contains filtered or unexported fields */},
		{Name: QueueAppsDLC, /* contains filtered or unexported fields */},
		{Name: QueueAppsFindGroup, /* contains filtered or unexported fields */},
		{Name: QueueAppsInflux, /* contains filtered or unexported fields */},
		{Name: QueueAppsItems, /* contains filtered or unexported fields */},
		{Name: QueueAppsMorelike, /* contains filtered or unexported fields */},
		{Name: QueueAppsNews, /* contains filtered or unexported fields */},
		{Name: QueueAppsReviews, /* contains filtered or unexported fields */},
		{Name: QueueAppsSameowners, /* contains filtered or unexported fields */},
		{Name: QueueAppsSearch, /* contains filtered or unexported fields */},
		{Name: QueueAppsSteamspy, /* contains filtered or unexported fields */},
		{Name: QueueAppsTwitch, /* contains filtered or unexported fields */},
		{Name: QueueAppsWishlists, /* contains filtered or unexported fields */},
		{Name: QueueAppsYoutube, /* contains filtered or unexported fields */},
		{Name: QueueBundles, /* contains filtered or unexported fields */},
		{Name: QueueBundlesSearch, /* contains filtered or unexported fields */},
		{Name: QueueChanges, /* contains filtered or unexported fields */},
		{Name: QueueDelay, /* contains filtered or unexported fields */},
		{Name: QueueFailed, /* contains filtered or unexported fields */},
		{Name: QueueGroups, /* contains filtered or unexported fields */},
		{Name: QueueGroupsPrimaries, /* contains filtered or unexported fields */},
		{Name: QueueGroupsSearch, /* contains filtered or unexported fields */},
		{Name: QueuePackages, /* contains filtered or unexported fields */},
		{Name: QueuePackagesPrices, /* contains filtered or unexported fields */},
		{Name: QueuePlayerRanks, /* contains filtered or unexported fields */},
		{Name: QueuePlayers, /* contains filtered or unexported fields */},
		{Name: QueuePlayersAchievements, /* contains filtered or unexported fields */},
		{Name: QueuePlayersAwards, /* contains filtered or unexported fields */},
		{Name: QueuePlayersAliases, /* contains filtered or unexported fields */},
		{Name: QueuePlayersBadges, /* contains filtered or unexported fields */},
		{Name: QueuePlayersGames, /* contains filtered or unexported fields */},
		{Name: QueuePlayersGroups, /* contains filtered or unexported fields */},
		{Name: QueuePlayersSearch, /* contains filtered or unexported fields */},
		{Name: QueuePlayersWishlist, /* contains filtered or unexported fields */},
		{Name: QueueStats, /* contains filtered or unexported fields */},
		{Name: QueueSteam},
		{Name: QueueTest, /* contains filtered or unexported fields */},
		{Name: QueueWebsockets},
	}

	FrontendDefinitions = []QueueDefinition{
		{Name: QueueAppPlayersTop},
		{Name: QueueAppPlayers},
		{Name: QueueAppsAchievementsSearch, /* contains filtered or unexported fields */},
		{Name: QueueAppsAchievements},
		{Name: QueueAppsArticlesSearch, /* contains filtered or unexported fields */},
		{Name: QueueAppsInflux},
		{Name: QueueAppsNews},
		{Name: QueueAppsReviews},
		{Name: QueueAppsSearch, /* contains filtered or unexported fields */},
		{Name: QueueAppsSteamspy},
		{Name: QueueAppsWishlists, /* contains filtered or unexported fields */},
		{Name: QueueAppsYoutube},
		{Name: QueueAppsSameowners},
		{Name: QueueApps},
		{Name: QueueBundles},
		{Name: QueueBundlesSearch, /* contains filtered or unexported fields */},
		{Name: QueueChanges},
		{Name: QueueDelay, /* contains filtered or unexported fields */},
		{Name: QueueFailed, /* contains filtered or unexported fields */},
		{Name: QueueGroupsPrimaries, /* contains filtered or unexported fields */},
		{Name: QueueGroupsSearch, /* contains filtered or unexported fields */},
		{Name: QueueGroups},
		{Name: QueuePackagesPrices},
		{Name: QueuePackages},
		{Name: QueuePlayerRanks},
		{Name: QueuePlayersGroups},
		{Name: QueuePlayersSearch, /* contains filtered or unexported fields */},
		{Name: QueuePlayersWishlist},
		{Name: QueuePlayers},
		{Name: QueueStats},
		{Name: QueueSteam},
		{Name: QueueTest},
		{Name: QueueWebsockets, /* contains filtered or unexported fields */},
	}

	QueueSteamDefinitions = []QueueDefinition{
		{Name: QueueApps},
		{Name: QueueChanges},
		{Name: QueueDelay, /* contains filtered or unexported fields */},
		{Name: QueuePackages},
		{Name: QueuePlayers},
		{Name: QueueSteam, /* contains filtered or unexported fields */},
	}

	QueueCronsDefinitions = []QueueDefinition{
		{Name: QueueAppPlayersTop},
		{Name: QueueAppPlayers},
		{Name: QueueAppsAchievementsSearch, /* contains filtered or unexported fields */},
		{Name: QueueAppsAchievements},
		{Name: QueueAppsInflux},
		{Name: QueueAppsNews},
		{Name: QueueAppsReviews},
		{Name: QueueAppsSearch, /* contains filtered or unexported fields */},
		{Name: QueueAppsSteamspy},
		{Name: QueueAppsWishlists, /* contains filtered or unexported fields */},
		{Name: QueueAppsYoutube},
		{Name: QueueAppsSameowners},
		{Name: QueueApps},
		{Name: QueueBundlesSearch, /* contains filtered or unexported fields */},
		{Name: QueueDelay, /* contains filtered or unexported fields */},
		{Name: QueueGroupsPrimaries, /* contains filtered or unexported fields */},
		{Name: QueueGroupsSearch, /* contains filtered or unexported fields */},
		{Name: QueueGroups},
		{Name: QueuePackages},
		{Name: QueuePlayerRanks},
		{Name: QueuePlayersGroups},
		{Name: QueuePlayersSearch, /* contains filtered or unexported fields */},
		{Name: QueuePlayers},
		{Name: QueueStats},
		{Name: QueueSteam},
		{Name: QueueWebsockets},
	}

	ChatbotDefinitions = []QueueDefinition{
		{Name: QueuePlayers},
		{Name: QueueWebsockets},
	}
)
View Source 
var ErrInQueue = errors.New("already in queue")
View Source 
var ErrIsBot = errors.New("bots can't update players")

Functions

func Init 

func Init(definitions []QueueDefinition)

func ProduceAchievementSearch 

func ProduceAchievementSearch(achievement mongo.AppAchievement, appName string, appOwners int64) (err error)

func ProduceApp 

func ProduceApp(payload AppMessage) (err error)

Producers

func ProduceAppAchievement 

func ProduceAppAchievement(appID int, appName string, appOwners int64) (err error)

func ProduceAppNews 

func ProduceAppNews(appID int) (err error)

func ProduceAppPlayers 

func ProduceAppPlayers(appIDs []int) (err error)

func ProduceAppPlayersTop 

func ProduceAppPlayersTop(appIDs []int) (err error)

func ProduceAppSearch 

func ProduceAppSearch(app *mongo.App, appID int, fields map[string]interface{}) (err error)

func ProduceAppSteamSpy 

func ProduceAppSteamSpy(appID int) (err error)

func ProduceAppsInflux 

func ProduceAppsInflux(appIDs []int) (err error)

func ProduceAppsReviews 

func ProduceAppsReviews(id int, skipMissingPlayers bool) (err error)

func ProduceAppsWishlists 

func ProduceAppsWishlists(id int) (err error)

func ProduceAppsYoutube 

func ProduceAppsYoutube(id int, name string) (err error)

func ProduceArticlesSearch 

func ProduceArticlesSearch(payload AppsArticlesSearchMessage) (err error)

func ProduceBundle 

func ProduceBundle(id int) (err error)

func ProduceBundleSearch 

func ProduceBundleSearch(bundle mongo.Bundle) (err error)

func ProduceChanges 

func ProduceChanges(payload ChangesMessage) (err error)

func ProduceDLC 

func ProduceDLC(appID int, DLCIDs []int) (err error)

func ProduceGroup 

func ProduceGroup(payload GroupMessage) (err error)

func ProduceGroupPrimaries 

func ProduceGroupPrimaries(groupID string, groupType string, prims int) (err error)

func ProduceGroupSearch 

func ProduceGroupSearch(group *mongo.Group, groupID string, groupType string) (err error)

func ProducePackage 

func ProducePackage(payload PackageMessage) (err error)

func ProducePlayer 

func ProducePlayer(payload PlayerMessage, event string) (err error)

func ProducePlayerAchievements 

func ProducePlayerAchievements(playerID int64, appID int, force bool, oldCount, oldCount100, oldCountApps int) (err error)

func ProducePlayerAlias 

func ProducePlayerAlias(id int64, removed bool) (err error)

func ProducePlayerGroup 

func ProducePlayerGroup(player mongo.Player, skipGroupUpdate bool, force bool) (err error)

func ProducePlayerRank 

func ProducePlayerRank(payload PlayerRanksMessage) (err error)

func ProducePlayerSearch 

func ProducePlayerSearch(player *mongo.Player, playerID int64) (err error)

func ProduceSameOwners 

func ProduceSameOwners(appID int) (err error)

func ProduceStats 

func ProduceStats(typex mongo.StatsType, ID int, appsCount int64) (err error)

func ProduceSteam 

func ProduceSteam(payload SteamMessage) (err error)

func ProduceTest 

func ProduceTest(id int) (err error)

func ProduceWebsocket 

func ProduceWebsocket(payload interface{}, pages ...websockets.WebsocketPage) (err error)

func SetSteamClient 

func SetSteamClient(c *steam.Client)

Types

type AdminPayload 

type AdminPayload struct {
	TaskID string `json:"task_id"`
	Action string `json:"action"`
	Time   int64  `json:"time"`
}

type AppAchievementsMessage 

type AppAchievementsMessage struct {
	AppID     int    `json:"id"`
	AppName   string `json:"app-name"`
	AppOwners int64  `json:"app_owners"`
}

func (AppAchievementsMessage) Queue 

func (m AppAchievementsMessage) Queue() rabbit.QueueName

type AppInfluxMessage 

type AppInfluxMessage struct {
	AppIDs []int `json:"app_ids"`
}

func (AppInfluxMessage) Queue 

func (m AppInfluxMessage) Queue() rabbit.QueueName

type AppItemsMessage 

type AppItemsMessage struct {
	AppID     int    `json:"id"`
	OldDigect string `json:"old_digect"`
}

func (AppItemsMessage) Queue 

func (m AppItemsMessage) Queue() rabbit.QueueName

type AppMessage 

type AppMessage struct {
	ID           int                    `json:"id"`
	ChangeNumber int                    `json:"change_number"`
	VDF          map[string]interface{} `json:"vdf"`
}

type AppMorelikeMessage 

type AppMorelikeMessage struct {
	AppID int `json:"id"`
}

func (AppMorelikeMessage) Queue 

func (m AppMorelikeMessage) Queue() rabbit.QueueName

type AppNewsMessage 

type AppNewsMessage struct {
	AppID int `json:"id"`
}

func (AppNewsMessage) Queue 

func (m AppNewsMessage) Queue() rabbit.QueueName

type AppPlayerMessage 

type AppPlayerMessage struct {
	IDs []int `json:"ids"`
}

type AppReviewsMessage 

type AppReviewsMessage struct {
	AppID              int  `json:"id"`
	SkipMissingPlayers bool `json:"skip_missing_players"`
}

func (AppReviewsMessage) Queue 

func (m AppReviewsMessage) Queue() rabbit.QueueName

type AppSameownersMessage 

type AppSameownersMessage struct {
	AppID int `json:"app_id"`
}

func (AppSameownersMessage) Queue 

func (m AppSameownersMessage) Queue() rabbit.QueueName

type AppSteamspyMessage 

type AppSteamspyMessage struct {
	AppID int `json:"id"`
}

func (AppSteamspyMessage) Queue 

func (m AppSteamspyMessage) Queue() rabbit.QueueName

type AppTwitchMessage 

type AppTwitchMessage struct {
	AppID int `json:"id"`
}

func (AppTwitchMessage) Queue 

func (m AppTwitchMessage) Queue() rabbit.QueueName

type AppWishlistsMessage 

type AppWishlistsMessage struct {
	AppID int `json:"id"`
}

type AppYoutubeMessage 

type AppYoutubeMessage struct {
	ID   int    `json:"id"`
	Name string `json:"name"`
}

type AppsAchievementsSearchMessage 

type AppsAchievementsSearchMessage struct {
	AppAchievement mongo.AppAchievement `json:"app_achievement"`
	AppName        string               `json:"app_name"`
	AppOwners      int64                `json:"app_owners"`
}

type AppsArticlesSearchMessage 

type AppsArticlesSearchMessage struct {
	Elastic elasticsearch.Article `json:"elastic"`
}

type AppsSearchMessage 

type AppsSearchMessage struct {
	App    *mongo.App             `json:"app"`
	AppID  int                    `json:"app_id"`
	Fields map[string]interface{} `json:"fields"` // Optional
}

func (AppsSearchMessage) Queue 

func (m AppsSearchMessage) Queue() rabbit.QueueName

type BundleMessage 

type BundleMessage struct {
	ID int `json:"id"`
}

type BundlesSearchMessage 

type BundlesSearchMessage struct {
	Bundle mongo.Bundle `json:"bundle"`
}

func (BundlesSearchMessage) Queue 

func (m BundlesSearchMessage) Queue() rabbit.QueueName

type ChangesMessage 

type ChangesMessage struct {
	AppIDs     map[uint32]uint32 `json:"app_ids"`
	PackageIDs map[uint32]uint32 `json:"package_ids"`
}

type ChangesPayload 

type ChangesPayload struct {
	Data [][]interface{} `json:"d"`
}

type ChatBotPayload 

type ChatBotPayload struct {
	RowData []interface{} `json:"row_data"`
}

type ChatPayload 

type ChatPayload struct {
	I            float32 `json:"i"`
	AuthorID     string  `json:"author_id"`
	AuthorUser   string  `json:"author_user"`
	AuthorAvatar string  `json:"author_avatar"`
	Content      string  `json:"content"`
	Channel      string  `json:"channel"`
	Time         string  `json:"timestamp"`
	Embeds       bool    `json:"embeds"`
}

type DLCMessage 

type DLCMessage struct {
	AppID  int   `json:"ap_id"`
	DLCIDs []int `json:"dlc_ids"`
}

type FindGroupMessage 

type FindGroupMessage struct {
	AppID int `json:"app_id"`
}

func (FindGroupMessage) Queue 

func (m FindGroupMessage) Queue() rabbit.QueueName

type GroupMessage 

type GroupMessage struct {
	ID        string  `json:"id"`
	UserAgent *string `json:"user_agent"`
}

func (GroupMessage) Queue 

func (m GroupMessage) Queue() rabbit.QueueName

type GroupPrimariesMessage 

type GroupPrimariesMessage struct {
	GroupID          string `json:"group_id"`
	GroupType        string `json:"group_type"`
	CurrentPrimaries int    `json:"current_primaries"`
}

func (GroupPrimariesMessage) Queue 

func (m GroupPrimariesMessage) Queue() rabbit.QueueName

type GroupSearchMessage 

type GroupSearchMessage struct {
	Group     *mongo.Group `json:"group"`
	GroupID   string       `json:"group_id"`   // Only if group is null
	GroupType string       `json:"group_type"` // Only if group is null
}

func (GroupSearchMessage) Queue 

func (m GroupSearchMessage) Queue() rabbit.QueueName

type IntPayload 

type IntPayload struct {
	ID int `json:"id"`
}

type NewsPayload 

type NewsPayload struct {
	RowData []interface{} `json:"row_data"`
}

type PackageMessage 

type PackageMessage struct {
	ID           int                    `json:"id"`
	ChangeNumber int                    `json:"change_number"`
	VDF          map[string]interface{} `json:"vdf"`
}

type PackagePriceMessage 

type PackagePriceMessage struct {
	PackageID   uint               `json:"id"`
	PackageName string             `json:"package_name"`
	PackageIcon string             `json:"package_icon"`
	ProductCC   steamapi.ProductCC `json:"prod_cc"`
	Time        time.Time          `json:"time"`
	BeforePrice *int               `json:"before_price"`
	LowestPrice *int               `json:"lowest_price"`
}

type PlayerAchievementsMessage 

type PlayerAchievementsMessage struct {
	PlayerID     int64 `json:"player_id"`
	AppID        int   `json:"app_id"`
	Force        bool  `json:"force"` // Re-add previous achievements
	OldCount     int   `json:"old_count"`
	OldCount100  int   `json:"old_count_100"`
	OldCountApps int   `json:"old_count_apps"`
}

type PlayerBadgesMessage 

type PlayerBadgesMessage struct {
	PlayerID     int64  `json:"player_id"`
	PlayerName   string `json:"player_name"`
	PlayerAvatar string `json:"player_avatar"`
	OldCount     int    `json:"old_count"`
	OldFoilCount int    `json:"old_foil_count"`
}

func (PlayerBadgesMessage) Queue 

func (m PlayerBadgesMessage) Queue() rabbit.QueueName

type PlayerGamesMessage 

type PlayerGamesMessage struct {
	PlayerID                 int64     `json:"player_id"`
	PlayerCountry            string    `json:"player_country"`
	PlayerUpdated            time.Time `json:"player_updated"`
	SkipAchievements         bool      `json:"skip_achievements"`
	ForceAchievementsRefresh bool      `json:"force_achievements_refresh"`
	OldAchievementCount      int       `json:"old_achievement_count"`
	OldAchievementCount100   int       `json:"old_achievement_count_100"`
	OldAchievementCountApps  int       `json:"old_achievement_count_apps"`
}

func (PlayerGamesMessage) Queue 

func (m PlayerGamesMessage) Queue() rabbit.QueueName

type PlayerMessage 

type PlayerMessage struct {
	ID                       int64   `json:"id"`
	SkipGroupUpdate          bool    `json:"dont_queue_group"`
	SkipAchievements         bool    `json:"skip_achievements"`
	SkipExistingPlayer       bool    `json:"skip_existing_player"`
	ForceAchievementsRefresh bool    `json:"force_achievements_refresh"`
	UserAgent                *string `json:"user_agent"`
}

type PlayerPayload 

type PlayerPayload struct {
	ID            string `json:"id"` // string for js
	Name          string `json:"name"`
	Link          string `json:"link"`
	Avatar        string `json:"avatar"`
	CreatedAt     int64  `json:"created_at"`
	Queue         string `json:"queue"`
	CommunityLink string `json:"community_link"`
	New           bool   `json:"new"`
}

type PlayerRanksMessage 

type PlayerRanksMessage struct {
	ObjectKey  string  `json:"object_key"`
	SortColumn string  `json:"sort_column"`
	Continent  *string `json:"continent"`
	Country    *string `json:"country"`
	State      *string `json:"state"`
}

type PlayersAliasesMessage 

type PlayersAliasesMessage struct {
	PlayerID      int64 `json:"player_id"`
	PlayerRemoved bool  `json:"player_removed"`
}

func (PlayersAliasesMessage) Queue 

func (m PlayersAliasesMessage) Queue() rabbit.QueueName

type PlayersAwardsMessage 

type PlayersAwardsMessage struct {
	PlayerID int64 `json:"player_id"`
}

func (PlayersAwardsMessage) Queue 

func (m PlayersAwardsMessage) Queue() rabbit.QueueName

type PlayersGroupsMessage 

type PlayersGroupsMessage struct {
	Player                    mongo.Player `json:"player"`
	SkipGroupUpdate           bool         `json:"skip_group"`
	ForceResavingPlayerGroups bool         `json:"force_resaving_player_groups"`
	UserAgent                 *string      `json:"user_agent"`
}

func (PlayersGroupsMessage) Queue 

func (m PlayersGroupsMessage) Queue() rabbit.QueueName

type PlayersSearchMessage 

type PlayersSearchMessage struct {
	Player   *mongo.Player `json:"player"`
	PlayerID int64         `json:"player_id"`
}

func (PlayersSearchMessage) Queue 

func (m PlayersSearchMessage) Queue() rabbit.QueueName

type PlayersWishlistMessage 

type PlayersWishlistMessage struct {
	PlayerID int64 `json:"player_id"`
}

func (PlayersWishlistMessage) Queue 

func (m PlayersWishlistMessage) Queue() rabbit.QueueName

type QueueDefinition 

type QueueDefinition struct {
	Name rabbit.QueueName
	// contains filtered or unexported fields
}

type QueueMessageInterface 

type QueueMessageInterface interface {
	Queue() rabbit.QueueName
}

type StatsMessage 

type StatsMessage struct {
	Type      mongo.StatsType `json:"type"`
	StatID    int             `json:"id"`
	AppsCount int64           `json:"apps_count"`
}

func (StatsMessage) Queue 

func (m StatsMessage) Queue() rabbit.QueueName

type SteamMessage 

type SteamMessage struct {
	AppIDs     []int `json:"app_ids"`
	PackageIDs []int `json:"package_ids"`
}

type StringPayload 

type StringPayload struct {
	String string `json:"id"`
}

type StringsPayload 

type StringsPayload struct {
	IDs []string `json:"id"`
}

type TestMessage 

type TestMessage struct {
	ID int `json:"id"`
}

type WebsocketMessage 

type WebsocketMessage struct {
	Pages   []websockets.WebsocketPage `json:"pages"`
	Message []byte                     `json:"message"`
}

Source Files

View all Source files

Directories

Path Synopsis
helpers
twitch
youtube

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.