server

package

Go to main page

Versions in this module

v2

v2.5.1

May 3, 2019

Changes in this version

type MatchPresenceList

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

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

+ type MatchPresenceListItem struct

+ Presence *MatchPresence

+ PresenceID *PresenceID

v2.5.0

Apr 25, 2019

Changes in this version

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

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

+ var ErrStorageWriteFailed = errors.New("Storage write failed.")

type ConsoleConfig

+ TokenExpirySec int64

type MatchHandler

+ PresenceList *MatchPresenceList

type MatchJoinMarkerList

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

type MatchPresenceList

+ func NewMatchPresenceList() *MatchPresenceList

+ func (m *MatchPresenceList) Size() int

+ 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)

v2.4.2

Mar 25, 2019

Changes in this version

+ const ObfuscationString

type Config

+ Clone func() (Config, error)

type ConsoleConfig

+ Address string

+ SigningKey string

type ConsoleServer

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

+ func (s *ConsoleServer) BanUser(ctx context.Context, in *console.AccountId) (*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) DeleteStorage(ctx context.Context, in *empty.Empty) (*empty.Empty, error)

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

+ func (s *ConsoleServer) DeleteWalletLedger(ctx context.Context, in *console.DeleteWalletLedgerRequest) (*empty.Empty, 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.Friends, error)

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

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

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

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

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

+ func (s *ConsoleServer) UnbanUser(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) 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)

type LocalMatchRegistry

+ func (r *LocalMatchRegistry) Count() int

type LocalSessionRegistry

+ func (r *LocalSessionRegistry) Count() int

+ type LocalStatusHandler struct

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

type MatchRegistry

+ Count func() int

+ type MetricsExporter struct

+ Input *atomic.Float64

+ Latency *atomic.Float64

+ Output *atomic.Float64

+ Rate *atomic.Float64

+ func NewMetricsExporter(logger *zap.Logger) *MetricsExporter

+ func (m *MetricsExporter) ExportView(vd *view.Data)

type Runtime

+ func (r *Runtime) EventSessionEnd() RuntimeEventSessionEndFunction

+ func (r *Runtime) EventSessionStart() RuntimeEventSessionStartFunction

type RuntimeConfig

+ EventQueueSize int

+ EventQueueWorkers int

+ 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) *RuntimeEventQueue

+ func (b *RuntimeEventQueue) Queue(fn func())

+ func (b *RuntimeEventQueue) Stop()

+ type RuntimeEventSessionEndFunction func(userID, username string, expiry int64, sessionID, clientIP, clientPort string, ...)

+ type RuntimeEventSessionStartFunction func(userID, username string, expiry int64, sessionID, clientIP, clientPort string, ...)

type RuntimeExecutionMode

+ const RuntimeExecutionModeEvent

type RuntimeGoInitializer

+ 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

type SessionRegistry

+ Count func() int

type SocketConfig

+ CertPEMBlock []byte

+ KeyPEMBlock []byte

+ type StatusHandler interface

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

+ func NewLocalStatusHandler(logger *zap.Logger, sessionRegistry SessionRegistry, ...) StatusHandler

v2.4.1

Mar 8, 2019

Changes in this version

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

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

type ConsoleConfig

+ IdleTimeoutMs int

+ MaxMessageSizeBytes int64

+ ReadTimeoutMs int

+ WriteTimeoutMs int

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) AccountDeleteId(ctx context.Context, userID string, recorded bool) error

v2.4.0

Feb 3, 2019

Changes in this version

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

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

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

+ func StackdriverTimeEncoder(t time.Time, enc zapcore.PrimitiveArrayEncoder)

+ type LocalSessionRegistry struct

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

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

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

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

+ func (r *LocalSessionRegistry) Stop()

+ type LocalStreamManager struct

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

type LoggerConfig

+ Format string

+ type LoggingFormat int8

+ const JSONFormat

+ const StackdriverFormat

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) SessionDisconnect(ctx context.Context, sessionID, node string) error

+ func (n *RuntimeGoNakamaModule) StreamUserKick(mode uint8, subject, subcontext, label string, presence runtime.Presence) error

type SessionRegistry

+ func NewLocalSessionRegistry() SessionRegistry

+ Add func(session Session)

+ Disconnect func(ctx context.Context, sessionID uuid.UUID, node string) error

+ Remove func(sessionID uuid.UUID)

+ type StreamManager interface

+ UserKick func(userID, sessionID uuid.UUID, node string, stream PresenceStream) error

+ func NewLocalStreamManager(config Config, sessionRegistry SessionRegistry, tracker Tracker) StreamManager

v2.3.2

Jan 17, 2019

v2.3.1

Jan 4, 2019

Changes in this version

type MatchConfig

+ JoinMarkerDeadlineMs int

v2.3.0

Dec 31, 2018

Changes in this version

+ const NotificationCodeDmRequest

+ const NotificationCodeFriendAccept

+ const NotificationCodeFriendJoinGame

+ const NotificationCodeFriendRequest

+ const NotificationCodeGroupAdd

+ const NotificationCodeGroupJoinRequest

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

+ var ErrNoJoinMarker = errors.New("no join marker received")

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

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

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

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

type Config

+ GetTracker func() *TrackerConfig

+ type DeferredMessage struct

+ Envelope *rtapi.Envelope

+ PresenceIDs []*PresenceID

type LocalMatchRegistry

+ func (r *LocalMatchRegistry) AwaitJoinMarker(ctx context.Context, id uuid.UUID, node string, sessionID uuid.UUID, ...) error

+ func (r *LocalMatchRegistry) GetMatchLabel(ctx context.Context, id uuid.UUID, node string) (string, error)

type LocalMessageRouter

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

type LoggerConfig

+ Compress bool

+ LocalTime bool

+ MaxAge int

+ MaxBackups int

+ MaxSize int

+ Rotation bool

type MatchConfig

+ DeferredQueueSize int

+ JoinAttemptQueueSize int

type MatchHandler

+ JoinMarkerList *MatchJoinMarkerList

+ func (mh *MatchHandler) QueueJoin(joins []*MatchPresence) 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

+ type MatchJoinMarker struct

+ type MatchJoinMarkerList struct

+ func (m *MatchJoinMarkerList) Add(sessionID uuid.UUID, expiryTick int64)

+ func (m *MatchJoinMarkerList) ClearExpired(tick int64)

+ func (m *MatchJoinMarkerList) Get(sessionID uuid.UUID) <-chan struct{}

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

+ type MatchPresenceList struct

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

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

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

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

type MatchRegistry

+ AwaitJoinMarker func(ctx context.Context, id uuid.UUID, node string, sessionID uuid.UUID, ...) error

+ GetMatchLabel func(ctx context.Context, id uuid.UUID, node string) (string, error)

type MessageRouter

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

type PresenceStream

+ Subcontext uuid.UUID

+ type RuntimeGoLogger struct

+ func (l *RuntimeGoLogger) Debug(format string, v ...interface{})

+ func (l *RuntimeGoLogger) Error(format string, v ...interface{})

+ func (l *RuntimeGoLogger) Fatal(v ...interface{})

+ func (l *RuntimeGoLogger) Fatalf(format string, v ...interface{})

+ func (l *RuntimeGoLogger) Fatalln(v ...interface{})

+ func (l *RuntimeGoLogger) Info(format string, v ...interface{})

+ func (l *RuntimeGoLogger) Panic(v ...interface{})

+ func (l *RuntimeGoLogger) Panicf(format string, v ...interface{})

+ func (l *RuntimeGoLogger) Panicln(v ...interface{})

+ func (l *RuntimeGoLogger) Print(v ...interface{})

+ func (l *RuntimeGoLogger) Printf(format string, v ...interface{})

+ func (l *RuntimeGoLogger) Println(v ...interface{})

+ func (l *RuntimeGoLogger) Warn(format string, v ...interface{})

type RuntimeGoMatchCore

+ func (r *RuntimeGoMatchCore) BroadcastMessageDeferred(opCode int64, data []byte, presences []runtime.Presence, ...) error

+ func (r *RuntimeGoMatchCore) Label() string

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) AccountsGetId(ctx context.Context, userIDs []string) ([]*api.Account, error)

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

type RuntimeLuaMatchCore

+ func (r *RuntimeLuaMatchCore) Label() string

type RuntimeMatchCore

+ Label func() string

+ type RuntimeMatchDeferMessageFunction func(msg *DeferredMessage) error

+ type TrackerConfig struct

+ EventQueueSize int

+ func NewTrackerConfig() *TrackerConfig

v2.2.1

Nov 20, 2018

v2.2.0

Nov 11, 2018

Changes in this version

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) StreamSendRaw(mode uint8, subject, descriptor, label string, msg *rtapi.Envelope) error

v2.1.3

Nov 2, 2018

Changes in this version

+ var MaxLabelSize = 2048

type LeaderboardCache

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

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

+ RefreshAllLeaderboards func(ctx context.Context) error

+ Remove func(id string)

type LeaderboardScheduler

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

+ Pause func()

+ Resume func()

type LocalLeaderboardCache

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

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

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

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

+ 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

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

type MatchIndexEntry

+ Node string

type MatchRegistry

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

type Runtime

+ func (r *Runtime) MatchCreateFunction() RuntimeMatchCreateFunction

v2.1.2

Oct 24, 2018

v2.1.1

Oct 21, 2018

Changes in this version

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

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

type LocalMatchRegistry

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

+ type MatchIndexEntry struct

+ Label map[string]interface{}

+ LabelString string

type MatchRegistry

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

type RuntimeGoMatchCore

+ func (r *RuntimeGoMatchCore) Cancel()

type RuntimeGoNakamaModule

+ func (n *RuntimeGoNakamaModule) GroupsGetId(ctx context.Context, groupIDs []string) ([]*api.Group, error)

type RuntimeLuaMatchCore

+ func (r *RuntimeLuaMatchCore) Cancel()

type RuntimeMatchCore

+ Cancel func()

+ type RuntimeMatchLabelUpdateFunction func(string) error

type Session

+ Context func() context.Context

v2.1.0

Oct 8, 2018

Changes in this version

+ const RUNTIME_LUA_CALLBACKS

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

+ 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")

+ func ExecuteRetryable(fn func() error) error

+ func LeaderboardRecordsHaystack(logger *zap.Logger, db *sql.DB, leaderboardCache LeaderboardCache, ...) ([]*api.LeaderboardRecord, error)

+ func NewRuntimeGoContext(env map[string]string, mode RuntimeExecutionMode, ...) context.Context

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

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

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

+ 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 RuntimeLuaConvertMapString(l *lua.LState, data map[string]string) *lua.LTable

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

+ func Terminate(graceSeconds int) func(mh *MatchHandler)

+ func TournamentAddAttempt(logger *zap.Logger, db *sql.DB, cache LeaderboardCache, leaderboardId string, ...) error

+ func TournamentCreate(logger *zap.Logger, cache LeaderboardCache, scheduler *LeaderboardScheduler, ...) error

+ func TournamentDelete(logger *zap.Logger, cache LeaderboardCache, rankCache LeaderboardRankCache, ...) error

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

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

+ func TournamentRecordWrite(logger *zap.Logger, db *sql.DB, leaderboardCache LeaderboardCache, ...) (*api.LeaderboardRecord, error)

+ func TournamentRecordsHaystack(logger *zap.Logger, db *sql.DB, leaderboardCache LeaderboardCache, ...) ([]*api.LeaderboardRecord, error)

type ApiServer

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

+ func (s *ApiServer) ListLeaderboardRecordsAroundOwner(ctx context.Context, in *api.ListLeaderboardRecordsAroundOwnerRequest) (*api.LeaderboardRecordList, 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) WriteTournamentRecord(ctx context.Context, in *api.WriteTournamentRecordRequest) (*api.LeaderboardRecord, error)

type Config

+ GetLeaderboard func() *LeaderboardConfig

+ GetShutdownGraceSec func() int

type ConsoleServer

+ func (s *ConsoleServer) RecordAccountDeletion(tx *sql.Tx, userID uuid.UUID) error

type Leaderboard

+ Category int

+ Description string

+ Duration int

+ EndTime int64

+ JoinRequired bool

+ MaxNumScore int

+ MaxSize int

+ ResetScheduleStr string

+ 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

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

+ GetAllLeaderboards func() []*Leaderboard

+ type LeaderboardConfig struct

+ BlacklistRankCache []string

+ func NewLeaderboardConfig() *LeaderboardConfig

+ type LeaderboardRankCache interface

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

+ DeleteLeaderboard func(leaderboardId string, expiryUnix int64)

+ 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)

+ type LeaderboardScheduler struct

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

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

+ func (ls *LeaderboardScheduler) Stop()

+ func (ls *LeaderboardScheduler) Update()

+ type LeaderboardWithExpiry struct

+ Expiry int64

+ LeaderboardId string

type LocalLeaderboardCache

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

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

+ type LocalLeaderboardRankCache struct

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

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

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

+ 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)

type MatchDataMessage

+ 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) GetSessionId() string

+ func (m *MatchDataMessage) GetStatus() string

+ func (m *MatchDataMessage) GetUserId() string

+ func (m *MatchDataMessage) GetUsername() string

type MatchPresence

+ 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 MatchmakerEntry

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

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

+ func (m *MatchmakerEntry) GetTicket() string

type MatchmakerPresence

+ 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 Presence

+ 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 PresenceMeta

+ func (pm *PresenceMeta) GetHidden() bool

+ func (pm *PresenceMeta) GetPersistence() bool

+ func (pm *PresenceMeta) GetStatus() string

+ func (pm *PresenceMeta) GetUsername() string

+ type RankData struct

+ OwnerId uuid.UUID

+ Rank int64

+ Score int64

+ Subscore int64

+ type RankMap struct

+ Haystack map[uuid.UUID]*RankData

+ Ranks []*RankData

+ SortOrder int

+ func (r RankMap) Len() int

+ func (r RankMap) Less(i, j int) bool

+ func (r RankMap) Swap(i, j int)

type Runtime

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

+ func (r *Runtime) AfterAddFriends() RuntimeAfterAddFriendsFunction

+ func (r *Runtime) AfterAddGroupUsers() RuntimeAfterAddGroupUsersFunction

+ func (r *Runtime) AfterAuthenticateCustom() RuntimeAfterAuthenticateCustomFunction

+ func (r *Runtime) AfterAuthenticateDevice() RuntimeAfterAuthenticateDeviceFunction

+ func (r *Runtime) AfterAuthenticateEmail() RuntimeAfterAuthenticateEmailFunction

+ func (r *Runtime) AfterAuthenticateFacebook() RuntimeAfterAuthenticateFacebookFunction

+ func (r *Runtime) AfterAuthenticateGameCenter() RuntimeAfterAuthenticateGameCenterFunction

+ func (r *Runtime) AfterAuthenticateGoogle() RuntimeAfterAuthenticateGoogleFunction

+ func (r *Runtime) AfterAuthenticateSteam() RuntimeAfterAuthenticateSteamFunction

+ 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) 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) AfterLinkCustom() RuntimeAfterLinkCustomFunction

+ func (r *Runtime) AfterLinkDevice() RuntimeAfterLinkDeviceFunction

+ func (r *Runtime) AfterLinkEmail() RuntimeAfterLinkEmailFunction

+ func (r *Runtime) AfterLinkFacebook() RuntimeAfterLinkFacebookFunction

+ 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) AfterUnlinkCustom() RuntimeAfterUnlinkCustomFunction

+ func (r *Runtime) AfterUnlinkDevice() RuntimeAfterUnlinkDeviceFunction

+ func (r *Runtime) AfterUnlinkEmail() RuntimeAfterUnlinkEmailFunction

+ func (r *Runtime) AfterUnlinkFacebook() RuntimeAfterUnlinkFacebookFunction

+ 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) BeforeAuthenticateCustom() RuntimeBeforeAuthenticateCustomFunction

+ func (r *Runtime) BeforeAuthenticateDevice() RuntimeBeforeAuthenticateDeviceFunction

+ func (r *Runtime) BeforeAuthenticateEmail() RuntimeBeforeAuthenticateEmailFunction

+ func (r *Runtime) BeforeAuthenticateFacebook() RuntimeBeforeAuthenticateFacebookFunction

+ func (r *Runtime) BeforeAuthenticateGameCenter() RuntimeBeforeAuthenticateGameCenterFunction

+ func (r *Runtime) BeforeAuthenticateGoogle() RuntimeBeforeAuthenticateGoogleFunction

+ func (r *Runtime) BeforeAuthenticateSteam() RuntimeBeforeAuthenticateSteamFunction

+ 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) 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) BeforeLinkCustom() RuntimeBeforeLinkCustomFunction

+ func (r *Runtime) BeforeLinkDevice() RuntimeBeforeLinkDeviceFunction

+ func (r *Runtime) BeforeLinkEmail() RuntimeBeforeLinkEmailFunction

+ func (r *Runtime) BeforeLinkFacebook() RuntimeBeforeLinkFacebookFunction

+ 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) BeforeUnlinkCustom() RuntimeBeforeUnlinkCustomFunction

+ func (r *Runtime) BeforeUnlinkDevice() RuntimeBeforeUnlinkDeviceFunction

+ func (r *Runtime) BeforeUnlinkEmail() RuntimeBeforeUnlinkEmailFunction

+ func (r *Runtime) BeforeUnlinkFacebook() RuntimeBeforeUnlinkFacebookFunction

+ 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) LeaderboardReset() RuntimeLeaderboardResetFunction

+ 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(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterAddGroupUsersFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterAuthenticateCustomFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterAuthenticateDeviceFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterAuthenticateEmailFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterAuthenticateFacebookFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterAuthenticateGameCenterFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterAuthenticateGoogleFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterAuthenticateSteamFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterBlockFriendsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterCreateGroupFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterDeleteFriendsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterDeleteGroupFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterDeleteLeaderboardRecordFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterDeleteNotificationFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterDeleteStorageObjectsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterGetAccountFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterGetUsersFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterImportFacebookFriendsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterJoinGroupFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterJoinTournamentFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterKickGroupUsersFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterLeaveGroupFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterLinkCustomFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterLinkDeviceFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterLinkEmailFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterLinkFacebookFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterLinkGameCenterFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterLinkGoogleFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterLinkSteamFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterListChannelMessagesFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterListFriendsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterListGroupUsersFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterListGroupsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterListLeaderboardRecordsAroundOwnerFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterListLeaderboardRecordsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterListMatchesFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterListNotificationsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterListStorageObjectsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterListTournamentRecordsAroundOwnerFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterListTournamentRecordsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterListTournamentsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterListUserGroupsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterPromoteGroupUsersFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterReadStorageObjectsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterReqFunctions struct

+ type RuntimeAfterRtFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterUnlinkCustomFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterUnlinkDeviceFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterUnlinkEmailFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterUnlinkFacebookFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterUnlinkGameCenterFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterUnlinkGoogleFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterUnlinkSteamFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterUpdateAccountFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterUpdateGroupFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterWriteLeaderboardRecordFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterWriteStorageObjectsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeAfterWriteTournamentRecordFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) error

+ type RuntimeBeforeAddFriendsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AddFriendsRequest, error, codes.Code)

+ type RuntimeBeforeAddGroupUsersFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AddGroupUsersRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateCustomFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AuthenticateCustomRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateDeviceFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AuthenticateDeviceRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateEmailFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AuthenticateEmailRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateFacebookFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AuthenticateFacebookRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateGameCenterFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AuthenticateGameCenterRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateGoogleFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AuthenticateGoogleRequest, error, codes.Code)

+ type RuntimeBeforeAuthenticateSteamFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AuthenticateSteamRequest, error, codes.Code)

+ type RuntimeBeforeBlockFriendsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.BlockFriendsRequest, error, codes.Code)

+ type RuntimeBeforeCreateGroupFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.CreateGroupRequest, error, codes.Code)

+ type RuntimeBeforeDeleteFriendsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.DeleteFriendsRequest, error, codes.Code)

+ type RuntimeBeforeDeleteGroupFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.DeleteGroupRequest, error, codes.Code)

+ type RuntimeBeforeDeleteLeaderboardRecordFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.DeleteLeaderboardRecordRequest, error, codes.Code)

+ type RuntimeBeforeDeleteNotificationFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.DeleteNotificationsRequest, error, codes.Code)

+ type RuntimeBeforeDeleteStorageObjectsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.DeleteStorageObjectsRequest, error, codes.Code)

+ type RuntimeBeforeGetAccountFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (error, codes.Code)

+ type RuntimeBeforeGetUsersFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.GetUsersRequest, error, codes.Code)

+ type RuntimeBeforeImportFacebookFriendsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ImportFacebookFriendsRequest, error, codes.Code)

+ type RuntimeBeforeJoinGroupFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.JoinGroupRequest, error, codes.Code)

+ type RuntimeBeforeJoinTournamentFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.JoinTournamentRequest, error, codes.Code)

+ type RuntimeBeforeKickGroupUsersFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.KickGroupUsersRequest, error, codes.Code)

+ type RuntimeBeforeLeaveGroupFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.LeaveGroupRequest, error, codes.Code)

+ type RuntimeBeforeLinkCustomFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AccountCustom, error, codes.Code)

+ type RuntimeBeforeLinkDeviceFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AccountDevice, error, codes.Code)

+ type RuntimeBeforeLinkEmailFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AccountEmail, error, codes.Code)

+ type RuntimeBeforeLinkFacebookFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.LinkFacebookRequest, error, codes.Code)

+ type RuntimeBeforeLinkGameCenterFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AccountGameCenter, error, codes.Code)

+ type RuntimeBeforeLinkGoogleFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AccountGoogle, error, codes.Code)

+ type RuntimeBeforeLinkSteamFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AccountSteam, error, codes.Code)

+ type RuntimeBeforeListChannelMessagesFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ListChannelMessagesRequest, error, codes.Code)

+ type RuntimeBeforeListFriendsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (error, codes.Code)

+ type RuntimeBeforeListGroupUsersFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ListGroupUsersRequest, error, codes.Code)

+ type RuntimeBeforeListGroupsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ListGroupsRequest, error, codes.Code)

+ type RuntimeBeforeListLeaderboardRecordsAroundOwnerFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ListLeaderboardRecordsAroundOwnerRequest, error, codes.Code)

+ type RuntimeBeforeListLeaderboardRecordsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ListLeaderboardRecordsRequest, error, codes.Code)

+ type RuntimeBeforeListMatchesFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ListMatchesRequest, error, codes.Code)

+ type RuntimeBeforeListNotificationsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ListNotificationsRequest, error, codes.Code)

+ type RuntimeBeforeListStorageObjectsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ListStorageObjectsRequest, error, codes.Code)

+ type RuntimeBeforeListTournamentRecordsAroundOwnerFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ListTournamentRecordsAroundOwnerRequest, error, codes.Code)

+ type RuntimeBeforeListTournamentRecordsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ListTournamentRecordsRequest, error, codes.Code)

+ type RuntimeBeforeListTournamentsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ListTournamentsRequest, error, codes.Code)

+ type RuntimeBeforeListUserGroupsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ListUserGroupsRequest, error, codes.Code)

+ type RuntimeBeforePromoteGroupUsersFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.PromoteGroupUsersRequest, error, codes.Code)

+ type RuntimeBeforeReadStorageObjectsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.ReadStorageObjectsRequest, error, codes.Code)

+ type RuntimeBeforeReqFunctions struct

+ type RuntimeBeforeRtFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*rtapi.Envelope, error)

+ type RuntimeBeforeUnlinkCustomFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AccountCustom, error, codes.Code)

+ type RuntimeBeforeUnlinkDeviceFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AccountDevice, error, codes.Code)

+ type RuntimeBeforeUnlinkEmailFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AccountEmail, error, codes.Code)

+ type RuntimeBeforeUnlinkFacebookFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AccountFacebook, error, codes.Code)

+ type RuntimeBeforeUnlinkGameCenterFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AccountGameCenter, error, codes.Code)

+ type RuntimeBeforeUnlinkGoogleFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AccountGoogle, error, codes.Code)

+ type RuntimeBeforeUnlinkSteamFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.AccountSteam, error, codes.Code)

+ type RuntimeBeforeUpdateAccountFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.UpdateAccountRequest, error, codes.Code)

+ type RuntimeBeforeUpdateGroupFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.UpdateGroupRequest, error, codes.Code)

+ type RuntimeBeforeWriteLeaderboardRecordFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.WriteLeaderboardRecordRequest, error, codes.Code)

+ type RuntimeBeforeWriteStorageObjectsFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.WriteStorageObjectsRequest, error, codes.Code)

+ type RuntimeBeforeWriteTournamentRecordFunction func(logger *zap.Logger, userID, username string, expiry int64, ...) (*api.WriteTournamentRecordRequest, error, codes.Code)

+ type RuntimeExecutionMode int

+ const RuntimeExecutionModeAfter

+ const RuntimeExecutionModeBefore

+ 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(...) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (ri *RuntimeGoInitializer) RegisterAfterRt(id string, ...) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateSteam(...) 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) RegisterBeforeGetAccount(...) 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) RegisterBeforeLinkCustom(...) error

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

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

+ func (ri *RuntimeGoInitializer) RegisterBeforeLinkFacebook(...) 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) RegisterBeforeUnlinkCustom(...) error

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

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

+ func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkFacebook(...) 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) RegisterLeaderboardReset(...) error

+ func (ri *RuntimeGoInitializer) RegisterMatch(name string, ...) error

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

+ func (ri *RuntimeGoInitializer) RegisterRpc(id string, ...) error

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

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

+ type RuntimeGoMatchCore struct

+ func (r *RuntimeGoMatchCore) BroadcastMessage(opCode int64, data []byte, presences []runtime.Presence, ...) error

+ func (r *RuntimeGoMatchCore) MatchInit(params map[string]interface{}) (interface{}, int, string, 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, ...) (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, config Config, socialClient *social.Client, ...) *RuntimeGoNakamaModule

+ 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) 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) 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) (string, int64, 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) GroupUsersList(ctx context.Context, id string) ([]*api.GroupUserList_GroupUser, 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) MatchCreate(module string, params map[string]interface{}) (string, error)

+ func (n *RuntimeGoNakamaModule) MatchList(ctx context.Context, limit int, authoritative bool, label string, ...) []*api.Match

+ 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) SetMatchCreateFn(fn RuntimeMatchCreateFunction)

+ 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, descriptor, label string) error

+ func (n *RuntimeGoNakamaModule) StreamCount(mode uint8, subject, descriptor, label string) (int, error)

+ func (n *RuntimeGoNakamaModule) StreamSend(mode uint8, subject, descriptor, label, data string) error

+ func (n *RuntimeGoNakamaModule) StreamUserGet(mode uint8, subject, descriptor, label, userID, sessionID string) (runtime.PresenceMeta, error)

+ func (n *RuntimeGoNakamaModule) StreamUserJoin(mode uint8, subject, descriptor, label, userID, sessionID string, ...) (bool, error)

+ func (n *RuntimeGoNakamaModule) StreamUserLeave(mode uint8, subject, descriptor, label, userID, sessionID string) error

+ func (n *RuntimeGoNakamaModule) StreamUserList(mode uint8, subject, descriptor, label string, ...) ([]runtime.Presence, error)

+ func (n *RuntimeGoNakamaModule) StreamUserUpdate(mode uint8, subject, descriptor, 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) ([]*api.LeaderboardRecord, error)

+ func (n *RuntimeGoNakamaModule) UserGroupsList(ctx context.Context, userID string) ([]*api.UserGroupList_UserGroup, 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) ([]runtime.WalletLedgerItem, 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, metadata map[string]interface{}) error

+ func (n *RuntimeGoNakamaModule) WalletsUpdate(ctx context.Context, updates []*runtime.WalletUpdate) error

+ type RuntimeLeaderboardResetFunction func(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)

+ func (r *RuntimeLua) NewStateThread() (*lua.LState, context.CancelFunc)

+ 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) (string, bool)

+ func (lc *RuntimeLuaLocalCache) Put(key, value string)

+ type RuntimeLuaMatchCore struct

+ func (r *RuntimeLuaMatchCore) MatchInit(params map[string]interface{}) (interface{}, int, string, 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, ...) (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, config Config, socialClient *social.Client, ...) *RuntimeLuaNakamaModule

+ func (n *RuntimeLuaNakamaModule) Loader(l *lua.LState) int

+ type RuntimeMatchCore interface

+ MatchInit func(params map[string]interface{}) (interface{}, int, string, error)

+ MatchJoin func(tick int64, state interface{}, joins []*MatchPresence) (interface{}, error)

+ MatchJoinAttempt func(tick int64, state interface{}, userID, sessionID uuid.UUID, ...) (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, matchRegistry MatchRegistry, tracker Tracker, ...) (RuntimeMatchCore, error)

+ func NewRuntimeLuaMatchCore(logger *zap.Logger, db *sql.DB, config Config, socialClient *social.Client, ...) (RuntimeMatchCore, error)

+ type RuntimeMatchCreateFunction func(logger *zap.Logger, id uuid.UUID, node string, name string, ...) (RuntimeMatchCore, error)

+ type RuntimeMatchmakerMatchedFunction func(entries []*MatchmakerEntry) (string, bool, error)

+ type RuntimeProviderLua struct

+ func (rp *RuntimeProviderLua) AfterReq(id string, logger *zap.Logger, userID, username string, expiry int64, ...) error

+ func (rp *RuntimeProviderLua) AfterRt(id string, logger *zap.Logger, userID, username string, expiry int64, ...) error

+ func (rp *RuntimeProviderLua) BeforeReq(id string, logger *zap.Logger, userID, username string, expiry int64, ...) (interface{}, error, codes.Code)

+ func (rp *RuntimeProviderLua) BeforeRt(id string, logger *zap.Logger, userID, username string, expiry int64, ...) (*rtapi.Envelope, error)

+ func (rp *RuntimeProviderLua) Get() *RuntimeLua

+ func (rp *RuntimeProviderLua) LeaderboardReset(leaderboard runtime.Leaderboard, reset int64) error

+ func (rp *RuntimeProviderLua) MatchmakerMatched(entries []*MatchmakerEntry) (string, bool, error)

+ func (rp *RuntimeProviderLua) Put(r *RuntimeLua)

+ func (rp *RuntimeProviderLua) Rpc(id string, queryParams map[string][]string, userID, username string, ...) (string, error, codes.Code)

+ func (rp *RuntimeProviderLua) TournamentEnd(tournament *api.Tournament, end, reset int64) error

+ func (rp *RuntimeProviderLua) TournamentReset(tournament *api.Tournament, end, reset int64) error

+ type RuntimeRpcFunction func(queryParams map[string][]string, userID, username string, expiry int64, ...) (string, error, codes.Code)

+ type RuntimeTournamentEndFunction func(tournament *api.Tournament, end, reset int64) error

+ type RuntimeTournamentResetFunction func(tournament *api.Tournament, end, reset int64) error

+ type Scannable interface

+ Scan func(dest ...interface{}) error

v2.0.3

Aug 10, 2018

Changes in this version

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

+ var Bit32LibName = "bit32"

+ func OpenBit32(l *lua.LState) int

type ConsoleServer

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

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

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

+ func (s *ConsoleServer) DeleteStorageObjects(context.Context, *empty.Empty) (*empty.Empty, error)

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

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

+ func (s *ConsoleServer) ListAccounts(context.Context, *empty.Empty) (*console.AccountList, error)

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

+ func (s *ConsoleServer) ListStorageObjects(ctx context.Context, in *console.ListStorageObjectRequest) (*console.StorageObjectList, error)

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

type Session

+ ClientIP func() string

+ ClientPort func() string

type SocketConfig

+ PingBackoffThreshold int

v2.0.2

Jul 9, 2018

Changes in this version

+ var MetricsApiCount = stats.Int64("nakama.api/server/request_count", "Number of calls to API functions", ...)

+ var MetricsApiTimeSpentMsec = stats.Float64("nakama.api/server/server_elapsed_time", ...)

+ var MetricsFunction = tag.NewKey("function")

+ var MetricsRtapiCount = stats.Int64("nakama.rtapi/server/request_count", ...)

+ var MetricsRtapiTimeSpentMsec = stats.Float64("nakama.rtapi/server/server_elapsed_time", ...)

+ var MetricsRuntimeCount = stats.Int64("nakama/runtime/count", "Number of pooled runtime instances", stats.UnitNone)

+ var MetricsSocketWsCloseCount = stats.Int64("nakama.socket/ws/close_count", "Number of closed WebSocket connections", ...)

+ var MetricsSocketWsOpenCount = stats.Int64("nakama.socket/ws/open_count", "Number of opened WebSocket connections", ...)

+ var MetricsSocketWsTimeSpentMsec = stats.Float64("nakama.socket/ws/server_elapsed_time", ...)

+ var SocketWsStatsCtx = context.Background()

+ func Join(joins []*MatchPresence) func(mh *MatchHandler)

type Config

+ GetMatch func() *MatchConfig

type LocalMatchRegistry

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

type LocalTracker

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

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

+ type MatchConfig struct

+ CallQueueSize int

+ InputQueueSize int

+ func NewMatchConfig() *MatchConfig

type MatchRegistry

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

type SocketConfig

+ Address string

+ Protocol string

type Tracker

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

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

v2.0.1

Jun 15, 2018

Changes in this version

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

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

type MatchDataMessage

+ ReceiveTime int64

+ type ModuleCache struct

+ Modules map[string]*RuntimeModule

+ Names []string

+ func (mc *ModuleCache) Add(m *RuntimeModule)

type RuntimeConfig

+ CallStackSize int

+ MaxCount int

+ MinCount int

+ RegistrySize int

v2.0.0

May 14, 2018

Changes in this version

+ const API_PREFIX

+ const CALLBACKS

+ const CallQueueSize

+ const ChannelMessageTypeChat

+ const ChannelMessageTypeChatRemove

+ const ChannelMessageTypeChatUpdate

+ const ChannelMessageTypeGroupAdd

+ const ChannelMessageTypeGroupJoin

+ const ChannelMessageTypeGroupKick

+ const ChannelMessageTypeGroupPromoted

+ const EventsQueueSize

+ const InputQueueSize

+ const LTSentinel

+ const LeaderboardOperatorBest

+ const LeaderboardOperatorIncrement

+ const LeaderboardOperatorSet

+ const LeaderboardSortOrderAscending

+ const LeaderboardSortOrderDescending

+ const NOTIFICATION_DM_REQUEST

+ const NOTIFICATION_FRIEND_ACCEPT

+ const NOTIFICATION_FRIEND_JOIN_GAME

+ const NOTIFICATION_FRIEND_REQUEST

+ const NOTIFICATION_GROUP_ADD

+ const NOTIFICATION_GROUP_JOIN_REQUEST

+ const RTAPI_PREFIX

+ const StreamModeChannel

+ const StreamModeDM

+ const StreamModeGroup

+ const StreamModeMatchAuthoritative

+ const StreamModeMatchRelayed

+ const StreamModeNotifications

+ const StreamModeStatus

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

+ 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 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 ErrLeaderboardAuthoritative = errors.New("leaderboard only allows authoritative submissions")

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

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

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

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

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

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

+ var MatchFilterAny = map[uint8]*uint8

+ var MatchFilterAuthoritative = map[uint8]*uint8

+ var MatchFilterPtr = &MatchFilterValue

+ var MatchFilterRelayed = map[uint8]*uint8

+ var MatchFilterValue = uint8(0)

+ func AddFriends(logger *zap.Logger, db *sql.DB, messageRouter MessageRouter, userID uuid.UUID, ...) error

+ func AddGroupUsers(logger *zap.Logger, db *sql.DB, caller uuid.UUID, groupID uuid.UUID, ...) error

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

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

+ func AuthenticateEmail(logger *zap.Logger, db *sql.DB, email, password, username string, create bool) (string, string, bool, error)

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

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

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

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

+ func BlockFriends(logger *zap.Logger, db *sql.DB, currentUser uuid.UUID, ids []string) error

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

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

+ func ConvertLuaValue(lv lua.LValue) interface

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

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

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

+ func DeleteFriends(logger *zap.Logger, db *sql.DB, currentUser uuid.UUID, ids []string) error

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

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

+ func GetAccount(logger *zap.Logger, db *sql.DB, tracker Tracker, userID uuid.UUID) (*api.Account, error)

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

+ func GetFriendIDs(logger *zap.Logger, db *sql.DB, userID uuid.UUID) (*api.Friends, error)

+ func GetFriends(logger *zap.Logger, db *sql.DB, tracker Tracker, userID uuid.UUID) (*api.Friends, error)

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

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

+ func JoinAttempt(resultCh chan *MatchJoinResult, userID, sessionID uuid.UUID, ...) func(mh *MatchHandler)

+ func JoinGroup(logger *zap.Logger, db *sql.DB, groupID uuid.UUID, userID uuid.UUID) error

+ func KickGroupUsers(logger *zap.Logger, db *sql.DB, caller uuid.UUID, groupID uuid.UUID, ...) error

+ func LeaderboardRecordDelete(logger *zap.Logger, db *sql.DB, leaderboardCache LeaderboardCache, ...) error

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

+ func LeaderboardRecordWrite(logger *zap.Logger, db *sql.DB, leaderboardCache LeaderboardCache, ...) (*api.LeaderboardRecord, error)

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

+ func LeaderboardRecordsList(logger *zap.Logger, db *sql.DB, leaderboardCache LeaderboardCache, ...) (*api.LeaderboardRecordList, error)

+ func Leave(leaves []*MatchPresence) func(mh *MatchHandler)

+ func LeaveGroup(logger *zap.Logger, db *sql.DB, groupID uuid.UUID, userID uuid.UUID) error

+ func ListGroupUsers(logger *zap.Logger, db *sql.DB, tracker Tracker, groupID uuid.UUID) (*api.GroupUserList, error)

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

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

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

+ func LoadRuntimeModules(startupLogger *zap.Logger, config Config) (map[string]lua.LGFunction, *sync.Map, error)

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

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

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

+ func NewLuaContext(l *lua.LState, env *lua.LTable, mode ExecutionMode, uid string, ...) *lua.LTable

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

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

+ func NotificationDelete(logger *zap.Logger, db *sql.DB, userID uuid.UUID, notificationIDs []string) error

+ func NotificationList(logger *zap.Logger, db *sql.DB, userID uuid.UUID, limit int, cursor string, ...) (*api.NotificationList, error)

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

+ func NotificationSend(logger *zap.Logger, db *sql.DB, messageRouter MessageRouter, ...) error

+ func OpenOs(L *lua.LState) int

+ func OpenPackage(modules *sync.Map) func(L *lua.LState) int

+ func PromoteGroupUsers(logger *zap.Logger, db *sql.DB, caller uuid.UUID, groupID uuid.UUID, ...) error

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

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

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

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

+ func StorageListObjectsPublicRead(logger *zap.Logger, db *sql.DB, collection string, limit int, cursor string, ...) (*api.StorageObjectList, error)

+ func StorageListObjectsPublicReadUser(logger *zap.Logger, db *sql.DB, userID uuid.UUID, collection string, limit int, ...) (*api.StorageObjectList, error)

+ func StorageListObjectsUser(logger *zap.Logger, db *sql.DB, authoritative bool, userID uuid.UUID, ...) (*api.StorageObjectList, error)

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

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

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

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

+ func UpdateAccount(db *sql.DB, logger *zap.Logger, userID uuid.UUID, username string, ...) error

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

+ func UpdateWalletLedger(logger *zap.Logger, db *sql.DB, id uuid.UUID, metadata string) (*walletLedger, error)

+ func UpdateWallets(logger *zap.Logger, db *sql.DB, updates []*walletUpdate) error

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

+ 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) 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) 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) 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) 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) 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) 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) 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 *empty.Empty) (*api.Friends, 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) 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) 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) Stop()

+ 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) 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)

+ type Callbacks struct

+ After map[string]*lua.LFunction

+ Before map[string]*lua.LFunction

+ Matchmaker *lua.LFunction

+ RPC map[string]*lua.LFunction

+ type ChannelIdToStreamResult struct

+ Stream PresenceStream

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

+ type Config interface

+ GetConsole func() *ConsoleConfig

+ GetDataDir func() string

+ GetDatabase func() *DatabaseConfig

+ GetLogger func() *LoggerConfig

+ GetMetrics func() *MetricsConfig

+ GetName func() string

+ GetRuntime func() *RuntimeConfig

+ GetSession func() *SessionConfig

+ GetSocial func() *SocialConfig

+ GetSocket func() *SocketConfig

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

+ type ConsoleConfig struct

+ Password string

+ Port int

+ Username string

+ func NewConsoleConfig() *ConsoleConfig

+ type ConsoleServer struct

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

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

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

+ func (s *ConsoleServer) Login(context.Context, *console.AuthenticateRequest) (*console.Session, error)

+ func (s *ConsoleServer) Stop()

+ type DatabaseConfig struct

+ Addresses []string

+ ConnMaxLifetimeMs int

+ MaxIdleConns int

+ MaxOpenConns int

+ func NewDatabaseConfig() *DatabaseConfig

+ type ExecutionMode int

+ const ExecutionModeAfter

+ const ExecutionModeBefore

+ const ExecutionModeMatch

+ const ExecutionModeMatchmaker

+ const ExecutionModeRPC

+ const ExecutionModeRunOnce

+ func (e ExecutionMode) String() string

+ type LSentinelType struct

+ func (s *LSentinelType) String() string

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

+ type Leaderboard struct

+ Authoritative bool

+ CreateTime int64

+ Id string

+ Metadata string

+ Operator int

+ ResetSchedule *cronexpr.Expression

+ SortOrder int

+ type LeaderboardCache interface

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

+ Delete func(id string) error

+ Get func(id string) *Leaderboard

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

+ type LocalLeaderboardCache struct

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

+ func (l *LocalLeaderboardCache) Delete(id string) error

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

+ type LocalMatchRegistry struct

+ func (r *LocalMatchRegistry) GetMatch(id uuid.UUID) *MatchHandler

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

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

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

+ func (r *LocalMatchRegistry) ListMatches(limit int, authoritative *wrappers.BoolValue, label *wrappers.StringValue, ...) []*api.Match

+ func (r *LocalMatchRegistry) NewMatch(name string, params interface{}) (*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()

+ type LocalMatchmaker struct

+ func (m *LocalMatchmaker) Add(session Session, query string, minCount int, maxCount int, ...) (string, []*MatchmakerEntry, error)

+ func (m *LocalMatchmaker) Remove(sessionID uuid.UUID, ticket string) error

+ func (m *LocalMatchmaker) RemoveAll(sessionID uuid.UUID) error

+ type LocalMessageRouter struct

+ 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 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) GetLocalBySessionIDStreamUserID(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID) *PresenceMeta

+ func (t *LocalTracker) ListByStream(stream PresenceStream, includeHidden 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) SetMatchLeaveListener(f func(id uuid.UUID, leaves []*MatchPresence))

+ 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

+ File string

+ Level string

+ Stdout bool

+ func NewLoggerConfig() *LoggerConfig

+ type MatchDataMessage struct

+ Data []byte

+ Node string

+ OpCode int64

+ SessionID uuid.UUID

+ UserID uuid.UUID

+ Username string

+ type MatchHandler struct

+ ID uuid.UUID

+ IDStr string

+ Label string

+ Node string

+ Rate int

+ Stream PresenceStream

+ func NewMatchHandler(logger *zap.Logger, db *sql.DB, config Config, socialClient *social.Client, ...) (*MatchHandler, error)

+ func (mh *MatchHandler) Close()

+ func (mh *MatchHandler) QueueCall(f func(*MatchHandler)) bool

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

+ func (mh *MatchHandler) Stop()

+ type MatchJoinResult struct

+ Allow bool

+ Label string

+ Reason string

+ type MatchPresence struct

+ Node string

+ SessionID uuid.UUID

+ UserID uuid.UUID

+ Username string

+ type MatchRegistry interface

+ GetMatch func(id uuid.UUID) *MatchHandler

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

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

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

+ ListMatches func(limit int, authoritative *wrappers.BoolValue, label *wrappers.StringValue, ...) []*api.Match

+ NewMatch func(name string, params interface{}) (*MatchHandler, error)

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

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

+ Stop func()

+ func NewLocalMatchRegistry(logger *zap.Logger, db *sql.DB, config Config, socialClient *social.Client, ...) MatchRegistry

+ type Matchmaker interface

+ Add func(session Session, query string, minCount int, maxCount int, ...) (string, []*MatchmakerEntry, error)

+ Remove func(sessionID uuid.UUID, ticket string) error

+ RemoveAll func(sessionID uuid.UUID) error

+ func NewLocalMatchmaker(startupLogger *zap.Logger, node string) Matchmaker

+ type MatchmakerEntry struct

+ NumericProperties map[string]float64

+ Presence *MatchmakerPresence

+ Properties map[string]interface{}

+ SessionID uuid.UUID

+ StringProperties map[string]string

+ Ticket string

+ type MatchmakerPresence struct

+ Node string

+ SessionId string

+ UserId string

+ Username string

+ type MessageRouter interface

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

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

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

+ type Metrics struct

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

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

+ type MetricsConfig struct

+ Namespace string

+ PrometheusPort int

+ ReportingFreqSec int

+ StackdriverProjectID string

+ func NewMetricsConfig() *MetricsConfig

+ type NakamaModule struct

+ func NewNakamaModule(logger *zap.Logger, db *sql.DB, config Config, socialClient *social.Client, ...) *NakamaModule

+ func (n *NakamaModule) Loader(l *lua.LState) int

+ type Pipeline struct

+ func NewPipeline(config Config, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, ...) *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

+ 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

+ type PresenceStream struct

+ Descriptor uuid.UUID

+ Label string

+ Mode uint8

+ Subject uuid.UUID

+ type RegCallbacks struct

+ After map[string]interface{}

+ Before map[string]interface{}

+ Matchmaker interface{}

+ RPC map[string]interface{}

+ func ValidateRuntimeModules(logger, startupLogger *zap.Logger, db *sql.DB, config Config, ...) (*RegCallbacks, error)

+ type Runtime struct

+ func (r *Runtime) GetCallback(e ExecutionMode, key string) *lua.LFunction

+ func (r *Runtime) InvokeFunction(execMode ExecutionMode, fn *lua.LFunction, uid string, username string, ...) (interface{}, error, codes.Code)

+ func (r *Runtime) NewStateThread() (*lua.LState, context.CancelFunc)

+ func (r *Runtime) Stop()

+ type RuntimeConfig struct

+ Env []string

+ Environment map[string]interface{}

+ HTTPKey string

+ Path string

+ func NewRuntimeConfig() *RuntimeConfig

+ type RuntimeModule struct

+ Content []byte

+ Name string

+ Path string

+ type RuntimePool struct

+ func NewRuntimePool(logger *zap.Logger, db *sql.DB, config Config, socialClient *social.Client, ...) *RuntimePool

+ func (rp *RuntimePool) Get() *Runtime

+ func (rp *RuntimePool) HasCallback(mode ExecutionMode, id string) bool

+ func (rp *RuntimePool) Put(r *Runtime)

+ type Session interface

+ Close func()

+ Consume func(func(logger *zap.Logger, session Session, envelope *rtapi.Envelope) bool)

+ Expiry func() int64

+ Format func() SessionFormat

+ ID func() uuid.UUID

+ Logger func() *zap.Logger

+ Send func(envelope *rtapi.Envelope) error

+ SendBytes func(payload []byte) error

+ SetUsername func(string)

+ UserID func() uuid.UUID

+ Username func() string

+ func NewSessionWS(logger *zap.Logger, config Config, userID uuid.UUID, username string, ...) Session

+ type SessionConfig struct

+ EncryptionKey string

+ TokenExpirySec int64

+ func NewSessionConfig() *SessionConfig

+ type SessionFormat uint8

+ const SessionFormatJson

+ const SessionFormatProtobuf

+ type SessionRegistry struct

+ func NewSessionRegistry() *SessionRegistry

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

+ func (r *SessionRegistry) Stop()

+ type SocialConfig struct

+ Steam *SocialConfigSteam

+ func NewSocialConfig() *SocialConfig

+ type SocialConfigSteam struct

+ AppID int

+ PublisherKey string

+ type SocketConfig struct

+ IdleTimeoutMs int

+ MaxMessageSizeBytes int64

+ OutgoingQueueSize int

+ PingPeriodMs int

+ PongWaitMs int

+ Port int

+ ReadTimeoutMs int

+ SSLCertificate string

+ SSLPrivateKey string

+ ServerKey string

+ TLSCert []tls.Certificate

+ WriteTimeoutMs int

+ WriteWaitMs int

+ func NewSocketConfig() *SocketConfig

+ type Tracker interface

+ Count func() int

+ CountByStream func(stream PresenceStream) int

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

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

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

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

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

+ ListPresenceIDByStream func(stream PresenceStream) []*PresenceID

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

+ 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, sessionRegistry *SessionRegistry, ...) Tracker

Other modules containing this package

gopkg.in/heroiclabs/nakama.v0

gopkg.in/heroiclabs/nakama.v1

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL