server

package

Go to main page

Versions in this module

v3

v3.21.1

Mar 22, 2024

Changes in this version

+ type LocalStatusRegistry struct

+ func (s *LocalStatusRegistry) FillOnlineAccounts(accounts []*api.Account)

+ func (s *LocalStatusRegistry) FillOnlineFriends(friends []*api.Friend)

+ func (s *LocalStatusRegistry) FillOnlineGroupUsers(groupUsers []*api.GroupUserList_GroupUser)

+ func (s *LocalStatusRegistry) FillOnlineUsers(users []*api.User)

+ func (s *LocalStatusRegistry) Follow(sessionID uuid.UUID, userIDs map[uuid.UUID]struct{})

+ func (s *LocalStatusRegistry) IsOnline(userID uuid.UUID) bool

+ func (s *LocalStatusRegistry) Queue(userID uuid.UUID, joins, leaves []*rtapi.UserPresence)

+ func (s *LocalStatusRegistry) Stop()

+ func (s *LocalStatusRegistry) Unfollow(sessionID uuid.UUID, userIDs []uuid.UUID)

+ func (s *LocalStatusRegistry) UnfollowAll(sessionID uuid.UUID)

type Session

+ CloseLock func()

+ CloseUnlock func()

type StatusRegistry

+ func NewLocalStatusRegistry(logger *zap.Logger, config Config, sessionRegistry SessionRegistry, ...) StatusRegistry

v3.21.0

Mar 17, 2024

Changes in this version

+ func NewLocalFmCallbackHandler(config Config) runtime.FmCallbackHandler

+ type LocalFmCallbackHandler struct

+ func (fch *LocalFmCallbackHandler) GenerateCallbackId() string

+ func (fch *LocalFmCallbackHandler) InvokeCallback(callbackId string, status runtime.FmCreateStatus, ...)

+ func (fch *LocalFmCallbackHandler) SetCallback(callbackId string, fn runtime.FmCreateCallbackFn)

type RuntimeGoInitializer

+ func (ri *RuntimeGoInitializer) RegisterFleetManager(fleetManager runtime.FleetManagerInitializer) error

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) CronNext(expression string, timestamp int64) (int64, error)

+ func (n *RuntimeGoNakamaModule) CronPrev(expression string, timestamp int64) (int64, error)

+ func (n *RuntimeGoNakamaModule) GetFleetManager() runtime.FleetManager

v3.20.1

Feb 3, 2024

Changes in this version

type LocalTracker

+ func (t *LocalTracker) ListPresenceIDByStreams(fill map[PresenceStream][]*PresenceID)

type Tracker

+ ListPresenceIDByStreams func(fill map[PresenceStream][]*PresenceID)

v3.20.0

Dec 15, 2023

v3.19.0

Nov 11, 2023

Changes in this version

+ func ValidatePurchaseFacebookInstant(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.ValidatePurchaseResponse, error)

type ApiServer

+ func (s *ApiServer) ValidatePurchaseFacebookInstant(ctx context.Context, in *api.ValidatePurchaseFacebookInstantRequest) (*api.ValidatePurchaseResponse, error)

type IAPConfig

+ FacebookInstant *IAPFacebookInstantConfig

+ type IAPFacebookInstantConfig struct

+ AppSecret string

type Runtime

+ func (r *Runtime) AfterValidatePurchaseFacebookInstant() RuntimeAfterValidatePurchaseFacebookInstantFunction

+ func (r *Runtime) BeforeValidatePurchaseFacebookInstant() RuntimeBeforeValidatePurchaseFacebookInstantFunction

+ type RuntimeAfterValidatePurchaseFacebookInstantFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeBeforeValidatePurchaseFacebookInstantFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ValidatePurchaseFacebookInstantRequest, error, codes.Code)

type RuntimeGoInitializer

+ func (ri *RuntimeGoInitializer) RegisterAfterValidatePurchaseFacebookInstant(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeValidatePurchaseFacebookInstant(...) error

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) PurchaseValidateFacebookInstant(ctx context.Context, userID, signedRequest string, persist bool) (*api.ValidatePurchaseResponse, error)

type RuntimeJavascriptLocalCache

+ func (lc *RuntimeJavascriptLocalCache) Clear()

type RuntimeLuaLocalCache

+ func (lc *RuntimeLuaLocalCache) Clear()

v3.18.0

Oct 24, 2023

Changes in this version

+ func ProfileGoja(w http.ResponseWriter, r *http.Request)

type Config

+ GetStorage func() *StorageConfig

type LeaderboardRankCache

+ GetDataByRank func(leaderboardId string, expiryUnix int64, sortOrder int, rank int64) (ownerID uuid.UUID, score, subscore int64, err error)

type LocalLeaderboardRankCache

+ func (l *LocalLeaderboardRankCache) GetDataByRank(leaderboardId string, expiryUnix int64, sortOrder int, rank int64) (ownerID uuid.UUID, score, subscore int64, err error)

type LocalMetrics

+ func (m *LocalMetrics) GaugeStorageIndexEntries(indexName string, value float64)

type Metrics

+ GaugeStorageIndexEntries func(indexName string, value float64)

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) LeaderboardRecordsListCursorFromRank(id string, rank, expiry int64) (string, error)

type SessionTokenClaims

+ TokenId string

+ type StorageConfig struct

+ DisableIndexOnly bool

+ func NewStorageConfig() *StorageConfig

v3.17.1

Aug 23, 2023

v3.17.0

Jul 19, 2023

Changes in this version

+ func ExecuteInTxPgx(ctx context.Context, db *sql.DB, fn func(pgx.Tx) error) error

+ func ExecuteRetryablePgx(ctx context.Context, db *sql.DB, fn func(conn *pgx.Conn) error) error

+ func RemapGoogleId(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error

+ type LeaderboardAllCursor struct

+ Offset int

type LeaderboardCache

+ ListAll func(limit int, reverse bool, cursor *LeaderboardAllCursor) ([]*Leaderboard, int, *LeaderboardAllCursor)

type LeaderboardConfig

+ RankCacheWorkers int

type LeaderboardListCursor

+ Offset int

type LocalLeaderboardCache

+ func (l *LocalLeaderboardCache) ListAll(limit int, reverse bool, cursor *LeaderboardAllCursor) ([]*Leaderboard, int, *LeaderboardAllCursor)

type LocalMessageRouter

+ func (r *LocalMessageRouter) SendToAll(logger *zap.Logger, envelope *rtapi.Envelope, reliable bool)

type LocalSessionRegistry

+ func (r *LocalSessionRegistry) Range(fn func(Session) bool)

+ type LocalStorageIndex struct

+ func (si *LocalStorageIndex) CreateIndex(ctx context.Context, name, collection, key string, fields []string, ...) error

+ func (si *LocalStorageIndex) Delete(ctx context.Context, objects StorageOpDeletes) (deletes int)

+ func (si *LocalStorageIndex) List(ctx context.Context, indexName, query string, limit int) (*api.StorageObjects, error)

+ func (si *LocalStorageIndex) Load(ctx context.Context) error

+ func (si *LocalStorageIndex) RegisterFilters(runtime *Runtime)

+ func (si *LocalStorageIndex) Write(ctx context.Context, objects StorageOpWrites) (updates int, deletes int)

type MessageRouter

+ SendToAll func(*zap.Logger, *rtapi.Envelope, bool)

+ type PartyJoinRequest struct

+ Presence *Presence

+ UserPresence *rtapi.UserPresence

+ type PartyLeader struct

+ PresenceID *PresenceID

+ UserPresence *rtapi.UserPresence

+ type PartyPresenceList struct

+ func NewPartyPresenceList(maxSize int) *PartyPresenceList

+ func (m *PartyPresenceList) Join(joins []*Presence) ([]*Presence, error)

+ func (m *PartyPresenceList) Leave(leaves []*Presence) ([]*Presence, []*Presence)

+ func (m *PartyPresenceList) List() []*PartyPresenceListItem

+ func (m *PartyPresenceList) Oldest() (*PresenceID, *rtapi.UserPresence)

+ func (m *PartyPresenceList) Release(presence *Presence)

+ func (m *PartyPresenceList) Reserve(presence *Presence) error

+ func (m *PartyPresenceList) Size() int

+ type PartyPresenceListItem struct

+ Presence *Presence

+ PresenceID *PresenceID

+ UserPresence *rtapi.UserPresence

type Runtime

+ func (r *Runtime) StorageIndexFilterFunction(indexName string) RuntimeStorageIndexFilterFunction

type RuntimeExecutionMode

+ const RuntimeExecutionModeStorageIndexFilter

type RuntimeGoInitializer

+ func (ri *RuntimeGoInitializer) RegisterStorageIndex(name, collection, key string, fields []string, maxEntries int) error

+ func (ri *RuntimeGoInitializer) RegisterStorageIndexFilter(indexName string, ...) error

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) StorageIndexList(ctx context.Context, indexName, query string, limit int) (*api.StorageObjects, error)

type RuntimeJavascriptCallbacks

+ StorageIndexFilter map[string]string

type RuntimeLuaCallbacks

+ StorageIndexFilter *MapOf[string, *lua.LFunction]

type RuntimeProviderJS

+ func (rp *RuntimeProviderJS) StorageIndexFilter(ctx context.Context, indexName string, storageWrite *StorageOpWrite) (bool, error)

type RuntimeProviderLua

+ func (rp *RuntimeProviderLua) StorageIndexFilter(ctx context.Context, indexName string, write *StorageOpWrite) (bool, error)

+ type RuntimeStorageIndexFilterFunction func(ctx context.Context, write *StorageOpWrite) (bool, error)

type SessionRegistry

+ Range func(fn func(session Session) bool)

+ type StorageIndex interface

+ CreateIndex func(ctx context.Context, name, collection, key string, fields []string, ...) error

+ Delete func(ctx context.Context, objects StorageOpDeletes) (deletes int)

+ List func(ctx context.Context, indexName, query string, limit int) (*api.StorageObjects, error)

+ Load func(ctx context.Context) error

+ RegisterFilters func(runtime *Runtime)

+ Write func(ctx context.Context, objects StorageOpWrites) (creates int, deletes int)

+ func NewLocalStorageIndex(logger *zap.Logger, db *sql.DB) (StorageIndex, error)

v3.16.0

Apr 18, 2023

Changes in this version

+ const NotificationCodeUserBanned

+ func GetPurchaseByTransactionId(ctx context.Context, db *sql.DB, transactionID string) (*api.ValidatedPurchase, error)

+ func RuntimeLuaConvertLuaTableString(vars *lua.LTable) (map[string]string, error)

+ func TournamentRecordDelete(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error

type ApiServer

+ func (s *ApiServer) DeleteTournamentRecord(ctx context.Context, in *api.DeleteTournamentRecordRequest) (*emptypb.Empty, error)

type Config

+ GetGoogleAuth func() *GoogleAuthConfig

+ GetSatori func() *SatoriConfig

+ type GoogleAuthConfig struct

+ CredentialsJSON string

+ OAuthConfig *oauth2.Config

+ func NewGoogleAuthConfig() *GoogleAuthConfig

type MatchmakerIndex

+ Entries []*MatchmakerEntry

type Runtime

+ func (r *Runtime) AfterDeleteTournamentRecord() RuntimeAfterDeleteTournamentRecordFunction

+ func (r *Runtime) BeforeDeleteTournamentRecord() RuntimeBeforeDeleteTournamentRecordFunction

+ type RuntimeAfterDeleteTournamentRecordFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeBeforeDeleteTournamentRecordFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.DeleteTournamentRecordRequest, error, codes.Code)

type RuntimeExecutionMode

+ const RuntimeExecutionModeMatchmakerOverride

type RuntimeGoInitializer

+ func (ri *RuntimeGoInitializer) RegisterAfterDeleteTournamentRecord(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeDeleteTournamentRecord(...) error

+ func (ri *RuntimeGoInitializer) RegisterMatchmakerOverride(...) error

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) GetSatori() runtime.Satori

+ func (n *RuntimeGoNakamaModule) TournamentRecordDelete(ctx context.Context, id, ownerID string) error

+ type RuntimeMatchmakerOverrideFunction func(ctx context.Context, candidateMatches [][]*MatchmakerEntry) (matches [][]*MatchmakerEntry)

+ type SatoriConfig struct

+ ApiKey string

+ ApiKeyName string

+ SigningKey string

+ Url string

+ func NewSatoriConfig() *SatoriConfig

+ func (sc *SatoriConfig) Validate(logger *zap.Logger)

v3.15.0

Jan 5, 2023

Changes in this version

+ const AppleNotificationTypeRefund

+ const AppleRootPEM

+ const BANNED_CODE

+ func ChannelMessageRemove(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) (*rtapi.ChannelMessageAck, error)

type ApiServer

+ func (s *ApiServer) DeleteAccount(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)

type ConsoleServer

+ func (s *ConsoleServer) AddGroupUsers(ctx context.Context, in *console.AddGroupUsersRequest) (*emptypb.Empty, error)

+ type GoogleRefundScheduler interface

+ Pause func()

+ Resume func()

+ Start func(runtime *Runtime)

+ Stop func()

+ func NewGoogleRefundScheduler(logger *zap.Logger, db *sql.DB, config Config) GoogleRefundScheduler

type IAPGoogleConfig

+ PackageName string

+ RefundCheckPeriodMin int

+ func (iapg *IAPGoogleConfig) Enabled() bool

+ type LocalGoogleRefundScheduler struct

+ func (g *LocalGoogleRefundScheduler) Pause()

+ func (g *LocalGoogleRefundScheduler) Resume()

+ func (g *LocalGoogleRefundScheduler) Start(runtime *Runtime)

+ func (g *LocalGoogleRefundScheduler) Stop()

type Runtime

+ func (r *Runtime) AfterDeleteAccount() RuntimeAfterDeleteAccountFunction

+ func (r *Runtime) BeforeDeleteAccount() RuntimeBeforeDeleteAccountFunction

+ func (r *Runtime) PurchaseNotificationApple() RuntimePurchaseNotificationAppleFunction

+ func (r *Runtime) PurchaseNotificationGoogle() RuntimePurchaseNotificationGoogleFunction

+ func (r *Runtime) SubscriptionNotificationApple() RuntimeSubscriptionNotificationAppleFunction

+ func (r *Runtime) SubscriptionNotificationGoogle() RuntimeSubscriptionNotificationGoogleFunction

+ type RuntimeAfterDeleteAccountFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeBeforeDeleteAccountFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (error, codes.Code)

type RuntimeExecutionMode

+ const RuntimeExecutionModePurchaseNotificationApple

+ const RuntimeExecutionModePurchaseNotificationGoogle

+ const RuntimeExecutionModeSubscriptionNotificationApple

+ const RuntimeExecutionModeSubscriptionNotificationGoogle

type RuntimeGoInitializer

+ func (ri *RuntimeGoInitializer) RegisterAfterDeleteAccount(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeDeleteAccount(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterPurchaseNotificationApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterPurchaseNotificationGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterSubscriptionNotificationApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterSubscriptionNotificationGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) ChannelMessageRemove(ctx context.Context, channelId, messageId string, ...) (*rtapi.ChannelMessageAck, error)

type RuntimeJavascriptCallbacks

+ PurchaseNotificationApple string

+ PurchaseNotificationGoogle string

+ SubscriptionNotificationApple string

+ SubscriptionNotificationGoogle string

type RuntimeLuaCallbacks

+ PurchaseNotificationApple *lua.LFunction

+ PurchaseNotificationGoogle *lua.LFunction

+ SubscriptionNotificationApple *lua.LFunction

+ SubscriptionNotificationGoogle *lua.LFunction

type RuntimeProviderJS

+ func (rp *RuntimeProviderJS) PurchaseNotificationApple(ctx context.Context, purchase *api.ValidatedPurchase, providerPayload string) error

+ func (rp *RuntimeProviderJS) PurchaseNotificationGoogle(ctx context.Context, purchase *api.ValidatedPurchase, providerPayload string) error

+ func (rp *RuntimeProviderJS) SubscriptionNotificationApple(ctx context.Context, subscription *api.ValidatedSubscription, ...) error

+ func (rp *RuntimeProviderJS) SubscriptionNotificationGoogle(ctx context.Context, subscription *api.ValidatedSubscription, ...) error

type RuntimeProviderLua

+ func (rp *RuntimeProviderLua) PurchaseNotificationApple(ctx context.Context, purchase *api.ValidatedPurchase, providerPayload string) error

+ func (rp *RuntimeProviderLua) PurchaseNotificationGoogle(ctx context.Context, purchase *api.ValidatedPurchase, providerPayload string) error

+ func (rp *RuntimeProviderLua) SubscriptionNotificationApple(ctx context.Context, subscription *api.ValidatedSubscription, ...) error

+ func (rp *RuntimeProviderLua) SubscriptionNotificationGoogle(ctx context.Context, subscription *api.ValidatedSubscription, ...) error

+ type RuntimePurchaseNotificationAppleFunction func(ctx context.Context, purchase *api.ValidatedPurchase, providerPayload string) error

+ type RuntimePurchaseNotificationGoogleFunction func(ctx context.Context, purchase *api.ValidatedPurchase, providerPayload string) error

+ type RuntimeSubscriptionNotificationAppleFunction func(ctx context.Context, subscription *api.ValidatedSubscription, ...) error

+ type RuntimeSubscriptionNotificationGoogleFunction func(ctx context.Context, subscription *api.ValidatedSubscription, ...) error

type SocketConfig

+ Headers map[string]string

+ ResponseHeaders []string

v3.14.0

Oct 14, 2022

Changes in this version

+ func GetRandomGroups(ctx context.Context, logger *zap.Logger, db *sql.DB, count int) ([]*api.Group, error)

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) GroupsGetRandom(ctx context.Context, count int) ([]*api.Group, error)

v3.13.1

Aug 18, 2022

v3.13.0

Aug 18, 2022

Changes in this version

+ var ApplePubKey = func() *rsa.PublicKey { ... }()

+ var ErrMatchInitStateNil = errors.New("Match initial state must not be nil")

+ var ErrSubscriptionNotFound = errors.New("subscription not found")

+ var ErrSubscriptionsListInvalidCursor = errors.New("subscriptions list cursor invalid")

+ func GetSubscriptionByProductId(ctx context.Context, logger *zap.Logger, db *sql.DB, userID, productID string) (string, *api.ValidatedSubscription, error)

+ func ListSubscriptions(ctx context.Context, logger *zap.Logger, db *sql.DB, userID string, limit int, ...) (*api.SubscriptionList, error)

+ func ValidateSubscriptionApple(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.ValidateSubscriptionResponse, error)

+ func ValidateSubscriptionGoogle(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.ValidateSubscriptionResponse, error)

type ApiServer

+ func (s *ApiServer) GetSubscription(ctx context.Context, in *api.GetSubscriptionRequest) (*api.ValidatedSubscription, error)

+ func (s *ApiServer) ListSubscriptions(ctx context.Context, in *api.ListSubscriptionsRequest) (*api.SubscriptionList, error)

+ func (s *ApiServer) ValidateSubscriptionApple(ctx context.Context, in *api.ValidateSubscriptionAppleRequest) (*api.ValidateSubscriptionResponse, error)

+ func (s *ApiServer) ValidateSubscriptionGoogle(ctx context.Context, in *api.ValidateSubscriptionGoogleRequest) (*api.ValidateSubscriptionResponse, error)

type ConsoleServer

+ func (s *ConsoleServer) AuthenticateLogout(ctx context.Context, in *console.AuthenticateLogoutRequest) (*emptypb.Empty, error)

+ func (s *ConsoleServer) DeleteChannelMessages(ctx context.Context, in *console.DeleteChannelMessagesRequest) (*console.DeleteChannelMessagesResponse, error)

+ func (s *ConsoleServer) ListChannelMessages(ctx context.Context, in *console.ListChannelMessagesRequest) (*api.ChannelMessageList, error)

+ func (s *ConsoleServer) ListSubscriptions(ctx context.Context, in *console.ListSubscriptionsRequest) (*api.SubscriptionList, error)

type ConsoleTokenClaims

+ ID string

type IAPAppleConfig

+ NotificationsEndpointId string

type IAPGoogleConfig

+ NotificationsEndpointId string

+ type LocalLoginAttemptCache struct

+ func (c *LocalLoginAttemptCache) Add(account, ip string) (LockoutType, time.Time)

+ func (c *LocalLoginAttemptCache) Allow(account, ip string) bool

+ func (c *LocalLoginAttemptCache) Reset(account string)

+ func (c *LocalLoginAttemptCache) Stop()

type LocalMatchmaker

+ func (m *LocalMatchmaker) Extract() []*MatchmakerExtract

+ func (m *LocalMatchmaker) Insert(extracts []*MatchmakerExtract) error

+ func (m *LocalMatchmaker) OnMatchedEntries(fn func(entries [][]*MatchmakerEntry))

+ func (m *LocalMatchmaker) Pause()

+ func (m *LocalMatchmaker) Process()

+ func (m *LocalMatchmaker) Remove(tickets []string)

+ func (m *LocalMatchmaker) RemoveAll(node string)

+ func (m *LocalMatchmaker) Resume()

type LocalMetrics

+ func (m *LocalMetrics) Matchmaker(tickets, activeTickets float64, processTime time.Duration)

+ func (m *LocalMetrics) StorageWriteRejectCount(tags map[string]string, delta int64)

+ type LockoutType uint8

+ const LockoutTypeAccount

+ const LockoutTypeIp

+ const LockoutTypeNone

+ type LoginAttemptCache interface

+ Add func(account, ip string) (LockoutType, time.Time)

+ Allow func(account, ip string) bool

+ Reset func(account string)

+ Stop func()

+ func NewLocalLoginAttemptCache() LoginAttemptCache

+ type MapOf struct

+ func (m *MapOf[K, V]) Delete(key K)

+ func (m *MapOf[K, V]) Load(key K) (value V, ok bool)

+ func (m *MapOf[K, V]) LoadAndDelete(key K) (value V, loaded bool)

+ func (m *MapOf[K, V]) LoadOrStore(key K, value V) (actual V, loaded bool)

+ func (m *MapOf[K, V]) Range(f func(key K, value V) bool)

+ func (m *MapOf[K, V]) Store(key K, value V)

type Matchmaker

+ Extract func() []*MatchmakerExtract

+ Insert func(extracts []*MatchmakerExtract) error

+ OnMatchedEntries func(fn func(entries [][]*MatchmakerEntry))

+ Pause func()

+ Remove func(tickets []string)

+ RemoveAll func(node string)

+ Resume func()

type MatchmakerConfig

+ RevPrecision bool

+ RevThreshold int

+ type MatchmakerExtract struct

+ Count int

+ CountMultiple int

+ CreatedAt int64

+ Intervals int

+ MaxCount int

+ MinCount int

+ Node string

+ NumericProperties map[string]float64

+ PartyId string

+ Presences []*MatchmakerPresence

+ Query string

+ SessionID string

+ StringProperties map[string]string

+ Ticket string

type MatchmakerIndex

+ Node string

+ NumericProperties map[string]float64

+ ParsedQuery bluge.Query

+ StringProperties map[string]string

type Metrics

+ Matchmaker func(tickets, activeTickets float64, processTime time.Duration)

+ StorageWriteRejectCount func(tags map[string]string, delta int64)

type Runtime

+ func (r *Runtime) AfterGetSubscription() RuntimeAfterGetSubscriptionFunction

+ func (r *Runtime) AfterListSubscriptions() RuntimeAfterListSubscriptionsFunction

+ func (r *Runtime) AfterValidateSubscriptionApple() RuntimeAfterValidateSubscriptionAppleFunction

+ func (r *Runtime) AfterValidateSubscriptionGoogle() RuntimeAfterValidateSubscriptionGoogleFunction

+ func (r *Runtime) BeforeGetSubscription() RuntimeBeforeGetSubscriptionFunction

+ func (r *Runtime) BeforeListSubscriptions() RuntimeBeforeListSubscriptionsFunction

+ func (r *Runtime) BeforeValidateSubscriptionApple() RuntimeBeforeValidateSubscriptionAppleFunction

+ func (r *Runtime) BeforeValidateSubscriptionGoogle() RuntimeBeforeValidateSubscriptionGoogleFunction

+ type RuntimeAfterGetSubscriptionFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListSubscriptionsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterValidateSubscriptionAppleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterValidateSubscriptionGoogleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeBeforeGetSubscriptionFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.GetSubscriptionRequest, error, codes.Code)

+ type RuntimeBeforeListSubscriptionsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListSubscriptionsRequest, error, codes.Code)

+ type RuntimeBeforeValidateSubscriptionAppleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ValidateSubscriptionAppleRequest, error, codes.Code)

+ type RuntimeBeforeValidateSubscriptionGoogleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ValidateSubscriptionGoogleRequest, error, codes.Code)

type RuntimeGoInitializer

+ func (ri *RuntimeGoInitializer) RegisterAfterGetSubscription(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListSubscriptions(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterValidateSubscriptionApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterValidateSubscriptionGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeGetSubscription(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListSubscriptions(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeValidateSubscriptionApple(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeValidateSubscriptionGoogle(...) error

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) NotificationsDelete(ctx context.Context, notifications []*runtime.NotificationDelete) error

+ func (n *RuntimeGoNakamaModule) SubscriptionGetByProductId(ctx context.Context, userID, productID string) (string, *api.ValidatedSubscription, error)

+ func (n *RuntimeGoNakamaModule) SubscriptionValidateApple(ctx context.Context, userID, receipt string, persist bool, ...) (*api.ValidateSubscriptionResponse, error)

+ func (n *RuntimeGoNakamaModule) SubscriptionValidateGoogle(ctx context.Context, userID, receipt string, persist bool, overrides ...) (*api.ValidateSubscriptionResponse, error)

+ func (n *RuntimeGoNakamaModule) SubscriptionsList(ctx context.Context, userID string, limit int, cursor string) (*api.SubscriptionList, error)

type RuntimeJS

+ func (r *RuntimeJS) SetContext(ctx context.Context)

v3.12.0

May 22, 2022

Changes in this version

type ConsoleServer

+ StreamManager StreamManager

type Leaderboard

+ func (l *Leaderboard) HasMaxSize() bool

type Runtime

+ func (r *Runtime) AfterDeleteNotifications() RuntimeAfterDeleteNotificationsFunction

+ func (r *Runtime) BeforeDeleteNotifications() RuntimeBeforeDeleteNotificationsFunction

+ type RuntimeAfterDeleteNotificationsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeBeforeDeleteNotificationsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.DeleteNotificationsRequest, error, codes.Code)

type RuntimeGoInitializer

+ func (ri *RuntimeGoInitializer) RegisterAfterDeleteNotifications(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeDeleteNotifications(...) error

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) ChannelMessagesList(ctx context.Context, channelId string, limit int, forward bool, cursor string) ([]*api.ChannelMessage, string, string, error)

+ func (n *RuntimeGoNakamaModule) FriendsBlock(ctx context.Context, userID string, username string, ids []string, ...) error

type StatusRegistry

+ func (s *StatusRegistry) FillOnlineAccounts(accounts []*api.Account)

+ func (s *StatusRegistry) FillOnlineFriends(friends []*api.Friend)

+ func (s *StatusRegistry) FillOnlineGroupUsers(groupUsers []*api.GroupUserList_GroupUser)

+ func (s *StatusRegistry) FillOnlineUsers(users []*api.User)

+ func (s *StatusRegistry) IsOnline(userID uuid.UUID) bool

v3.11.0

Mar 21, 2022

Changes in this version

+ var ErrEmptyMemberDemote = errors.New("could not demote member")

+ var ErrEmptyMemberKick = errors.New("could not kick member")

+ var ErrEmptyMemberPromote = errors.New("could not promote member")

+ func NotificationSendAll(ctx context.Context, logger *zap.Logger, db *sql.DB, tracker Tracker, ...) error

type ConsoleServer

+ func (s *ConsoleServer) DeleteAllData(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)

+ func (s *ConsoleServer) DeleteGroup(ctx context.Context, in *console.DeleteGroupRequest) (*emptypb.Empty, error)

+ func (s *ConsoleServer) DemoteGroupMember(ctx context.Context, in *console.UpdateGroupUserStateRequest) (*emptypb.Empty, error)

+ func (s *ConsoleServer) ExportGroup(ctx context.Context, in *console.GroupId) (*console.GroupExport, error)

+ func (s *ConsoleServer) GetGroup(ctx context.Context, in *console.GroupId) (*api.Group, error)

+ func (s *ConsoleServer) GetMembers(ctx context.Context, in *console.GroupId) (*api.GroupUserList, error)

+ func (s *ConsoleServer) ListGroups(ctx context.Context, in *console.ListGroupsRequest) (*console.GroupList, error)

+ func (s *ConsoleServer) PromoteGroupMember(ctx context.Context, in *console.UpdateGroupUserStateRequest) (*emptypb.Empty, error)

+ func (s *ConsoleServer) UpdateGroup(ctx context.Context, in *console.UpdateGroupRequest) (*emptypb.Empty, error)

type LocalMetrics

+ func (m *LocalMetrics) ApiRpc(id string, elapsed time.Duration, recvBytes, sentBytes int64, isErr bool)

type MatchmakerIndex

+ CountMultiple int

+ type MatchmakerIndexGroup struct

type Metrics

+ ApiRpc func(id string, elapsed time.Duration, recvBytes, sentBytes int64, isErr bool)

type RuntimeConfig

+ JsReadOnlyGlobals bool

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) FriendsAdd(ctx context.Context, userID string, username string, ids []string, ...) error

+ func (n *RuntimeGoNakamaModule) FriendsDelete(ctx context.Context, userID string, username string, ids []string, ...) error

+ func (n *RuntimeGoNakamaModule) GroupUsersBan(ctx context.Context, callerID, groupID string, userIDs []string) error

+ func (n *RuntimeGoNakamaModule) LeaderboardRecordsHaystack(ctx context.Context, id, ownerID string, limit int, expiry int64) ([]*api.LeaderboardRecord, error)

+ func (n *RuntimeGoNakamaModule) NotificationSendAll(ctx context.Context, subject string, content map[string]interface{}, code int, ...) error

v3.10.0

Dec 16, 2021

Changes in this version

+ var BlugeKeywordAnalyzer = analyzer.NewKeywordAnalyzer()

+ func BlugeInMemoryConfig() bluge.Config

type DatabaseConfig

+ DnsScanIntervalSec int

type RuntimeGoMatchCore

+ func (r *RuntimeGoMatchCore) Cleanup()

type RuntimeJavaScriptMatchCore

+ func (rm *RuntimeJavaScriptMatchCore) Cleanup()

type RuntimeLuaMatchCore

+ func (r *RuntimeLuaMatchCore) Cleanup()

type RuntimeMatchCore

+ Cleanup func()

v3.9.0

Oct 29, 2021

Changes in this version

+ var ErrDatabaseDriverMismatch = errors.New("database driver mismatch")

+ func BlugeWalkDocument(data interface{}, path []string, doc *bluge.Document)

+ func MapMatchIndexEntry(id string, in *MatchIndexEntry, logger *zap.Logger) (*bluge.Document, error)

+ func MapMatchmakerIndex(id string, in *MatchmakerIndex) (*bluge.Document, error)

+ func ParseQueryString(query string) (bluge.Query, error)

+ type BlugeResult struct

+ Hits []*blugeMatch

+ func IterateBlugeMatches(dmi search.DocumentMatchIterator, loadFields map[string]struct{}, ...) (*BlugeResult, error)

+ type ValidatableQuery interface

+ Validate func() error

v3.8.0

Oct 15, 2021

Changes in this version

+ const NotificationCodeSingleSocket

+ var ErrMatchBusy = errors.New("match busy")

+ func DbConnect(multiLogger *zap.Logger, config Config) (*sql.DB, string)

type LocalMatchRegistry

+ func (r *LocalMatchRegistry) Signal(ctx context.Context, id, data string) (string, error)

type MatchConfig

+ SignalQueueSize int

type MatchFnId

+ const MatchSignal

type MatchHandler

+ func (mh *MatchHandler) QueueSignal(ctx context.Context, resultCh chan<- *MatchSignalResult, data string) bool

+ type MatchJoinAttemptResult struct

+ Allow bool

+ Label string

+ Reason string

type MatchRegistry

+ Signal func(ctx context.Context, id, data string) (string, error)

+ type MatchSignalResult struct

+ Result string

+ Success bool

type RuntimeGoMatchCore

+ func (r *RuntimeGoMatchCore) MatchSignal(tick int64, state interface{}, data string) (interface{}, string, error)

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) MatchSignal(ctx context.Context, id string, data string) (string, error)

type RuntimeJavaScriptMatchCore

+ func (rm *RuntimeJavaScriptMatchCore) MatchSignal(tick int64, state interface{}, data string) (interface{}, string, error)

type RuntimeLuaMatchCore

+ func (r *RuntimeLuaMatchCore) MatchSignal(tick int64, state interface{}, data string) (interface{}, string, error)

type RuntimeMatchCore

+ MatchSignal func(tick int64, state interface{}, data string) (interface{}, string, error)

v3.7.0

Sep 28, 2021

Changes in this version

type LocalSessionRegistry

+ func (r *LocalSessionRegistry) SingleSession(ctx context.Context, tracker Tracker, userID, sessionID uuid.UUID)

type LocalTracker

+ func (t *LocalTracker) UntrackLocalByModes(sessionID uuid.UUID, modes map[uint8]struct{}, skipStream PresenceStream)

type SessionConfig

+ SingleMatch bool

+ SingleSocket bool

type SessionRegistry

+ SingleSession func(ctx context.Context, tracker Tracker, userID, sessionID uuid.UUID)

type Tracker

+ UntrackLocalByModes func(sessionID uuid.UUID, modes map[uint8]struct{}, skipStream PresenceStream)

v3.6.0

Sep 9, 2021

Changes in this version

+ var ErrCannotDecodeParams = errors.New("error creating match: cannot decode params")

+ func ChannelMessageUpdate(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) (*rtapi.ChannelMessageAck, error)

+ type LocalMetrics struct

+ PrometheusScope tally.Scope

+ func NewLocalMetrics(logger, startupLogger *zap.Logger, db *sql.DB, config Config) *LocalMetrics

+ func (m *LocalMetrics) Api(name string, elapsed time.Duration, recvBytes, sentBytes int64, isErr bool)

+ func (m *LocalMetrics) ApiAfter(name string, elapsed time.Duration, isErr bool)

+ func (m *LocalMetrics) ApiBefore(name string, elapsed time.Duration, isErr bool)

+ func (m *LocalMetrics) CountDroppedEvents(delta int64)

+ func (m *LocalMetrics) CountWebsocketClosed(delta int64)

+ func (m *LocalMetrics) CountWebsocketOpened(delta int64)

+ func (m *LocalMetrics) CustomCounter(name string, tags map[string]string, delta int64)

+ func (m *LocalMetrics) CustomGauge(name string, tags map[string]string, value float64)

+ func (m *LocalMetrics) CustomTimer(name string, tags map[string]string, value time.Duration)

+ func (m *LocalMetrics) GaugeAuthoritativeMatches(value float64)

+ func (m *LocalMetrics) GaugeJsRuntimes(value float64)

+ func (m *LocalMetrics) GaugeLuaRuntimes(value float64)

+ func (m *LocalMetrics) GaugePresences(value float64)

+ func (m *LocalMetrics) GaugeRuntimes(value float64)

+ func (m *LocalMetrics) GaugeSessions(value float64)

+ func (m *LocalMetrics) Message(recvBytes int64, isErr bool)

+ func (m *LocalMetrics) MessageBytesSent(sentBytes int64)

+ func (m *LocalMetrics) PresenceEvent(dequeueElapsed, processElapsed time.Duration)

+ func (m *LocalMetrics) SnapshotLatencyMs() float64

+ func (m *LocalMetrics) SnapshotRateSec() float64

+ func (m *LocalMetrics) SnapshotRecvKbSec() float64

+ func (m *LocalMetrics) SnapshotSentKbSec() float64

+ func (m *LocalMetrics) Stop(logger *zap.Logger)

type Metrics

+ PresenceEvent func(dequeueElapsed, processElapsed time.Duration)

type MetricsGrpcHandler

+ MetricsFn func(name string, elapsed time.Duration, recvBytes, sentBytes int64, isErr bool)

type PresenceEvent

+ QueueTime time.Time

type RuntimeConfig

+ LuaApiStacktrace bool

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) ChannelMessageUpdate(ctx context.Context, channelId, messageId string, ...) (*rtapi.ChannelMessageAck, error)

v3.5.0

Aug 10, 2021

Changes in this version

+ var ErrGroupCreatorInvalid = errors.New("group creator user ID not valid")

+ var ErrTournamentAuthoritative = errors.New("tournament only allows authoritative submissions")

+ func ChannelMessageSend(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) (*rtapi.ChannelMessageAck, error)

+ func GetRandomUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, tracker Tracker, ...) ([]*api.User, error)

type PresenceStream

+ func BuildChannelId(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (string, PresenceStream, error)

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) ChannelIdBuild(ctx context.Context, target string, chanType runtime.ChannelType) (string, error)

+ func (n *RuntimeGoNakamaModule) ChannelMessageSend(ctx context.Context, channelId string, content map[string]interface{}, ...) (*rtapi.ChannelMessageAck, error)

+ func (n *RuntimeGoNakamaModule) UsersGetRandom(ctx context.Context, count int) ([]*api.User, error)

v3.4.0

Jul 8, 2021

Changes in this version

+ var OperatorIntToEnum = map[int]api.Operator

+ func LeaderboardList(logger *zap.Logger, leaderboardCache LeaderboardCache, ...) (*api.LeaderboardList, error)

+ func LeaderboardsGet(leaderboardCache LeaderboardCache, leaderboardIDs []string) []*api.Leaderboard

+ func RedirectStdLog(logger *zap.Logger)

type LeaderboardCache

+ List func(categoryStart, categoryEnd, limit int, cursor *LeaderboardListCursor) ([]*Leaderboard, *LeaderboardListCursor, error)

+ type LeaderboardListCursor = TournamentListCursor

type LocalLeaderboardCache

+ func (l *LocalLeaderboardCache) List(categoryStart, categoryEnd, limit int, cursor *LeaderboardListCursor) ([]*Leaderboard, *LeaderboardListCursor, error)

type Metrics

+ func (m *Metrics) CustomCounter(name string, tags map[string]string, delta int64)

+ func (m *Metrics) CustomGauge(name string, tags map[string]string, value float64)

+ func (m *Metrics) CustomTimer(name string, tags map[string]string, value time.Duration)

type MetricsConfig

+ CustomPrefix string

+ type RedirectStdLogWriter struct

+ func (r *RedirectStdLogWriter) Write(p []byte) (int, error)

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) GroupsList(ctx context.Context, name, langTag string, members *int, open *bool, limit int, ...) ([]*api.Group, string, error)

+ func (n *RuntimeGoNakamaModule) LeaderboardList(categoryStart, categoryEnd, limit int, cursor string) (*api.LeaderboardList, error)

+ func (n *RuntimeGoNakamaModule) LeaderboardsGetId(ctx context.Context, IDs []string) ([]*api.Leaderboard, error)

+ func (n *RuntimeGoNakamaModule) MetricsCounterAdd(name string, tags map[string]string, delta int64)

+ func (n *RuntimeGoNakamaModule) MetricsGaugeSet(name string, tags map[string]string, value float64)

+ func (n *RuntimeGoNakamaModule) MetricsTimerRecord(name string, tags map[string]string, value time.Duration)

type Session

+ Lang func() string

v3.3.0

May 17, 2021

Changes in this version

+ const LeaderboardOperatorDecrement

+ var API_PREFIX_LOWERCASE = strings.ToLower(API_PREFIX)

+ var ErrInvalidOperator = errors.New("invalid operator")

+ var RTAPI_PREFIX_LOWERCASE = strings.ToLower(RTAPI_PREFIX)

+ func RuntimeJsConvertJsValue(jv interface{}) interface

v3.2.1

Apr 18, 2021

v3.2.0

Apr 14, 2021

Changes in this version

+ var ErrPurchasesListInvalidCursor = errors.New("purchases list cursor invalid")

+ var ErrRefreshTokenInvalid = errors.New("refresh token invalid")

+ var ErrSessionTokenInvalid = errors.New("session token invalid")

+ func GetPurchaseByTransactionID(ctx context.Context, logger *zap.Logger, db *sql.DB, transactionID string) (string, *api.ValidatedPurchase, error)

+ func ListPurchases(ctx context.Context, logger *zap.Logger, db *sql.DB, userID string, limit int, ...) (*api.PurchaseList, error)

+ func SessionLogout(config Config, sessionCache SessionCache, userID uuid.UUID, ...) error

+ func ValidatePurchaseGoogle(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.ValidatePurchaseResponse, error)

+ func ValidatePurchaseHuawei(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.ValidatePurchaseResponse, error)

+ func ValidatePurchasesApple(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.ValidatePurchaseResponse, error)

type ApiServer

+ func (s *ApiServer) SessionLogout(ctx context.Context, in *api.SessionLogoutRequest) (*empty.Empty, error)

+ func (s *ApiServer) ValidatePurchaseApple(ctx context.Context, in *api.ValidatePurchaseAppleRequest) (*api.ValidatePurchaseResponse, error)

+ func (s *ApiServer) ValidatePurchaseGoogle(ctx context.Context, in *api.ValidatePurchaseGoogleRequest) (*api.ValidatePurchaseResponse, error)

+ func (s *ApiServer) ValidatePurchaseHuawei(ctx context.Context, in *api.ValidatePurchaseHuaweiRequest) (*api.ValidatePurchaseResponse, error)

type Config

+ GetIAP func() *IAPConfig

type ConsoleServer

+ func (s *ConsoleServer) ListPurchases(ctx context.Context, in *console.ListPurchasesRequest) (*api.PurchaseList, error)

+ type IAPAppleConfig struct

+ SharedPassword string

+ type IAPConfig struct

+ Apple *IAPAppleConfig

+ Google *IAPGoogleConfig

+ Huawei *IAPHuaweiConfig

+ func NewIAPConfig() *IAPConfig

+ type IAPGoogleConfig struct

+ ClientEmail string

+ PrivateKey string

+ type IAPHuaweiConfig struct

+ ClientID string

+ ClientSecret string

+ PublicKey string

+ type LocalSessionCache struct

+ func (s *LocalSessionCache) Add(userID uuid.UUID, sessionExp int64, sessionToken string, refreshExp int64, ...)

+ func (s *LocalSessionCache) Ban(userIDs []uuid.UUID)

+ func (s *LocalSessionCache) IsValidRefresh(userID uuid.UUID, exp int64, token string) bool

+ func (s *LocalSessionCache) IsValidSession(userID uuid.UUID, exp int64, token string) bool

+ func (s *LocalSessionCache) Remove(userID uuid.UUID, sessionExp int64, sessionToken string, refreshExp int64, ...)

+ func (s *LocalSessionCache) RemoveAll(userID uuid.UUID)

+ func (s *LocalSessionCache) Stop()

+ func (s *LocalSessionCache) Unban(userIDs []uuid.UUID)

type MatchDataMessage

+ func (m *MatchDataMessage) GetReason() runtime.PresenceReason

type MatchPresence

+ Reason runtime.PresenceReason

+ func (p *MatchPresence) GetReason() runtime.PresenceReason

type MatchmakerConfig

+ BatchPoolSize int

type MatchmakerPresence

+ func (p *MatchmakerPresence) GetReason() runtime.PresenceReason

type Presence

+ func (p *Presence) GetReason() runtime.PresenceReason

type PresenceMeta

+ Reason uint32

+ func (pm *PresenceMeta) GetReason() runtime.PresenceReason

type Runtime

+ func (r *Runtime) AfterSessionLogout() RuntimeAfterSessionLogoutFunction

+ func (r *Runtime) AfterValidatePurchaseApple() RuntimeAfterValidatePurchaseAppleFunction

+ func (r *Runtime) AfterValidatePurchaseGoogle() RuntimeAfterValidatePurchaseGoogleFunction

+ func (r *Runtime) AfterValidatePurchaseHuawei() RuntimeAfterValidatePurchaseHuaweiFunction

+ func (r *Runtime) BeforeSessionLogout() RuntimeBeforeSessionLogoutFunction

+ func (r *Runtime) BeforeValidatePurchaseApple() RuntimeBeforeValidatePurchaseAppleFunction

+ func (r *Runtime) BeforeValidatePurchaseGoogle() RuntimeBeforeValidatePurchaseGoogleFunction

+ func (r *Runtime) BeforeValidatePurchaseHuawei() RuntimeBeforeValidatePurchaseHuaweiFunction

+ type RuntimeAfterSessionLogoutFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterValidatePurchaseAppleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterValidatePurchaseGoogleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterValidatePurchaseHuaweiFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeBeforeSessionLogoutFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.SessionLogoutRequest, error, codes.Code)

+ type RuntimeBeforeValidatePurchaseAppleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ValidatePurchaseAppleRequest, error, codes.Code)

+ type RuntimeBeforeValidatePurchaseGoogleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ValidatePurchaseGoogleRequest, error, codes.Code)

+ type RuntimeBeforeValidatePurchaseHuaweiFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ValidatePurchaseHuaweiRequest, error, codes.Code)

type RuntimeGoInitializer

+ func (ri *RuntimeGoInitializer) RegisterAfterSessionLogout(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterValidatePurchaseApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterValidatePurchaseGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterValidatePurchaseHuawei(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeSessionLogout(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeValidatePurchaseApple(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeValidatePurchaseGoogle(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeValidatePurchaseHuawei(...) error

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) PurchaseGetByTransactionId(ctx context.Context, transactionID string) (string, *api.ValidatedPurchase, error)

+ func (n *RuntimeGoNakamaModule) PurchaseValidateApple(ctx context.Context, userID, receipt string) (*api.ValidatePurchaseResponse, error)

+ func (n *RuntimeGoNakamaModule) PurchaseValidateGoogle(ctx context.Context, userID, receipt string) (*api.ValidatePurchaseResponse, error)

+ func (n *RuntimeGoNakamaModule) PurchaseValidateHuawei(ctx context.Context, userID, signature, inAppPurchaseData string) (*api.ValidatePurchaseResponse, error)

+ func (n *RuntimeGoNakamaModule) PurchasesList(ctx context.Context, userID string, limit int, cursor string) (*api.PurchaseList, error)

+ func (n *RuntimeGoNakamaModule) SessionLogout(userID, token, refreshToken string) error

+ type SessionCache interface

+ Add func(userID uuid.UUID, sessionExp int64, sessionToken string, refreshExp int64, ...)

+ Ban func(userIDs []uuid.UUID)

+ IsValidRefresh func(userID uuid.UUID, exp int64, token string) bool

+ IsValidSession func(userID uuid.UUID, exp int64, token string) bool

+ Remove func(userID uuid.UUID, sessionExp int64, sessionToken string, refreshExp int64, ...)

+ RemoveAll func(userID uuid.UUID)

+ Stop func()

+ Unban func(userIDs []uuid.UUID)

+ func NewLocalSessionCache(config Config) SessionCache

type SocialConfig

+ FacebookLimitedLogin *SocialConfigFacebookLimitedLogin

+ type SocialConfigFacebookLimitedLogin struct

+ AppId string

v3.1.2

Mar 3, 2021

Changes in this version

type MatchConfig

+ LabelUpdateIntervalMs int

type MatchHandler

+ func (mh *MatchHandler) CreateTime() int64

+ func (mh *MatchHandler) HandlerName() string

+ func (mh *MatchHandler) TickRate() int

type MatchIndexEntry

+ CreateTime int64

type RuntimeGoMatchCore

+ func (r *RuntimeGoMatchCore) CreateTime() int64

+ func (r *RuntimeGoMatchCore) TickRate() int

type RuntimeJavaScriptMatchCore

+ func (rm *RuntimeJavaScriptMatchCore) CreateTime() int64

+ func (rm *RuntimeJavaScriptMatchCore) TickRate() int

type RuntimeLuaMatchCore

+ func (r *RuntimeLuaMatchCore) CreateTime() int64

+ func (r *RuntimeLuaMatchCore) TickRate() int

type RuntimeMatchCore

+ CreateTime func() int64

+ TickRate func() int

v3.1.1

Feb 15, 2021

Changes in this version

+ type StatusRegistry struct

+ func NewStatusRegistry(logger *zap.Logger, config Config, sessionRegistry SessionRegistry, ...) *StatusRegistry

+ func (s *StatusRegistry) Follow(sessionID uuid.UUID, userIDs map[uuid.UUID]struct{})

+ func (s *StatusRegistry) Queue(userID uuid.UUID, joins, leaves []*rtapi.UserPresence)

+ func (s *StatusRegistry) Stop()

+ func (s *StatusRegistry) Unfollow(sessionID uuid.UUID, userIDs []uuid.UUID)

+ func (s *StatusRegistry) UnfollowAll(sessionID uuid.UUID)

v3.1.0

Feb 4, 2021

Changes in this version

+ const MatchInit

+ const MatchJoin

+ const MatchJoinAttempt

+ const MatchLeave

+ const MatchLoop

+ const MatchTerminate

type ApiServer

+ func (s *ApiServer) ImportSteamFriends(ctx context.Context, in *api.ImportSteamFriendsRequest) (*empty.Empty, error)

type LocalTracker

+ func (t *LocalTracker) TrackMulti(ctx context.Context, sessionID uuid.UUID, ops []*TrackerOp, userID uuid.UUID, ...) bool

+ func (t *LocalTracker) UntrackMulti(sessionID uuid.UUID, streams []*PresenceStream, userID uuid.UUID)

+ type MatchFnId string

type MatchPresenceList

+ func (m *MatchPresenceList) FilterPresenceIDs(ids []*PresenceID) []*PresenceID

type Runtime

+ func (r *Runtime) AfterImportSteamFriends() RuntimeAfterImportSteamFriendsFunction

+ func (r *Runtime) BeforeImportSteamFriends() RuntimeBeforeImportSteamFriendsFunction

+ type RuntimeAfterImportSteamFriendsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeBeforeImportSteamFriendsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ImportSteamFriendsRequest, error, codes.Code)

type RuntimeGoInitializer

+ func (ri *RuntimeGoInitializer) RegisterAfterImportSteamFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeImportSteamFriends(...) error

type RuntimeJSModule

+ Ast *ast.Program

+ type RuntimeJavascriptLocalCache struct

+ func NewRuntimeJavascriptLocalCache() *RuntimeJavascriptLocalCache

+ func (lc *RuntimeJavascriptLocalCache) Delete(key string)

+ func (lc *RuntimeJavascriptLocalCache) Get(key string) (goja.Value, bool)

+ func (lc *RuntimeJavascriptLocalCache) Put(key string, value goja.Value)

type Tracker

+ TrackMulti func(ctx context.Context, sessionID uuid.UUID, ops []*TrackerOp, userID uuid.UUID, ...) bool

+ UntrackMulti func(sessionID uuid.UUID, streams []*PresenceStream, userID uuid.UUID)

+ type TrackerOp struct

+ Meta PresenceMeta

+ Stream PresenceStream

v3.0.0

Jan 16, 2021

Changes in this version

+ const API_PREFIX

+ const ChannelMessageTypeChat

+ const ChannelMessageTypeChatRemove

+ const ChannelMessageTypeChatUpdate

+ const ChannelMessageTypeGroupAdd

+ const ChannelMessageTypeGroupBan

+ const ChannelMessageTypeGroupDemote

+ const ChannelMessageTypeGroupJoin

+ const ChannelMessageTypeGroupKick

+ const ChannelMessageTypeGroupLeave

+ const ChannelMessageTypeGroupPromote

+ const INIT_MODULE_FN_NAME

+ const JsEntrypointFilename

+ const LTSentinel

+ const LeaderboardOperatorBest

+ const LeaderboardOperatorIncrement

+ const LeaderboardOperatorSet

+ const LeaderboardSortOrderAscending

+ const LeaderboardSortOrderDescending

+ const NotificationCodeDmRequest

+ const NotificationCodeFriendAccept

+ const NotificationCodeFriendJoinGame

+ const NotificationCodeFriendRequest

+ const NotificationCodeGroupAdd

+ const NotificationCodeGroupJoinRequest

+ const ObfuscationString

+ const RTAPI_PREFIX

+ const StreamModeChannel

+ const StreamModeDM

+ const StreamModeGroup

+ const StreamModeMatchAuthoritative

+ const StreamModeMatchRelayed

+ const StreamModeNotifications

+ const StreamModeParty

+ const StreamModeStatus

+ var Bit32Default64 = int64(math.Pow(2, 32) - 1)

+ var Bit32LibName = "bit32"

+ var ErrAccountNotFound = errors.New("account not found")

+ var ErrCannotEncodeParams = errors.New("error creating match: cannot encode params")

+ var ErrChannelCursorInvalid = errors.New("invalid channel cursor")

+ var ErrChannelGroupNotFound = errors.New("group not found")

+ var ErrChannelIDInvalid = errors.New("invalid channel id")

+ var ErrChannelMessageUpdateNotFound = errors.New("channel message not found")

+ var ErrDeferredBroadcastFull = errors.New("too many deferred message broadcasts per tick")

+ var ErrFriendInvalidCursor = errors.New("friend cursor invalid")

+ var ErrGroupFull = errors.New("group is full")

+ var ErrGroupLastSuperadmin = errors.New("user is last group superadmin")

+ var ErrGroupNameInUse = errors.New("group name in use")

+ var ErrGroupNoUpdateOps = errors.New("no group updates")

+ var ErrGroupNotFound = errors.New("group not found")

+ var ErrGroupNotUpdated = errors.New("group not updated")

+ var ErrGroupPermissionDenied = errors.New("group permission denied")

+ var ErrGroupUserInvalidCursor = errors.New("group user cursor invalid")

+ var ErrGroupUserNotFound = errors.New("user not found")

+ var ErrLeaderboardAuthoritative = errors.New("leaderboard only allows authoritative submissions")

+ var ErrLeaderboardInvalidCursor = errors.New("leaderboard cursor invalid")

+ var ErrLeaderboardNotFound = errors.New("leaderboard not found")

+ var ErrMatchIdInvalid = errors.New("match id invalid")

+ var ErrMatchLabelTooLong = errors.New("match label too long, must be 0-2048 bytes")

+ var ErrMatchNotFound = errors.New("match not found")

+ var ErrMatchStateFailed = errors.New("match did not return state")

+ var ErrMatchStopped = errors.New("match stopped")

+ var ErrMatchmakerDelete = errors.New("matchmaker delete error")

+ var ErrMatchmakerDuplicateSession = errors.New("matchmaker duplicate session")

+ var ErrMatchmakerIndex = errors.New("matchmaker index error")

+ var ErrMatchmakerNotAvailable = errors.New("matchmaker not available")

+ var ErrMatchmakerQueryInvalid = errors.New("matchmaker query invalid")

+ var ErrMatchmakerTicketNotFound = errors.New("matchmaker ticket not found")

+ var ErrMatchmakerTooManyTickets = errors.New("matchmaker too many tickets")

+ var ErrNodeNotFound = errors.New("node not found")

+ var ErrPartyAcceptRequest = errors.New("party could not accept request")

+ var ErrPartyClosed = errors.New("party closed")

+ var ErrPartyFull = errors.New("party full")

+ var ErrPartyJoinRequestsFull = errors.New("party join requests full")

+ var ErrPartyNotFound = errors.New("party not found")

+ var ErrPartyNotLeader = errors.New("party leader only")

+ var ErrPartyNotMember = errors.New("party member not found")

+ var ErrPartyNotRequest = errors.New("party join request not found")

+ var ErrPartyRemove = errors.New("party could not remove")

+ var ErrPartyRemoveSelf = errors.New("party cannot remove self")

+ var ErrRowsAffectedCount = errors.New("rows_affected_count")

+ var ErrRuntimeRPCNotFound = errors.New("RPC function not found")

+ var ErrSessionNotFound = errors.New("session not found")

+ var ErrSessionQueueFull = errors.New("session outgoing queue full")

+ var ErrStorageRejectedPermission = errors.New("Storage write rejected - permission denied.")

+ var ErrStorageRejectedVersion = errors.New("Storage write rejected - version check failed.")

+ var ErrTournamentMaxSizeReached = errors.New("tournament max size reached")

+ var ErrTournamentNotFound = errors.New("tournament not found")

+ var ErrTournamentOutsideDuration = errors.New("tournament outside of duration")

+ var ErrTournamentWriteJoinRequired = errors.New("required to join before writing tournament record")

+ var ErrTournamentWriteMaxNumScoreReached = errors.New("max number score count reached")

+ var ErrUserGroupInvalidCursor = errors.New("user group cursor invalid")

+ var ErrWalletLedgerInvalidCursor = errors.New("wallet ledger cursor invalid")

+ var LSentinel = lua.LValue(&LSentinelType{})

+ var MatchFilterPtr = &MatchFilterValue

+ var MatchFilterRelayed = map[uint8]*uint8

+ var MatchFilterValue = uint8(0)

+ var MatchLabelMaxBytes = 2048

+ func AddFriends(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error

+ func AddGroupUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error

+ func AuthenticateApple(ctx context.Context, logger *zap.Logger, db *sql.DB, client *social.Client, ...) (string, string, bool, error)

+ func AuthenticateCustom(ctx context.Context, logger *zap.Logger, db *sql.DB, customID, username string, ...) (string, string, bool, error)

+ func AuthenticateDevice(ctx context.Context, logger *zap.Logger, db *sql.DB, deviceID, username string, ...) (string, string, bool, error)

+ func AuthenticateEmail(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) (string, string, bool, error)

+ func AuthenticateFacebook(ctx context.Context, logger *zap.Logger, db *sql.DB, client *social.Client, ...) (string, string, bool, error)

+ func AuthenticateFacebookInstantGame(ctx context.Context, logger *zap.Logger, db *sql.DB, client *social.Client, ...) (string, string, bool, error)

+ func AuthenticateGameCenter(ctx context.Context, logger *zap.Logger, db *sql.DB, client *social.Client, ...) (string, string, bool, error)

+ func AuthenticateGoogle(ctx context.Context, logger *zap.Logger, db *sql.DB, client *social.Client, ...) (string, string, bool, error)

+ func AuthenticateSteam(ctx context.Context, logger *zap.Logger, db *sql.DB, client *social.Client, ...) (string, string, bool, error)

+ func AuthenticateUsername(ctx context.Context, logger *zap.Logger, db *sql.DB, username, password string) (string, error)

+ func BanGroupUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error

+ func BanUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, ids []string) error

+ func BlockFriends(ctx context.Context, logger *zap.Logger, db *sql.DB, currentUser uuid.UUID, ...) error

+ func ChannelMessagesList(ctx context.Context, logger *zap.Logger, db *sql.DB, caller uuid.UUID, ...) (*api.ChannelMessageList, error)

+ func CheckConfig(logger *zap.Logger, config Config) map[string]string

+ func CheckRuntime(logger *zap.Logger, config Config) error

+ func CheckRuntimeProviderGo(logger *zap.Logger, rootPath string, paths []string) error

+ func CheckRuntimeProviderJavascript(logger *zap.Logger, config Config) error

+ func CheckRuntimeProviderLua(logger *zap.Logger, config Config, paths []string) error

+ func CreateGroup(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.Group, error)

+ func DeleteAccount(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) error

+ func DeleteFriends(ctx context.Context, logger *zap.Logger, db *sql.DB, currentUser uuid.UUID, ...) error

+ func DeleteGroup(ctx context.Context, logger *zap.Logger, db *sql.DB, groupID uuid.UUID, ...) error

+ func DeleteUser(ctx context.Context, tx *sql.Tx, userID uuid.UUID) (int64, error)

+ func DemoteGroupUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error

+ func ExecuteInTx(ctx context.Context, tx Tx, fn func() error) (err error)

+ func ExecuteRetryable(fn func() error) error

+ func ExportAccount(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID) (*console.AccountExport, error)

+ func FileRead(rootPath, relPath string) (*os.File, error)

+ func GetAccount(ctx context.Context, logger *zap.Logger, db *sql.DB, tracker Tracker, ...) (*api.Account, error)

+ func GetAccounts(ctx context.Context, logger *zap.Logger, db *sql.DB, tracker Tracker, ...) ([]*api.Account, error)

+ func GetChannelMessages(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID) ([]*api.ChannelMessage, error)

+ func GetFriendIDs(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID) (*api.FriendList, error)

+ func GetGroups(ctx context.Context, logger *zap.Logger, db *sql.DB, ids []string) ([]*api.Group, error)

+ func GetRuntimePaths(logger *zap.Logger, rootPath string) ([]string, error)

+ func GetUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, tracker Tracker, ...) (*api.Users, error)

+ func GroupDeleteAll(ctx context.Context, logger *zap.Logger, tx *sql.Tx, userID uuid.UUID) error

+ func HashFromId(id uuid.UUID) [6]byte

+ func JoinGroup(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error

+ func KickGroupUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error

+ func LeaderboardRecordDelete(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error

+ func LeaderboardRecordReadAll(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID) ([]*api.LeaderboardRecord, error)

+ func LeaderboardRecordWrite(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) (*api.LeaderboardRecord, error)

+ func LeaderboardRecordsDeleteAll(ctx context.Context, logger *zap.Logger, tx *sql.Tx, userID uuid.UUID) error

+ func LeaderboardRecordsHaystack(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) ([]*api.LeaderboardRecord, error)

+ func LeaderboardRecordsList(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) (*api.LeaderboardRecordList, error)

+ func LeaveGroup(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error

+ func LinkApple(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) error

+ func LinkCustom(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) error

+ func LinkDevice(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) error

+ func LinkEmail(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) error

+ func LinkFacebook(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error

+ func LinkFacebookInstantGame(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) error

+ func LinkGameCenter(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error

+ func LinkGoogle(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error

+ func LinkSteam(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) error

+ func ListFriends(ctx context.Context, logger *zap.Logger, db *sql.DB, tracker Tracker, ...) (*api.FriendList, error)

+ func ListGroupUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, tracker Tracker, ...) (*api.GroupUserList, error)

+ func ListGroups(ctx context.Context, logger *zap.Logger, db *sql.DB, name string, limit int, ...) (*api.GroupList, error)

+ func ListUserGroups(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.UserGroupList, error)

+ func ListWalletLedger(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) ([]*walletLedger, string, error)

+ func MultiUpdate(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) ([]*api.StorageObjectAck, []*runtime.WalletUpdateResult, error)

+ func NewConfig(logger *zap.Logger) *config

+ func NewJSONFileLogger(consoleLogger *zap.Logger, fileName string, level zapcore.Level, ...) *zap.Logger

+ func NewJSONLogger(output *os.File, level zapcore.Level, format LoggingFormat) *zap.Logger

+ func NewJsLogger(logger *zap.Logger) *jsLogger

+ func NewMultiLogger(loggers ...*zap.Logger) *zap.Logger

+ func NewRotatingJSONFileLogger(consoleLogger *zap.Logger, config Config, level zapcore.Level, ...) *zap.Logger

+ func NewRuntime(logger, startupLogger *zap.Logger, db *sql.DB, ...) (*Runtime, *RuntimeInfo, error)

+ func NewRuntimeGoContext(ctx context.Context, node string, env map[string]string, ...) context.Context

+ func NewRuntimeGoLogger(logger *zap.Logger) nkruntime.Logger

+ func NewRuntimeJavascriptNakamaModule(logger *zap.Logger, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, ...) *runtimeJavascriptNakamaModule

+ func NewRuntimeJsContext(r *goja.Runtime, node string, env goja.Value, mode RuntimeExecutionMode, ...) *goja.Object

+ func NewRuntimeJsInitContext(r *goja.Runtime, node string, env map[string]string) *goja.Object

+ func NewRuntimeLuaContext(l *lua.LState, node string, env *lua.LTable, mode RuntimeExecutionMode, ...) *lua.LTable

+ func NewRuntimeProviderGo(logger, startupLogger *zap.Logger, db *sql.DB, ...) ([]string, map[string]RuntimeRpcFunction, map[string]RuntimeBeforeRtFunction, ...)

+ func NewRuntimeProviderJS(logger, startupLogger *zap.Logger, db *sql.DB, ...) ([]string, map[string]RuntimeRpcFunction, map[string]RuntimeBeforeRtFunction, ...)

+ func NewRuntimeProviderLua(logger, startupLogger *zap.Logger, db *sql.DB, ...) ([]string, map[string]RuntimeRpcFunction, map[string]RuntimeBeforeRtFunction, ...)

+ func NewSocketWsAcceptor(logger *zap.Logger, config Config, sessionRegistry SessionRegistry, ...) func(http.ResponseWriter, *http.Request)

+ func NodeToHash(node string) [6]byte

+ func NotificationDelete(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) error

+ func NotificationList(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.NotificationList, error)

+ func NotificationSave(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error

+ func NotificationSend(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error

+ func OpenBit32(l *lua.LState) int

+ func OpenOs(L *lua.LState) int

+ func OpenPackage(moduleCache *RuntimeLuaModuleCache) func(L *lua.LState) int

+ func PromoteGroupUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error

+ func RuntimeLuaConvertLuaTable(lv *lua.LTable) map[string]interface

+ func RuntimeLuaConvertLuaValue(lv lua.LValue) interface

+ func RuntimeLuaConvertMap(l *lua.LState, data map[string]interface{}) *lua.LTable

+ func RuntimeLuaConvertMapInt64(l *lua.LState, data map[string]int64) *lua.LTable

+ func RuntimeLuaConvertMapString(l *lua.LState, data map[string]string) *lua.LTable

+ func RuntimeLuaConvertValue(l *lua.LState, val interface{}) lua.LValue

+ func SessionRefresh(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) (string, string, map[string]string, error)

+ func SetupLogging(tmpLogger *zap.Logger, config Config) (*zap.Logger, *zap.Logger)

+ func StackdriverLevelEncoder(l zapcore.Level, enc zapcore.PrimitiveArrayEncoder)

+ func StatusError(code codes.Code, msg string, cause error) error

+ func StorageDeleteObjects(ctx context.Context, logger *zap.Logger, db *sql.DB, authoritativeDelete bool, ...) (codes.Code, error)

+ func StorageListObjects(ctx context.Context, logger *zap.Logger, db *sql.DB, caller uuid.UUID, ...) (*api.StorageObjectList, codes.Code, error)

+ func StorageListObjectsAll(ctx context.Context, logger *zap.Logger, db *sql.DB, authoritative bool, ...) (*api.StorageObjectList, error)

+ func StorageListObjectsPublicReadUser(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.StorageObjectList, error)

+ func StorageListObjectsUser(ctx context.Context, logger *zap.Logger, db *sql.DB, authoritative bool, ...) (*api.StorageObjectList, error)

+ func StorageReadAllUserObjects(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID) ([]*api.StorageObject, error)

+ func StorageReadObjects(ctx context.Context, logger *zap.Logger, db *sql.DB, caller uuid.UUID, ...) (*api.StorageObjects, error)

+ func StorageWriteObjects(ctx context.Context, logger *zap.Logger, db *sql.DB, authoritativeWrite bool, ...) (*api.StorageObjectAcks, codes.Code, error)

+ func StreamToChannelId(stream PresenceStream) (string, error)

+ func TournamentAddAttempt(ctx context.Context, logger *zap.Logger, db *sql.DB, cache LeaderboardCache, ...) error

+ func TournamentCreate(ctx context.Context, logger *zap.Logger, cache LeaderboardCache, ...) error

+ func TournamentDelete(ctx context.Context, cache LeaderboardCache, rankCache LeaderboardRankCache, ...) error

+ func TournamentJoin(ctx context.Context, logger *zap.Logger, db *sql.DB, cache LeaderboardCache, ...) error

+ func TournamentList(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) (*api.TournamentList, error)

+ func TournamentRecordWrite(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) (*api.LeaderboardRecord, error)

+ func TournamentRecordsHaystack(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) ([]*api.LeaderboardRecord, error)

+ func TournamentRecordsList(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) (*api.TournamentRecordList, error)

+ func TournamentsGet(ctx context.Context, logger *zap.Logger, db *sql.DB, tournamentIDs []string) ([]*api.Tournament, error)

+ func UnbanUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, ids []string) error

+ func UnlinkApple(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) error

+ func UnlinkCustom(ctx context.Context, logger *zap.Logger, db *sql.DB, id uuid.UUID, ...) error

+ func UnlinkDevice(ctx context.Context, logger *zap.Logger, db *sql.DB, id uuid.UUID, ...) error

+ func UnlinkEmail(ctx context.Context, logger *zap.Logger, db *sql.DB, id uuid.UUID, ...) error

+ func UnlinkFacebook(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error

+ func UnlinkFacebookInstantGame(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) error

+ func UnlinkGameCenter(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error

+ func UnlinkGoogle(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error

+ func UnlinkSteam(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) error

+ func UpdateAccounts(ctx context.Context, logger *zap.Logger, db *sql.DB, updates []*accountUpdate) error

+ func UpdateGroup(ctx context.Context, logger *zap.Logger, db *sql.DB, groupID uuid.UUID, ...) error

+ func UpdateWalletLedger(ctx context.Context, logger *zap.Logger, db *sql.DB, id uuid.UUID, ...) (*walletLedger, error)

+ func UpdateWallets(ctx context.Context, logger *zap.Logger, db *sql.DB, updates []*walletUpdate, ...) ([]*runtime.WalletUpdateResult, error)

+ func UserExistsAndDoesNotBlock(ctx context.Context, db *sql.DB, checkUserID, blocksUserID uuid.UUID) (bool, error)

+ type AmbiguousCommitError struct

+ func (e *AmbiguousCommitError) Cause() error

+ func (e *AmbiguousCommitError) Error() string

+ type ApiServer struct

+ func StartApiServer(logger *zap.Logger, startupLogger *zap.Logger, db *sql.DB, ...) *ApiServer

+ func (s *ApiServer) AddFriends(ctx context.Context, in *api.AddFriendsRequest) (*empty.Empty, error)

+ func (s *ApiServer) AddGroupUsers(ctx context.Context, in *api.AddGroupUsersRequest) (*empty.Empty, error)

+ func (s *ApiServer) AuthenticateApple(ctx context.Context, in *api.AuthenticateAppleRequest) (*api.Session, error)

+ func (s *ApiServer) AuthenticateCustom(ctx context.Context, in *api.AuthenticateCustomRequest) (*api.Session, error)

+ func (s *ApiServer) AuthenticateDevice(ctx context.Context, in *api.AuthenticateDeviceRequest) (*api.Session, error)

+ func (s *ApiServer) AuthenticateEmail(ctx context.Context, in *api.AuthenticateEmailRequest) (*api.Session, error)

+ func (s *ApiServer) AuthenticateFacebook(ctx context.Context, in *api.AuthenticateFacebookRequest) (*api.Session, error)

+ func (s *ApiServer) AuthenticateFacebookInstantGame(ctx context.Context, in *api.AuthenticateFacebookInstantGameRequest) (*api.Session, error)

+ func (s *ApiServer) AuthenticateGameCenter(ctx context.Context, in *api.AuthenticateGameCenterRequest) (*api.Session, error)

+ func (s *ApiServer) AuthenticateGoogle(ctx context.Context, in *api.AuthenticateGoogleRequest) (*api.Session, error)

+ func (s *ApiServer) AuthenticateSteam(ctx context.Context, in *api.AuthenticateSteamRequest) (*api.Session, error)

+ func (s *ApiServer) BanGroupUsers(ctx context.Context, in *api.BanGroupUsersRequest) (*empty.Empty, error)

+ func (s *ApiServer) BlockFriends(ctx context.Context, in *api.BlockFriendsRequest) (*empty.Empty, error)

+ func (s *ApiServer) CreateGroup(ctx context.Context, in *api.CreateGroupRequest) (*api.Group, error)

+ func (s *ApiServer) DeleteFriends(ctx context.Context, in *api.DeleteFriendsRequest) (*empty.Empty, error)

+ func (s *ApiServer) DeleteGroup(ctx context.Context, in *api.DeleteGroupRequest) (*empty.Empty, error)

+ func (s *ApiServer) DeleteLeaderboardRecord(ctx context.Context, in *api.DeleteLeaderboardRecordRequest) (*empty.Empty, error)

+ func (s *ApiServer) DeleteNotifications(ctx context.Context, in *api.DeleteNotificationsRequest) (*empty.Empty, error)

+ func (s *ApiServer) DeleteStorageObjects(ctx context.Context, in *api.DeleteStorageObjectsRequest) (*empty.Empty, error)

+ func (s *ApiServer) DemoteGroupUsers(ctx context.Context, in *api.DemoteGroupUsersRequest) (*empty.Empty, error)

+ func (s *ApiServer) Event(ctx context.Context, in *api.Event) (*empty.Empty, error)

+ func (s *ApiServer) GetAccount(ctx context.Context, in *empty.Empty) (*api.Account, error)

+ func (s *ApiServer) GetUsers(ctx context.Context, in *api.GetUsersRequest) (*api.Users, error)

+ func (s *ApiServer) Healthcheck(ctx context.Context, in *empty.Empty) (*empty.Empty, error)

+ func (s *ApiServer) ImportFacebookFriends(ctx context.Context, in *api.ImportFacebookFriendsRequest) (*empty.Empty, error)

+ func (s *ApiServer) JoinGroup(ctx context.Context, in *api.JoinGroupRequest) (*empty.Empty, error)

+ func (s *ApiServer) JoinTournament(ctx context.Context, in *api.JoinTournamentRequest) (*empty.Empty, error)

+ func (s *ApiServer) KickGroupUsers(ctx context.Context, in *api.KickGroupUsersRequest) (*empty.Empty, error)

+ func (s *ApiServer) LeaveGroup(ctx context.Context, in *api.LeaveGroupRequest) (*empty.Empty, error)

+ func (s *ApiServer) LinkApple(ctx context.Context, in *api.AccountApple) (*empty.Empty, error)

+ func (s *ApiServer) LinkCustom(ctx context.Context, in *api.AccountCustom) (*empty.Empty, error)

+ func (s *ApiServer) LinkDevice(ctx context.Context, in *api.AccountDevice) (*empty.Empty, error)

+ func (s *ApiServer) LinkEmail(ctx context.Context, in *api.AccountEmail) (*empty.Empty, error)

+ func (s *ApiServer) LinkFacebook(ctx context.Context, in *api.LinkFacebookRequest) (*empty.Empty, error)

+ func (s *ApiServer) LinkFacebookInstantGame(ctx context.Context, in *api.AccountFacebookInstantGame) (*empty.Empty, error)

+ func (s *ApiServer) LinkGameCenter(ctx context.Context, in *api.AccountGameCenter) (*empty.Empty, error)

+ func (s *ApiServer) LinkGoogle(ctx context.Context, in *api.AccountGoogle) (*empty.Empty, error)

+ func (s *ApiServer) LinkSteam(ctx context.Context, in *api.AccountSteam) (*empty.Empty, error)

+ func (s *ApiServer) ListChannelMessages(ctx context.Context, in *api.ListChannelMessagesRequest) (*api.ChannelMessageList, error)

+ func (s *ApiServer) ListFriends(ctx context.Context, in *api.ListFriendsRequest) (*api.FriendList, error)

+ func (s *ApiServer) ListGroupUsers(ctx context.Context, in *api.ListGroupUsersRequest) (*api.GroupUserList, error)

+ func (s *ApiServer) ListGroups(ctx context.Context, in *api.ListGroupsRequest) (*api.GroupList, error)

+ func (s *ApiServer) ListLeaderboardRecords(ctx context.Context, in *api.ListLeaderboardRecordsRequest) (*api.LeaderboardRecordList, error)

+ func (s *ApiServer) ListLeaderboardRecordsAroundOwner(ctx context.Context, in *api.ListLeaderboardRecordsAroundOwnerRequest) (*api.LeaderboardRecordList, error)

+ func (s *ApiServer) ListMatches(ctx context.Context, in *api.ListMatchesRequest) (*api.MatchList, error)

+ func (s *ApiServer) ListNotifications(ctx context.Context, in *api.ListNotificationsRequest) (*api.NotificationList, error)

+ func (s *ApiServer) ListStorageObjects(ctx context.Context, in *api.ListStorageObjectsRequest) (*api.StorageObjectList, error)

+ func (s *ApiServer) ListTournamentRecords(ctx context.Context, in *api.ListTournamentRecordsRequest) (*api.TournamentRecordList, error)

+ func (s *ApiServer) ListTournamentRecordsAroundOwner(ctx context.Context, in *api.ListTournamentRecordsAroundOwnerRequest) (*api.TournamentRecordList, error)

+ func (s *ApiServer) ListTournaments(ctx context.Context, in *api.ListTournamentsRequest) (*api.TournamentList, error)

+ func (s *ApiServer) ListUserGroups(ctx context.Context, in *api.ListUserGroupsRequest) (*api.UserGroupList, error)

+ func (s *ApiServer) PromoteGroupUsers(ctx context.Context, in *api.PromoteGroupUsersRequest) (*empty.Empty, error)

+ func (s *ApiServer) ReadStorageObjects(ctx context.Context, in *api.ReadStorageObjectsRequest) (*api.StorageObjects, error)

+ func (s *ApiServer) RpcFunc(ctx context.Context, in *api.Rpc) (*api.Rpc, error)

+ func (s *ApiServer) RpcFuncHttp(w http.ResponseWriter, r *http.Request)

+ func (s *ApiServer) SessionRefresh(ctx context.Context, in *api.SessionRefreshRequest) (*api.Session, error)

+ func (s *ApiServer) Stop()

+ func (s *ApiServer) UnlinkApple(ctx context.Context, in *api.AccountApple) (*empty.Empty, error)

+ func (s *ApiServer) UnlinkCustom(ctx context.Context, in *api.AccountCustom) (*empty.Empty, error)

+ func (s *ApiServer) UnlinkDevice(ctx context.Context, in *api.AccountDevice) (*empty.Empty, error)

+ func (s *ApiServer) UnlinkEmail(ctx context.Context, in *api.AccountEmail) (*empty.Empty, error)

+ func (s *ApiServer) UnlinkFacebook(ctx context.Context, in *api.AccountFacebook) (*empty.Empty, error)

+ func (s *ApiServer) UnlinkFacebookInstantGame(ctx context.Context, in *api.AccountFacebookInstantGame) (*empty.Empty, error)

+ func (s *ApiServer) UnlinkGameCenter(ctx context.Context, in *api.AccountGameCenter) (*empty.Empty, error)

+ func (s *ApiServer) UnlinkGoogle(ctx context.Context, in *api.AccountGoogle) (*empty.Empty, error)

+ func (s *ApiServer) UnlinkSteam(ctx context.Context, in *api.AccountSteam) (*empty.Empty, error)

+ func (s *ApiServer) UpdateAccount(ctx context.Context, in *api.UpdateAccountRequest) (*empty.Empty, error)

+ func (s *ApiServer) UpdateGroup(ctx context.Context, in *api.UpdateGroupRequest) (*empty.Empty, error)

+ func (s *ApiServer) WriteLeaderboardRecord(ctx context.Context, in *api.WriteLeaderboardRecordRequest) (*api.LeaderboardRecord, error)

+ func (s *ApiServer) WriteStorageObjects(ctx context.Context, in *api.WriteStorageObjectsRequest) (*api.StorageObjectAcks, error)

+ func (s *ApiServer) WriteTournamentRecord(ctx context.Context, in *api.WriteTournamentRecordRequest) (*api.LeaderboardRecord, error)

+ type ChannelIdToStreamResult struct

+ Stream PresenceStream

+ func ChannelIdToStream(channelID string) (*ChannelIdToStreamResult, error)

+ type Config interface

+ Clone func() (Config, error)

+ GetConsole func() *ConsoleConfig

+ GetDataDir func() string

+ GetDatabase func() *DatabaseConfig

+ GetLeaderboard func() *LeaderboardConfig

+ GetLogger func() *LoggerConfig

+ GetMatch func() *MatchConfig

+ GetMatchmaker func() *MatchmakerConfig

+ GetMetrics func() *MetricsConfig

+ GetName func() string

+ GetRuntime func() *RuntimeConfig

+ GetSession func() *SessionConfig

+ GetShutdownGraceSec func() int

+ GetSocial func() *SocialConfig

+ GetSocket func() *SocketConfig

+ GetTracker func() *TrackerConfig

+ func ParseArgs(logger *zap.Logger, args []string) Config

+ type ConsoleConfig struct

+ Address string

+ IdleTimeoutMs int

+ MaxMessageSizeBytes int64

+ Password string

+ Port int

+ ReadTimeoutMs int

+ SigningKey string

+ TokenExpirySec int64

+ Username string

+ WriteTimeoutMs int

+ func NewConsoleConfig() *ConsoleConfig

+ type ConsoleServer struct

+ func StartConsoleServer(logger *zap.Logger, startupLogger *zap.Logger, db *sql.DB, config Config, ...) *ConsoleServer

+ func (s *ConsoleServer) AddUser(ctx context.Context, in *console.AddUserRequest) (*empty.Empty, error)

+ func (s *ConsoleServer) Authenticate(ctx context.Context, in *console.AuthenticateRequest) (*console.ConsoleSession, error)

+ func (s *ConsoleServer) BanAccount(ctx context.Context, in *console.AccountId) (*empty.Empty, error)

+ func (s *ConsoleServer) CallApiEndpoint(ctx context.Context, in *console.CallApiEndpointRequest) (*console.CallApiEndpointResponse, error)

+ func (s *ConsoleServer) CallRpcEndpoint(ctx context.Context, in *console.CallApiEndpointRequest) (*console.CallApiEndpointResponse, error)

+ func (s *ConsoleServer) DeleteAccount(ctx context.Context, in *console.AccountDeleteRequest) (*empty.Empty, error)

+ func (s *ConsoleServer) DeleteAccounts(ctx context.Context, in *empty.Empty) (*empty.Empty, error)

+ func (s *ConsoleServer) DeleteFriend(ctx context.Context, in *console.DeleteFriendRequest) (*empty.Empty, error)

+ func (s *ConsoleServer) DeleteGroupUser(ctx context.Context, in *console.DeleteGroupUserRequest) (*empty.Empty, error)

+ func (s *ConsoleServer) DeleteLeaderboard(ctx context.Context, in *console.LeaderboardRequest) (*empty.Empty, error)

+ func (s *ConsoleServer) DeleteLeaderboardRecord(ctx context.Context, in *console.DeleteLeaderboardRecordRequest) (*empty.Empty, error)

+ func (s *ConsoleServer) DeleteStorage(ctx context.Context, in *empty.Empty) (*empty.Empty, error)

+ func (s *ConsoleServer) DeleteStorageObject(ctx context.Context, in *console.DeleteStorageObjectRequest) (*empty.Empty, error)

+ func (s *ConsoleServer) DeleteUser(ctx context.Context, in *console.Username) (*empty.Empty, error)

+ func (s *ConsoleServer) DeleteWalletLedger(ctx context.Context, in *console.DeleteWalletLedgerRequest) (*empty.Empty, error)

+ func (s *ConsoleServer) ExportAccount(ctx context.Context, in *console.AccountId) (*console.AccountExport, error)

+ func (s *ConsoleServer) GetAccount(ctx context.Context, in *console.AccountId) (*console.Account, error)

+ func (s *ConsoleServer) GetConfig(ctx context.Context, in *empty.Empty) (*console.Config, error)

+ func (s *ConsoleServer) GetFriends(ctx context.Context, in *console.AccountId) (*api.FriendList, error)

+ func (s *ConsoleServer) GetGroups(ctx context.Context, in *console.AccountId) (*api.UserGroupList, error)

+ func (s *ConsoleServer) GetLeaderboard(ctx context.Context, in *console.LeaderboardRequest) (*console.Leaderboard, error)

+ func (s *ConsoleServer) GetMatchState(ctx context.Context, in *console.MatchStateRequest) (*console.MatchState, error)

+ func (s *ConsoleServer) GetRuntime(ctx context.Context, in *empty.Empty) (*console.RuntimeInfo, error)

+ func (s *ConsoleServer) GetStatus(ctx context.Context, in *empty.Empty) (*console.StatusList, error)

+ func (s *ConsoleServer) GetStorage(ctx context.Context, in *api.ReadStorageObjectId) (*api.StorageObject, error)

+ func (s *ConsoleServer) GetWalletLedger(ctx context.Context, in *console.AccountId) (*console.WalletLedgerList, error)

+ func (s *ConsoleServer) ListAccounts(ctx context.Context, in *console.ListAccountsRequest) (*console.AccountList, error)

+ func (s *ConsoleServer) ListApiEndpoints(ctx context.Context, _ *empty.Empty) (*console.ApiEndpointList, error)

+ func (s *ConsoleServer) ListLeaderboardRecords(ctx context.Context, in *api.ListLeaderboardRecordsRequest) (*api.LeaderboardRecordList, error)

+ func (s *ConsoleServer) ListLeaderboards(ctx context.Context, _ *empty.Empty) (*console.LeaderboardList, error)

+ func (s *ConsoleServer) ListMatches(ctx context.Context, in *api.ListMatchesRequest) (*api.MatchList, error)

+ func (s *ConsoleServer) ListStorage(ctx context.Context, in *console.ListStorageRequest) (*console.StorageList, error)

+ func (s *ConsoleServer) ListStorageCollections(ctx context.Context, in *empty.Empty) (*console.StorageCollectionsList, error)

+ func (s *ConsoleServer) ListUsers(ctx context.Context, in *empty.Empty) (*console.UserList, error)

+ func (s *ConsoleServer) Stop()

+ func (s *ConsoleServer) UnbanAccount(ctx context.Context, in *console.AccountId) (*empty.Empty, error)

+ func (s *ConsoleServer) UnlinkApple(ctx context.Context, in *console.AccountId) (*empty.Empty, error)

+ func (s *ConsoleServer) UnlinkCustom(ctx context.Context, in *console.AccountId) (*empty.Empty, error)

+ func (s *ConsoleServer) UnlinkDevice(ctx context.Context, in *console.UnlinkDeviceRequest) (*empty.Empty, error)

+ func (s *ConsoleServer) UnlinkEmail(ctx context.Context, in *console.AccountId) (*empty.Empty, error)

+ func (s *ConsoleServer) UnlinkFacebook(ctx context.Context, in *console.AccountId) (*empty.Empty, error)

+ func (s *ConsoleServer) UnlinkFacebookInstantGame(ctx context.Context, in *console.AccountId) (*empty.Empty, error)

+ func (s *ConsoleServer) UnlinkGameCenter(ctx context.Context, in *console.AccountId) (*empty.Empty, error)

+ func (s *ConsoleServer) UnlinkGoogle(ctx context.Context, in *console.AccountId) (*empty.Empty, error)

+ func (s *ConsoleServer) UnlinkSteam(ctx context.Context, in *console.AccountId) (*empty.Empty, error)

+ func (s *ConsoleServer) UpdateAccount(ctx context.Context, in *console.UpdateAccountRequest) (*empty.Empty, error)

+ func (s *ConsoleServer) WriteStorageObject(ctx context.Context, in *console.WriteStorageObjectRequest) (*api.StorageObjectAck, error)

+ type ConsoleTokenClaims struct

+ Cookie string

+ Email string

+ ExpiresAt int64

+ Role console.UserRole

+ Username string

+ func (stc *ConsoleTokenClaims) Valid() error

+ type DatabaseConfig struct

+ Addresses []string

+ ConnMaxLifetimeMs int

+ MaxIdleConns int

+ MaxOpenConns int

+ func NewDatabaseConfig() *DatabaseConfig

+ type DeferredMessage struct

+ Envelope *rtapi.Envelope

+ PresenceIDs []*PresenceID

+ Reliable bool

+ type ErrorCauser interface

+ Cause func() error

+ type JsErrorType int

+ const JsErrorException

+ const JsErrorRuntime

+ func (e JsErrorType) String() string

+ type LSentinelType struct

+ func (s *LSentinelType) String() string

+ func (s *LSentinelType) Type() lua.LValueType

+ type Leaderboard struct

+ Authoritative bool

+ Category int

+ CreateTime int64

+ Description string

+ Duration int

+ EndTime int64

+ Id string

+ JoinRequired bool

+ MaxNumScore int

+ MaxSize int

+ Metadata string

+ Operator int

+ ResetSchedule *cronexpr.Expression

+ ResetScheduleStr string

+ SortOrder int

+ StartTime int64

+ Title string

+ func (l *Leaderboard) GetAuthoritative() bool

+ func (l *Leaderboard) GetCreateTime() int64

+ func (l *Leaderboard) GetId() string

+ func (l *Leaderboard) GetMetadata() map[string]interface{}

+ func (l *Leaderboard) GetOperator() string

+ func (l *Leaderboard) GetReset() string

+ func (l *Leaderboard) GetSortOrder() string

+ func (l *Leaderboard) IsTournament() bool

+ type LeaderboardCache interface

+ Create func(ctx context.Context, id string, authoritative bool, sortOrder, operator int, ...) (*Leaderboard, error)

+ CreateTournament func(ctx context.Context, id string, sortOrder, operator int, ...) (*Leaderboard, error)

+ Delete func(ctx context.Context, id string) error

+ Get func(id string) *Leaderboard

+ GetAllLeaderboards func() []*Leaderboard

+ Insert func(id string, authoritative bool, sortOrder, operator int, ...)

+ InsertTournament func(id string, sortOrder, operator int, ...)

+ ListTournaments func(now int64, categoryStart, categoryEnd int, startTime, endTime int64, limit int, ...) ([]*Leaderboard, *TournamentListCursor, error)

+ RefreshAllLeaderboards func(ctx context.Context) error

+ Remove func(id string)

+ func NewLocalLeaderboardCache(logger, startupLogger *zap.Logger, db *sql.DB) LeaderboardCache

+ type LeaderboardConfig struct

+ BlacklistRankCache []string

+ CallbackQueueSize int

+ CallbackQueueWorkers int

+ func NewLeaderboardConfig() *LeaderboardConfig

+ type LeaderboardRankCache interface

+ Delete func(leaderboardId string, expiryUnix int64, ownerID uuid.UUID) bool

+ DeleteLeaderboard func(leaderboardId string, expiryUnix int64) bool

+ Fill func(leaderboardId string, expiryUnix int64, records []*api.LeaderboardRecord)

+ Get func(leaderboardId string, expiryUnix int64, ownerID uuid.UUID) int64

+ Insert func(leaderboardId string, expiryUnix int64, sortOrder int, ownerID uuid.UUID, ...) int64

+ TrimExpired func(nowUnix int64) bool

+ func NewLocalLeaderboardRankCache(startupLogger *zap.Logger, db *sql.DB, config *LeaderboardConfig, ...) LeaderboardRankCache

+ type LeaderboardScheduler interface

+ Pause func()

+ Resume func()

+ Start func(runtime *Runtime)

+ Stop func()

+ Update func()

+ func NewLocalLeaderboardScheduler(logger *zap.Logger, db *sql.DB, config Config, cache LeaderboardCache, ...) LeaderboardScheduler

+ type LeaderboardSchedulerCallback struct

+ type LeaderboardWithExpiry struct

+ Expiry int64

+ LeaderboardId string

+ type LocalLeaderboardCache struct

+ func (l *LocalLeaderboardCache) Create(ctx context.Context, id string, authoritative bool, sortOrder, operator int, ...) (*Leaderboard, error)

+ func (l *LocalLeaderboardCache) CreateTournament(ctx context.Context, id string, sortOrder, operator int, ...) (*Leaderboard, error)

+ func (l *LocalLeaderboardCache) Delete(ctx context.Context, id string) error

+ func (l *LocalLeaderboardCache) Get(id string) *Leaderboard

+ func (l *LocalLeaderboardCache) GetAllLeaderboards() []*Leaderboard

+ func (l *LocalLeaderboardCache) Insert(id string, authoritative bool, sortOrder, operator int, ...)

+ func (l *LocalLeaderboardCache) InsertTournament(id string, sortOrder, operator int, ...)

+ func (l *LocalLeaderboardCache) ListTournaments(now int64, categoryStart, categoryEnd int, startTime, endTime int64, limit int, ...) ([]*Leaderboard, *TournamentListCursor, error)

+ func (l *LocalLeaderboardCache) RefreshAllLeaderboards(ctx context.Context) error

+ func (l *LocalLeaderboardCache) Remove(id string)

+ type LocalLeaderboardRankCache struct

+ func (l *LocalLeaderboardRankCache) Delete(leaderboardId string, expiryUnix int64, ownerID uuid.UUID) bool

+ func (l *LocalLeaderboardRankCache) DeleteLeaderboard(leaderboardId string, expiryUnix int64) bool

+ func (l *LocalLeaderboardRankCache) Fill(leaderboardId string, expiryUnix int64, records []*api.LeaderboardRecord)

+ func (l *LocalLeaderboardRankCache) Get(leaderboardId string, expiryUnix int64, ownerID uuid.UUID) int64

+ func (l *LocalLeaderboardRankCache) Insert(leaderboardId string, expiryUnix int64, sortOrder int, ownerID uuid.UUID, ...) int64

+ func (l *LocalLeaderboardRankCache) TrimExpired(nowUnix int64) bool

+ type LocalLeaderboardScheduler struct

+ func (ls *LocalLeaderboardScheduler) Pause()

+ func (ls *LocalLeaderboardScheduler) Resume()

+ func (ls *LocalLeaderboardScheduler) Start(runtime *Runtime)

+ func (ls *LocalLeaderboardScheduler) Stop()

+ func (ls *LocalLeaderboardScheduler) Update()

+ type LocalMatchRegistry struct

+ func (r *LocalMatchRegistry) Count() int

+ func (r *LocalMatchRegistry) CreateMatch(ctx context.Context, logger *zap.Logger, createFn RuntimeMatchCreateFunction, ...) (string, error)

+ func (r *LocalMatchRegistry) GetMatch(ctx context.Context, id string) (*api.Match, error)

+ func (r *LocalMatchRegistry) GetState(ctx context.Context, id uuid.UUID, node string) ([]*rtapi.UserPresence, int64, string, error)

+ func (r *LocalMatchRegistry) Join(id uuid.UUID, presences []*MatchPresence)

+ func (r *LocalMatchRegistry) JoinAttempt(ctx context.Context, id uuid.UUID, node string, userID, sessionID uuid.UUID, ...) (bool, bool, bool, string, string, []*MatchPresence)

+ func (r *LocalMatchRegistry) Kick(stream PresenceStream, presences []*MatchPresence)

+ func (r *LocalMatchRegistry) Leave(id uuid.UUID, presences []*MatchPresence)

+ func (r *LocalMatchRegistry) ListMatches(ctx context.Context, limit int, authoritative *wrappers.BoolValue, ...) ([]*api.Match, error)

+ func (r *LocalMatchRegistry) NewMatch(logger *zap.Logger, id uuid.UUID, core RuntimeMatchCore, stopped *atomic.Bool, ...) (*MatchHandler, error)

+ func (r *LocalMatchRegistry) RemoveMatch(id uuid.UUID, stream PresenceStream)

+ func (r *LocalMatchRegistry) SendData(id uuid.UUID, node string, userID, sessionID uuid.UUID, ...)

+ func (r *LocalMatchRegistry) Stop(graceSeconds int) chan struct{}

+ func (r *LocalMatchRegistry) UpdateMatchLabel(id uuid.UUID, tickRate int, handlerName, label string) error

+ type LocalMatchmaker struct

+ func (m *LocalMatchmaker) Add(presences []*MatchmakerPresence, sessionID, partyId, query string, ...) (string, error)

+ func (m *LocalMatchmaker) RemoveParty(partyID, ticket string) error

+ func (m *LocalMatchmaker) RemovePartyAll(partyID string) error

+ func (m *LocalMatchmaker) RemoveSession(sessionID, ticket string) error

+ func (m *LocalMatchmaker) RemoveSessionAll(sessionID string) error

+ func (m *LocalMatchmaker) Stop()

+ type LocalMessageRouter struct

+ func (r *LocalMessageRouter) SendDeferred(logger *zap.Logger, messages []*DeferredMessage)

+ func (r *LocalMessageRouter) SendToPresenceIDs(logger *zap.Logger, presenceIDs []*PresenceID, envelope *rtapi.Envelope, ...)

+ func (r *LocalMessageRouter) SendToStream(logger *zap.Logger, stream PresenceStream, envelope *rtapi.Envelope, ...)

+ type LocalPartyRegistry struct

+ func (p *LocalPartyRegistry) Create(open bool, maxSize int) *PartyHandler

+ func (p *LocalPartyRegistry) Delete(id uuid.UUID)

+ func (p *LocalPartyRegistry) Join(id uuid.UUID, presences []*Presence)

+ func (p *LocalPartyRegistry) Leave(id uuid.UUID, presences []*Presence)

+ func (p *LocalPartyRegistry) PartyAccept(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, ...) error

+ func (p *LocalPartyRegistry) PartyClose(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string) error

+ func (p *LocalPartyRegistry) PartyDataSend(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, ...) error

+ func (p *LocalPartyRegistry) PartyJoinRequest(ctx context.Context, id uuid.UUID, node string, presence *Presence) (bool, error)

+ func (p *LocalPartyRegistry) PartyJoinRequestList(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string) ([]*rtapi.UserPresence, error)

+ func (p *LocalPartyRegistry) PartyMatchmakerAdd(ctx context.Context, id uuid.UUID, node, sessionID, fromNode, query string, ...) (string, error)

+ func (p *LocalPartyRegistry) PartyMatchmakerRemove(ctx context.Context, id uuid.UUID, node, sessionID, fromNode, ticket string) error

+ func (p *LocalPartyRegistry) PartyPromote(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, ...) error

+ func (p *LocalPartyRegistry) PartyRemove(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, ...) error

+ type LocalSessionRegistry struct

+ func (r *LocalSessionRegistry) Add(session Session)

+ func (r *LocalSessionRegistry) Count() int

+ func (r *LocalSessionRegistry) Disconnect(ctx context.Context, sessionID uuid.UUID) error

+ func (r *LocalSessionRegistry) Get(sessionID uuid.UUID) Session

+ func (r *LocalSessionRegistry) Remove(sessionID uuid.UUID)

+ func (r *LocalSessionRegistry) Stop()

+ type LocalStatusHandler struct

+ func (s *LocalStatusHandler) GetStatus(ctx context.Context) ([]*console.StatusList_Status, error)

+ type LocalStreamManager struct

+ func (m *LocalStreamManager) UserJoin(stream PresenceStream, userID, sessionID uuid.UUID, hidden, persistence bool, ...) (bool, bool, error)

+ func (m *LocalStreamManager) UserLeave(stream PresenceStream, userID, sessionID uuid.UUID) error

+ func (m *LocalStreamManager) UserUpdate(stream PresenceStream, userID, sessionID uuid.UUID, hidden, persistence bool, ...) (bool, error)

+ type LocalTracker struct

+ func (t *LocalTracker) Count() int

+ func (t *LocalTracker) CountByStream(stream PresenceStream) int

+ func (t *LocalTracker) CountByStreamModeFilter(modes map[uint8]*uint8) map[*PresenceStream]int32

+ func (t *LocalTracker) GetBySessionIDStreamUserID(node string, sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID) *PresenceMeta

+ func (t *LocalTracker) GetLocalBySessionIDStreamUserID(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID) *PresenceMeta

+ func (t *LocalTracker) ListByStream(stream PresenceStream, includeHidden bool, includeNotHidden bool) []*Presence

+ func (t *LocalTracker) ListLocalSessionIDByStream(stream PresenceStream) []uuid.UUID

+ func (t *LocalTracker) ListNodesForStream(stream PresenceStream) map[string]struct{}

+ func (t *LocalTracker) ListPresenceIDByStream(stream PresenceStream) []*PresenceID

+ func (t *LocalTracker) SetMatchJoinListener(f func(id uuid.UUID, joins []*MatchPresence))

+ func (t *LocalTracker) SetMatchLeaveListener(f func(id uuid.UUID, leaves []*MatchPresence))

+ func (t *LocalTracker) SetPartyJoinListener(f func(id uuid.UUID, joins []*Presence))

+ func (t *LocalTracker) SetPartyLeaveListener(f func(id uuid.UUID, leaves []*Presence))

+ func (t *LocalTracker) Stop()

+ func (t *LocalTracker) StreamExists(stream PresenceStream) bool

+ func (t *LocalTracker) Track(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID, ...) (bool, bool)

+ func (t *LocalTracker) Untrack(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID)

+ func (t *LocalTracker) UntrackAll(sessionID uuid.UUID)

+ func (t *LocalTracker) UntrackByStream(stream PresenceStream)

+ func (t *LocalTracker) UntrackLocalByStream(stream PresenceStream)

+ func (t *LocalTracker) Update(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID, ...) bool

+ type LoggerConfig struct

+ Compress bool

+ File string

+ Format string

+ Level string

+ LocalTime bool

+ MaxAge int

+ MaxBackups int

+ MaxSize int

+ Rotation bool

+ Stdout bool

+ func NewLoggerConfig() *LoggerConfig

+ type LoggingFormat int8

+ const JSONFormat

+ const StackdriverFormat

+ type MatchConfig struct

+ CallQueueSize int

+ DeferredQueueSize int

+ InputQueueSize int

+ JoinAttemptQueueSize int

+ JoinMarkerDeadlineMs int

+ MaxEmptySec int

+ func NewMatchConfig() *MatchConfig

+ type MatchDataMessage struct

+ Data []byte

+ Node string

+ OpCode int64

+ ReceiveTime int64

+ Reliable bool

+ SessionID uuid.UUID

+ UserID uuid.UUID

+ Username string

+ func (m *MatchDataMessage) GetData() []byte

+ func (m *MatchDataMessage) GetHidden() bool

+ func (m *MatchDataMessage) GetNodeId() string

+ func (m *MatchDataMessage) GetOpCode() int64

+ func (m *MatchDataMessage) GetPersistence() bool

+ func (m *MatchDataMessage) GetReceiveTime() int64

+ func (m *MatchDataMessage) GetReliable() bool

+ func (m *MatchDataMessage) GetSessionId() string

+ func (m *MatchDataMessage) GetStatus() string

+ func (m *MatchDataMessage) GetUserId() string

+ func (m *MatchDataMessage) GetUsername() string

+ type MatchGetStateResult struct

+ Error error

+ Presences []*MatchPresence

+ State string

+ Tick int64

+ type MatchHandler struct

+ Core RuntimeMatchCore

+ ID uuid.UUID

+ IDStr string

+ JoinMarkerList *MatchJoinMarkerList

+ Node string

+ PresenceList *MatchPresenceList

+ Rate int64

+ Stream PresenceStream

+ func NewMatchHandler(logger *zap.Logger, config Config, sessionRegistry SessionRegistry, ...) (*MatchHandler, error)

+ func (mh *MatchHandler) Label() string

+ func (mh *MatchHandler) QueueData(m *MatchDataMessage)

+ func (mh *MatchHandler) QueueGetState(ctx context.Context, resultCh chan<- *MatchGetStateResult) bool

+ func (mh *MatchHandler) QueueJoin(joins []*MatchPresence, mark bool) bool

+ func (mh *MatchHandler) QueueJoinAttempt(ctx context.Context, resultCh chan<- *MatchJoinResult, ...) bool

+ func (mh *MatchHandler) QueueLeave(leaves []*MatchPresence) bool

+ func (mh *MatchHandler) QueueTerminate(graceSeconds int) bool

+ func (mh *MatchHandler) Stop()

+ type MatchIndexEntry struct

+ HandlerName string

+ Label map[string]interface{}

+ LabelString string

+ Node string

+ TickRate int

+ type MatchJoinMarker struct

+ type MatchJoinMarkerList struct

+ func NewMatchJoinMarkerList(config Config, tickRate int64) *MatchJoinMarkerList

+ func (m *MatchJoinMarkerList) Add(presence *MatchPresence, currentTick int64)

+ func (m *MatchJoinMarkerList) ClearExpired(tick int64) []*MatchPresence

+ func (m *MatchJoinMarkerList) Mark(sessionID uuid.UUID)

+ type MatchJoinResult struct

+ Allow bool

+ Label string

+ Reason string

+ type MatchNamesListFunction func() []string

+ type MatchPresence struct

+ Node string

+ SessionID uuid.UUID

+ UserID uuid.UUID

+ Username string

+ func (p *MatchPresence) GetHidden() bool

+ func (p *MatchPresence) GetNodeId() string

+ func (p *MatchPresence) GetPersistence() bool

+ func (p *MatchPresence) GetSessionId() string

+ func (p *MatchPresence) GetStatus() string

+ func (p *MatchPresence) GetUserId() string

+ func (p *MatchPresence) GetUsername() string

+ type MatchPresenceList struct

+ func NewMatchPresenceList() *MatchPresenceList

+ func (m *MatchPresenceList) Contains(presence *PresenceID) bool

+ func (m *MatchPresenceList) Join(joins []*MatchPresence) []*MatchPresence

+ func (m *MatchPresenceList) Leave(leaves []*MatchPresence) []*MatchPresence

+ func (m *MatchPresenceList) ListPresenceIDs() []*PresenceID

+ func (m *MatchPresenceList) ListPresences() []*MatchPresence

+ func (m *MatchPresenceList) Size() int

+ type MatchPresenceListItem struct

+ Presence *MatchPresence

+ PresenceID *PresenceID

+ type MatchProvider struct

+ func NewMatchProvider() *MatchProvider

+ func (mp *MatchProvider) CreateMatch(ctx context.Context, logger *zap.Logger, id uuid.UUID, node string, ...) (RuntimeMatchCore, error)

+ func (mp *MatchProvider) RegisterCreateFn(name string, fn RuntimeMatchCreateFunction)

+ type MatchRegistry interface

+ Count func() int

+ CreateMatch func(ctx context.Context, logger *zap.Logger, createFn RuntimeMatchCreateFunction, ...) (string, error)

+ GetMatch func(ctx context.Context, id string) (*api.Match, error)

+ GetState func(ctx context.Context, id uuid.UUID, node string) ([]*rtapi.UserPresence, int64, string, error)

+ Join func(id uuid.UUID, presences []*MatchPresence)

+ JoinAttempt func(ctx context.Context, id uuid.UUID, node string, userID, sessionID uuid.UUID, ...) (bool, bool, bool, string, string, []*MatchPresence)

+ Kick func(stream PresenceStream, presences []*MatchPresence)

+ Leave func(id uuid.UUID, presences []*MatchPresence)

+ ListMatches func(ctx context.Context, limit int, authoritative *wrappers.BoolValue, ...) ([]*api.Match, error)

+ NewMatch func(logger *zap.Logger, id uuid.UUID, core RuntimeMatchCore, stopped *atomic.Bool, ...) (*MatchHandler, error)

+ RemoveMatch func(id uuid.UUID, stream PresenceStream)

+ SendData func(id uuid.UUID, node string, userID, sessionID uuid.UUID, ...)

+ Stop func(graceSeconds int) chan struct{}

+ UpdateMatchLabel func(id uuid.UUID, tickRate int, handlerName, label string) error

+ func NewLocalMatchRegistry(logger, startupLogger *zap.Logger, config Config, ...) MatchRegistry

+ type Matchmaker interface

+ Add func(presences []*MatchmakerPresence, sessionID, partyId, query string, ...) (string, error)

+ RemoveParty func(partyID, ticket string) error

+ RemovePartyAll func(partyID string) error

+ RemoveSession func(sessionID, ticket string) error

+ RemoveSessionAll func(sessionID string) error

+ Stop func()

+ func NewLocalMatchmaker(logger, startupLogger *zap.Logger, config Config, router MessageRouter, ...) Matchmaker

+ type MatchmakerConfig struct

+ IntervalSec int

+ MaxIntervals int

+ MaxTickets int

+ func NewMatchmakerConfig() *MatchmakerConfig

+ type MatchmakerEntry struct

+ NumericProperties map[string]float64

+ PartyId string

+ Presence *MatchmakerPresence

+ Properties map[string]interface{}

+ StringProperties map[string]string

+ Ticket string

+ func (m *MatchmakerEntry) GetPartyId() string

+ func (m *MatchmakerEntry) GetPresence() runtime.Presence

+ func (m *MatchmakerEntry) GetProperties() map[string]interface{}

+ func (m *MatchmakerEntry) GetTicket() string

+ type MatchmakerIndex struct

+ Count int

+ CreatedAt int64

+ Intervals int

+ MaxCount int

+ MinCount int

+ PartyId string

+ Properties map[string]interface{}

+ Query string

+ SessionID string

+ SessionIDs map[string]struct{}

+ Ticket string

+ type MatchmakerPresence struct

+ Node string

+ SessionID uuid.UUID

+ SessionId string

+ UserId string

+ Username string

+ func (p *MatchmakerPresence) GetHidden() bool

+ func (p *MatchmakerPresence) GetNodeId() string

+ func (p *MatchmakerPresence) GetPersistence() bool

+ func (p *MatchmakerPresence) GetSessionId() string

+ func (p *MatchmakerPresence) GetStatus() string

+ func (p *MatchmakerPresence) GetUserId() string

+ func (p *MatchmakerPresence) GetUsername() string

+ type MessageRouter interface

+ SendDeferred func(*zap.Logger, []*DeferredMessage)

+ SendToPresenceIDs func(*zap.Logger, []*PresenceID, *rtapi.Envelope, bool)

+ SendToStream func(*zap.Logger, PresenceStream, *rtapi.Envelope, bool)

+ func NewLocalMessageRouter(sessionRegistry SessionRegistry, tracker Tracker, ...) MessageRouter

+ type MethodName string

+ type Metrics struct

+ SnapshotLatencyMs *atomic.Float64

+ SnapshotRateSec *atomic.Float64

+ SnapshotRecvKbSec *atomic.Float64

+ SnapshotSentKbSec *atomic.Float64

+ func NewMetrics(logger, startupLogger *zap.Logger, config Config) *Metrics

+ func (m *Metrics) Api(name string, elapsed time.Duration, recvBytes, sentBytes int64, isErr bool)

+ func (m *Metrics) ApiAfter(name string, elapsed time.Duration, isErr bool)

+ func (m *Metrics) ApiBefore(name string, elapsed time.Duration, isErr bool)

+ func (m *Metrics) CountDroppedEvents(delta int64)

+ func (m *Metrics) CountWebsocketClosed(delta int64)

+ func (m *Metrics) CountWebsocketOpened(delta int64)

+ func (m *Metrics) GaugeAuthoritativeMatches(value float64)

+ func (m *Metrics) GaugeJsRuntimes(value float64)

+ func (m *Metrics) GaugeLuaRuntimes(value float64)

+ func (m *Metrics) GaugePresences(value float64)

+ func (m *Metrics) GaugeRuntimes(value float64)

+ func (m *Metrics) GaugeSessions(value float64)

+ func (m *Metrics) Message(recvBytes int64, isErr bool)

+ func (m *Metrics) MessageBytesSent(sentBytes int64)

+ func (m *Metrics) Stop(logger *zap.Logger)

+ type MetricsConfig struct

+ Namespace string

+ Prefix string

+ PrometheusPort int

+ ReportingFreqSec int

+ func NewMetricsConfig() *MetricsConfig

+ type MetricsGrpcHandler struct

+ func (m *MetricsGrpcHandler) HandleConn(context.Context, stats.ConnStats)

+ func (m *MetricsGrpcHandler) HandleRPC(ctx context.Context, rs stats.RPCStats)

+ func (m *MetricsGrpcHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context

+ func (m *MetricsGrpcHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context

+ type OrderedTournaments []*Leaderboard

+ func (t OrderedTournaments) Len() int

+ func (t OrderedTournaments) Less(i, j int) bool

+ func (t OrderedTournaments) Swap(i, j int)

+ type PartyHandler struct

+ ID uuid.UUID

+ IDStr string

+ MaxSize int

+ Node string

+ Open bool

+ Stream PresenceStream

+ func NewPartyHandler(logger *zap.Logger, partyRegistry PartyRegistry, matchmaker Matchmaker, ...) *PartyHandler

+ func (p *PartyHandler) Accept(sessionID, node string, presence *rtapi.UserPresence) error

+ func (p *PartyHandler) Close(sessionID, node string) error

+ func (p *PartyHandler) DataSend(sessionID, node string, opCode int64, data []byte) error

+ func (p *PartyHandler) Join(presences []*Presence)

+ func (p *PartyHandler) JoinRequest(presence *Presence) (bool, error)

+ func (p *PartyHandler) JoinRequestList(sessionID, node string) ([]*rtapi.UserPresence, error)

+ func (p *PartyHandler) Leave(presences []*Presence)

+ func (p *PartyHandler) MatchmakerAdd(sessionID, node, query string, minCount, maxCount int, ...) (string, error)

+ func (p *PartyHandler) MatchmakerRemove(sessionID, node, ticket string) error

+ func (p *PartyHandler) Promote(sessionID, node string, presence *rtapi.UserPresence) error

+ func (p *PartyHandler) Remove(sessionID, node string, presence *rtapi.UserPresence) error

+ type PartyRegistry interface

+ Create func(open bool, maxSize int) *PartyHandler

+ Delete func(id uuid.UUID)

+ Join func(id uuid.UUID, presences []*Presence)

+ Leave func(id uuid.UUID, presences []*Presence)

+ PartyAccept func(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, ...) error

+ PartyClose func(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string) error

+ PartyDataSend func(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, ...) error

+ PartyJoinRequest func(ctx context.Context, id uuid.UUID, node string, presence *Presence) (bool, error)

+ PartyJoinRequestList func(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string) ([]*rtapi.UserPresence, error)

+ PartyMatchmakerAdd func(ctx context.Context, id uuid.UUID, node, sessionID, fromNode, query string, ...) (string, error)

+ PartyMatchmakerRemove func(ctx context.Context, id uuid.UUID, node, sessionID, fromNode, ticket string) error

+ PartyPromote func(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, ...) error

+ PartyRemove func(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, ...) error

+ func NewLocalPartyRegistry(logger *zap.Logger, matchmaker Matchmaker, tracker Tracker, ...) PartyRegistry

+ type Pipeline struct

+ func NewPipeline(logger *zap.Logger, config Config, db *sql.DB, ...) *Pipeline

+ func (p *Pipeline) ProcessRequest(logger *zap.Logger, session Session, envelope *rtapi.Envelope) bool

+ type Presence struct

+ ID PresenceID

+ Meta PresenceMeta

+ Stream PresenceStream

+ UserID uuid.UUID

+ func (p *Presence) GetHidden() bool

+ func (p *Presence) GetNodeId() string

+ func (p *Presence) GetPersistence() bool

+ func (p *Presence) GetSessionId() string

+ func (p *Presence) GetStatus() string

+ func (p *Presence) GetUserId() string

+ func (p *Presence) GetUsername() string

+ type PresenceEvent struct

+ Joins []Presence

+ Leaves []Presence

+ type PresenceID struct

+ Node string

+ SessionID uuid.UUID

+ type PresenceMeta struct

+ Format SessionFormat

+ Hidden bool

+ Persistence bool

+ Status string

+ Username string

+ func (pm *PresenceMeta) GetHidden() bool

+ func (pm *PresenceMeta) GetPersistence() bool

+ func (pm *PresenceMeta) GetStatus() string

+ func (pm *PresenceMeta) GetUsername() string

+ type PresenceStream struct

+ Label string

+ Mode uint8

+ Subcontext uuid.UUID

+ Subject uuid.UUID

+ type RankAsc struct

+ OwnerId uuid.UUID

+ Score int64

+ Subscore int64

+ func (r *RankAsc) Less(other interface{}) bool

+ type RankCache struct

+ type RankDesc struct

+ OwnerId uuid.UUID

+ Score int64

+ Subscore int64

+ func (r *RankDesc) Less(other interface{}) bool

+ type Runtime struct

+ func (r *Runtime) AfterAddFriends() RuntimeAfterAddFriendsFunction

+ func (r *Runtime) AfterAddGroupUsers() RuntimeAfterAddGroupUsersFunction

+ func (r *Runtime) AfterAuthenticateApple() RuntimeAfterAuthenticateAppleFunction

+ func (r *Runtime) AfterAuthenticateCustom() RuntimeAfterAuthenticateCustomFunction

+ func (r *Runtime) AfterAuthenticateDevice() RuntimeAfterAuthenticateDeviceFunction

+ func (r *Runtime) AfterAuthenticateEmail() RuntimeAfterAuthenticateEmailFunction

+ func (r *Runtime) AfterAuthenticateFacebook() RuntimeAfterAuthenticateFacebookFunction

+ func (r *Runtime) AfterAuthenticateFacebookInstantGame() RuntimeAfterAuthenticateFacebookInstantGameFunction

+ func (r *Runtime) AfterAuthenticateGameCenter() RuntimeAfterAuthenticateGameCenterFunction

+ func (r *Runtime) AfterAuthenticateGoogle() RuntimeAfterAuthenticateGoogleFunction

+ func (r *Runtime) AfterAuthenticateSteam() RuntimeAfterAuthenticateSteamFunction

+ func (r *Runtime) AfterBanGroupUsers() RuntimeAfterBanGroupUsersFunction

+ func (r *Runtime) AfterBlockFriends() RuntimeAfterBlockFriendsFunction

+ func (r *Runtime) AfterCreateGroup() RuntimeAfterCreateGroupFunction

+ func (r *Runtime) AfterDeleteFriends() RuntimeAfterDeleteFriendsFunction

+ func (r *Runtime) AfterDeleteGroup() RuntimeAfterDeleteGroupFunction

+ func (r *Runtime) AfterDeleteLeaderboardRecord() RuntimeAfterDeleteLeaderboardRecordFunction

+ func (r *Runtime) AfterDeleteNotification() RuntimeAfterDeleteNotificationFunction

+ func (r *Runtime) AfterDeleteStorageObjects() RuntimeAfterDeleteStorageObjectsFunction

+ func (r *Runtime) AfterDemoteGroupUsers() RuntimeAfterDemoteGroupUsersFunction

+ func (r *Runtime) AfterEvent() RuntimeAfterEventFunction

+ func (r *Runtime) AfterGetAccount() RuntimeAfterGetAccountFunction

+ func (r *Runtime) AfterGetUsers() RuntimeAfterGetUsersFunction

+ func (r *Runtime) AfterImportFacebookFriends() RuntimeAfterImportFacebookFriendsFunction

+ func (r *Runtime) AfterJoinGroup() RuntimeAfterJoinGroupFunction

+ func (r *Runtime) AfterJoinTournament() RuntimeAfterJoinTournamentFunction

+ func (r *Runtime) AfterKickGroupUsers() RuntimeAfterKickGroupUsersFunction

+ func (r *Runtime) AfterLeaveGroup() RuntimeAfterLeaveGroupFunction

+ func (r *Runtime) AfterLinkApple() RuntimeAfterLinkAppleFunction

+ func (r *Runtime) AfterLinkCustom() RuntimeAfterLinkCustomFunction

+ func (r *Runtime) AfterLinkDevice() RuntimeAfterLinkDeviceFunction

+ func (r *Runtime) AfterLinkEmail() RuntimeAfterLinkEmailFunction

+ func (r *Runtime) AfterLinkFacebook() RuntimeAfterLinkFacebookFunction

+ func (r *Runtime) AfterLinkFacebookInstantGame() RuntimeAfterLinkFacebookInstantGameFunction

+ func (r *Runtime) AfterLinkGameCenter() RuntimeAfterLinkGameCenterFunction

+ func (r *Runtime) AfterLinkGoogle() RuntimeAfterLinkGoogleFunction

+ func (r *Runtime) AfterLinkSteam() RuntimeAfterLinkSteamFunction

+ func (r *Runtime) AfterListChannelMessages() RuntimeAfterListChannelMessagesFunction

+ func (r *Runtime) AfterListFriends() RuntimeAfterListFriendsFunction

+ func (r *Runtime) AfterListGroupUsers() RuntimeAfterListGroupUsersFunction

+ func (r *Runtime) AfterListGroups() RuntimeAfterListGroupsFunction

+ func (r *Runtime) AfterListLeaderboardRecords() RuntimeAfterListLeaderboardRecordsFunction

+ func (r *Runtime) AfterListLeaderboardRecordsAroundOwner() RuntimeAfterListLeaderboardRecordsAroundOwnerFunction

+ func (r *Runtime) AfterListMatches() RuntimeAfterListMatchesFunction

+ func (r *Runtime) AfterListNotifications() RuntimeAfterListNotificationsFunction

+ func (r *Runtime) AfterListStorageObjects() RuntimeAfterListStorageObjectsFunction

+ func (r *Runtime) AfterListTournamentRecords() RuntimeAfterListTournamentRecordsFunction

+ func (r *Runtime) AfterListTournamentRecordsAroundOwner() RuntimeAfterListTournamentRecordsAroundOwnerFunction

+ func (r *Runtime) AfterListTournaments() RuntimeAfterListTournamentsFunction

+ func (r *Runtime) AfterListUserGroups() RuntimeAfterListUserGroupsFunction

+ func (r *Runtime) AfterPromoteGroupUsers() RuntimeAfterPromoteGroupUsersFunction

+ func (r *Runtime) AfterReadStorageObjects() RuntimeAfterReadStorageObjectsFunction

+ func (r *Runtime) AfterRt(id string) RuntimeAfterRtFunction

+ func (r *Runtime) AfterSessionRefresh() RuntimeAfterSessionRefreshFunction

+ func (r *Runtime) AfterUnlinkApple() RuntimeAfterUnlinkAppleFunction

+ func (r *Runtime) AfterUnlinkCustom() RuntimeAfterUnlinkCustomFunction

+ func (r *Runtime) AfterUnlinkDevice() RuntimeAfterUnlinkDeviceFunction

+ func (r *Runtime) AfterUnlinkEmail() RuntimeAfterUnlinkEmailFunction

+ func (r *Runtime) AfterUnlinkFacebook() RuntimeAfterUnlinkFacebookFunction

+ func (r *Runtime) AfterUnlinkFacebookInstantGame() RuntimeAfterUnlinkFacebookInstantGameFunction

+ func (r *Runtime) AfterUnlinkGameCenter() RuntimeAfterUnlinkGameCenterFunction

+ func (r *Runtime) AfterUnlinkGoogle() RuntimeAfterUnlinkGoogleFunction

+ func (r *Runtime) AfterUnlinkSteam() RuntimeAfterUnlinkSteamFunction

+ func (r *Runtime) AfterUpdateAccount() RuntimeAfterUpdateAccountFunction

+ func (r *Runtime) AfterUpdateGroup() RuntimeAfterUpdateGroupFunction

+ func (r *Runtime) AfterWriteLeaderboardRecord() RuntimeAfterWriteLeaderboardRecordFunction

+ func (r *Runtime) AfterWriteStorageObjects() RuntimeAfterWriteStorageObjectsFunction

+ func (r *Runtime) AfterWriteTournamentRecord() RuntimeAfterWriteTournamentRecordFunction

+ func (r *Runtime) BeforeAddFriends() RuntimeBeforeAddFriendsFunction

+ func (r *Runtime) BeforeAddGroupUsers() RuntimeBeforeAddGroupUsersFunction

+ func (r *Runtime) BeforeAuthenticateApple() RuntimeBeforeAuthenticateAppleFunction

+ func (r *Runtime) BeforeAuthenticateCustom() RuntimeBeforeAuthenticateCustomFunction

+ func (r *Runtime) BeforeAuthenticateDevice() RuntimeBeforeAuthenticateDeviceFunction

+ func (r *Runtime) BeforeAuthenticateEmail() RuntimeBeforeAuthenticateEmailFunction

+ func (r *Runtime) BeforeAuthenticateFacebook() RuntimeBeforeAuthenticateFacebookFunction

+ func (r *Runtime) BeforeAuthenticateFacebookInstantGame() RuntimeBeforeAuthenticateFacebookInstantGameFunction

+ func (r *Runtime) BeforeAuthenticateGameCenter() RuntimeBeforeAuthenticateGameCenterFunction

+ func (r *Runtime) BeforeAuthenticateGoogle() RuntimeBeforeAuthenticateGoogleFunction

+ func (r *Runtime) BeforeAuthenticateSteam() RuntimeBeforeAuthenticateSteamFunction

+ func (r *Runtime) BeforeBanGroupUsers() RuntimeBeforeBanGroupUsersFunction

+ func (r *Runtime) BeforeBlockFriends() RuntimeBeforeBlockFriendsFunction

+ func (r *Runtime) BeforeCreateGroup() RuntimeBeforeCreateGroupFunction

+ func (r *Runtime) BeforeDeleteFriends() RuntimeBeforeDeleteFriendsFunction

+ func (r *Runtime) BeforeDeleteGroup() RuntimeBeforeDeleteGroupFunction

+ func (r *Runtime) BeforeDeleteLeaderboardRecord() RuntimeBeforeDeleteLeaderboardRecordFunction

+ func (r *Runtime) BeforeDeleteNotification() RuntimeBeforeDeleteNotificationFunction

+ func (r *Runtime) BeforeDeleteStorageObjects() RuntimeBeforeDeleteStorageObjectsFunction

+ func (r *Runtime) BeforeDemoteGroupUsers() RuntimeBeforeDemoteGroupUsersFunction

+ func (r *Runtime) BeforeEvent() RuntimeBeforeEventFunction

+ func (r *Runtime) BeforeGetAccount() RuntimeBeforeGetAccountFunction

+ func (r *Runtime) BeforeGetUsers() RuntimeBeforeGetUsersFunction

+ func (r *Runtime) BeforeImportFacebookFriends() RuntimeBeforeImportFacebookFriendsFunction

+ func (r *Runtime) BeforeJoinGroup() RuntimeBeforeJoinGroupFunction

+ func (r *Runtime) BeforeJoinTournament() RuntimeBeforeJoinTournamentFunction

+ func (r *Runtime) BeforeKickGroupUsers() RuntimeBeforeKickGroupUsersFunction

+ func (r *Runtime) BeforeLeaveGroup() RuntimeBeforeLeaveGroupFunction

+ func (r *Runtime) BeforeLinkApple() RuntimeBeforeLinkAppleFunction

+ func (r *Runtime) BeforeLinkCustom() RuntimeBeforeLinkCustomFunction

+ func (r *Runtime) BeforeLinkDevice() RuntimeBeforeLinkDeviceFunction

+ func (r *Runtime) BeforeLinkEmail() RuntimeBeforeLinkEmailFunction

+ func (r *Runtime) BeforeLinkFacebook() RuntimeBeforeLinkFacebookFunction

+ func (r *Runtime) BeforeLinkFacebookInstantGame() RuntimeBeforeLinkFacebookInstantGameFunction

+ func (r *Runtime) BeforeLinkGameCenter() RuntimeBeforeLinkGameCenterFunction

+ func (r *Runtime) BeforeLinkGoogle() RuntimeBeforeLinkGoogleFunction

+ func (r *Runtime) BeforeLinkSteam() RuntimeBeforeLinkSteamFunction

+ func (r *Runtime) BeforeListChannelMessages() RuntimeBeforeListChannelMessagesFunction

+ func (r *Runtime) BeforeListFriends() RuntimeBeforeListFriendsFunction

+ func (r *Runtime) BeforeListGroupUsers() RuntimeBeforeListGroupUsersFunction

+ func (r *Runtime) BeforeListGroups() RuntimeBeforeListGroupsFunction

+ func (r *Runtime) BeforeListLeaderboardRecords() RuntimeBeforeListLeaderboardRecordsFunction

+ func (r *Runtime) BeforeListLeaderboardRecordsAroundOwner() RuntimeBeforeListLeaderboardRecordsAroundOwnerFunction

+ func (r *Runtime) BeforeListMatches() RuntimeBeforeListMatchesFunction

+ func (r *Runtime) BeforeListNotifications() RuntimeBeforeListNotificationsFunction

+ func (r *Runtime) BeforeListStorageObjects() RuntimeBeforeListStorageObjectsFunction

+ func (r *Runtime) BeforeListTournamentRecords() RuntimeBeforeListTournamentRecordsFunction

+ func (r *Runtime) BeforeListTournamentRecordsAroundOwner() RuntimeBeforeListTournamentRecordsAroundOwnerFunction

+ func (r *Runtime) BeforeListTournaments() RuntimeBeforeListTournamentsFunction

+ func (r *Runtime) BeforeListUserGroups() RuntimeBeforeListUserGroupsFunction

+ func (r *Runtime) BeforePromoteGroupUsers() RuntimeBeforePromoteGroupUsersFunction

+ func (r *Runtime) BeforeReadStorageObjects() RuntimeBeforeReadStorageObjectsFunction

+ func (r *Runtime) BeforeRt(id string) RuntimeBeforeRtFunction

+ func (r *Runtime) BeforeSessionRefresh() RuntimeBeforeSessionRefreshFunction

+ func (r *Runtime) BeforeUnlinkApple() RuntimeBeforeUnlinkAppleFunction

+ func (r *Runtime) BeforeUnlinkCustom() RuntimeBeforeUnlinkCustomFunction

+ func (r *Runtime) BeforeUnlinkDevice() RuntimeBeforeUnlinkDeviceFunction

+ func (r *Runtime) BeforeUnlinkEmail() RuntimeBeforeUnlinkEmailFunction

+ func (r *Runtime) BeforeUnlinkFacebook() RuntimeBeforeUnlinkFacebookFunction

+ func (r *Runtime) BeforeUnlinkFacebookInstantGame() RuntimeBeforeUnlinkFacebookInstantGameFunction

+ func (r *Runtime) BeforeUnlinkGameCenter() RuntimeBeforeUnlinkGameCenterFunction

+ func (r *Runtime) BeforeUnlinkGoogle() RuntimeBeforeUnlinkGoogleFunction

+ func (r *Runtime) BeforeUnlinkSteam() RuntimeBeforeUnlinkSteamFunction

+ func (r *Runtime) BeforeUpdateAccount() RuntimeBeforeUpdateAccountFunction

+ func (r *Runtime) BeforeUpdateGroup() RuntimeBeforeUpdateGroupFunction

+ func (r *Runtime) BeforeWriteLeaderboardRecord() RuntimeBeforeWriteLeaderboardRecordFunction

+ func (r *Runtime) BeforeWriteStorageObjects() RuntimeBeforeWriteStorageObjectsFunction

+ func (r *Runtime) BeforeWriteTournamentRecord() RuntimeBeforeWriteTournamentRecordFunction

+ func (r *Runtime) Event() RuntimeEventCustomFunction

+ func (r *Runtime) EventSessionEnd() RuntimeEventSessionEndFunction

+ func (r *Runtime) EventSessionStart() RuntimeEventSessionStartFunction

+ func (r *Runtime) LeaderboardReset() RuntimeLeaderboardResetFunction

+ func (r *Runtime) MatchCreateFunction() RuntimeMatchCreateFunction

+ func (r *Runtime) MatchmakerMatched() RuntimeMatchmakerMatchedFunction

+ func (r *Runtime) Rpc(id string) RuntimeRpcFunction

+ func (r *Runtime) TournamentEnd() RuntimeTournamentEndFunction

+ func (r *Runtime) TournamentReset() RuntimeTournamentResetFunction

+ type RuntimeAfterAddFriendsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterAddGroupUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterAuthenticateAppleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterAuthenticateCustomFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterAuthenticateDeviceFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterAuthenticateEmailFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterAuthenticateFacebookFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterAuthenticateFacebookInstantGameFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterAuthenticateGameCenterFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterAuthenticateGoogleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterAuthenticateSteamFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterBanGroupUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterBlockFriendsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterCreateGroupFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterDeleteFriendsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterDeleteGroupFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterDeleteLeaderboardRecordFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterDeleteNotificationFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterDeleteStorageObjectsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterDemoteGroupUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterEventFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterGetAccountFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterGetUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterImportFacebookFriendsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterJoinGroupFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterJoinTournamentFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterKickGroupUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterLeaveGroupFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterLinkAppleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterLinkCustomFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterLinkDeviceFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterLinkEmailFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterLinkFacebookFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterLinkFacebookInstantGameFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterLinkGameCenterFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterLinkGoogleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterLinkSteamFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListChannelMessagesFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListFriendsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListGroupUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListGroupsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListLeaderboardRecordsAroundOwnerFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListLeaderboardRecordsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListMatchesFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListNotificationsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListStorageObjectsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListTournamentRecordsAroundOwnerFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListTournamentRecordsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListTournamentsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterListUserGroupsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterPromoteGroupUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterReadStorageObjectsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterReqFunctions struct

+ type RuntimeAfterRtFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterSessionRefreshFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterUnlinkAppleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterUnlinkCustomFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterUnlinkDeviceFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterUnlinkEmailFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterUnlinkFacebookFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterUnlinkFacebookInstantGameFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterUnlinkGameCenterFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterUnlinkGoogleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterUnlinkSteamFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterUpdateAccountFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterUpdateGroupFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterWriteLeaderboardRecordFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterWriteStorageObjectsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeAfterWriteTournamentRecordFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) error

+ type RuntimeBeforeAddFriendsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AddFriendsRequest, error, codes.Code)

+ type RuntimeBeforeAddGroupUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AddGroupUsersRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateAppleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AuthenticateAppleRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateCustomFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AuthenticateCustomRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateDeviceFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AuthenticateDeviceRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateEmailFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AuthenticateEmailRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateFacebookFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AuthenticateFacebookRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateFacebookInstantGameFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AuthenticateFacebookInstantGameRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateGameCenterFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AuthenticateGameCenterRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateGoogleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AuthenticateGoogleRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateSteamFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AuthenticateSteamRequest, error, codes.Code)

+ type RuntimeBeforeBanGroupUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.BanGroupUsersRequest, error, codes.Code)

+ type RuntimeBeforeBlockFriendsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.BlockFriendsRequest, error, codes.Code)

+ type RuntimeBeforeCreateGroupFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.CreateGroupRequest, error, codes.Code)

+ type RuntimeBeforeDeleteFriendsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.DeleteFriendsRequest, error, codes.Code)

+ type RuntimeBeforeDeleteGroupFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.DeleteGroupRequest, error, codes.Code)

+ type RuntimeBeforeDeleteLeaderboardRecordFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.DeleteLeaderboardRecordRequest, error, codes.Code)

+ type RuntimeBeforeDeleteNotificationFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.DeleteNotificationsRequest, error, codes.Code)

+ type RuntimeBeforeDeleteStorageObjectsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.DeleteStorageObjectsRequest, error, codes.Code)

+ type RuntimeBeforeDemoteGroupUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.DemoteGroupUsersRequest, error, codes.Code)

+ type RuntimeBeforeEventFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.Event, error, codes.Code)

+ type RuntimeBeforeGetAccountFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (error, codes.Code)

+ type RuntimeBeforeGetUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.GetUsersRequest, error, codes.Code)

+ type RuntimeBeforeImportFacebookFriendsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ImportFacebookFriendsRequest, error, codes.Code)

+ type RuntimeBeforeJoinGroupFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.JoinGroupRequest, error, codes.Code)

+ type RuntimeBeforeJoinTournamentFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.JoinTournamentRequest, error, codes.Code)

+ type RuntimeBeforeKickGroupUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.KickGroupUsersRequest, error, codes.Code)

+ type RuntimeBeforeLeaveGroupFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.LeaveGroupRequest, error, codes.Code)

+ type RuntimeBeforeLinkAppleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountApple, error, codes.Code)

+ type RuntimeBeforeLinkCustomFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountCustom, error, codes.Code)

+ type RuntimeBeforeLinkDeviceFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountDevice, error, codes.Code)

+ type RuntimeBeforeLinkEmailFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountEmail, error, codes.Code)

+ type RuntimeBeforeLinkFacebookFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.LinkFacebookRequest, error, codes.Code)

+ type RuntimeBeforeLinkFacebookInstantGameFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountFacebookInstantGame, error, codes.Code)

+ type RuntimeBeforeLinkGameCenterFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountGameCenter, error, codes.Code)

+ type RuntimeBeforeLinkGoogleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountGoogle, error, codes.Code)

+ type RuntimeBeforeLinkSteamFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountSteam, error, codes.Code)

+ type RuntimeBeforeListChannelMessagesFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListChannelMessagesRequest, error, codes.Code)

+ type RuntimeBeforeListFriendsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListFriendsRequest, error, codes.Code)

+ type RuntimeBeforeListGroupUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListGroupUsersRequest, error, codes.Code)

+ type RuntimeBeforeListGroupsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListGroupsRequest, error, codes.Code)

+ type RuntimeBeforeListLeaderboardRecordsAroundOwnerFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListLeaderboardRecordsAroundOwnerRequest, error, codes.Code)

+ type RuntimeBeforeListLeaderboardRecordsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListLeaderboardRecordsRequest, error, codes.Code)

+ type RuntimeBeforeListMatchesFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListMatchesRequest, error, codes.Code)

+ type RuntimeBeforeListNotificationsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListNotificationsRequest, error, codes.Code)

+ type RuntimeBeforeListStorageObjectsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListStorageObjectsRequest, error, codes.Code)

+ type RuntimeBeforeListTournamentRecordsAroundOwnerFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListTournamentRecordsAroundOwnerRequest, error, codes.Code)

+ type RuntimeBeforeListTournamentRecordsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListTournamentRecordsRequest, error, codes.Code)

+ type RuntimeBeforeListTournamentsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListTournamentsRequest, error, codes.Code)

+ type RuntimeBeforeListUserGroupsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ListUserGroupsRequest, error, codes.Code)

+ type RuntimeBeforePromoteGroupUsersFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.PromoteGroupUsersRequest, error, codes.Code)

+ type RuntimeBeforeReadStorageObjectsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.ReadStorageObjectsRequest, error, codes.Code)

+ type RuntimeBeforeReqFunctions struct

+ type RuntimeBeforeRtFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*rtapi.Envelope, error)

+ type RuntimeBeforeSessionRefreshFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.SessionRefreshRequest, error, codes.Code)

+ type RuntimeBeforeUnlinkAppleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountApple, error, codes.Code)

+ type RuntimeBeforeUnlinkCustomFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountCustom, error, codes.Code)

+ type RuntimeBeforeUnlinkDeviceFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountDevice, error, codes.Code)

+ type RuntimeBeforeUnlinkEmailFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountEmail, error, codes.Code)

+ type RuntimeBeforeUnlinkFacebookFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountFacebook, error, codes.Code)

+ type RuntimeBeforeUnlinkFacebookInstantGameFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountFacebookInstantGame, error, codes.Code)

+ type RuntimeBeforeUnlinkGameCenterFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountGameCenter, error, codes.Code)

+ type RuntimeBeforeUnlinkGoogleFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountGoogle, error, codes.Code)

+ type RuntimeBeforeUnlinkSteamFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.AccountSteam, error, codes.Code)

+ type RuntimeBeforeUpdateAccountFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.UpdateAccountRequest, error, codes.Code)

+ type RuntimeBeforeUpdateGroupFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.UpdateGroupRequest, error, codes.Code)

+ type RuntimeBeforeWriteLeaderboardRecordFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.WriteLeaderboardRecordRequest, error, codes.Code)

+ type RuntimeBeforeWriteStorageObjectsFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.WriteStorageObjectsRequest, error, codes.Code)

+ type RuntimeBeforeWriteTournamentRecordFunction func(ctx context.Context, logger *zap.Logger, userID, username string, ...) (*api.WriteTournamentRecordRequest, error, codes.Code)

+ type RuntimeConfig struct

+ CallStackSize int

+ Env []string

+ Environment map[string]string

+ EventQueueSize int

+ EventQueueWorkers int

+ HTTPKey string

+ JsEntrypoint string

+ JsMaxCount int

+ JsMinCount int

+ LuaCallStackSize int

+ LuaMaxCount int

+ LuaMinCount int

+ LuaReadOnlyGlobals bool

+ LuaRegistrySize int

+ MaxCount int

+ MinCount int

+ Path string

+ ReadOnlyGlobals bool

+ RegistrySize int

+ func NewRuntimeConfig() *RuntimeConfig

+ func (r *RuntimeConfig) GetLuaCallStackSize() int

+ func (r *RuntimeConfig) GetLuaMaxCount() int

+ func (r *RuntimeConfig) GetLuaMinCount() int

+ func (r *RuntimeConfig) GetLuaReadOnlyGlobals() bool

+ func (r *RuntimeConfig) GetLuaRegistrySize() int

+ type RuntimeEventCustomFunction func(ctx context.Context, evt *api.Event)

+ type RuntimeEventFunction func(ctx context.Context, logger runtime.Logger, evt *api.Event)

+ type RuntimeEventFunctions struct

+ type RuntimeEventQueue struct

+ func NewRuntimeEventQueue(logger *zap.Logger, config Config, metrics *Metrics) *RuntimeEventQueue

+ func (b *RuntimeEventQueue) Queue(fn func())

+ func (b *RuntimeEventQueue) Stop()

+ type RuntimeEventSessionEndFunction func(userID, username string, vars map[string]string, expiry int64, ...)

+ type RuntimeEventSessionStartFunction func(userID, username string, vars map[string]string, expiry int64, ...)

+ type RuntimeExecutionMode int

+ const RuntimeExecutionModeAfter

+ const RuntimeExecutionModeBefore

+ const RuntimeExecutionModeEvent

+ const RuntimeExecutionModeLeaderboardReset

+ const RuntimeExecutionModeMatch

+ const RuntimeExecutionModeMatchCreate

+ const RuntimeExecutionModeMatchmaker

+ const RuntimeExecutionModeRPC

+ const RuntimeExecutionModeRunOnce

+ const RuntimeExecutionModeTournamentEnd

+ const RuntimeExecutionModeTournamentReset

+ func (e RuntimeExecutionMode) String() string

+ type RuntimeGoInitializer struct

+ func (ri *RuntimeGoInitializer) RegisterAfterAddFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterAddGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateCustom(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateDevice(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateEmail(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateFacebook(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateFacebookInstantGame(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateGameCenter(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateSteam(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterBanGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterBlockFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterCreateGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterDeleteFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterDeleteGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterDeleteLeaderboardRecord(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterDeleteNotification(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterDeleteStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterDemoteGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterEvent(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterGetAccount(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterGetUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterImportFacebookFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterJoinGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterJoinTournament(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterKickGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterLeaveGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterLinkApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterLinkCustom(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterLinkDevice(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterLinkEmail(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterLinkFacebook(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterLinkFacebookInstantGame(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterLinkGameCenter(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterLinkGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterLinkSteam(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListChannelMessages(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListGroups(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListLeaderboardRecords(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListLeaderboardRecordsAroundOwner(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListMatches(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListNotifications(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListTournamentRecords(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListTournamentRecordsAroundOwner(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListTournaments(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterListUserGroups(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterPromoteGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterReadStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterRt(id string, ...) error

+ func (ri *RuntimeGoInitializer) RegisterAfterSessionRefresh(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterUnlinkApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterUnlinkCustom(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterUnlinkDevice(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterUnlinkEmail(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterUnlinkFacebook(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterUnlinkFacebookInstantGame(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterUnlinkGameCenter(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterUnlinkGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterUnlinkSteam(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterUpdateAccount(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterUpdateGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterWriteLeaderboardRecord(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterWriteStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterAfterWriteTournamentRecord(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeAddFriends(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeAddGroupUsers(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateApple(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateCustom(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateDevice(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateEmail(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateFacebook(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateFacebookInstantGame(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateGameCenter(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateGoogle(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateSteam(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeBanGroupUsers(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeBlockFriends(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeCreateGroup(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeDeleteFriends(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeDeleteGroup(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeDeleteLeaderboardRecord(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeDeleteNotification(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeDeleteStorageObjects(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeDemoteGroupUsers(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeEvent(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeGetAccount(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeGetUsers(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeImportFacebookFriends(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeJoinGroup(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeJoinTournament(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeKickGroupUsers(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeLeaveGroup(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeLinkApple(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeLinkCustom(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeLinkDevice(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeLinkEmail(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeLinkFacebook(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeLinkFacebookInstantGame(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeLinkGameCenter(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeLinkGoogle(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeLinkSteam(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListChannelMessages(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListFriends(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListGroupUsers(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListGroups(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListLeaderboardRecords(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListLeaderboardRecordsAroundOwner(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListMatches(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListNotifications(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListStorageObjects(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListTournamentRecords(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListTournamentRecordsAroundOwner(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListTournaments(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeListUserGroups(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforePromoteGroupUsers(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeReadStorageObjects(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeRt(id string, ...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeSessionRefresh(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkApple(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkCustom(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkDevice(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkEmail(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkFacebook(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkFacebookInstantGame(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkGameCenter(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkGoogle(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkSteam(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeUpdateAccount(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeUpdateGroup(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeWriteLeaderboardRecord(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeWriteStorageObjects(...) error

+ func (ri *RuntimeGoInitializer) RegisterBeforeWriteTournamentRecord(...) error

+ func (ri *RuntimeGoInitializer) RegisterEvent(fn func(ctx context.Context, logger runtime.Logger, evt *api.Event)) error

+ func (ri *RuntimeGoInitializer) RegisterEventSessionEnd(fn func(ctx context.Context, logger runtime.Logger, evt *api.Event)) error

+ func (ri *RuntimeGoInitializer) RegisterEventSessionStart(fn func(ctx context.Context, logger runtime.Logger, evt *api.Event)) error

+ func (ri *RuntimeGoInitializer) RegisterLeaderboardReset(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterMatch(name string, ...) error

+ func (ri *RuntimeGoInitializer) RegisterMatchmakerMatched(...) error

+ func (ri *RuntimeGoInitializer) RegisterRpc(id string, ...) error

+ func (ri *RuntimeGoInitializer) RegisterTournamentEnd(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ func (ri *RuntimeGoInitializer) RegisterTournamentReset(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error

+ type RuntimeGoLogger struct

+ func (l *RuntimeGoLogger) Debug(format string, v ...interface{})

+ func (l *RuntimeGoLogger) Error(format string, v ...interface{})

+ func (l *RuntimeGoLogger) Fields() map[string]interface{}

+ func (l *RuntimeGoLogger) Info(format string, v ...interface{})

+ func (l *RuntimeGoLogger) Warn(format string, v ...interface{})

+ func (l *RuntimeGoLogger) WithField(key string, v interface{}) nkruntime.Logger

+ func (l *RuntimeGoLogger) WithFields(fields map[string]interface{}) nkruntime.Logger

+ type RuntimeGoMatchCore struct

+ func (r *RuntimeGoMatchCore) BroadcastMessage(opCode int64, data []byte, presences []runtime.Presence, ...) error

+ func (r *RuntimeGoMatchCore) BroadcastMessageDeferred(opCode int64, data []byte, presences []runtime.Presence, ...) error

+ func (r *RuntimeGoMatchCore) Cancel()

+ func (r *RuntimeGoMatchCore) GetState(state interface{}) (string, error)

+ func (r *RuntimeGoMatchCore) HandlerName() string

+ func (r *RuntimeGoMatchCore) Label() string

+ func (r *RuntimeGoMatchCore) MatchInit(presenceList *MatchPresenceList, ...) (interface{}, int, error)

+ func (r *RuntimeGoMatchCore) MatchJoin(tick int64, state interface{}, joins []*MatchPresence) (interface{}, error)

+ func (r *RuntimeGoMatchCore) MatchJoinAttempt(tick int64, state interface{}, userID, sessionID uuid.UUID, username string, ...) (interface{}, bool, string, error)

+ func (r *RuntimeGoMatchCore) MatchKick(presences []runtime.Presence) error

+ func (r *RuntimeGoMatchCore) MatchLabelUpdate(label string) error

+ func (r *RuntimeGoMatchCore) MatchLeave(tick int64, state interface{}, leaves []*MatchPresence) (interface{}, error)

+ func (r *RuntimeGoMatchCore) MatchLoop(tick int64, state interface{}, inputCh <-chan *MatchDataMessage) (interface{}, error)

+ func (r *RuntimeGoMatchCore) MatchTerminate(tick int64, state interface{}, graceSeconds int) (interface{}, error)

+ type RuntimeGoNakamaModule struct

+ func NewRuntimeGoNakamaModule(logger *zap.Logger, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, ...) *RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) AccountDeleteId(ctx context.Context, userID string, recorded bool) error

+ func (n *RuntimeGoNakamaModule) AccountExportId(ctx context.Context, userID string) (string, error)

+ func (n *RuntimeGoNakamaModule) AccountGetId(ctx context.Context, userID string) (*api.Account, error)

+ func (n *RuntimeGoNakamaModule) AccountUpdateId(ctx context.Context, userID, username string, metadata map[string]interface{}, ...) error

+ func (n *RuntimeGoNakamaModule) AccountsGetId(ctx context.Context, userIDs []string) ([]*api.Account, error)

+ func (n *RuntimeGoNakamaModule) AuthenticateApple(ctx context.Context, token, username string, create bool) (string, string, bool, error)

+ func (n *RuntimeGoNakamaModule) AuthenticateCustom(ctx context.Context, id, username string, create bool) (string, string, bool, error)

+ func (n *RuntimeGoNakamaModule) AuthenticateDevice(ctx context.Context, id, username string, create bool) (string, string, bool, error)

+ func (n *RuntimeGoNakamaModule) AuthenticateEmail(ctx context.Context, email, password, username string, create bool) (string, string, bool, error)

+ func (n *RuntimeGoNakamaModule) AuthenticateFacebook(ctx context.Context, token string, importFriends bool, username string, ...) (string, string, bool, error)

+ func (n *RuntimeGoNakamaModule) AuthenticateFacebookInstantGame(ctx context.Context, signedPlayerInfo string, username string, create bool) (string, string, bool, error)

+ func (n *RuntimeGoNakamaModule) AuthenticateGameCenter(ctx context.Context, playerID, bundleID string, timestamp int64, ...) (string, string, bool, error)

+ func (n *RuntimeGoNakamaModule) AuthenticateGoogle(ctx context.Context, token, username string, create bool) (string, string, bool, error)

+ func (n *RuntimeGoNakamaModule) AuthenticateSteam(ctx context.Context, token, username string, create bool) (string, string, bool, error)

+ func (n *RuntimeGoNakamaModule) AuthenticateTokenGenerate(userID, username string, exp int64, vars map[string]string) (string, int64, error)

+ func (n *RuntimeGoNakamaModule) Event(ctx context.Context, evt *api.Event) error

+ func (n *RuntimeGoNakamaModule) FriendsList(ctx context.Context, userID string, limit int, state *int, cursor string) ([]*api.Friend, string, error)

+ func (n *RuntimeGoNakamaModule) GroupCreate(ctx context.Context, ...) (*api.Group, error)

+ func (n *RuntimeGoNakamaModule) GroupDelete(ctx context.Context, id string) error

+ func (n *RuntimeGoNakamaModule) GroupUpdate(ctx context.Context, ...) error

+ func (n *RuntimeGoNakamaModule) GroupUserJoin(ctx context.Context, groupID, userID, username string) error

+ func (n *RuntimeGoNakamaModule) GroupUserLeave(ctx context.Context, groupID, userID, username string) error

+ func (n *RuntimeGoNakamaModule) GroupUsersAdd(ctx context.Context, groupID string, userIDs []string) error

+ func (n *RuntimeGoNakamaModule) GroupUsersDemote(ctx context.Context, groupID string, userIDs []string) error

+ func (n *RuntimeGoNakamaModule) GroupUsersKick(ctx context.Context, groupID string, userIDs []string) error

+ func (n *RuntimeGoNakamaModule) GroupUsersList(ctx context.Context, id string, limit int, state *int, cursor string) ([]*api.GroupUserList_GroupUser, string, error)

+ func (n *RuntimeGoNakamaModule) GroupUsersPromote(ctx context.Context, groupID string, userIDs []string) error

+ func (n *RuntimeGoNakamaModule) GroupsGetId(ctx context.Context, groupIDs []string) ([]*api.Group, error)

+ func (n *RuntimeGoNakamaModule) LeaderboardCreate(ctx context.Context, id string, authoritative bool, ...) error

+ func (n *RuntimeGoNakamaModule) LeaderboardDelete(ctx context.Context, id string) error

+ func (n *RuntimeGoNakamaModule) LeaderboardRecordDelete(ctx context.Context, id, ownerID string) error

+ func (n *RuntimeGoNakamaModule) LeaderboardRecordWrite(ctx context.Context, id, ownerID, username string, score, subscore int64, ...) (*api.LeaderboardRecord, error)

+ func (n *RuntimeGoNakamaModule) LeaderboardRecordsList(ctx context.Context, id string, ownerIDs []string, limit int, cursor string, ...) ([]*api.LeaderboardRecord, []*api.LeaderboardRecord, string, string, error)

+ func (n *RuntimeGoNakamaModule) LinkApple(ctx context.Context, userID, token string) error

+ func (n *RuntimeGoNakamaModule) LinkCustom(ctx context.Context, userID, customID string) error

+ func (n *RuntimeGoNakamaModule) LinkDevice(ctx context.Context, userID, deviceID string) error

+ func (n *RuntimeGoNakamaModule) LinkEmail(ctx context.Context, userID, email, password string) error

+ func (n *RuntimeGoNakamaModule) LinkFacebook(ctx context.Context, userID, username, token string, importFriends bool) error

+ func (n *RuntimeGoNakamaModule) LinkFacebookInstantGame(ctx context.Context, userID, signedPlayerInfo string) error

+ func (n *RuntimeGoNakamaModule) LinkGameCenter(ctx context.Context, userID, playerID, bundleID string, timestamp int64, ...) error

+ func (n *RuntimeGoNakamaModule) LinkGoogle(ctx context.Context, userID, token string) error

+ func (n *RuntimeGoNakamaModule) LinkSteam(ctx context.Context, userID, token string) error

+ func (n *RuntimeGoNakamaModule) MatchCreate(ctx context.Context, module string, params map[string]interface{}) (string, error)

+ func (n *RuntimeGoNakamaModule) MatchGet(ctx context.Context, id string) (*api.Match, error)

+ func (n *RuntimeGoNakamaModule) MatchList(ctx context.Context, limit int, authoritative bool, label string, ...) ([]*api.Match, error)

+ func (n *RuntimeGoNakamaModule) MultiUpdate(ctx context.Context, accountUpdates []*runtime.AccountUpdate, ...) ([]*api.StorageObjectAck, []*runtime.WalletUpdateResult, error)

+ func (n *RuntimeGoNakamaModule) NotificationSend(ctx context.Context, userID, subject string, content map[string]interface{}, ...) error

+ func (n *RuntimeGoNakamaModule) NotificationsSend(ctx context.Context, notifications []*runtime.NotificationSend) error

+ func (n *RuntimeGoNakamaModule) ReadFile(relPath string) (*os.File, error)

+ func (n *RuntimeGoNakamaModule) SessionDisconnect(ctx context.Context, sessionID string) error

+ func (n *RuntimeGoNakamaModule) SetEventFn(fn RuntimeEventCustomFunction)

+ func (n *RuntimeGoNakamaModule) StorageDelete(ctx context.Context, deletes []*runtime.StorageDelete) error

+ func (n *RuntimeGoNakamaModule) StorageList(ctx context.Context, userID, collection string, limit int, cursor string) ([]*api.StorageObject, string, error)

+ func (n *RuntimeGoNakamaModule) StorageRead(ctx context.Context, reads []*runtime.StorageRead) ([]*api.StorageObject, error)

+ func (n *RuntimeGoNakamaModule) StorageWrite(ctx context.Context, writes []*runtime.StorageWrite) ([]*api.StorageObjectAck, error)

+ func (n *RuntimeGoNakamaModule) StreamClose(mode uint8, subject, subcontext, label string) error

+ func (n *RuntimeGoNakamaModule) StreamCount(mode uint8, subject, subcontext, label string) (int, error)

+ func (n *RuntimeGoNakamaModule) StreamSend(mode uint8, subject, subcontext, label, data string, ...) error

+ func (n *RuntimeGoNakamaModule) StreamSendRaw(mode uint8, subject, subcontext, label string, msg *rtapi.Envelope, ...) error

+ func (n *RuntimeGoNakamaModule) StreamUserGet(mode uint8, subject, subcontext, label, userID, sessionID string) (runtime.PresenceMeta, error)

+ func (n *RuntimeGoNakamaModule) StreamUserJoin(mode uint8, subject, subcontext, label, userID, sessionID string, ...) (bool, error)

+ func (n *RuntimeGoNakamaModule) StreamUserKick(mode uint8, subject, subcontext, label string, presence runtime.Presence) error

+ func (n *RuntimeGoNakamaModule) StreamUserLeave(mode uint8, subject, subcontext, label, userID, sessionID string) error

+ func (n *RuntimeGoNakamaModule) StreamUserList(mode uint8, subject, subcontext, label string, ...) ([]runtime.Presence, error)

+ func (n *RuntimeGoNakamaModule) StreamUserUpdate(mode uint8, subject, subcontext, label, userID, sessionID string, ...) error

+ func (n *RuntimeGoNakamaModule) TournamentAddAttempt(ctx context.Context, id, ownerID string, count int) error

+ func (n *RuntimeGoNakamaModule) TournamentCreate(ctx context.Context, id string, sortOrder, operator, resetSchedule string, ...) error

+ func (n *RuntimeGoNakamaModule) TournamentDelete(ctx context.Context, id string) error

+ func (n *RuntimeGoNakamaModule) TournamentJoin(ctx context.Context, id, ownerID, username string) error

+ func (n *RuntimeGoNakamaModule) TournamentList(ctx context.Context, categoryStart, categoryEnd, startTime, endTime, limit int, ...) (*api.TournamentList, error)

+ func (n *RuntimeGoNakamaModule) TournamentRecordWrite(ctx context.Context, id, ownerID, username string, score, subscore int64, ...) (*api.LeaderboardRecord, error)

+ func (n *RuntimeGoNakamaModule) TournamentRecordsHaystack(ctx context.Context, id, ownerID string, limit int, expiry int64) ([]*api.LeaderboardRecord, error)

+ func (n *RuntimeGoNakamaModule) TournamentRecordsList(ctx context.Context, tournamentId string, ownerIDs []string, limit int, ...) ([]*api.LeaderboardRecord, []*api.LeaderboardRecord, string, string, error)

+ func (n *RuntimeGoNakamaModule) TournamentsGetId(ctx context.Context, tournamentIDs []string) ([]*api.Tournament, error)

+ func (n *RuntimeGoNakamaModule) UnlinkApple(ctx context.Context, userID, token string) error

+ func (n *RuntimeGoNakamaModule) UnlinkCustom(ctx context.Context, userID, customID string) error

+ func (n *RuntimeGoNakamaModule) UnlinkDevice(ctx context.Context, userID, deviceID string) error

+ func (n *RuntimeGoNakamaModule) UnlinkEmail(ctx context.Context, userID, email string) error

+ func (n *RuntimeGoNakamaModule) UnlinkFacebook(ctx context.Context, userID, token string) error

+ func (n *RuntimeGoNakamaModule) UnlinkFacebookInstantGame(ctx context.Context, userID, signedPlayerInfo string) error

+ func (n *RuntimeGoNakamaModule) UnlinkGameCenter(ctx context.Context, userID, playerID, bundleID string, timestamp int64, ...) error

+ func (n *RuntimeGoNakamaModule) UnlinkGoogle(ctx context.Context, userID, token string) error

+ func (n *RuntimeGoNakamaModule) UnlinkSteam(ctx context.Context, userID, token string) error

+ func (n *RuntimeGoNakamaModule) UserGroupsList(ctx context.Context, userID string, limit int, state *int, cursor string) ([]*api.UserGroupList_UserGroup, string, error)

+ func (n *RuntimeGoNakamaModule) UsersBanId(ctx context.Context, userIDs []string) error

+ func (n *RuntimeGoNakamaModule) UsersGetId(ctx context.Context, userIDs []string) ([]*api.User, error)

+ func (n *RuntimeGoNakamaModule) UsersGetUsername(ctx context.Context, usernames []string) ([]*api.User, error)

+ func (n *RuntimeGoNakamaModule) UsersUnbanId(ctx context.Context, userIDs []string) error

+ func (n *RuntimeGoNakamaModule) WalletLedgerList(ctx context.Context, userID string, limit int, cursor string) ([]runtime.WalletLedgerItem, string, error)

+ func (n *RuntimeGoNakamaModule) WalletLedgerUpdate(ctx context.Context, itemID string, metadata map[string]interface{}) (runtime.WalletLedgerItem, error)

+ func (n *RuntimeGoNakamaModule) WalletUpdate(ctx context.Context, userID string, changeset map[string]int64, ...) (map[string]int64, map[string]int64, error)

+ func (n *RuntimeGoNakamaModule) WalletsUpdate(ctx context.Context, updates []*runtime.WalletUpdate, updateLedger bool) ([]*runtime.WalletUpdateResult, error)

+ type RuntimeInfo struct

+ GoModules []*moduleInfo

+ GoRpcFunctions []string

+ JavaScriptModules []*moduleInfo

+ JavaScriptRpcFunctions []string

+ LuaModules []*moduleInfo

+ LuaRpcFunctions []string

+ type RuntimeJS struct

+ func (r *RuntimeJS) GetCallback(e RuntimeExecutionMode, key string) interface{}

+ func (r *RuntimeJS) InvokeFunction(execMode RuntimeExecutionMode, id string, fn goja.Callable, ...) (interface{}, error, codes.Code)

+ type RuntimeJSModule struct

+ Name string

+ Path string

+ Program *goja.Program

+ type RuntimeJSModuleCache struct

+ Modules map[string]*RuntimeJSModule

+ Names []string

+ func (mc *RuntimeJSModuleCache) Add(m *RuntimeJSModule)

+ type RuntimeJavaScriptMatchCore struct

+ func (rm *RuntimeJavaScriptMatchCore) Cancel()

+ func (rm *RuntimeJavaScriptMatchCore) GetState(state interface{}) (string, error)

+ func (rm *RuntimeJavaScriptMatchCore) HandlerName() string

+ func (rm *RuntimeJavaScriptMatchCore) Label() string

+ func (rm *RuntimeJavaScriptMatchCore) MatchInit(presenceList *MatchPresenceList, ...) (interface{}, int, error)

+ func (rm *RuntimeJavaScriptMatchCore) MatchJoin(tick int64, state interface{}, joins []*MatchPresence) (interface{}, error)

+ func (rm *RuntimeJavaScriptMatchCore) MatchJoinAttempt(tick int64, state interface{}, userID, sessionID uuid.UUID, username string, ...) (interface{}, bool, string, error)

+ func (rm *RuntimeJavaScriptMatchCore) MatchLeave(tick int64, state interface{}, leaves []*MatchPresence) (interface{}, error)

+ func (rm *RuntimeJavaScriptMatchCore) MatchLoop(tick int64, state interface{}, inputCh <-chan *MatchDataMessage) (interface{}, error)

+ func (rm *RuntimeJavaScriptMatchCore) MatchTerminate(tick int64, state interface{}, graceSeconds int) (interface{}, error)

+ type RuntimeJavascriptCallbacks struct

+ After map[string]interface{}

+ Before map[string]interface{}

+ LeaderboardReset interface{}

+ Matchmaker interface{}

+ Rpc map[string]interface{}

+ TournamentEnd interface{}

+ TournamentReset interface{}

+ type RuntimeJavascriptInitModule struct

+ Callbacks *RuntimeJavascriptCallbacks

+ Logger *zap.Logger

+ MatchCallbacks *RuntimeJavascriptMatchHandlers

+ func NewRuntimeJavascriptInitModule(logger *zap.Logger, announceCallbackFn func(RuntimeExecutionMode, string)) *RuntimeJavascriptInitModule

+ func (im *RuntimeJavascriptInitModule) Constructor(r *goja.Runtime) func(goja.ConstructorCall) *goja.Object

+ type RuntimeJavascriptMatchHandlers struct

+ func (rmh *RuntimeJavascriptMatchHandlers) Add(name string, handlers *jsMatchHandlers)

+ func (rmh *RuntimeJavascriptMatchHandlers) Get(name string) *jsMatchHandlers

+ type RuntimeLeaderboardResetFunction func(ctx context.Context, leaderboard runtime.Leaderboard, reset int64) error

+ type RuntimeLua struct

+ func (r *RuntimeLua) GetCallback(e RuntimeExecutionMode, key string) *lua.LFunction

+ func (r *RuntimeLua) InvokeFunction(execMode RuntimeExecutionMode, fn *lua.LFunction, ...) (interface{}, error, codes.Code, bool)

+ func (r *RuntimeLua) Stop()

+ type RuntimeLuaCallbacks struct

+ After map[string]*lua.LFunction

+ Before map[string]*lua.LFunction

+ LeaderboardReset *lua.LFunction

+ Matchmaker *lua.LFunction

+ RPC map[string]*lua.LFunction

+ TournamentEnd *lua.LFunction

+ TournamentReset *lua.LFunction

+ type RuntimeLuaLocalCache struct

+ func NewRuntimeLuaLocalCache() *RuntimeLuaLocalCache

+ func (lc *RuntimeLuaLocalCache) Delete(key string)

+ func (lc *RuntimeLuaLocalCache) Get(key string) (lua.LValue, bool)

+ func (lc *RuntimeLuaLocalCache) Put(key string, value lua.LValue)

+ type RuntimeLuaMatchCore struct

+ func (r *RuntimeLuaMatchCore) Cancel()

+ func (r *RuntimeLuaMatchCore) GetState(state interface{}) (string, error)

+ func (r *RuntimeLuaMatchCore) HandlerName() string

+ func (r *RuntimeLuaMatchCore) Label() string

+ func (r *RuntimeLuaMatchCore) MatchInit(presenceList *MatchPresenceList, ...) (interface{}, int, error)

+ func (r *RuntimeLuaMatchCore) MatchJoin(tick int64, state interface{}, joins []*MatchPresence) (interface{}, error)

+ func (r *RuntimeLuaMatchCore) MatchJoinAttempt(tick int64, state interface{}, userID, sessionID uuid.UUID, username string, ...) (interface{}, bool, string, error)

+ func (r *RuntimeLuaMatchCore) MatchLeave(tick int64, state interface{}, leaves []*MatchPresence) (interface{}, error)

+ func (r *RuntimeLuaMatchCore) MatchLoop(tick int64, state interface{}, inputCh <-chan *MatchDataMessage) (interface{}, error)

+ func (r *RuntimeLuaMatchCore) MatchTerminate(tick int64, state interface{}, graceSeconds int) (interface{}, error)

+ type RuntimeLuaModule struct

+ Content []byte

+ Name string

+ Path string

+ type RuntimeLuaModuleCache struct

+ Modules map[string]*RuntimeLuaModule

+ Names []string

+ func (mc *RuntimeLuaModuleCache) Add(m *RuntimeLuaModule)

+ type RuntimeLuaNakamaModule struct

+ func NewRuntimeLuaNakamaModule(logger *zap.Logger, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, ...) *RuntimeLuaNakamaModule

+ func (n *RuntimeLuaNakamaModule) Loader(l *lua.LState) int

+ type RuntimeMatchCore interface

+ Cancel func()

+ GetState func(state interface{}) (string, error)

+ HandlerName func() string

+ Label func() string

+ MatchInit func(presenceList *MatchPresenceList, ...) (interface{}, int, error)

+ MatchJoin func(tick int64, state interface{}, joins []*MatchPresence) (interface{}, error)

+ MatchJoinAttempt func(tick int64, state interface{}, userID, sessionID uuid.UUID, username string, ...) (interface{}, bool, string, error)

+ MatchLeave func(tick int64, state interface{}, leaves []*MatchPresence) (interface{}, error)

+ MatchLoop func(tick int64, state interface{}, inputCh <-chan *MatchDataMessage) (interface{}, error)

+ MatchTerminate func(tick int64, state interface{}, graceSeconds int) (interface{}, error)

+ func NewRuntimeGoMatchCore(logger *zap.Logger, module string, matchRegistry MatchRegistry, ...) (RuntimeMatchCore, error)

+ func NewRuntimeJavascriptMatchCore(logger *zap.Logger, module string, db *sql.DB, ...) (RuntimeMatchCore, error)

+ func NewRuntimeLuaMatchCore(logger *zap.Logger, module string, db *sql.DB, ...) (RuntimeMatchCore, error)

+ type RuntimeMatchCreateFunction func(ctx context.Context, logger *zap.Logger, id uuid.UUID, node string, ...) (RuntimeMatchCore, error)

+ type RuntimeMatchDeferMessageFunction func(msg *DeferredMessage) error

+ type RuntimeMatchmakerMatchedFunction func(ctx context.Context, entries []*MatchmakerEntry) (string, bool, error)

+ type RuntimeProviderJS struct

+ func (rp *RuntimeProviderJS) AfterReq(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) error

+ func (rp *RuntimeProviderJS) AfterRt(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) error

+ func (rp *RuntimeProviderJS) BeforeReq(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) (interface{}, error, codes.Code)

+ func (rp *RuntimeProviderJS) BeforeRt(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) (*rtapi.Envelope, error)

+ func (rp *RuntimeProviderJS) Get(ctx context.Context) (*RuntimeJS, error)

+ func (rp *RuntimeProviderJS) LeaderboardReset(ctx context.Context, leaderboard runtime.Leaderboard, reset int64) error

+ func (rp *RuntimeProviderJS) MatchmakerMatched(ctx context.Context, entries []*MatchmakerEntry) (string, bool, error)

+ func (rp *RuntimeProviderJS) Put(r *RuntimeJS)

+ func (rp *RuntimeProviderJS) Rpc(ctx context.Context, id string, queryParams map[string][]string, ...) (string, error, codes.Code)

+ func (rp *RuntimeProviderJS) TournamentEnd(ctx context.Context, tournament *api.Tournament, end, reset int64) error

+ func (rp *RuntimeProviderJS) TournamentReset(ctx context.Context, tournament *api.Tournament, end, reset int64) error

+ type RuntimeProviderLua struct

+ func (rp *RuntimeProviderLua) AfterReq(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) error

+ func (rp *RuntimeProviderLua) AfterRt(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) error

+ func (rp *RuntimeProviderLua) BeforeReq(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) (interface{}, error, codes.Code)

+ func (rp *RuntimeProviderLua) BeforeRt(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) (*rtapi.Envelope, error)

+ func (rp *RuntimeProviderLua) Get(ctx context.Context) (*RuntimeLua, error)

+ func (rp *RuntimeProviderLua) LeaderboardReset(ctx context.Context, leaderboard runtime.Leaderboard, reset int64) error

+ func (rp *RuntimeProviderLua) MatchmakerMatched(ctx context.Context, entries []*MatchmakerEntry) (string, bool, error)

+ func (rp *RuntimeProviderLua) Put(r *RuntimeLua)

+ func (rp *RuntimeProviderLua) Rpc(ctx context.Context, id string, queryParams map[string][]string, ...) (string, error, codes.Code)

+ func (rp *RuntimeProviderLua) TournamentEnd(ctx context.Context, tournament *api.Tournament, end, reset int64) error

+ func (rp *RuntimeProviderLua) TournamentReset(ctx context.Context, tournament *api.Tournament, end, reset int64) error

+ type RuntimeRpcFunction func(ctx context.Context, queryParams map[string][]string, userID, username string, ...) (string, error, codes.Code)

+ type RuntimeTournamentEndFunction func(ctx context.Context, tournament *api.Tournament, end, reset int64) error

+ type RuntimeTournamentResetFunction func(ctx context.Context, tournament *api.Tournament, end, reset int64) error

+ type Scannable interface

+ Scan func(dest ...interface{}) error

+ type Session interface

+ ClientIP func() string

+ ClientPort func() string

+ Close func(reason string)

+ Consume func()

+ Context func() context.Context

+ Expiry func() int64

+ Format func() SessionFormat

+ ID func() uuid.UUID

+ Logger func() *zap.Logger

+ Send func(envelope *rtapi.Envelope, reliable bool) error

+ SendBytes func(payload []byte, reliable bool) error

+ SetUsername func(string)

+ UserID func() uuid.UUID

+ Username func() string

+ Vars func() map[string]string

+ func NewSessionWS(logger *zap.Logger, config Config, format SessionFormat, ...) Session

+ type SessionConfig struct

+ EncryptionKey string

+ RefreshEncryptionKey string

+ RefreshTokenExpirySec int64

+ TokenExpirySec int64

+ func NewSessionConfig() *SessionConfig

+ type SessionFormat uint8

+ const SessionFormatJson

+ const SessionFormatProtobuf

+ type SessionRegistry interface

+ Add func(session Session)

+ Count func() int

+ Disconnect func(ctx context.Context, sessionID uuid.UUID) error

+ Get func(sessionID uuid.UUID) Session

+ Remove func(sessionID uuid.UUID)

+ Stop func()

+ func NewLocalSessionRegistry(metrics *Metrics) SessionRegistry

+ type SessionTokenClaims struct

+ ExpiresAt int64

+ UserId string

+ Username string

+ Vars map[string]string

+ func (stc *SessionTokenClaims) Valid() error

+ type SocialConfig struct

+ Apple *SocialConfigApple

+ FacebookInstantGame *SocialConfigFacebookInstantGame

+ Steam *SocialConfigSteam

+ func NewSocialConfig() *SocialConfig

+ type SocialConfigApple struct

+ BundleId string

+ type SocialConfigFacebookInstantGame struct

+ AppSecret string

+ type SocialConfigSteam struct

+ AppID int

+ PublisherKey string

+ type SocketConfig struct

+ Address string

+ CertPEMBlock []byte

+ IdleTimeoutMs int

+ KeyPEMBlock []byte

+ MaxMessageSizeBytes int64

+ MaxRequestSizeBytes int64

+ OutgoingQueueSize int

+ PingBackoffThreshold int

+ PingPeriodMs int

+ PongWaitMs int

+ Port int

+ Protocol string

+ ReadBufferSizeBytes int

+ ReadTimeoutMs int

+ SSLCertificate string

+ SSLPrivateKey string

+ ServerKey string

+ TLSCert []tls.Certificate

+ WriteBufferSizeBytes int

+ WriteTimeoutMs int

+ WriteWaitMs int

+ func NewSocketConfig() *SocketConfig

+ type StatusHandler interface

+ GetStatus func(ctx context.Context) ([]*console.StatusList_Status, error)

+ func NewLocalStatusHandler(logger *zap.Logger, sessionRegistry SessionRegistry, ...) StatusHandler

+ type StorageOpDelete struct

+ ObjectID *api.DeleteStorageObjectId

+ OwnerID string

+ type StorageOpDeletes []*StorageOpDelete

+ func (s StorageOpDeletes) Len() int

+ func (s StorageOpDeletes) Less(i, j int) bool

+ func (s StorageOpDeletes) Swap(i, j int)

+ type StorageOpWrite struct

+ Object *api.WriteStorageObject

+ OwnerID string

+ type StorageOpWrites []*StorageOpWrite

+ func (s StorageOpWrites) Len() int

+ func (s StorageOpWrites) Less(i, j int) bool

+ func (s StorageOpWrites) Swap(i, j int)

+ type StreamManager interface

+ UserJoin func(stream PresenceStream, userID, sessionID uuid.UUID, hidden, persistence bool, ...) (bool, bool, error)

+ UserLeave func(stream PresenceStream, userID, sessionID uuid.UUID) error

+ UserUpdate func(stream PresenceStream, userID, sessionID uuid.UUID, hidden, persistence bool, ...) (bool, error)

+ func NewLocalStreamManager(config Config, sessionRegistry SessionRegistry, tracker Tracker) StreamManager

+ type TournamentListCursor struct

+ Id string

+ type Tracker interface

+ Count func() int

+ CountByStream func(stream PresenceStream) int

+ CountByStreamModeFilter func(modes map[uint8]*uint8) map[*PresenceStream]int32

+ GetBySessionIDStreamUserID func(node string, sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID) *PresenceMeta

+ GetLocalBySessionIDStreamUserID func(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID) *PresenceMeta

+ ListByStream func(stream PresenceStream, includeHidden bool, includeNotHidden bool) []*Presence

+ ListLocalSessionIDByStream func(stream PresenceStream) []uuid.UUID

+ ListNodesForStream func(stream PresenceStream) map[string]struct{}

+ ListPresenceIDByStream func(stream PresenceStream) []*PresenceID

+ SetMatchJoinListener func(func(id uuid.UUID, joins []*MatchPresence))

+ SetMatchLeaveListener func(func(id uuid.UUID, leaves []*MatchPresence))

+ SetPartyJoinListener func(func(id uuid.UUID, joins []*Presence))

+ SetPartyLeaveListener func(func(id uuid.UUID, leaves []*Presence))

+ Stop func()

+ StreamExists func(stream PresenceStream) bool

+ Track func(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID, ...) (bool, bool)

+ Untrack func(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID)

+ UntrackAll func(sessionID uuid.UUID)

+ UntrackByStream func(stream PresenceStream)

+ UntrackLocalByStream func(stream PresenceStream)

+ Update func(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID, ...) bool

+ func StartLocalTracker(logger *zap.Logger, config Config, sessionRegistry SessionRegistry, ...) Tracker

+ type TrackerConfig struct

+ EventQueueSize int

+ func NewTrackerConfig() *TrackerConfig

+ type Tx interface

+ Commit func() error

+ ExecContext func(context.Context, string, ...interface{}) (sql.Result, error)

+ Rollback func() error

+ type TxnRestartError struct

+ func (e *TxnRestartError) Cause() error

+ func (e *TxnRestartError) Error() string

+ func (e *TxnRestartError) RetryCause() error

Other modules containing this package

github.com/heroiclabs/nakama

github.com/heroiclabs/nakama/v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL