Documentation
¶
Index ¶
- Constants
- Variables
- func AddFriends(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error
- func AddGroupUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error
- func AuthenticateApple(ctx context.Context, logger *zap.Logger, db *sql.DB, client *social.Client, ...) (string, string, bool, error)
- func AuthenticateCustom(ctx context.Context, logger *zap.Logger, db *sql.DB, customID, username string, ...) (string, string, bool, error)
- func AuthenticateDevice(ctx context.Context, logger *zap.Logger, db *sql.DB, deviceID, username string, ...) (string, string, bool, error)
- func AuthenticateEmail(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) (string, string, bool, error)
- func AuthenticateFacebook(ctx context.Context, logger *zap.Logger, db *sql.DB, client *social.Client, ...) (string, string, bool, error)
- func AuthenticateFacebookInstantGame(ctx context.Context, logger *zap.Logger, db *sql.DB, client *social.Client, ...) (string, string, bool, error)
- func AuthenticateGameCenter(ctx context.Context, logger *zap.Logger, db *sql.DB, client *social.Client, ...) (string, string, bool, error)
- func AuthenticateGoogle(ctx context.Context, logger *zap.Logger, db *sql.DB, client *social.Client, ...) (string, string, bool, error)
- func AuthenticateSteam(ctx context.Context, logger *zap.Logger, db *sql.DB, client *social.Client, ...) (string, string, string, bool, error)
- func AuthenticateUsername(ctx context.Context, logger *zap.Logger, db *sql.DB, username, password string) (string, error)
- func BanGroupUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error
- func BanUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, ids []string) error
- func BlockFriends(ctx context.Context, logger *zap.Logger, db *sql.DB, currentUser uuid.UUID, ...) error
- func ChannelMessagesList(ctx context.Context, logger *zap.Logger, db *sql.DB, caller uuid.UUID, ...) (*api.ChannelMessageList, error)
- func CheckConfig(logger *zap.Logger, config Config) map[string]string
- func CheckRuntime(logger *zap.Logger, config Config) error
- func CheckRuntimeProviderGo(logger *zap.Logger, rootPath string, paths []string) error
- func CheckRuntimeProviderJavascript(logger *zap.Logger, config Config) error
- func CheckRuntimeProviderLua(logger *zap.Logger, config Config, paths []string) error
- func CreateGroup(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.Group, error)
- func DeleteAccount(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) error
- func DeleteFriends(ctx context.Context, logger *zap.Logger, db *sql.DB, currentUser uuid.UUID, ...) error
- func DeleteGroup(ctx context.Context, logger *zap.Logger, db *sql.DB, groupID uuid.UUID, ...) error
- func DeleteUser(ctx context.Context, tx *sql.Tx, userID uuid.UUID) (int64, error)
- func DemoteGroupUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error
- func ExecuteInTx(ctx context.Context, tx Tx, fn func() error) (err error)
- func ExecuteRetryable(fn func() error) error
- func ExportAccount(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID) (*console.AccountExport, error)
- func FileRead(rootPath, relPath string) (*os.File, error)
- func GetAccount(ctx context.Context, logger *zap.Logger, db *sql.DB, tracker Tracker, ...) (*api.Account, error)
- func GetAccounts(ctx context.Context, logger *zap.Logger, db *sql.DB, tracker Tracker, ...) ([]*api.Account, error)
- func GetChannelMessages(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID) ([]*api.ChannelMessage, error)
- func GetFriendIDs(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID) (*api.FriendList, error)
- func GetGroups(ctx context.Context, logger *zap.Logger, db *sql.DB, ids []string) ([]*api.Group, error)
- func GetRuntimePaths(logger *zap.Logger, rootPath string) ([]string, error)
- func GetUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, tracker Tracker, ...) (*api.Users, error)
- func GroupDeleteAll(ctx context.Context, logger *zap.Logger, tx *sql.Tx, userID uuid.UUID) error
- func HashFromId(id uuid.UUID) [6]byte
- func JoinGroup(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error
- func KickGroupUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error
- func LeaderboardRecordDelete(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error
- func LeaderboardRecordReadAll(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID) ([]*api.LeaderboardRecord, error)
- func LeaderboardRecordWrite(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) (*api.LeaderboardRecord, error)
- func LeaderboardRecordsDeleteAll(ctx context.Context, logger *zap.Logger, tx *sql.Tx, userID uuid.UUID) error
- func LeaderboardRecordsHaystack(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) ([]*api.LeaderboardRecord, error)
- func LeaderboardRecordsList(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) (*api.LeaderboardRecordList, error)
- func LeaveGroup(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error
- func LinkApple(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) error
- func LinkCustom(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) error
- func LinkDevice(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) error
- func LinkEmail(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) error
- func LinkFacebook(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error
- func LinkFacebookInstantGame(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) error
- func LinkGameCenter(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error
- func LinkGoogle(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error
- func LinkSteam(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) error
- func ListFriends(ctx context.Context, logger *zap.Logger, db *sql.DB, tracker Tracker, ...) (*api.FriendList, error)
- func ListGroupUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, tracker Tracker, ...) (*api.GroupUserList, error)
- func ListGroups(ctx context.Context, logger *zap.Logger, db *sql.DB, name string, limit int, ...) (*api.GroupList, error)
- func ListUserGroups(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.UserGroupList, error)
- func ListWalletLedger(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) ([]*walletLedger, string, error)
- func MultiUpdate(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) ([]*api.StorageObjectAck, []*runtime.WalletUpdateResult, error)
- func NewConfig(logger *zap.Logger) *config
- func NewJSONFileLogger(consoleLogger *zap.Logger, fileName string, level zapcore.Level, ...) *zap.Logger
- func NewJSONLogger(output *os.File, level zapcore.Level, format LoggingFormat) *zap.Logger
- func NewJsLogger(logger *zap.Logger) *jsLogger
- func NewMultiLogger(loggers ...*zap.Logger) *zap.Logger
- func NewRotatingJSONFileLogger(consoleLogger *zap.Logger, config Config, level zapcore.Level, ...) *zap.Logger
- func NewRuntime(logger, startupLogger *zap.Logger, db *sql.DB, ...) (*Runtime, *RuntimeInfo, error)
- func NewRuntimeGoContext(ctx context.Context, node string, env map[string]string, ...) context.Context
- func NewRuntimeGoLogger(logger *zap.Logger) nkruntime.Logger
- func NewRuntimeJavascriptNakamaModule(logger *zap.Logger, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, ...) *runtimeJavascriptNakamaModule
- func NewRuntimeJsContext(r *goja.Runtime, node string, env goja.Value, mode RuntimeExecutionMode, ...) *goja.Object
- func NewRuntimeJsInitContext(r *goja.Runtime, node string, env map[string]string) *goja.Object
- func NewRuntimeLuaContext(l *lua.LState, node string, env *lua.LTable, mode RuntimeExecutionMode, ...) *lua.LTable
- func NewRuntimeProviderGo(logger, startupLogger *zap.Logger, db *sql.DB, ...) ([]string, map[string]RuntimeRpcFunction, map[string]RuntimeBeforeRtFunction, ...)
- func NewRuntimeProviderJS(logger, startupLogger *zap.Logger, db *sql.DB, ...) ([]string, map[string]RuntimeRpcFunction, map[string]RuntimeBeforeRtFunction, ...)
- func NewRuntimeProviderLua(logger, startupLogger *zap.Logger, db *sql.DB, ...) ([]string, map[string]RuntimeRpcFunction, map[string]RuntimeBeforeRtFunction, ...)
- func NewSocketWsAcceptor(logger *zap.Logger, config Config, sessionRegistry SessionRegistry, ...) func(http.ResponseWriter, *http.Request)
- func NodeToHash(node string) [6]byte
- func NotificationDelete(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) error
- func NotificationList(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.NotificationList, error)
- func NotificationSave(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error
- func NotificationSend(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error
- func OpenBit32(l *lua.LState) int
- func OpenOs(L *lua.LState) int
- func OpenPackage(moduleCache *RuntimeLuaModuleCache) func(L *lua.LState) int
- func PromoteGroupUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, router MessageRouter, ...) error
- func RuntimeLuaConvertLuaTable(lv *lua.LTable) map[string]interface{}
- func RuntimeLuaConvertLuaValue(lv lua.LValue) interface{}
- func RuntimeLuaConvertMap(l *lua.LState, data map[string]interface{}) *lua.LTable
- func RuntimeLuaConvertMapInt64(l *lua.LState, data map[string]int64) *lua.LTable
- func RuntimeLuaConvertMapString(l *lua.LState, data map[string]string) *lua.LTable
- func RuntimeLuaConvertValue(l *lua.LState, val interface{}) lua.LValue
- func SessionRefresh(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) (string, string, map[string]string, error)
- func SetupLogging(tmpLogger *zap.Logger, config Config) (*zap.Logger, *zap.Logger)
- func StackdriverLevelEncoder(l zapcore.Level, enc zapcore.PrimitiveArrayEncoder)
- func StatusError(code codes.Code, msg string, cause error) error
- func StorageDeleteObjects(ctx context.Context, logger *zap.Logger, db *sql.DB, authoritativeDelete bool, ...) (codes.Code, error)
- func StorageListObjects(ctx context.Context, logger *zap.Logger, db *sql.DB, caller uuid.UUID, ...) (*api.StorageObjectList, codes.Code, error)
- func StorageListObjectsAll(ctx context.Context, logger *zap.Logger, db *sql.DB, authoritative bool, ...) (*api.StorageObjectList, error)
- func StorageListObjectsPublicReadUser(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID, ...) (*api.StorageObjectList, error)
- func StorageListObjectsUser(ctx context.Context, logger *zap.Logger, db *sql.DB, authoritative bool, ...) (*api.StorageObjectList, error)
- func StorageReadAllUserObjects(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID) ([]*api.StorageObject, error)
- func StorageReadObjects(ctx context.Context, logger *zap.Logger, db *sql.DB, caller uuid.UUID, ...) (*api.StorageObjects, error)
- func StorageWriteObjects(ctx context.Context, logger *zap.Logger, db *sql.DB, authoritativeWrite bool, ...) (*api.StorageObjectAcks, codes.Code, error)
- func StreamToChannelId(stream PresenceStream) (string, error)
- func TournamentAddAttempt(ctx context.Context, logger *zap.Logger, db *sql.DB, cache LeaderboardCache, ...) error
- func TournamentCreate(ctx context.Context, logger *zap.Logger, cache LeaderboardCache, ...) error
- func TournamentDelete(ctx context.Context, cache LeaderboardCache, rankCache LeaderboardRankCache, ...) error
- func TournamentJoin(ctx context.Context, logger *zap.Logger, db *sql.DB, cache LeaderboardCache, ...) error
- func TournamentList(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) (*api.TournamentList, error)
- func TournamentRecordWrite(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) (*api.LeaderboardRecord, error)
- func TournamentRecordsHaystack(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) ([]*api.LeaderboardRecord, error)
- func TournamentRecordsList(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) (*api.TournamentRecordList, error)
- func TournamentsGet(ctx context.Context, logger *zap.Logger, db *sql.DB, tournamentIDs []string) ([]*api.Tournament, error)
- func UnbanUsers(ctx context.Context, logger *zap.Logger, db *sql.DB, ids []string) error
- func UnlinkApple(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) error
- func UnlinkCustom(ctx context.Context, logger *zap.Logger, db *sql.DB, id uuid.UUID, ...) error
- func UnlinkDevice(ctx context.Context, logger *zap.Logger, db *sql.DB, id uuid.UUID, ...) error
- func UnlinkEmail(ctx context.Context, logger *zap.Logger, db *sql.DB, id uuid.UUID, ...) error
- func UnlinkFacebook(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error
- func UnlinkFacebookInstantGame(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) error
- func UnlinkGameCenter(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error
- func UnlinkGoogle(ctx context.Context, logger *zap.Logger, db *sql.DB, ...) error
- func UnlinkSteam(ctx context.Context, logger *zap.Logger, db *sql.DB, config Config, ...) error
- func UpdateAccounts(ctx context.Context, logger *zap.Logger, db *sql.DB, updates []*accountUpdate) error
- func UpdateGroup(ctx context.Context, logger *zap.Logger, db *sql.DB, groupID uuid.UUID, ...) error
- func UpdateWalletLedger(ctx context.Context, logger *zap.Logger, db *sql.DB, id uuid.UUID, ...) (*walletLedger, error)
- func UpdateWallets(ctx context.Context, logger *zap.Logger, db *sql.DB, updates []*walletUpdate, ...) ([]*runtime.WalletUpdateResult, error)
- func UserExistsAndDoesNotBlock(ctx context.Context, db *sql.DB, checkUserID, blocksUserID uuid.UUID) (bool, error)
- type AmbiguousCommitError
- type ApiServer
- func (s *ApiServer) AddFriends(ctx context.Context, in *api.AddFriendsRequest) (*empty.Empty, error)
- func (s *ApiServer) AddGroupUsers(ctx context.Context, in *api.AddGroupUsersRequest) (*empty.Empty, error)
- func (s *ApiServer) AuthenticateApple(ctx context.Context, in *api.AuthenticateAppleRequest) (*api.Session, error)
- func (s *ApiServer) AuthenticateCustom(ctx context.Context, in *api.AuthenticateCustomRequest) (*api.Session, error)
- func (s *ApiServer) AuthenticateDevice(ctx context.Context, in *api.AuthenticateDeviceRequest) (*api.Session, error)
- func (s *ApiServer) AuthenticateEmail(ctx context.Context, in *api.AuthenticateEmailRequest) (*api.Session, error)
- func (s *ApiServer) AuthenticateFacebook(ctx context.Context, in *api.AuthenticateFacebookRequest) (*api.Session, error)
- func (s *ApiServer) AuthenticateFacebookInstantGame(ctx context.Context, in *api.AuthenticateFacebookInstantGameRequest) (*api.Session, error)
- func (s *ApiServer) AuthenticateGameCenter(ctx context.Context, in *api.AuthenticateGameCenterRequest) (*api.Session, error)
- func (s *ApiServer) AuthenticateGoogle(ctx context.Context, in *api.AuthenticateGoogleRequest) (*api.Session, error)
- func (s *ApiServer) AuthenticateSteam(ctx context.Context, in *api.AuthenticateSteamRequest) (*api.Session, error)
- func (s *ApiServer) BanGroupUsers(ctx context.Context, in *api.BanGroupUsersRequest) (*empty.Empty, error)
- func (s *ApiServer) BlockFriends(ctx context.Context, in *api.BlockFriendsRequest) (*empty.Empty, error)
- func (s *ApiServer) CreateGroup(ctx context.Context, in *api.CreateGroupRequest) (*api.Group, error)
- func (s *ApiServer) DeleteFriends(ctx context.Context, in *api.DeleteFriendsRequest) (*empty.Empty, error)
- func (s *ApiServer) DeleteGroup(ctx context.Context, in *api.DeleteGroupRequest) (*empty.Empty, error)
- func (s *ApiServer) DeleteLeaderboardRecord(ctx context.Context, in *api.DeleteLeaderboardRecordRequest) (*empty.Empty, error)
- func (s *ApiServer) DeleteNotifications(ctx context.Context, in *api.DeleteNotificationsRequest) (*empty.Empty, error)
- func (s *ApiServer) DeleteStorageObjects(ctx context.Context, in *api.DeleteStorageObjectsRequest) (*empty.Empty, error)
- func (s *ApiServer) DemoteGroupUsers(ctx context.Context, in *api.DemoteGroupUsersRequest) (*empty.Empty, error)
- func (s *ApiServer) Event(ctx context.Context, in *api.Event) (*empty.Empty, error)
- func (s *ApiServer) GetAccount(ctx context.Context, in *empty.Empty) (*api.Account, error)
- func (s *ApiServer) GetUsers(ctx context.Context, in *api.GetUsersRequest) (*api.Users, error)
- func (s *ApiServer) Healthcheck(ctx context.Context, in *empty.Empty) (*empty.Empty, error)
- func (s *ApiServer) ImportFacebookFriends(ctx context.Context, in *api.ImportFacebookFriendsRequest) (*empty.Empty, error)
- func (s *ApiServer) ImportSteamFriends(ctx context.Context, in *api.ImportSteamFriendsRequest) (*empty.Empty, error)
- func (s *ApiServer) JoinGroup(ctx context.Context, in *api.JoinGroupRequest) (*empty.Empty, error)
- func (s *ApiServer) JoinTournament(ctx context.Context, in *api.JoinTournamentRequest) (*empty.Empty, error)
- func (s *ApiServer) KickGroupUsers(ctx context.Context, in *api.KickGroupUsersRequest) (*empty.Empty, error)
- func (s *ApiServer) LeaveGroup(ctx context.Context, in *api.LeaveGroupRequest) (*empty.Empty, error)
- func (s *ApiServer) LinkApple(ctx context.Context, in *api.AccountApple) (*empty.Empty, error)
- func (s *ApiServer) LinkCustom(ctx context.Context, in *api.AccountCustom) (*empty.Empty, error)
- func (s *ApiServer) LinkDevice(ctx context.Context, in *api.AccountDevice) (*empty.Empty, error)
- func (s *ApiServer) LinkEmail(ctx context.Context, in *api.AccountEmail) (*empty.Empty, error)
- func (s *ApiServer) LinkFacebook(ctx context.Context, in *api.LinkFacebookRequest) (*empty.Empty, error)
- func (s *ApiServer) LinkFacebookInstantGame(ctx context.Context, in *api.AccountFacebookInstantGame) (*empty.Empty, error)
- func (s *ApiServer) LinkGameCenter(ctx context.Context, in *api.AccountGameCenter) (*empty.Empty, error)
- func (s *ApiServer) LinkGoogle(ctx context.Context, in *api.AccountGoogle) (*empty.Empty, error)
- func (s *ApiServer) LinkSteam(ctx context.Context, in *api.LinkSteamRequest) (*empty.Empty, error)
- func (s *ApiServer) ListChannelMessages(ctx context.Context, in *api.ListChannelMessagesRequest) (*api.ChannelMessageList, error)
- func (s *ApiServer) ListFriends(ctx context.Context, in *api.ListFriendsRequest) (*api.FriendList, error)
- func (s *ApiServer) ListGroupUsers(ctx context.Context, in *api.ListGroupUsersRequest) (*api.GroupUserList, error)
- func (s *ApiServer) ListGroups(ctx context.Context, in *api.ListGroupsRequest) (*api.GroupList, error)
- func (s *ApiServer) ListLeaderboardRecords(ctx context.Context, in *api.ListLeaderboardRecordsRequest) (*api.LeaderboardRecordList, error)
- func (s *ApiServer) ListLeaderboardRecordsAroundOwner(ctx context.Context, in *api.ListLeaderboardRecordsAroundOwnerRequest) (*api.LeaderboardRecordList, error)
- func (s *ApiServer) ListMatches(ctx context.Context, in *api.ListMatchesRequest) (*api.MatchList, error)
- func (s *ApiServer) ListNotifications(ctx context.Context, in *api.ListNotificationsRequest) (*api.NotificationList, error)
- func (s *ApiServer) ListStorageObjects(ctx context.Context, in *api.ListStorageObjectsRequest) (*api.StorageObjectList, error)
- func (s *ApiServer) ListTournamentRecords(ctx context.Context, in *api.ListTournamentRecordsRequest) (*api.TournamentRecordList, error)
- func (s *ApiServer) ListTournamentRecordsAroundOwner(ctx context.Context, in *api.ListTournamentRecordsAroundOwnerRequest) (*api.TournamentRecordList, error)
- func (s *ApiServer) ListTournaments(ctx context.Context, in *api.ListTournamentsRequest) (*api.TournamentList, error)
- func (s *ApiServer) ListUserGroups(ctx context.Context, in *api.ListUserGroupsRequest) (*api.UserGroupList, error)
- func (s *ApiServer) PromoteGroupUsers(ctx context.Context, in *api.PromoteGroupUsersRequest) (*empty.Empty, error)
- func (s *ApiServer) ReadStorageObjects(ctx context.Context, in *api.ReadStorageObjectsRequest) (*api.StorageObjects, error)
- func (s *ApiServer) RpcFunc(ctx context.Context, in *api.Rpc) (*api.Rpc, error)
- func (s *ApiServer) RpcFuncHttp(w http.ResponseWriter, r *http.Request)
- func (s *ApiServer) SessionRefresh(ctx context.Context, in *api.SessionRefreshRequest) (*api.Session, error)
- func (s *ApiServer) Stop()
- func (s *ApiServer) UnlinkApple(ctx context.Context, in *api.AccountApple) (*empty.Empty, error)
- func (s *ApiServer) UnlinkCustom(ctx context.Context, in *api.AccountCustom) (*empty.Empty, error)
- func (s *ApiServer) UnlinkDevice(ctx context.Context, in *api.AccountDevice) (*empty.Empty, error)
- func (s *ApiServer) UnlinkEmail(ctx context.Context, in *api.AccountEmail) (*empty.Empty, error)
- func (s *ApiServer) UnlinkFacebook(ctx context.Context, in *api.AccountFacebook) (*empty.Empty, error)
- func (s *ApiServer) UnlinkFacebookInstantGame(ctx context.Context, in *api.AccountFacebookInstantGame) (*empty.Empty, error)
- func (s *ApiServer) UnlinkGameCenter(ctx context.Context, in *api.AccountGameCenter) (*empty.Empty, error)
- func (s *ApiServer) UnlinkGoogle(ctx context.Context, in *api.AccountGoogle) (*empty.Empty, error)
- func (s *ApiServer) UnlinkSteam(ctx context.Context, in *api.AccountSteam) (*empty.Empty, error)
- func (s *ApiServer) UpdateAccount(ctx context.Context, in *api.UpdateAccountRequest) (*empty.Empty, error)
- func (s *ApiServer) UpdateGroup(ctx context.Context, in *api.UpdateGroupRequest) (*empty.Empty, error)
- func (s *ApiServer) WriteLeaderboardRecord(ctx context.Context, in *api.WriteLeaderboardRecordRequest) (*api.LeaderboardRecord, error)
- func (s *ApiServer) WriteStorageObjects(ctx context.Context, in *api.WriteStorageObjectsRequest) (*api.StorageObjectAcks, error)
- func (s *ApiServer) WriteTournamentRecord(ctx context.Context, in *api.WriteTournamentRecordRequest) (*api.LeaderboardRecord, error)
- type ChannelIdToStreamResult
- type Config
- type ConsoleConfig
- type ConsoleServer
- func (s *ConsoleServer) AddUser(ctx context.Context, in *console.AddUserRequest) (*empty.Empty, error)
- func (s *ConsoleServer) Authenticate(ctx context.Context, in *console.AuthenticateRequest) (*console.ConsoleSession, error)
- func (s *ConsoleServer) BanAccount(ctx context.Context, in *console.AccountId) (*empty.Empty, error)
- func (s *ConsoleServer) CallApiEndpoint(ctx context.Context, in *console.CallApiEndpointRequest) (*console.CallApiEndpointResponse, error)
- func (s *ConsoleServer) CallRpcEndpoint(ctx context.Context, in *console.CallApiEndpointRequest) (*console.CallApiEndpointResponse, error)
- func (s *ConsoleServer) DeleteAccount(ctx context.Context, in *console.AccountDeleteRequest) (*empty.Empty, error)
- func (s *ConsoleServer) DeleteAccounts(ctx context.Context, in *empty.Empty) (*empty.Empty, error)
- func (s *ConsoleServer) DeleteFriend(ctx context.Context, in *console.DeleteFriendRequest) (*empty.Empty, error)
- func (s *ConsoleServer) DeleteGroupUser(ctx context.Context, in *console.DeleteGroupUserRequest) (*empty.Empty, error)
- func (s *ConsoleServer) DeleteLeaderboard(ctx context.Context, in *console.LeaderboardRequest) (*empty.Empty, error)
- func (s *ConsoleServer) DeleteLeaderboardRecord(ctx context.Context, in *console.DeleteLeaderboardRecordRequest) (*empty.Empty, error)
- func (s *ConsoleServer) DeleteStorage(ctx context.Context, in *empty.Empty) (*empty.Empty, error)
- func (s *ConsoleServer) DeleteStorageObject(ctx context.Context, in *console.DeleteStorageObjectRequest) (*empty.Empty, error)
- func (s *ConsoleServer) DeleteUser(ctx context.Context, in *console.Username) (*empty.Empty, error)
- func (s *ConsoleServer) DeleteWalletLedger(ctx context.Context, in *console.DeleteWalletLedgerRequest) (*empty.Empty, error)
- func (s *ConsoleServer) ExportAccount(ctx context.Context, in *console.AccountId) (*console.AccountExport, error)
- func (s *ConsoleServer) GetAccount(ctx context.Context, in *console.AccountId) (*console.Account, error)
- func (s *ConsoleServer) GetConfig(ctx context.Context, in *empty.Empty) (*console.Config, error)
- func (s *ConsoleServer) GetFriends(ctx context.Context, in *console.AccountId) (*api.FriendList, error)
- func (s *ConsoleServer) GetGroups(ctx context.Context, in *console.AccountId) (*api.UserGroupList, error)
- func (s *ConsoleServer) GetLeaderboard(ctx context.Context, in *console.LeaderboardRequest) (*console.Leaderboard, error)
- func (s *ConsoleServer) GetMatchState(ctx context.Context, in *console.MatchStateRequest) (*console.MatchState, error)
- func (s *ConsoleServer) GetRuntime(ctx context.Context, in *empty.Empty) (*console.RuntimeInfo, error)
- func (s *ConsoleServer) GetStatus(ctx context.Context, in *empty.Empty) (*console.StatusList, error)
- func (s *ConsoleServer) GetStorage(ctx context.Context, in *api.ReadStorageObjectId) (*api.StorageObject, error)
- func (s *ConsoleServer) GetWalletLedger(ctx context.Context, in *console.AccountId) (*console.WalletLedgerList, error)
- func (s *ConsoleServer) ListAccounts(ctx context.Context, in *console.ListAccountsRequest) (*console.AccountList, error)
- func (s *ConsoleServer) ListApiEndpoints(ctx context.Context, _ *empty.Empty) (*console.ApiEndpointList, error)
- func (s *ConsoleServer) ListLeaderboardRecords(ctx context.Context, in *api.ListLeaderboardRecordsRequest) (*api.LeaderboardRecordList, error)
- func (s *ConsoleServer) ListLeaderboards(ctx context.Context, _ *empty.Empty) (*console.LeaderboardList, error)
- func (s *ConsoleServer) ListMatches(ctx context.Context, in *api.ListMatchesRequest) (*api.MatchList, error)
- func (s *ConsoleServer) ListStorage(ctx context.Context, in *console.ListStorageRequest) (*console.StorageList, error)
- func (s *ConsoleServer) ListStorageCollections(ctx context.Context, in *empty.Empty) (*console.StorageCollectionsList, error)
- func (s *ConsoleServer) ListUsers(ctx context.Context, in *empty.Empty) (*console.UserList, error)
- func (s *ConsoleServer) Stop()
- func (s *ConsoleServer) UnbanAccount(ctx context.Context, in *console.AccountId) (*empty.Empty, error)
- func (s *ConsoleServer) UnlinkApple(ctx context.Context, in *console.AccountId) (*empty.Empty, error)
- func (s *ConsoleServer) UnlinkCustom(ctx context.Context, in *console.AccountId) (*empty.Empty, error)
- func (s *ConsoleServer) UnlinkDevice(ctx context.Context, in *console.UnlinkDeviceRequest) (*empty.Empty, error)
- func (s *ConsoleServer) UnlinkEmail(ctx context.Context, in *console.AccountId) (*empty.Empty, error)
- func (s *ConsoleServer) UnlinkFacebook(ctx context.Context, in *console.AccountId) (*empty.Empty, error)
- func (s *ConsoleServer) UnlinkFacebookInstantGame(ctx context.Context, in *console.AccountId) (*empty.Empty, error)
- func (s *ConsoleServer) UnlinkGameCenter(ctx context.Context, in *console.AccountId) (*empty.Empty, error)
- func (s *ConsoleServer) UnlinkGoogle(ctx context.Context, in *console.AccountId) (*empty.Empty, error)
- func (s *ConsoleServer) UnlinkSteam(ctx context.Context, in *console.AccountId) (*empty.Empty, error)
- func (s *ConsoleServer) UpdateAccount(ctx context.Context, in *console.UpdateAccountRequest) (*empty.Empty, error)
- func (s *ConsoleServer) WriteStorageObject(ctx context.Context, in *console.WriteStorageObjectRequest) (*api.StorageObjectAck, error)
- type ConsoleTokenClaims
- type DatabaseConfig
- type DeferredMessage
- type ErrorCauser
- type JsErrorType
- type LSentinelType
- type Leaderboard
- 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
- type LeaderboardConfig
- type LeaderboardRankCache
- type LeaderboardScheduler
- type LeaderboardSchedulerCallback
- type LeaderboardWithExpiry
- type LocalLeaderboardCache
- func (l *LocalLeaderboardCache) Create(ctx context.Context, id string, authoritative bool, sortOrder, operator int, ...) (*Leaderboard, error)
- func (l *LocalLeaderboardCache) CreateTournament(ctx context.Context, id string, sortOrder, operator int, ...) (*Leaderboard, error)
- func (l *LocalLeaderboardCache) Delete(ctx context.Context, id string) error
- func (l *LocalLeaderboardCache) Get(id string) *Leaderboard
- func (l *LocalLeaderboardCache) GetAllLeaderboards() []*Leaderboard
- func (l *LocalLeaderboardCache) Insert(id string, authoritative bool, sortOrder, operator int, ...)
- func (l *LocalLeaderboardCache) InsertTournament(id string, sortOrder, operator int, ...)
- func (l *LocalLeaderboardCache) ListTournaments(now int64, categoryStart, categoryEnd int, startTime, endTime int64, limit int, ...) ([]*Leaderboard, *TournamentListCursor, error)
- func (l *LocalLeaderboardCache) RefreshAllLeaderboards(ctx context.Context) error
- func (l *LocalLeaderboardCache) Remove(id string)
- type LocalLeaderboardRankCache
- func (l *LocalLeaderboardRankCache) Delete(leaderboardId string, expiryUnix int64, ownerID uuid.UUID) bool
- func (l *LocalLeaderboardRankCache) DeleteLeaderboard(leaderboardId string, expiryUnix int64) bool
- func (l *LocalLeaderboardRankCache) Fill(leaderboardId string, expiryUnix int64, records []*api.LeaderboardRecord)
- func (l *LocalLeaderboardRankCache) Get(leaderboardId string, expiryUnix int64, ownerID uuid.UUID) int64
- func (l *LocalLeaderboardRankCache) Insert(leaderboardId string, expiryUnix int64, sortOrder int, ownerID uuid.UUID, ...) int64
- func (l *LocalLeaderboardRankCache) TrimExpired(nowUnix int64) bool
- type LocalLeaderboardScheduler
- type LocalMatchRegistry
- func (r *LocalMatchRegistry) Count() int
- func (r *LocalMatchRegistry) CreateMatch(ctx context.Context, logger *zap.Logger, createFn RuntimeMatchCreateFunction, ...) (string, error)
- func (r *LocalMatchRegistry) GetMatch(ctx context.Context, id string) (*api.Match, error)
- func (r *LocalMatchRegistry) GetState(ctx context.Context, id uuid.UUID, node string) ([]*rtapi.UserPresence, int64, string, error)
- func (r *LocalMatchRegistry) Join(id uuid.UUID, presences []*MatchPresence)
- func (r *LocalMatchRegistry) JoinAttempt(ctx context.Context, id uuid.UUID, node string, userID, sessionID uuid.UUID, ...) (bool, bool, bool, string, string, []*MatchPresence)
- func (r *LocalMatchRegistry) Kick(stream PresenceStream, presences []*MatchPresence)
- func (r *LocalMatchRegistry) Leave(id uuid.UUID, presences []*MatchPresence)
- func (r *LocalMatchRegistry) ListMatches(ctx context.Context, limit int, authoritative *wrappers.BoolValue, ...) ([]*api.Match, error)
- func (r *LocalMatchRegistry) NewMatch(logger *zap.Logger, id uuid.UUID, core RuntimeMatchCore, stopped *atomic.Bool, ...) (*MatchHandler, error)
- func (r *LocalMatchRegistry) RemoveMatch(id uuid.UUID, stream PresenceStream)
- func (r *LocalMatchRegistry) SendData(id uuid.UUID, node string, userID, sessionID uuid.UUID, ...)
- func (r *LocalMatchRegistry) Stop(graceSeconds int) chan struct{}
- func (r *LocalMatchRegistry) UpdateMatchLabel(id uuid.UUID, tickRate int, handlerName, label string) error
- type LocalMatchmaker
- func (m *LocalMatchmaker) Add(presences []*MatchmakerPresence, sessionID, partyId, query string, ...) (string, error)
- func (m *LocalMatchmaker) RemoveParty(partyID, ticket string) error
- func (m *LocalMatchmaker) RemovePartyAll(partyID string) error
- func (m *LocalMatchmaker) RemoveSession(sessionID, ticket string) error
- func (m *LocalMatchmaker) RemoveSessionAll(sessionID string) error
- func (m *LocalMatchmaker) Stop()
- type LocalMessageRouter
- func (r *LocalMessageRouter) SendDeferred(logger *zap.Logger, messages []*DeferredMessage)
- func (r *LocalMessageRouter) SendToPresenceIDs(logger *zap.Logger, presenceIDs []*PresenceID, envelope *rtapi.Envelope, ...)
- func (r *LocalMessageRouter) SendToStream(logger *zap.Logger, stream PresenceStream, envelope *rtapi.Envelope, ...)
- type LocalPartyRegistry
- func (p *LocalPartyRegistry) Create(open bool, maxSize int) *PartyHandler
- func (p *LocalPartyRegistry) Delete(id uuid.UUID)
- func (p *LocalPartyRegistry) Join(id uuid.UUID, presences []*Presence)
- func (p *LocalPartyRegistry) Leave(id uuid.UUID, presences []*Presence)
- func (p *LocalPartyRegistry) PartyAccept(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, ...) error
- func (p *LocalPartyRegistry) PartyClose(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string) error
- func (p *LocalPartyRegistry) PartyDataSend(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, ...) error
- func (p *LocalPartyRegistry) PartyJoinRequest(ctx context.Context, id uuid.UUID, node string, presence *Presence) (bool, error)
- func (p *LocalPartyRegistry) PartyJoinRequestList(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string) ([]*rtapi.UserPresence, error)
- func (p *LocalPartyRegistry) PartyMatchmakerAdd(ctx context.Context, id uuid.UUID, node, sessionID, fromNode, query string, ...) (string, error)
- func (p *LocalPartyRegistry) PartyMatchmakerRemove(ctx context.Context, id uuid.UUID, node, sessionID, fromNode, ticket string) error
- func (p *LocalPartyRegistry) PartyPromote(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, ...) error
- func (p *LocalPartyRegistry) PartyRemove(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, ...) error
- type LocalSessionRegistry
- func (r *LocalSessionRegistry) Add(session Session)
- func (r *LocalSessionRegistry) Count() int
- func (r *LocalSessionRegistry) Disconnect(ctx context.Context, sessionID uuid.UUID) error
- func (r *LocalSessionRegistry) Get(sessionID uuid.UUID) Session
- func (r *LocalSessionRegistry) Remove(sessionID uuid.UUID)
- func (r *LocalSessionRegistry) Stop()
- type LocalStatusHandler
- type LocalStreamManager
- func (m *LocalStreamManager) UserJoin(stream PresenceStream, userID, sessionID uuid.UUID, hidden, persistence bool, ...) (bool, bool, error)
- func (m *LocalStreamManager) UserLeave(stream PresenceStream, userID, sessionID uuid.UUID) error
- func (m *LocalStreamManager) UserUpdate(stream PresenceStream, userID, sessionID uuid.UUID, hidden, persistence bool, ...) (bool, error)
- type LocalTracker
- func (t *LocalTracker) Count() int
- func (t *LocalTracker) CountByStream(stream PresenceStream) int
- func (t *LocalTracker) CountByStreamModeFilter(modes map[uint8]*uint8) map[*PresenceStream]int32
- func (t *LocalTracker) GetBySessionIDStreamUserID(node string, sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID) *PresenceMeta
- func (t *LocalTracker) GetLocalBySessionIDStreamUserID(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID) *PresenceMeta
- func (t *LocalTracker) ListByStream(stream PresenceStream, includeHidden bool, includeNotHidden bool) []*Presence
- func (t *LocalTracker) ListLocalSessionIDByStream(stream PresenceStream) []uuid.UUID
- func (t *LocalTracker) ListNodesForStream(stream PresenceStream) map[string]struct{}
- func (t *LocalTracker) ListPresenceIDByStream(stream PresenceStream) []*PresenceID
- func (t *LocalTracker) SetMatchJoinListener(f func(id uuid.UUID, joins []*MatchPresence))
- func (t *LocalTracker) SetMatchLeaveListener(f func(id uuid.UUID, leaves []*MatchPresence))
- func (t *LocalTracker) SetPartyJoinListener(f func(id uuid.UUID, joins []*Presence))
- func (t *LocalTracker) SetPartyLeaveListener(f func(id uuid.UUID, leaves []*Presence))
- func (t *LocalTracker) Stop()
- func (t *LocalTracker) StreamExists(stream PresenceStream) bool
- func (t *LocalTracker) Track(ctx context.Context, sessionID uuid.UUID, stream PresenceStream, ...) (bool, bool)
- func (t *LocalTracker) TrackMulti(ctx context.Context, sessionID uuid.UUID, ops []*TrackerOp, userID uuid.UUID, ...) 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) UntrackMulti(sessionID uuid.UUID, streams []*PresenceStream, userID uuid.UUID)
- func (t *LocalTracker) Update(ctx context.Context, sessionID uuid.UUID, stream PresenceStream, ...) bool
- type LoggerConfig
- type LoggingFormat
- type MatchConfig
- 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) GetReliable() bool
- func (m *MatchDataMessage) GetSessionId() string
- func (m *MatchDataMessage) GetStatus() string
- func (m *MatchDataMessage) GetUserId() string
- func (m *MatchDataMessage) GetUsername() string
- type MatchFnId
- type MatchGetStateResult
- type MatchHandler
- func (mh *MatchHandler) Label() string
- func (mh *MatchHandler) QueueData(m *MatchDataMessage)
- func (mh *MatchHandler) QueueGetState(ctx context.Context, resultCh chan<- *MatchGetStateResult) bool
- func (mh *MatchHandler) QueueJoin(joins []*MatchPresence, mark bool) bool
- func (mh *MatchHandler) QueueJoinAttempt(ctx context.Context, resultCh chan<- *MatchJoinResult, ...) bool
- func (mh *MatchHandler) QueueLeave(leaves []*MatchPresence) bool
- func (mh *MatchHandler) QueueTerminate(graceSeconds int) bool
- func (mh *MatchHandler) Stop()
- type MatchIndexEntry
- type MatchJoinMarker
- type MatchJoinMarkerList
- type MatchJoinResult
- type MatchNamesListFunction
- 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 MatchPresenceList
- func (m *MatchPresenceList) Contains(presence *PresenceID) bool
- func (m *MatchPresenceList) FilterPresenceIDs(ids []*PresenceID) []*PresenceID
- func (m *MatchPresenceList) Join(joins []*MatchPresence) []*MatchPresence
- func (m *MatchPresenceList) Leave(leaves []*MatchPresence) []*MatchPresence
- func (m *MatchPresenceList) ListPresenceIDs() []*PresenceID
- func (m *MatchPresenceList) ListPresences() []*MatchPresence
- func (m *MatchPresenceList) Size() int
- type MatchPresenceListItem
- type MatchProvider
- type MatchRegistry
- type Matchmaker
- type MatchmakerConfig
- type MatchmakerEntry
- type MatchmakerIndex
- 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 MessageRouter
- type MethodName
- type Metrics
- func (m *Metrics) Api(name string, elapsed time.Duration, recvBytes, sentBytes int64, isErr bool)
- func (m *Metrics) ApiAfter(name string, elapsed time.Duration, isErr bool)
- func (m *Metrics) ApiBefore(name string, elapsed time.Duration, isErr bool)
- func (m *Metrics) CountDroppedEvents(delta int64)
- func (m *Metrics) CountWebsocketClosed(delta int64)
- func (m *Metrics) CountWebsocketOpened(delta int64)
- func (m *Metrics) GaugeAuthoritativeMatches(value float64)
- func (m *Metrics) GaugeJsRuntimes(value float64)
- func (m *Metrics) GaugeLuaRuntimes(value float64)
- func (m *Metrics) GaugePresences(value float64)
- func (m *Metrics) GaugeRuntimes(value float64)
- func (m *Metrics) GaugeSessions(value float64)
- func (m *Metrics) Message(recvBytes int64, isErr bool)
- func (m *Metrics) MessageBytesSent(sentBytes int64)
- func (m *Metrics) Stop(logger *zap.Logger)
- type MetricsConfig
- type MetricsGrpcHandler
- func (m *MetricsGrpcHandler) HandleConn(context.Context, stats.ConnStats)
- func (m *MetricsGrpcHandler) HandleRPC(ctx context.Context, rs stats.RPCStats)
- func (m *MetricsGrpcHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context
- func (m *MetricsGrpcHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context
- type OrderedTournaments
- type PartyHandler
- func (p *PartyHandler) Accept(sessionID, node string, presence *rtapi.UserPresence) error
- func (p *PartyHandler) Close(sessionID, node string) error
- func (p *PartyHandler) DataSend(sessionID, node string, opCode int64, data []byte) error
- func (p *PartyHandler) Join(presences []*Presence)
- func (p *PartyHandler) JoinRequest(presence *Presence) (bool, error)
- func (p *PartyHandler) JoinRequestList(sessionID, node string) ([]*rtapi.UserPresence, error)
- func (p *PartyHandler) Leave(presences []*Presence)
- func (p *PartyHandler) MatchmakerAdd(sessionID, node, query string, minCount, maxCount int, ...) (string, error)
- func (p *PartyHandler) MatchmakerRemove(sessionID, node, ticket string) error
- func (p *PartyHandler) Promote(sessionID, node string, presence *rtapi.UserPresence) error
- func (p *PartyHandler) Remove(sessionID, node string, presence *rtapi.UserPresence) error
- type PartyRegistry
- type Pipeline
- type Presence
- type PresenceEvent
- type PresenceID
- type PresenceMeta
- type PresenceStream
- type RankAsc
- type RankCache
- type RankDesc
- type Runtime
- func (r *Runtime) AfterAddFriends() RuntimeAfterAddFriendsFunction
- func (r *Runtime) AfterAddGroupUsers() RuntimeAfterAddGroupUsersFunction
- func (r *Runtime) AfterAuthenticateApple() RuntimeAfterAuthenticateAppleFunction
- func (r *Runtime) AfterAuthenticateCustom() RuntimeAfterAuthenticateCustomFunction
- func (r *Runtime) AfterAuthenticateDevice() RuntimeAfterAuthenticateDeviceFunction
- func (r *Runtime) AfterAuthenticateEmail() RuntimeAfterAuthenticateEmailFunction
- func (r *Runtime) AfterAuthenticateFacebook() RuntimeAfterAuthenticateFacebookFunction
- func (r *Runtime) AfterAuthenticateFacebookInstantGame() RuntimeAfterAuthenticateFacebookInstantGameFunction
- func (r *Runtime) AfterAuthenticateGameCenter() RuntimeAfterAuthenticateGameCenterFunction
- func (r *Runtime) AfterAuthenticateGoogle() RuntimeAfterAuthenticateGoogleFunction
- func (r *Runtime) AfterAuthenticateSteam() RuntimeAfterAuthenticateSteamFunction
- func (r *Runtime) AfterBanGroupUsers() RuntimeAfterBanGroupUsersFunction
- func (r *Runtime) AfterBlockFriends() RuntimeAfterBlockFriendsFunction
- func (r *Runtime) AfterCreateGroup() RuntimeAfterCreateGroupFunction
- func (r *Runtime) AfterDeleteFriends() RuntimeAfterDeleteFriendsFunction
- func (r *Runtime) AfterDeleteGroup() RuntimeAfterDeleteGroupFunction
- func (r *Runtime) AfterDeleteLeaderboardRecord() RuntimeAfterDeleteLeaderboardRecordFunction
- func (r *Runtime) AfterDeleteNotification() RuntimeAfterDeleteNotificationFunction
- func (r *Runtime) AfterDeleteStorageObjects() RuntimeAfterDeleteStorageObjectsFunction
- func (r *Runtime) AfterDemoteGroupUsers() RuntimeAfterDemoteGroupUsersFunction
- func (r *Runtime) AfterEvent() RuntimeAfterEventFunction
- func (r *Runtime) AfterGetAccount() RuntimeAfterGetAccountFunction
- func (r *Runtime) AfterGetUsers() RuntimeAfterGetUsersFunction
- func (r *Runtime) AfterImportFacebookFriends() RuntimeAfterImportFacebookFriendsFunction
- func (r *Runtime) AfterImportSteamFriends() RuntimeAfterImportSteamFriendsFunction
- func (r *Runtime) AfterJoinGroup() RuntimeAfterJoinGroupFunction
- func (r *Runtime) AfterJoinTournament() RuntimeAfterJoinTournamentFunction
- func (r *Runtime) AfterKickGroupUsers() RuntimeAfterKickGroupUsersFunction
- func (r *Runtime) AfterLeaveGroup() RuntimeAfterLeaveGroupFunction
- func (r *Runtime) AfterLinkApple() RuntimeAfterLinkAppleFunction
- func (r *Runtime) AfterLinkCustom() RuntimeAfterLinkCustomFunction
- func (r *Runtime) AfterLinkDevice() RuntimeAfterLinkDeviceFunction
- func (r *Runtime) AfterLinkEmail() RuntimeAfterLinkEmailFunction
- func (r *Runtime) AfterLinkFacebook() RuntimeAfterLinkFacebookFunction
- func (r *Runtime) AfterLinkFacebookInstantGame() RuntimeAfterLinkFacebookInstantGameFunction
- func (r *Runtime) AfterLinkGameCenter() RuntimeAfterLinkGameCenterFunction
- func (r *Runtime) AfterLinkGoogle() RuntimeAfterLinkGoogleFunction
- func (r *Runtime) AfterLinkSteam() RuntimeAfterLinkSteamFunction
- func (r *Runtime) AfterListChannelMessages() RuntimeAfterListChannelMessagesFunction
- func (r *Runtime) AfterListFriends() RuntimeAfterListFriendsFunction
- func (r *Runtime) AfterListGroupUsers() RuntimeAfterListGroupUsersFunction
- func (r *Runtime) AfterListGroups() RuntimeAfterListGroupsFunction
- func (r *Runtime) AfterListLeaderboardRecords() RuntimeAfterListLeaderboardRecordsFunction
- func (r *Runtime) AfterListLeaderboardRecordsAroundOwner() RuntimeAfterListLeaderboardRecordsAroundOwnerFunction
- func (r *Runtime) AfterListMatches() RuntimeAfterListMatchesFunction
- func (r *Runtime) AfterListNotifications() RuntimeAfterListNotificationsFunction
- func (r *Runtime) AfterListStorageObjects() RuntimeAfterListStorageObjectsFunction
- func (r *Runtime) AfterListTournamentRecords() RuntimeAfterListTournamentRecordsFunction
- func (r *Runtime) AfterListTournamentRecordsAroundOwner() RuntimeAfterListTournamentRecordsAroundOwnerFunction
- func (r *Runtime) AfterListTournaments() RuntimeAfterListTournamentsFunction
- func (r *Runtime) AfterListUserGroups() RuntimeAfterListUserGroupsFunction
- func (r *Runtime) AfterPromoteGroupUsers() RuntimeAfterPromoteGroupUsersFunction
- func (r *Runtime) AfterReadStorageObjects() RuntimeAfterReadStorageObjectsFunction
- func (r *Runtime) AfterRt(id string) RuntimeAfterRtFunction
- func (r *Runtime) AfterSessionRefresh() RuntimeAfterSessionRefreshFunction
- func (r *Runtime) AfterUnlinkApple() RuntimeAfterUnlinkAppleFunction
- func (r *Runtime) AfterUnlinkCustom() RuntimeAfterUnlinkCustomFunction
- func (r *Runtime) AfterUnlinkDevice() RuntimeAfterUnlinkDeviceFunction
- func (r *Runtime) AfterUnlinkEmail() RuntimeAfterUnlinkEmailFunction
- func (r *Runtime) AfterUnlinkFacebook() RuntimeAfterUnlinkFacebookFunction
- func (r *Runtime) AfterUnlinkFacebookInstantGame() RuntimeAfterUnlinkFacebookInstantGameFunction
- func (r *Runtime) AfterUnlinkGameCenter() RuntimeAfterUnlinkGameCenterFunction
- func (r *Runtime) AfterUnlinkGoogle() RuntimeAfterUnlinkGoogleFunction
- func (r *Runtime) AfterUnlinkSteam() RuntimeAfterUnlinkSteamFunction
- func (r *Runtime) AfterUpdateAccount() RuntimeAfterUpdateAccountFunction
- func (r *Runtime) AfterUpdateGroup() RuntimeAfterUpdateGroupFunction
- func (r *Runtime) AfterWriteLeaderboardRecord() RuntimeAfterWriteLeaderboardRecordFunction
- func (r *Runtime) AfterWriteStorageObjects() RuntimeAfterWriteStorageObjectsFunction
- func (r *Runtime) AfterWriteTournamentRecord() RuntimeAfterWriteTournamentRecordFunction
- func (r *Runtime) BeforeAddFriends() RuntimeBeforeAddFriendsFunction
- func (r *Runtime) BeforeAddGroupUsers() RuntimeBeforeAddGroupUsersFunction
- func (r *Runtime) BeforeAuthenticateApple() RuntimeBeforeAuthenticateAppleFunction
- func (r *Runtime) BeforeAuthenticateCustom() RuntimeBeforeAuthenticateCustomFunction
- func (r *Runtime) BeforeAuthenticateDevice() RuntimeBeforeAuthenticateDeviceFunction
- func (r *Runtime) BeforeAuthenticateEmail() RuntimeBeforeAuthenticateEmailFunction
- func (r *Runtime) BeforeAuthenticateFacebook() RuntimeBeforeAuthenticateFacebookFunction
- func (r *Runtime) BeforeAuthenticateFacebookInstantGame() RuntimeBeforeAuthenticateFacebookInstantGameFunction
- func (r *Runtime) BeforeAuthenticateGameCenter() RuntimeBeforeAuthenticateGameCenterFunction
- func (r *Runtime) BeforeAuthenticateGoogle() RuntimeBeforeAuthenticateGoogleFunction
- func (r *Runtime) BeforeAuthenticateSteam() RuntimeBeforeAuthenticateSteamFunction
- func (r *Runtime) BeforeBanGroupUsers() RuntimeBeforeBanGroupUsersFunction
- func (r *Runtime) BeforeBlockFriends() RuntimeBeforeBlockFriendsFunction
- func (r *Runtime) BeforeCreateGroup() RuntimeBeforeCreateGroupFunction
- func (r *Runtime) BeforeDeleteFriends() RuntimeBeforeDeleteFriendsFunction
- func (r *Runtime) BeforeDeleteGroup() RuntimeBeforeDeleteGroupFunction
- func (r *Runtime) BeforeDeleteLeaderboardRecord() RuntimeBeforeDeleteLeaderboardRecordFunction
- func (r *Runtime) BeforeDeleteNotification() RuntimeBeforeDeleteNotificationFunction
- func (r *Runtime) BeforeDeleteStorageObjects() RuntimeBeforeDeleteStorageObjectsFunction
- func (r *Runtime) BeforeDemoteGroupUsers() RuntimeBeforeDemoteGroupUsersFunction
- func (r *Runtime) BeforeEvent() RuntimeBeforeEventFunction
- func (r *Runtime) BeforeGetAccount() RuntimeBeforeGetAccountFunction
- func (r *Runtime) BeforeGetUsers() RuntimeBeforeGetUsersFunction
- func (r *Runtime) BeforeImportFacebookFriends() RuntimeBeforeImportFacebookFriendsFunction
- func (r *Runtime) BeforeImportSteamFriends() RuntimeBeforeImportSteamFriendsFunction
- func (r *Runtime) BeforeJoinGroup() RuntimeBeforeJoinGroupFunction
- func (r *Runtime) BeforeJoinTournament() RuntimeBeforeJoinTournamentFunction
- func (r *Runtime) BeforeKickGroupUsers() RuntimeBeforeKickGroupUsersFunction
- func (r *Runtime) BeforeLeaveGroup() RuntimeBeforeLeaveGroupFunction
- func (r *Runtime) BeforeLinkApple() RuntimeBeforeLinkAppleFunction
- func (r *Runtime) BeforeLinkCustom() RuntimeBeforeLinkCustomFunction
- func (r *Runtime) BeforeLinkDevice() RuntimeBeforeLinkDeviceFunction
- func (r *Runtime) BeforeLinkEmail() RuntimeBeforeLinkEmailFunction
- func (r *Runtime) BeforeLinkFacebook() RuntimeBeforeLinkFacebookFunction
- func (r *Runtime) BeforeLinkFacebookInstantGame() RuntimeBeforeLinkFacebookInstantGameFunction
- func (r *Runtime) BeforeLinkGameCenter() RuntimeBeforeLinkGameCenterFunction
- func (r *Runtime) BeforeLinkGoogle() RuntimeBeforeLinkGoogleFunction
- func (r *Runtime) BeforeLinkSteam() RuntimeBeforeLinkSteamFunction
- func (r *Runtime) BeforeListChannelMessages() RuntimeBeforeListChannelMessagesFunction
- func (r *Runtime) BeforeListFriends() RuntimeBeforeListFriendsFunction
- func (r *Runtime) BeforeListGroupUsers() RuntimeBeforeListGroupUsersFunction
- func (r *Runtime) BeforeListGroups() RuntimeBeforeListGroupsFunction
- func (r *Runtime) BeforeListLeaderboardRecords() RuntimeBeforeListLeaderboardRecordsFunction
- func (r *Runtime) BeforeListLeaderboardRecordsAroundOwner() RuntimeBeforeListLeaderboardRecordsAroundOwnerFunction
- func (r *Runtime) BeforeListMatches() RuntimeBeforeListMatchesFunction
- func (r *Runtime) BeforeListNotifications() RuntimeBeforeListNotificationsFunction
- func (r *Runtime) BeforeListStorageObjects() RuntimeBeforeListStorageObjectsFunction
- func (r *Runtime) BeforeListTournamentRecords() RuntimeBeforeListTournamentRecordsFunction
- func (r *Runtime) BeforeListTournamentRecordsAroundOwner() RuntimeBeforeListTournamentRecordsAroundOwnerFunction
- func (r *Runtime) BeforeListTournaments() RuntimeBeforeListTournamentsFunction
- func (r *Runtime) BeforeListUserGroups() RuntimeBeforeListUserGroupsFunction
- func (r *Runtime) BeforePromoteGroupUsers() RuntimeBeforePromoteGroupUsersFunction
- func (r *Runtime) BeforeReadStorageObjects() RuntimeBeforeReadStorageObjectsFunction
- func (r *Runtime) BeforeRt(id string) RuntimeBeforeRtFunction
- func (r *Runtime) BeforeSessionRefresh() RuntimeBeforeSessionRefreshFunction
- func (r *Runtime) BeforeUnlinkApple() RuntimeBeforeUnlinkAppleFunction
- func (r *Runtime) BeforeUnlinkCustom() RuntimeBeforeUnlinkCustomFunction
- func (r *Runtime) BeforeUnlinkDevice() RuntimeBeforeUnlinkDeviceFunction
- func (r *Runtime) BeforeUnlinkEmail() RuntimeBeforeUnlinkEmailFunction
- func (r *Runtime) BeforeUnlinkFacebook() RuntimeBeforeUnlinkFacebookFunction
- func (r *Runtime) BeforeUnlinkFacebookInstantGame() RuntimeBeforeUnlinkFacebookInstantGameFunction
- func (r *Runtime) BeforeUnlinkGameCenter() RuntimeBeforeUnlinkGameCenterFunction
- func (r *Runtime) BeforeUnlinkGoogle() RuntimeBeforeUnlinkGoogleFunction
- func (r *Runtime) BeforeUnlinkSteam() RuntimeBeforeUnlinkSteamFunction
- func (r *Runtime) BeforeUpdateAccount() RuntimeBeforeUpdateAccountFunction
- func (r *Runtime) BeforeUpdateGroup() RuntimeBeforeUpdateGroupFunction
- func (r *Runtime) BeforeWriteLeaderboardRecord() RuntimeBeforeWriteLeaderboardRecordFunction
- func (r *Runtime) BeforeWriteStorageObjects() RuntimeBeforeWriteStorageObjectsFunction
- func (r *Runtime) BeforeWriteTournamentRecord() RuntimeBeforeWriteTournamentRecordFunction
- func (r *Runtime) Event() RuntimeEventCustomFunction
- func (r *Runtime) EventSessionEnd() RuntimeEventSessionEndFunction
- func (r *Runtime) EventSessionStart() RuntimeEventSessionStartFunction
- func (r *Runtime) LeaderboardReset() RuntimeLeaderboardResetFunction
- func (r *Runtime) MatchCreateFunction() RuntimeMatchCreateFunction
- func (r *Runtime) MatchmakerMatched() RuntimeMatchmakerMatchedFunction
- func (r *Runtime) Rpc(id string) RuntimeRpcFunction
- func (r *Runtime) TournamentEnd() RuntimeTournamentEndFunction
- func (r *Runtime) TournamentReset() RuntimeTournamentResetFunction
- type RuntimeAfterAddFriendsFunction
- type RuntimeAfterAddGroupUsersFunction
- type RuntimeAfterAuthenticateAppleFunction
- type RuntimeAfterAuthenticateCustomFunction
- type RuntimeAfterAuthenticateDeviceFunction
- type RuntimeAfterAuthenticateEmailFunction
- type RuntimeAfterAuthenticateFacebookFunction
- type RuntimeAfterAuthenticateFacebookInstantGameFunction
- type RuntimeAfterAuthenticateGameCenterFunction
- type RuntimeAfterAuthenticateGoogleFunction
- type RuntimeAfterAuthenticateSteamFunction
- type RuntimeAfterBanGroupUsersFunction
- type RuntimeAfterBlockFriendsFunction
- type RuntimeAfterCreateGroupFunction
- type RuntimeAfterDeleteFriendsFunction
- type RuntimeAfterDeleteGroupFunction
- type RuntimeAfterDeleteLeaderboardRecordFunction
- type RuntimeAfterDeleteNotificationFunction
- type RuntimeAfterDeleteStorageObjectsFunction
- type RuntimeAfterDemoteGroupUsersFunction
- type RuntimeAfterEventFunction
- type RuntimeAfterGetAccountFunction
- type RuntimeAfterGetUsersFunction
- type RuntimeAfterImportFacebookFriendsFunction
- type RuntimeAfterImportSteamFriendsFunction
- type RuntimeAfterJoinGroupFunction
- type RuntimeAfterJoinTournamentFunction
- type RuntimeAfterKickGroupUsersFunction
- type RuntimeAfterLeaveGroupFunction
- type RuntimeAfterLinkAppleFunction
- type RuntimeAfterLinkCustomFunction
- type RuntimeAfterLinkDeviceFunction
- type RuntimeAfterLinkEmailFunction
- type RuntimeAfterLinkFacebookFunction
- type RuntimeAfterLinkFacebookInstantGameFunction
- type RuntimeAfterLinkGameCenterFunction
- type RuntimeAfterLinkGoogleFunction
- type RuntimeAfterLinkSteamFunction
- type RuntimeAfterListChannelMessagesFunction
- type RuntimeAfterListFriendsFunction
- type RuntimeAfterListGroupUsersFunction
- type RuntimeAfterListGroupsFunction
- type RuntimeAfterListLeaderboardRecordsAroundOwnerFunction
- type RuntimeAfterListLeaderboardRecordsFunction
- type RuntimeAfterListMatchesFunction
- type RuntimeAfterListNotificationsFunction
- type RuntimeAfterListStorageObjectsFunction
- type RuntimeAfterListTournamentRecordsAroundOwnerFunction
- type RuntimeAfterListTournamentRecordsFunction
- type RuntimeAfterListTournamentsFunction
- type RuntimeAfterListUserGroupsFunction
- type RuntimeAfterPromoteGroupUsersFunction
- type RuntimeAfterReadStorageObjectsFunction
- type RuntimeAfterReqFunctions
- type RuntimeAfterRtFunction
- type RuntimeAfterSessionRefreshFunction
- type RuntimeAfterUnlinkAppleFunction
- type RuntimeAfterUnlinkCustomFunction
- type RuntimeAfterUnlinkDeviceFunction
- type RuntimeAfterUnlinkEmailFunction
- type RuntimeAfterUnlinkFacebookFunction
- type RuntimeAfterUnlinkFacebookInstantGameFunction
- type RuntimeAfterUnlinkGameCenterFunction
- type RuntimeAfterUnlinkGoogleFunction
- type RuntimeAfterUnlinkSteamFunction
- type RuntimeAfterUpdateAccountFunction
- type RuntimeAfterUpdateGroupFunction
- type RuntimeAfterWriteLeaderboardRecordFunction
- type RuntimeAfterWriteStorageObjectsFunction
- type RuntimeAfterWriteTournamentRecordFunction
- type RuntimeBeforeAddFriendsFunction
- type RuntimeBeforeAddGroupUsersFunction
- type RuntimeBeforeAuthenticateAppleFunction
- type RuntimeBeforeAuthenticateCustomFunction
- type RuntimeBeforeAuthenticateDeviceFunction
- type RuntimeBeforeAuthenticateEmailFunction
- type RuntimeBeforeAuthenticateFacebookFunction
- type RuntimeBeforeAuthenticateFacebookInstantGameFunction
- type RuntimeBeforeAuthenticateGameCenterFunction
- type RuntimeBeforeAuthenticateGoogleFunction
- type RuntimeBeforeAuthenticateSteamFunction
- type RuntimeBeforeBanGroupUsersFunction
- type RuntimeBeforeBlockFriendsFunction
- type RuntimeBeforeCreateGroupFunction
- type RuntimeBeforeDeleteFriendsFunction
- type RuntimeBeforeDeleteGroupFunction
- type RuntimeBeforeDeleteLeaderboardRecordFunction
- type RuntimeBeforeDeleteNotificationFunction
- type RuntimeBeforeDeleteStorageObjectsFunction
- type RuntimeBeforeDemoteGroupUsersFunction
- type RuntimeBeforeEventFunction
- type RuntimeBeforeGetAccountFunction
- type RuntimeBeforeGetUsersFunction
- type RuntimeBeforeImportFacebookFriendsFunction
- type RuntimeBeforeImportSteamFriendsFunction
- type RuntimeBeforeJoinGroupFunction
- type RuntimeBeforeJoinTournamentFunction
- type RuntimeBeforeKickGroupUsersFunction
- type RuntimeBeforeLeaveGroupFunction
- type RuntimeBeforeLinkAppleFunction
- type RuntimeBeforeLinkCustomFunction
- type RuntimeBeforeLinkDeviceFunction
- type RuntimeBeforeLinkEmailFunction
- type RuntimeBeforeLinkFacebookFunction
- type RuntimeBeforeLinkFacebookInstantGameFunction
- type RuntimeBeforeLinkGameCenterFunction
- type RuntimeBeforeLinkGoogleFunction
- type RuntimeBeforeLinkSteamFunction
- type RuntimeBeforeListChannelMessagesFunction
- type RuntimeBeforeListFriendsFunction
- type RuntimeBeforeListGroupUsersFunction
- type RuntimeBeforeListGroupsFunction
- type RuntimeBeforeListLeaderboardRecordsAroundOwnerFunction
- type RuntimeBeforeListLeaderboardRecordsFunction
- type RuntimeBeforeListMatchesFunction
- type RuntimeBeforeListNotificationsFunction
- type RuntimeBeforeListStorageObjectsFunction
- type RuntimeBeforeListTournamentRecordsAroundOwnerFunction
- type RuntimeBeforeListTournamentRecordsFunction
- type RuntimeBeforeListTournamentsFunction
- type RuntimeBeforeListUserGroupsFunction
- type RuntimeBeforePromoteGroupUsersFunction
- type RuntimeBeforeReadStorageObjectsFunction
- type RuntimeBeforeReqFunctions
- type RuntimeBeforeRtFunction
- type RuntimeBeforeSessionRefreshFunction
- type RuntimeBeforeUnlinkAppleFunction
- type RuntimeBeforeUnlinkCustomFunction
- type RuntimeBeforeUnlinkDeviceFunction
- type RuntimeBeforeUnlinkEmailFunction
- type RuntimeBeforeUnlinkFacebookFunction
- type RuntimeBeforeUnlinkFacebookInstantGameFunction
- type RuntimeBeforeUnlinkGameCenterFunction
- type RuntimeBeforeUnlinkGoogleFunction
- type RuntimeBeforeUnlinkSteamFunction
- type RuntimeBeforeUpdateAccountFunction
- type RuntimeBeforeUpdateGroupFunction
- type RuntimeBeforeWriteLeaderboardRecordFunction
- type RuntimeBeforeWriteStorageObjectsFunction
- type RuntimeBeforeWriteTournamentRecordFunction
- type RuntimeConfig
- type RuntimeEventCustomFunction
- type RuntimeEventFunction
- type RuntimeEventFunctions
- type RuntimeEventQueue
- type RuntimeEventSessionEndFunction
- type RuntimeEventSessionStartFunction
- type RuntimeExecutionMode
- type RuntimeGoInitializer
- func (ri *RuntimeGoInitializer) RegisterAfterAddFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterAddGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateCustom(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateDevice(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateEmail(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateFacebook(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateFacebookInstantGame(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateGameCenter(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateSteam(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterBanGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterBlockFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterCreateGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterDeleteFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterDeleteGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterDeleteLeaderboardRecord(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterDeleteNotification(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterDeleteStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterDemoteGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterEvent(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterGetAccount(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterGetUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterImportFacebookFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterImportSteamFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterJoinGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterJoinTournament(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterKickGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterLeaveGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterLinkApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterLinkCustom(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterLinkDevice(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterLinkEmail(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterLinkFacebook(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterLinkFacebookInstantGame(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterLinkGameCenter(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterLinkGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterLinkSteam(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterListChannelMessages(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterListFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterListGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterListGroups(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterListLeaderboardRecords(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterListLeaderboardRecordsAroundOwner(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterListMatches(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterListNotifications(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterListStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterListTournamentRecords(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterListTournamentRecordsAroundOwner(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterListTournaments(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterListUserGroups(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterPromoteGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterReadStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterRt(id string, ...) error
- func (ri *RuntimeGoInitializer) RegisterAfterSessionRefresh(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterUnlinkApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterUnlinkCustom(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterUnlinkDevice(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterUnlinkEmail(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterUnlinkFacebook(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterUnlinkFacebookInstantGame(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterUnlinkGameCenter(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterUnlinkGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterUnlinkSteam(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterUpdateAccount(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterUpdateGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterWriteLeaderboardRecord(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterWriteStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterAfterWriteTournamentRecord(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterBeforeAddFriends(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeAddGroupUsers(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateApple(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateCustom(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateDevice(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateEmail(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateFacebook(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateFacebookInstantGame(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateGameCenter(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateGoogle(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateSteam(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeBanGroupUsers(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeBlockFriends(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeCreateGroup(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeDeleteFriends(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeDeleteGroup(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeDeleteLeaderboardRecord(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeDeleteNotification(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeDeleteStorageObjects(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeDemoteGroupUsers(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeEvent(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeGetAccount(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterBeforeGetUsers(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeImportFacebookFriends(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeImportSteamFriends(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeJoinGroup(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeJoinTournament(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeKickGroupUsers(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeLeaveGroup(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeLinkApple(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeLinkCustom(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeLinkDevice(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeLinkEmail(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeLinkFacebook(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeLinkFacebookInstantGame(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeLinkGameCenter(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeLinkGoogle(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeLinkSteam(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeListChannelMessages(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeListFriends(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeListGroupUsers(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeListGroups(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeListLeaderboardRecords(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeListLeaderboardRecordsAroundOwner(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeListMatches(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeListNotifications(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeListStorageObjects(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeListTournamentRecords(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeListTournamentRecordsAroundOwner(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeListTournaments(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeListUserGroups(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforePromoteGroupUsers(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeReadStorageObjects(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeRt(id string, ...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeSessionRefresh(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkApple(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkCustom(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkDevice(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkEmail(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkFacebook(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkFacebookInstantGame(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkGameCenter(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkGoogle(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkSteam(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeUpdateAccount(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeUpdateGroup(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeWriteLeaderboardRecord(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeWriteStorageObjects(...) error
- func (ri *RuntimeGoInitializer) RegisterBeforeWriteTournamentRecord(...) error
- func (ri *RuntimeGoInitializer) RegisterEvent(fn func(ctx context.Context, logger runtime.Logger, evt *api.Event)) error
- func (ri *RuntimeGoInitializer) RegisterEventSessionEnd(fn func(ctx context.Context, logger runtime.Logger, evt *api.Event)) error
- func (ri *RuntimeGoInitializer) RegisterEventSessionStart(fn func(ctx context.Context, logger runtime.Logger, evt *api.Event)) error
- func (ri *RuntimeGoInitializer) RegisterLeaderboardReset(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterMatch(name string, ...) error
- func (ri *RuntimeGoInitializer) RegisterMatchmakerMatched(...) error
- func (ri *RuntimeGoInitializer) RegisterRpc(id string, ...) error
- func (ri *RuntimeGoInitializer) RegisterTournamentEnd(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- func (ri *RuntimeGoInitializer) RegisterTournamentReset(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, ...) error) error
- type RuntimeGoLogger
- func (l *RuntimeGoLogger) Debug(format string, v ...interface{})
- func (l *RuntimeGoLogger) Error(format string, v ...interface{})
- func (l *RuntimeGoLogger) Fields() map[string]interface{}
- func (l *RuntimeGoLogger) Info(format string, v ...interface{})
- func (l *RuntimeGoLogger) Warn(format string, v ...interface{})
- func (l *RuntimeGoLogger) WithField(key string, v interface{}) nkruntime.Logger
- func (l *RuntimeGoLogger) WithFields(fields map[string]interface{}) nkruntime.Logger
- type RuntimeGoMatchCore
- func (r *RuntimeGoMatchCore) BroadcastMessage(opCode int64, data []byte, presences []runtime.Presence, ...) error
- func (r *RuntimeGoMatchCore) BroadcastMessageDeferred(opCode int64, data []byte, presences []runtime.Presence, ...) error
- func (r *RuntimeGoMatchCore) Cancel()
- func (r *RuntimeGoMatchCore) GetState(state interface{}) (string, error)
- func (r *RuntimeGoMatchCore) HandlerName() string
- func (r *RuntimeGoMatchCore) Label() string
- func (r *RuntimeGoMatchCore) MatchInit(presenceList *MatchPresenceList, ...) (interface{}, int, error)
- func (r *RuntimeGoMatchCore) MatchJoin(tick int64, state interface{}, joins []*MatchPresence) (interface{}, error)
- func (r *RuntimeGoMatchCore) MatchJoinAttempt(tick int64, state interface{}, userID, sessionID uuid.UUID, username string, ...) (interface{}, bool, string, error)
- func (r *RuntimeGoMatchCore) MatchKick(presences []runtime.Presence) error
- func (r *RuntimeGoMatchCore) MatchLabelUpdate(label string) error
- func (r *RuntimeGoMatchCore) MatchLeave(tick int64, state interface{}, leaves []*MatchPresence) (interface{}, error)
- func (r *RuntimeGoMatchCore) MatchLoop(tick int64, state interface{}, inputCh <-chan *MatchDataMessage) (interface{}, error)
- func (r *RuntimeGoMatchCore) MatchTerminate(tick int64, state interface{}, graceSeconds int) (interface{}, error)
- type RuntimeGoNakamaModule
- func (n *RuntimeGoNakamaModule) AccountDeleteId(ctx context.Context, userID string, recorded bool) error
- func (n *RuntimeGoNakamaModule) AccountExportId(ctx context.Context, userID string) (string, error)
- func (n *RuntimeGoNakamaModule) AccountGetId(ctx context.Context, userID string) (*api.Account, error)
- func (n *RuntimeGoNakamaModule) AccountUpdateId(ctx context.Context, userID, username string, metadata map[string]interface{}, ...) error
- func (n *RuntimeGoNakamaModule) AccountsGetId(ctx context.Context, userIDs []string) ([]*api.Account, error)
- func (n *RuntimeGoNakamaModule) AuthenticateApple(ctx context.Context, token, username string, create bool) (string, string, bool, error)
- func (n *RuntimeGoNakamaModule) AuthenticateCustom(ctx context.Context, id, username string, create bool) (string, string, bool, error)
- func (n *RuntimeGoNakamaModule) AuthenticateDevice(ctx context.Context, id, username string, create bool) (string, string, bool, error)
- func (n *RuntimeGoNakamaModule) AuthenticateEmail(ctx context.Context, email, password, username string, create bool) (string, string, bool, error)
- func (n *RuntimeGoNakamaModule) AuthenticateFacebook(ctx context.Context, token string, importFriends bool, username string, ...) (string, string, bool, error)
- func (n *RuntimeGoNakamaModule) AuthenticateFacebookInstantGame(ctx context.Context, signedPlayerInfo string, username string, create bool) (string, string, bool, error)
- func (n *RuntimeGoNakamaModule) AuthenticateGameCenter(ctx context.Context, playerID, bundleID string, timestamp int64, ...) (string, string, bool, error)
- func (n *RuntimeGoNakamaModule) AuthenticateGoogle(ctx context.Context, token, username string, create bool) (string, string, bool, error)
- func (n *RuntimeGoNakamaModule) AuthenticateSteam(ctx context.Context, token, username string, create bool) (string, string, bool, error)
- func (n *RuntimeGoNakamaModule) AuthenticateTokenGenerate(userID, username string, exp int64, vars map[string]string) (string, int64, error)
- func (n *RuntimeGoNakamaModule) Event(ctx context.Context, evt *api.Event) error
- func (n *RuntimeGoNakamaModule) FriendsList(ctx context.Context, userID string, limit int, state *int, cursor string) ([]*api.Friend, string, error)
- func (n *RuntimeGoNakamaModule) GroupCreate(ctx context.Context, ...) (*api.Group, error)
- func (n *RuntimeGoNakamaModule) GroupDelete(ctx context.Context, id string) error
- func (n *RuntimeGoNakamaModule) GroupUpdate(ctx context.Context, ...) error
- func (n *RuntimeGoNakamaModule) GroupUserJoin(ctx context.Context, groupID, userID, username string) error
- func (n *RuntimeGoNakamaModule) GroupUserLeave(ctx context.Context, groupID, userID, username string) error
- func (n *RuntimeGoNakamaModule) GroupUsersAdd(ctx context.Context, groupID string, userIDs []string) error
- func (n *RuntimeGoNakamaModule) GroupUsersDemote(ctx context.Context, groupID string, userIDs []string) error
- func (n *RuntimeGoNakamaModule) GroupUsersKick(ctx context.Context, groupID string, userIDs []string) error
- func (n *RuntimeGoNakamaModule) GroupUsersList(ctx context.Context, id string, limit int, state *int, cursor string) ([]*api.GroupUserList_GroupUser, string, error)
- func (n *RuntimeGoNakamaModule) GroupUsersPromote(ctx context.Context, groupID string, userIDs []string) error
- func (n *RuntimeGoNakamaModule) GroupsGetId(ctx context.Context, groupIDs []string) ([]*api.Group, error)
- func (n *RuntimeGoNakamaModule) LeaderboardCreate(ctx context.Context, id string, authoritative bool, ...) error
- func (n *RuntimeGoNakamaModule) LeaderboardDelete(ctx context.Context, id string) error
- func (n *RuntimeGoNakamaModule) LeaderboardRecordDelete(ctx context.Context, id, ownerID string) error
- func (n *RuntimeGoNakamaModule) LeaderboardRecordWrite(ctx context.Context, id, ownerID, username string, score, subscore int64, ...) (*api.LeaderboardRecord, error)
- func (n *RuntimeGoNakamaModule) LeaderboardRecordsList(ctx context.Context, id string, ownerIDs []string, limit int, cursor string, ...) ([]*api.LeaderboardRecord, []*api.LeaderboardRecord, string, string, error)
- func (n *RuntimeGoNakamaModule) LinkApple(ctx context.Context, userID, token string) error
- func (n *RuntimeGoNakamaModule) LinkCustom(ctx context.Context, userID, customID string) error
- func (n *RuntimeGoNakamaModule) LinkDevice(ctx context.Context, userID, deviceID string) error
- func (n *RuntimeGoNakamaModule) LinkEmail(ctx context.Context, userID, email, password string) error
- func (n *RuntimeGoNakamaModule) LinkFacebook(ctx context.Context, userID, username, token string, importFriends bool) error
- func (n *RuntimeGoNakamaModule) LinkFacebookInstantGame(ctx context.Context, userID, signedPlayerInfo string) error
- func (n *RuntimeGoNakamaModule) LinkGameCenter(ctx context.Context, userID, playerID, bundleID string, timestamp int64, ...) error
- func (n *RuntimeGoNakamaModule) LinkGoogle(ctx context.Context, userID, token string) error
- func (n *RuntimeGoNakamaModule) LinkSteam(ctx context.Context, userID, username, token string, importFriends bool) error
- func (n *RuntimeGoNakamaModule) MatchCreate(ctx context.Context, module string, params map[string]interface{}) (string, error)
- func (n *RuntimeGoNakamaModule) MatchGet(ctx context.Context, id string) (*api.Match, error)
- func (n *RuntimeGoNakamaModule) MatchList(ctx context.Context, limit int, authoritative bool, label string, ...) ([]*api.Match, error)
- func (n *RuntimeGoNakamaModule) MultiUpdate(ctx context.Context, accountUpdates []*runtime.AccountUpdate, ...) ([]*api.StorageObjectAck, []*runtime.WalletUpdateResult, error)
- func (n *RuntimeGoNakamaModule) NotificationSend(ctx context.Context, userID, subject string, content map[string]interface{}, ...) error
- func (n *RuntimeGoNakamaModule) NotificationsSend(ctx context.Context, notifications []*runtime.NotificationSend) error
- func (n *RuntimeGoNakamaModule) ReadFile(relPath string) (*os.File, error)
- func (n *RuntimeGoNakamaModule) SessionDisconnect(ctx context.Context, sessionID string) error
- func (n *RuntimeGoNakamaModule) SetEventFn(fn RuntimeEventCustomFunction)
- func (n *RuntimeGoNakamaModule) StorageDelete(ctx context.Context, deletes []*runtime.StorageDelete) error
- func (n *RuntimeGoNakamaModule) StorageList(ctx context.Context, userID, collection string, limit int, cursor string) ([]*api.StorageObject, string, error)
- func (n *RuntimeGoNakamaModule) StorageRead(ctx context.Context, reads []*runtime.StorageRead) ([]*api.StorageObject, error)
- func (n *RuntimeGoNakamaModule) StorageWrite(ctx context.Context, writes []*runtime.StorageWrite) ([]*api.StorageObjectAck, error)
- func (n *RuntimeGoNakamaModule) StreamClose(mode uint8, subject, subcontext, label string) error
- func (n *RuntimeGoNakamaModule) StreamCount(mode uint8, subject, subcontext, label string) (int, error)
- func (n *RuntimeGoNakamaModule) StreamSend(mode uint8, subject, subcontext, label, data string, ...) error
- func (n *RuntimeGoNakamaModule) StreamSendRaw(mode uint8, subject, subcontext, label string, msg *rtapi.Envelope, ...) error
- func (n *RuntimeGoNakamaModule) StreamUserGet(mode uint8, subject, subcontext, label, userID, sessionID string) (runtime.PresenceMeta, error)
- func (n *RuntimeGoNakamaModule) StreamUserJoin(mode uint8, subject, subcontext, label, userID, sessionID string, ...) (bool, error)
- func (n *RuntimeGoNakamaModule) StreamUserKick(mode uint8, subject, subcontext, label string, presence runtime.Presence) error
- func (n *RuntimeGoNakamaModule) StreamUserLeave(mode uint8, subject, subcontext, label, userID, sessionID string) error
- func (n *RuntimeGoNakamaModule) StreamUserList(mode uint8, subject, subcontext, label string, ...) ([]runtime.Presence, error)
- func (n *RuntimeGoNakamaModule) StreamUserUpdate(mode uint8, subject, subcontext, label, userID, sessionID string, ...) error
- func (n *RuntimeGoNakamaModule) TournamentAddAttempt(ctx context.Context, id, ownerID string, count int) error
- func (n *RuntimeGoNakamaModule) TournamentCreate(ctx context.Context, id string, sortOrder, operator, resetSchedule string, ...) error
- func (n *RuntimeGoNakamaModule) TournamentDelete(ctx context.Context, id string) error
- func (n *RuntimeGoNakamaModule) TournamentJoin(ctx context.Context, id, ownerID, username string) error
- func (n *RuntimeGoNakamaModule) TournamentList(ctx context.Context, categoryStart, categoryEnd, startTime, endTime, limit int, ...) (*api.TournamentList, error)
- func (n *RuntimeGoNakamaModule) TournamentRecordWrite(ctx context.Context, id, ownerID, username string, score, subscore int64, ...) (*api.LeaderboardRecord, error)
- func (n *RuntimeGoNakamaModule) TournamentRecordsHaystack(ctx context.Context, id, ownerID string, limit int, expiry int64) ([]*api.LeaderboardRecord, error)
- func (n *RuntimeGoNakamaModule) TournamentRecordsList(ctx context.Context, tournamentId string, ownerIDs []string, limit int, ...) ([]*api.LeaderboardRecord, []*api.LeaderboardRecord, string, string, error)
- func (n *RuntimeGoNakamaModule) TournamentsGetId(ctx context.Context, tournamentIDs []string) ([]*api.Tournament, error)
- func (n *RuntimeGoNakamaModule) UnlinkApple(ctx context.Context, userID, token string) error
- func (n *RuntimeGoNakamaModule) UnlinkCustom(ctx context.Context, userID, customID string) error
- func (n *RuntimeGoNakamaModule) UnlinkDevice(ctx context.Context, userID, deviceID string) error
- func (n *RuntimeGoNakamaModule) UnlinkEmail(ctx context.Context, userID, email string) error
- func (n *RuntimeGoNakamaModule) UnlinkFacebook(ctx context.Context, userID, token string) error
- func (n *RuntimeGoNakamaModule) UnlinkFacebookInstantGame(ctx context.Context, userID, signedPlayerInfo string) error
- func (n *RuntimeGoNakamaModule) UnlinkGameCenter(ctx context.Context, userID, playerID, bundleID string, timestamp int64, ...) error
- func (n *RuntimeGoNakamaModule) UnlinkGoogle(ctx context.Context, userID, token string) error
- func (n *RuntimeGoNakamaModule) UnlinkSteam(ctx context.Context, userID, token string) error
- func (n *RuntimeGoNakamaModule) UserGroupsList(ctx context.Context, userID string, limit int, state *int, cursor string) ([]*api.UserGroupList_UserGroup, string, error)
- func (n *RuntimeGoNakamaModule) UsersBanId(ctx context.Context, userIDs []string) error
- func (n *RuntimeGoNakamaModule) UsersGetId(ctx context.Context, userIDs []string) ([]*api.User, error)
- func (n *RuntimeGoNakamaModule) UsersGetUsername(ctx context.Context, usernames []string) ([]*api.User, error)
- func (n *RuntimeGoNakamaModule) UsersUnbanId(ctx context.Context, userIDs []string) error
- func (n *RuntimeGoNakamaModule) WalletLedgerList(ctx context.Context, userID string, limit int, cursor string) ([]runtime.WalletLedgerItem, string, error)
- func (n *RuntimeGoNakamaModule) WalletLedgerUpdate(ctx context.Context, itemID string, metadata map[string]interface{}) (runtime.WalletLedgerItem, error)
- func (n *RuntimeGoNakamaModule) WalletUpdate(ctx context.Context, userID string, changeset map[string]int64, ...) (map[string]int64, map[string]int64, error)
- func (n *RuntimeGoNakamaModule) WalletsUpdate(ctx context.Context, updates []*runtime.WalletUpdate, updateLedger bool) ([]*runtime.WalletUpdateResult, error)
- type RuntimeInfo
- type RuntimeJS
- type RuntimeJSModule
- type RuntimeJSModuleCache
- type RuntimeJavaScriptMatchCore
- func (rm *RuntimeJavaScriptMatchCore) Cancel()
- func (rm *RuntimeJavaScriptMatchCore) GetState(state interface{}) (string, error)
- func (rm *RuntimeJavaScriptMatchCore) HandlerName() string
- func (rm *RuntimeJavaScriptMatchCore) Label() string
- func (rm *RuntimeJavaScriptMatchCore) MatchInit(presenceList *MatchPresenceList, ...) (interface{}, int, error)
- func (rm *RuntimeJavaScriptMatchCore) MatchJoin(tick int64, state interface{}, joins []*MatchPresence) (interface{}, error)
- func (rm *RuntimeJavaScriptMatchCore) MatchJoinAttempt(tick int64, state interface{}, userID, sessionID uuid.UUID, username string, ...) (interface{}, bool, string, error)
- func (rm *RuntimeJavaScriptMatchCore) MatchLeave(tick int64, state interface{}, leaves []*MatchPresence) (interface{}, error)
- func (rm *RuntimeJavaScriptMatchCore) MatchLoop(tick int64, state interface{}, inputCh <-chan *MatchDataMessage) (interface{}, error)
- func (rm *RuntimeJavaScriptMatchCore) MatchTerminate(tick int64, state interface{}, graceSeconds int) (interface{}, error)
- type RuntimeJavascriptCallbacks
- type RuntimeJavascriptInitModule
- type RuntimeJavascriptLocalCache
- type RuntimeJavascriptMatchHandlers
- type RuntimeLeaderboardResetFunction
- type RuntimeLua
- type RuntimeLuaCallbacks
- type RuntimeLuaLocalCache
- type RuntimeLuaMatchCore
- func (r *RuntimeLuaMatchCore) Cancel()
- func (r *RuntimeLuaMatchCore) GetState(state interface{}) (string, error)
- func (r *RuntimeLuaMatchCore) HandlerName() string
- func (r *RuntimeLuaMatchCore) Label() string
- func (r *RuntimeLuaMatchCore) MatchInit(presenceList *MatchPresenceList, ...) (interface{}, int, error)
- func (r *RuntimeLuaMatchCore) MatchJoin(tick int64, state interface{}, joins []*MatchPresence) (interface{}, error)
- func (r *RuntimeLuaMatchCore) MatchJoinAttempt(tick int64, state interface{}, userID, sessionID uuid.UUID, username string, ...) (interface{}, bool, string, error)
- func (r *RuntimeLuaMatchCore) MatchLeave(tick int64, state interface{}, leaves []*MatchPresence) (interface{}, error)
- func (r *RuntimeLuaMatchCore) MatchLoop(tick int64, state interface{}, inputCh <-chan *MatchDataMessage) (interface{}, error)
- func (r *RuntimeLuaMatchCore) MatchTerminate(tick int64, state interface{}, graceSeconds int) (interface{}, error)
- type RuntimeLuaModule
- type RuntimeLuaModuleCache
- type RuntimeLuaNakamaModule
- type RuntimeMatchCore
- func NewRuntimeGoMatchCore(logger *zap.Logger, module string, matchRegistry MatchRegistry, ...) (RuntimeMatchCore, error)
- func NewRuntimeJavascriptMatchCore(logger *zap.Logger, module string, db *sql.DB, ...) (RuntimeMatchCore, error)
- func NewRuntimeLuaMatchCore(logger *zap.Logger, module string, db *sql.DB, ...) (RuntimeMatchCore, error)
- type RuntimeMatchCreateFunction
- type RuntimeMatchDeferMessageFunction
- type RuntimeMatchmakerMatchedFunction
- type RuntimeProviderJS
- func (rp *RuntimeProviderJS) AfterReq(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) error
- func (rp *RuntimeProviderJS) AfterRt(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) error
- func (rp *RuntimeProviderJS) BeforeReq(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) (interface{}, error, codes.Code)
- func (rp *RuntimeProviderJS) BeforeRt(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) (*rtapi.Envelope, error)
- func (rp *RuntimeProviderJS) Get(ctx context.Context) (*RuntimeJS, error)
- func (rp *RuntimeProviderJS) LeaderboardReset(ctx context.Context, leaderboard runtime.Leaderboard, reset int64) error
- func (rp *RuntimeProviderJS) MatchmakerMatched(ctx context.Context, entries []*MatchmakerEntry) (string, bool, error)
- func (rp *RuntimeProviderJS) Put(r *RuntimeJS)
- func (rp *RuntimeProviderJS) Rpc(ctx context.Context, id string, queryParams map[string][]string, ...) (string, error, codes.Code)
- func (rp *RuntimeProviderJS) TournamentEnd(ctx context.Context, tournament *api.Tournament, end, reset int64) error
- func (rp *RuntimeProviderJS) TournamentReset(ctx context.Context, tournament *api.Tournament, end, reset int64) error
- type RuntimeProviderLua
- func (rp *RuntimeProviderLua) AfterReq(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) error
- func (rp *RuntimeProviderLua) AfterRt(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) error
- func (rp *RuntimeProviderLua) BeforeReq(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) (interface{}, error, codes.Code)
- func (rp *RuntimeProviderLua) BeforeRt(ctx context.Context, id string, logger *zap.Logger, userID, username string, ...) (*rtapi.Envelope, error)
- func (rp *RuntimeProviderLua) Get(ctx context.Context) (*RuntimeLua, error)
- func (rp *RuntimeProviderLua) LeaderboardReset(ctx context.Context, leaderboard runtime.Leaderboard, reset int64) error
- func (rp *RuntimeProviderLua) MatchmakerMatched(ctx context.Context, entries []*MatchmakerEntry) (string, bool, error)
- func (rp *RuntimeProviderLua) Put(r *RuntimeLua)
- func (rp *RuntimeProviderLua) Rpc(ctx context.Context, id string, queryParams map[string][]string, ...) (string, error, codes.Code)
- func (rp *RuntimeProviderLua) TournamentEnd(ctx context.Context, tournament *api.Tournament, end, reset int64) error
- func (rp *RuntimeProviderLua) TournamentReset(ctx context.Context, tournament *api.Tournament, end, reset int64) error
- type RuntimeRpcFunction
- type RuntimeTournamentEndFunction
- type RuntimeTournamentResetFunction
- type Scannable
- type Session
- type SessionConfig
- type SessionFormat
- type SessionRegistry
- type SessionTokenClaims
- type SocialConfig
- type SocialConfigApple
- type SocialConfigFacebookInstantGame
- type SocialConfigSteam
- type SocketConfig
- type StatusHandler
- type StorageOpDelete
- type StorageOpDeletes
- type StorageOpWrite
- type StorageOpWrites
- type StreamManager
- type TournamentListCursor
- type Tracker
- type TrackerConfig
- type TrackerOp
- type Tx
- type TxnRestartError
Constants ¶
View Source
const ( NotificationCodeDmRequest int32 = -1 NotificationCodeFriendRequest int32 = -2 NotificationCodeFriendAccept int32 = -3 NotificationCodeGroupAdd int32 = -4 NotificationCodeGroupJoinRequest int32 = -5 NotificationCodeFriendJoinGame int32 = -6 )
View Source
const ( LeaderboardSortOrderAscending = iota LeaderboardSortOrderDescending )
View Source
const ( LeaderboardOperatorBest = iota LeaderboardOperatorSet LeaderboardOperatorIncrement )
View Source
const ( ChannelMessageTypeChat int32 = iota ChannelMessageTypeChatUpdate ChannelMessageTypeChatRemove ChannelMessageTypeGroupJoin ChannelMessageTypeGroupAdd ChannelMessageTypeGroupLeave ChannelMessageTypeGroupKick ChannelMessageTypeGroupPromote ChannelMessageTypeGroupBan ChannelMessageTypeGroupDemote )
View Source
const ( MatchInit MatchFnId = "matchInit" MatchJoinAttempt = "matchJoinAttempt" MatchJoin = "matchJoin" MatchLeave = "matchLeave" MatchLoop = "matchLoop" MatchTerminate = "matchTerminate" )
View Source
const ( StreamModeNotifications uint8 = iota StreamModeStatus StreamModeChannel StreamModeGroup StreamModeDM StreamModeMatchRelayed StreamModeMatchAuthoritative StreamModeParty )
View Source
const API_PREFIX = "/nakama.api.Nakama/"
View Source
const INIT_MODULE_FN_NAME = "InitModule"
View Source
const JsEntrypointFilename = "index.js"
View Source
const LTSentinel = lua.LValueType(-1)
View Source
const ObfuscationString = "REDACTED"
View Source
const RTAPI_PREFIX = "*rtapi.Envelope_"
Variables ¶
View Source
var ( ErrChannelIDInvalid = errors.New("invalid channel id") ErrChannelCursorInvalid = errors.New("invalid channel cursor") ErrChannelGroupNotFound = errors.New("group not found") )
View Source
var ( ErrGroupNameInUse = errors.New("group name in use") ErrGroupPermissionDenied = errors.New("group permission denied") ErrGroupNoUpdateOps = errors.New("no group updates") ErrGroupNotUpdated = errors.New("group not updated") ErrGroupNotFound = errors.New("group not found") ErrGroupFull = errors.New("group is full") ErrGroupUserNotFound = errors.New("user not found") ErrGroupLastSuperadmin = errors.New("user is last group superadmin") ErrGroupUserInvalidCursor = errors.New("group user cursor invalid") ErrUserGroupInvalidCursor = errors.New("user group cursor invalid") )
View Source
var ( ErrLeaderboardNotFound = errors.New("leaderboard not found") ErrLeaderboardAuthoritative = errors.New("leaderboard only allows authoritative submissions") ErrLeaderboardInvalidCursor = errors.New("leaderboard cursor invalid") )
View Source
var ( ErrStorageRejectedVersion = errors.New("Storage write rejected - version check failed.") ErrStorageRejectedPermission = errors.New("Storage write rejected - permission denied.") )
View Source
var ( ErrTournamentNotFound = errors.New("tournament not found") ErrTournamentMaxSizeReached = errors.New("tournament max size reached") ErrTournamentOutsideDuration = errors.New("tournament outside of duration") ErrTournamentWriteMaxNumScoreReached = errors.New("max number score count reached") ErrTournamentWriteJoinRequired = errors.New("required to join before writing tournament record") )
View Source
var ( MatchFilterValue = uint8(0) MatchFilterPtr = &MatchFilterValue MatchFilterRelayed = map[uint8]*uint8{StreamModeMatchRelayed: MatchFilterPtr} MatchLabelMaxBytes = 2048 ErrCannotEncodeParams = errors.New("error creating match: cannot encode params") ErrMatchIdInvalid = errors.New("match id invalid") ErrMatchNotFound = errors.New("match not found") ErrMatchStateFailed = errors.New("match did not return state") ErrMatchLabelTooLong = errors.New("match label too long, must be 0-2048 bytes") ErrDeferredBroadcastFull = errors.New("too many deferred message broadcasts per tick") )
View Source
var ( ErrMatchmakerQueryInvalid = errors.New("matchmaker query invalid") ErrMatchmakerDuplicateSession = errors.New("matchmaker duplicate session") ErrMatchmakerIndex = errors.New("matchmaker index error") ErrMatchmakerDelete = errors.New("matchmaker delete error") ErrMatchmakerNotAvailable = errors.New("matchmaker not available") ErrMatchmakerTooManyTickets = errors.New("matchmaker too many tickets") ErrMatchmakerTicketNotFound = errors.New("matchmaker ticket not found") )
View Source
var ( ErrPartyClosed = errors.New("party closed") ErrPartyFull = errors.New("party full") ErrPartyJoinRequestsFull = errors.New("party join requests full") ErrPartyNotLeader = errors.New("party leader only") ErrPartyNotMember = errors.New("party member not found") ErrPartyNotRequest = errors.New("party join request not found") ErrPartyAcceptRequest = errors.New("party could not accept request") ErrPartyRemove = errors.New("party could not remove") ErrPartyRemoveSelf = errors.New("party cannot remove self") )
View Source
var ( Bit32LibName = "bit32" Bit32Default64 = int64(math.Pow(2, 32) - 1) )
View Source
var ( ErrNodeNotFound = errors.New("node not found") ErrSessionNotFound = errors.New("session not found") )
View Source
var ErrAccountNotFound = errors.New("account not found")
View Source
var ErrChannelMessageUpdateNotFound = errors.New("channel message not found")
View Source
var ErrFriendInvalidCursor = errors.New("friend cursor invalid")
View Source
var ErrMatchStopped = errors.New("match stopped")
View Source
var ErrPartyNotFound = errors.New("party not found")
View Source
var ErrRowsAffectedCount = errors.New("rows_affected_count")
View Source
var (
ErrRuntimeRPCNotFound = errors.New("RPC function not found")
)
View Source
var ErrSessionQueueFull = errors.New("session outgoing queue full")
View Source
var ErrWalletLedgerInvalidCursor = errors.New("wallet ledger cursor invalid")
View Source
var LSentinel = lua.LValue(&LSentinelType{})
Functions ¶
func AddFriends ¶
func AddGroupUsers ¶
func AuthenticateApple ¶
func AuthenticateCustom ¶
func AuthenticateDevice ¶
func AuthenticateEmail ¶
func AuthenticateFacebook ¶
func AuthenticateGameCenter ¶
func AuthenticateGoogle ¶
func AuthenticateSteam ¶
func AuthenticateUsername ¶
func BanGroupUsers ¶
func BlockFriends ¶
func ChannelMessagesList ¶
func CheckRuntimeProviderGo ¶
func CheckRuntimeProviderLua ¶
func CreateGroup ¶
func DeleteAccount ¶
func DeleteFriends ¶
func DeleteGroup ¶
func DemoteGroupUsers ¶
func ExecuteInTx ¶
ExecuteInTx runs fn inside tx which should already have begun. *WARNING*: Do not execute any statements on the supplied tx before calling this function. ExecuteInTx will only retry statements that are performed within the supplied closure (fn). Any statements performed on the tx before ExecuteInTx is invoked will *not* be re-run if the transaction needs to be retried.
fn is subject to the same restrictions as the fn passed to ExecuteTx.
func ExecuteRetryable ¶
Retry functions that perform non-transactional database operations.
func ExportAccount ¶
func GetAccount ¶
func GetAccounts ¶
func GetChannelMessages ¶
func GetFriendIDs ¶
func GetFriendIDs(ctx context.Context, logger *zap.Logger, db *sql.DB, userID uuid.UUID) (*api.FriendList, error)
Only used to get all friend IDs for the console. NOTE: Not intended for use in client/runtime APIs.
func GroupDeleteAll ¶
func HashFromId ¶
func KickGroupUsers ¶
func LeaderboardRecordDelete ¶
func LeaderboardRecordWrite ¶
func LeaderboardRecordsList ¶
func LeaderboardRecordsList(ctx context.Context, logger *zap.Logger, db *sql.DB, leaderboardCache LeaderboardCache, rankCache LeaderboardRankCache, leaderboardId string, limit *wrappers.Int32Value, cursor string, ownerIds []string, overrideExpiry int64) (*api.LeaderboardRecordList, error)
func LeaveGroup ¶
func LinkCustom ¶
func LinkDevice ¶
func LinkFacebook ¶
func LinkFacebookInstantGame ¶
func LinkGameCenter ¶
func LinkGoogle ¶
func ListFriends ¶
func ListGroupUsers ¶
func ListGroups ¶
func ListUserGroups ¶
func ListWalletLedger ¶
func MultiUpdate ¶
func MultiUpdate(ctx context.Context, logger *zap.Logger, db *sql.DB, accountUpdates []*accountUpdate, storageWrites StorageOpWrites, walletUpdates []*walletUpdate, updateLedger bool) ([]*api.StorageObjectAck, []*runtime.WalletUpdateResult, error)
func NewConfig ¶
NewConfig constructs a Config struct which represents server settings, and populates it with default values.
func NewJSONFileLogger ¶
func NewJSONLogger ¶
func NewJsLogger ¶
func NewRuntime ¶
func NewRuntime(logger, startupLogger *zap.Logger, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, jsonpbUnmarshaler *jsonpb.Unmarshaler, config Config, socialClient *social.Client, leaderboardCache LeaderboardCache, leaderboardRankCache LeaderboardRankCache, leaderboardScheduler LeaderboardScheduler, sessionRegistry SessionRegistry, matchRegistry MatchRegistry, tracker Tracker, metrics *Metrics, streamManager StreamManager, router MessageRouter) (*Runtime, *RuntimeInfo, error)
func NewRuntimeGoContext ¶
func NewRuntimeJavascriptNakamaModule ¶
func NewRuntimeJavascriptNakamaModule(logger *zap.Logger, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, jsonpbUnmarshaler *jsonpb.Unmarshaler, config Config, socialClient *social.Client, leaderboardCache LeaderboardCache, rankCache LeaderboardRankCache, localCache *RuntimeJavascriptLocalCache, leaderboardScheduler LeaderboardScheduler, sessionRegistry SessionRegistry, matchRegistry MatchRegistry, tracker Tracker, streamManager StreamManager, router MessageRouter, eventFn RuntimeEventCustomFunction, matchCreateFn RuntimeMatchCreateFunction) *runtimeJavascriptNakamaModule
func NewRuntimeJsContext ¶
func NewRuntimeJsInitContext ¶
func NewRuntimeLuaContext ¶
func NewRuntimeProviderGo ¶
func NewRuntimeProviderGo(logger, startupLogger *zap.Logger, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, config Config, socialClient *social.Client, leaderboardCache LeaderboardCache, leaderboardRankCache LeaderboardRankCache, leaderboardScheduler LeaderboardScheduler, sessionRegistry SessionRegistry, matchRegistry MatchRegistry, tracker Tracker, streamManager StreamManager, router MessageRouter, rootPath string, paths []string, eventQueue *RuntimeEventQueue, matchProvider *MatchProvider) ([]string, map[string]RuntimeRpcFunction, map[string]RuntimeBeforeRtFunction, map[string]RuntimeAfterRtFunction, *RuntimeBeforeReqFunctions, *RuntimeAfterReqFunctions, RuntimeMatchmakerMatchedFunction, RuntimeTournamentEndFunction, RuntimeTournamentResetFunction, RuntimeLeaderboardResetFunction, *RuntimeEventFunctions, func() []string, error)
func NewRuntimeProviderJS ¶
func NewRuntimeProviderJS(logger, startupLogger *zap.Logger, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, jsonpbUnmarshaler *jsonpb.Unmarshaler, config Config, socialClient *social.Client, leaderboardCache LeaderboardCache, leaderboardRankCache LeaderboardRankCache, leaderboardScheduler LeaderboardScheduler, sessionRegistry SessionRegistry, matchRegistry MatchRegistry, tracker Tracker, metrics *Metrics, streamManager StreamManager, router MessageRouter, eventFn RuntimeEventCustomFunction, path, entrypoint string, matchProvider *MatchProvider) ([]string, map[string]RuntimeRpcFunction, map[string]RuntimeBeforeRtFunction, map[string]RuntimeAfterRtFunction, *RuntimeBeforeReqFunctions, *RuntimeAfterReqFunctions, RuntimeMatchmakerMatchedFunction, RuntimeTournamentEndFunction, RuntimeTournamentResetFunction, RuntimeLeaderboardResetFunction, error)
func NewRuntimeProviderLua ¶
func NewRuntimeProviderLua(logger, startupLogger *zap.Logger, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, jsonpbUnmarshaler *jsonpb.Unmarshaler, config Config, socialClient *social.Client, leaderboardCache LeaderboardCache, leaderboardRankCache LeaderboardRankCache, leaderboardScheduler LeaderboardScheduler, sessionRegistry SessionRegistry, matchRegistry MatchRegistry, tracker Tracker, metrics *Metrics, streamManager StreamManager, router MessageRouter, eventFn RuntimeEventCustomFunction, rootPath string, paths []string, matchProvider *MatchProvider) ([]string, map[string]RuntimeRpcFunction, map[string]RuntimeBeforeRtFunction, map[string]RuntimeAfterRtFunction, *RuntimeBeforeReqFunctions, *RuntimeAfterReqFunctions, RuntimeMatchmakerMatchedFunction, RuntimeTournamentEndFunction, RuntimeTournamentResetFunction, RuntimeLeaderboardResetFunction, error)
func NewSocketWsAcceptor ¶
func NewSocketWsAcceptor(logger *zap.Logger, config Config, sessionRegistry SessionRegistry, matchmaker Matchmaker, tracker Tracker, metrics *Metrics, runtime *Runtime, jsonpbMarshaler *jsonpb.Marshaler, jsonpbUnmarshaler *jsonpb.Unmarshaler, pipeline *Pipeline) func(http.ResponseWriter, *http.Request)
func NodeToHash ¶
func NotificationDelete ¶
func NotificationList ¶
func NotificationSave ¶
func NotificationSend ¶
func OpenPackage ¶
func OpenPackage(moduleCache *RuntimeLuaModuleCache) func(L *lua.LState) int
func PromoteGroupUsers ¶
func RuntimeLuaConvertLuaTable ¶
func RuntimeLuaConvertLuaTable(lv *lua.LTable) map[string]interface{}
func RuntimeLuaConvertLuaValue ¶
func RuntimeLuaConvertLuaValue(lv lua.LValue) interface{}
func RuntimeLuaConvertMap ¶
func RuntimeLuaConvertMap(l *lua.LState, data map[string]interface{}) *lua.LTable
func RuntimeLuaConvertValue ¶
func RuntimeLuaConvertValue(l *lua.LState, val interface{}) lua.LValue
func SessionRefresh ¶
func SetupLogging ¶
func StackdriverLevelEncoder ¶
func StackdriverLevelEncoder(l zapcore.Level, enc zapcore.PrimitiveArrayEncoder)
func StatusError ¶
Helper function for creating status errors that wrap underlying causes, usually DB errors.
func StorageDeleteObjects ¶
func StorageListObjects ¶
func StorageListObjectsAll ¶
func StorageListObjectsUser ¶
func StorageReadObjects ¶
func StorageWriteObjects ¶
func StreamToChannelId ¶
func StreamToChannelId(stream PresenceStream) (string, error)
func TournamentAddAttempt ¶
func TournamentCreate ¶
func TournamentCreate(ctx context.Context, logger *zap.Logger, cache LeaderboardCache, scheduler LeaderboardScheduler, leaderboardId string, sortOrder, operator int, resetSchedule, metadata, title, description string, category, startTime, endTime, duration, maxSize, maxNumScore int, joinRequired bool) error
func TournamentDelete ¶
func TournamentDelete(ctx context.Context, cache LeaderboardCache, rankCache LeaderboardRankCache, scheduler LeaderboardScheduler, leaderboardId string) error
func TournamentJoin ¶
func TournamentList ¶
func TournamentList(ctx context.Context, logger *zap.Logger, db *sql.DB, leaderboardCache LeaderboardCache, categoryStart, categoryEnd, startTime, endTime, limit int, cursor *TournamentListCursor) (*api.TournamentList, error)
func TournamentRecordWrite ¶
func TournamentRecordsList ¶
func TournamentRecordsList(ctx context.Context, logger *zap.Logger, db *sql.DB, leaderboardCache LeaderboardCache, rankCache LeaderboardRankCache, tournamentId string, ownerIds []string, limit *wrappers.Int32Value, cursor string, overrideExpiry int64) (*api.TournamentRecordList, error)
func TournamentsGet ¶
func UnbanUsers ¶
func UnlinkApple ¶
func UnlinkCustom ¶
func UnlinkDevice ¶
func UnlinkEmail ¶
func UnlinkFacebook ¶
func UnlinkGameCenter ¶
func UnlinkGoogle ¶
func UnlinkSteam ¶
func UpdateAccounts ¶
func UpdateGroup ¶
func UpdateWalletLedger ¶
func UpdateWallets ¶
Types ¶
type AmbiguousCommitError ¶
type AmbiguousCommitError struct {
// contains filtered or unexported fields
}
AmbiguousCommitError represents an error that left a transaction in an ambiguous state: unclear if it committed or not.
type ApiServer ¶
type ApiServer struct {
apigrpc.UnimplementedNakamaServer
// contains filtered or unexported fields
}
func StartApiServer ¶
func StartApiServer(logger *zap.Logger, startupLogger *zap.Logger, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, jsonpbUnmarshaler *jsonpb.Unmarshaler, config Config, socialClient *social.Client, leaderboardCache LeaderboardCache, leaderboardRankCache LeaderboardRankCache, sessionRegistry SessionRegistry, matchRegistry MatchRegistry, matchmaker Matchmaker, tracker Tracker, router MessageRouter, metrics *Metrics, pipeline *Pipeline, runtime *Runtime) *ApiServer
func (*ApiServer) AddFriends ¶
func (*ApiServer) AddGroupUsers ¶
func (*ApiServer) AuthenticateApple ¶
func (*ApiServer) AuthenticateCustom ¶
func (*ApiServer) AuthenticateDevice ¶
func (*ApiServer) AuthenticateEmail ¶
func (*ApiServer) AuthenticateFacebook ¶
func (*ApiServer) AuthenticateFacebookInstantGame ¶
func (*ApiServer) AuthenticateGameCenter ¶
func (*ApiServer) AuthenticateGoogle ¶
func (*ApiServer) AuthenticateSteam ¶
func (*ApiServer) BanGroupUsers ¶
func (*ApiServer) BlockFriends ¶
func (*ApiServer) CreateGroup ¶
func (*ApiServer) DeleteFriends ¶
func (*ApiServer) DeleteGroup ¶
func (*ApiServer) DeleteLeaderboardRecord ¶
func (*ApiServer) DeleteNotifications ¶
func (*ApiServer) DeleteStorageObjects ¶
func (*ApiServer) DemoteGroupUsers ¶
func (*ApiServer) GetAccount ¶
func (*ApiServer) Healthcheck ¶
func (*ApiServer) ImportFacebookFriends ¶
func (*ApiServer) ImportSteamFriends ¶ added in v3.1.0
func (*ApiServer) JoinTournament ¶
func (*ApiServer) KickGroupUsers ¶
func (*ApiServer) LeaveGroup ¶
func (*ApiServer) LinkCustom ¶
func (*ApiServer) LinkDevice ¶
func (*ApiServer) LinkFacebook ¶
func (*ApiServer) LinkFacebookInstantGame ¶
func (*ApiServer) LinkGameCenter ¶
func (*ApiServer) LinkGoogle ¶
func (*ApiServer) ListChannelMessages ¶
func (s *ApiServer) ListChannelMessages(ctx context.Context, in *api.ListChannelMessagesRequest) (*api.ChannelMessageList, error)
func (*ApiServer) ListFriends ¶
func (s *ApiServer) ListFriends(ctx context.Context, in *api.ListFriendsRequest) (*api.FriendList, error)
func (*ApiServer) ListGroupUsers ¶
func (s *ApiServer) ListGroupUsers(ctx context.Context, in *api.ListGroupUsersRequest) (*api.GroupUserList, error)
func (*ApiServer) ListGroups ¶
func (*ApiServer) ListLeaderboardRecords ¶
func (s *ApiServer) ListLeaderboardRecords(ctx context.Context, in *api.ListLeaderboardRecordsRequest) (*api.LeaderboardRecordList, error)
func (*ApiServer) ListLeaderboardRecordsAroundOwner ¶
func (s *ApiServer) ListLeaderboardRecordsAroundOwner(ctx context.Context, in *api.ListLeaderboardRecordsAroundOwnerRequest) (*api.LeaderboardRecordList, error)
func (*ApiServer) ListMatches ¶
func (*ApiServer) ListNotifications ¶
func (s *ApiServer) ListNotifications(ctx context.Context, in *api.ListNotificationsRequest) (*api.NotificationList, error)
func (*ApiServer) ListStorageObjects ¶
func (s *ApiServer) ListStorageObjects(ctx context.Context, in *api.ListStorageObjectsRequest) (*api.StorageObjectList, error)
func (*ApiServer) ListTournamentRecords ¶
func (s *ApiServer) ListTournamentRecords(ctx context.Context, in *api.ListTournamentRecordsRequest) (*api.TournamentRecordList, error)
func (*ApiServer) ListTournamentRecordsAroundOwner ¶
func (s *ApiServer) ListTournamentRecordsAroundOwner(ctx context.Context, in *api.ListTournamentRecordsAroundOwnerRequest) (*api.TournamentRecordList, error)
func (*ApiServer) ListTournaments ¶
func (s *ApiServer) ListTournaments(ctx context.Context, in *api.ListTournamentsRequest) (*api.TournamentList, error)
func (*ApiServer) ListUserGroups ¶
func (s *ApiServer) ListUserGroups(ctx context.Context, in *api.ListUserGroupsRequest) (*api.UserGroupList, error)
func (*ApiServer) PromoteGroupUsers ¶
func (*ApiServer) ReadStorageObjects ¶
func (s *ApiServer) ReadStorageObjects(ctx context.Context, in *api.ReadStorageObjectsRequest) (*api.StorageObjects, error)
func (*ApiServer) RpcFuncHttp ¶
func (s *ApiServer) RpcFuncHttp(w http.ResponseWriter, r *http.Request)
func (*ApiServer) SessionRefresh ¶
func (*ApiServer) UnlinkApple ¶
func (*ApiServer) UnlinkCustom ¶
func (*ApiServer) UnlinkDevice ¶
func (*ApiServer) UnlinkEmail ¶
func (*ApiServer) UnlinkFacebook ¶
func (*ApiServer) UnlinkFacebookInstantGame ¶
func (*ApiServer) UnlinkGameCenter ¶
func (*ApiServer) UnlinkGoogle ¶
func (*ApiServer) UnlinkSteam ¶
func (*ApiServer) UpdateAccount ¶
func (*ApiServer) UpdateGroup ¶
func (*ApiServer) WriteLeaderboardRecord ¶
func (s *ApiServer) WriteLeaderboardRecord(ctx context.Context, in *api.WriteLeaderboardRecordRequest) (*api.LeaderboardRecord, error)
func (*ApiServer) WriteStorageObjects ¶
func (s *ApiServer) WriteStorageObjects(ctx context.Context, in *api.WriteStorageObjectsRequest) (*api.StorageObjectAcks, error)
func (*ApiServer) WriteTournamentRecord ¶
func (s *ApiServer) WriteTournamentRecord(ctx context.Context, in *api.WriteTournamentRecordRequest) (*api.LeaderboardRecord, error)
type ChannelIdToStreamResult ¶
type ChannelIdToStreamResult struct {
Stream PresenceStream
}
Wrapper type to avoid allocating a stream struct when the input is invalid.
func ChannelIdToStream ¶
func ChannelIdToStream(channelID string) (*ChannelIdToStreamResult, error)
type Config ¶
type Config interface {
GetName() string
GetDataDir() string
GetShutdownGraceSec() int
GetLogger() *LoggerConfig
GetMetrics() *MetricsConfig
GetSession() *SessionConfig
GetSocket() *SocketConfig
GetDatabase() *DatabaseConfig
GetSocial() *SocialConfig
GetRuntime() *RuntimeConfig
GetMatch() *MatchConfig
GetTracker() *TrackerConfig
GetConsole() *ConsoleConfig
GetLeaderboard() *LeaderboardConfig
GetMatchmaker() *MatchmakerConfig
Clone() (Config, error)
}
Config interface is the Nakama core configuration.
type ConsoleConfig ¶
type ConsoleConfig struct {
Port int `yaml:"port" json:"port" usage:"The port for accepting connections for the embedded console, listening on all interfaces."`
Address string `` /* 157-byte string literal not displayed */
MaxMessageSizeBytes int64 `` /* 154-byte string literal not displayed */
ReadTimeoutMs int `yaml:"read_timeout_ms" json:"read_timeout_ms" usage:"Maximum duration in milliseconds for reading the entire request."`
WriteTimeoutMs int `` /* 130-byte string literal not displayed */
IdleTimeoutMs int `` /* 151-byte string literal not displayed */
Username string `yaml:"username" json:"username" usage:"Username for the embedded console. Default username is 'admin'."`
Password string `yaml:"password" json:"password" usage:"Password for the embedded console. Default password is 'password'."`
TokenExpirySec int64 `yaml:"token_expiry_sec" json:"token_expiry_sec" usage:"Token expiry in seconds. Default 86400."`
SigningKey string `yaml:"signing_key" json:"signing_key" usage:"Key used to sign console session tokens."`
}
ConsoleConfig is configuration relevant to the embedded console.
func NewConsoleConfig ¶
func NewConsoleConfig() *ConsoleConfig
NewConsoleConfig creates a new ConsoleConfig struct.
type ConsoleServer ¶
type ConsoleServer struct {
console.UnimplementedConsoleServer
// contains filtered or unexported fields
}
func StartConsoleServer ¶
func StartConsoleServer(logger *zap.Logger, startupLogger *zap.Logger, db *sql.DB, config Config, tracker Tracker, router MessageRouter, statusHandler StatusHandler, runtimeInfo *RuntimeInfo, matchRegistry MatchRegistry, configWarnings map[string]string, serverVersion string, leaderboardCache LeaderboardCache, leaderboardRankCache LeaderboardRankCache, api *ApiServer, cookie string) *ConsoleServer
func (*ConsoleServer) AddUser ¶
func (s *ConsoleServer) AddUser(ctx context.Context, in *console.AddUserRequest) (*empty.Empty, error)
func (*ConsoleServer) Authenticate ¶
func (s *ConsoleServer) Authenticate(ctx context.Context, in *console.AuthenticateRequest) (*console.ConsoleSession, error)
func (*ConsoleServer) BanAccount ¶
func (*ConsoleServer) CallApiEndpoint ¶
func (s *ConsoleServer) CallApiEndpoint(ctx context.Context, in *console.CallApiEndpointRequest) (*console.CallApiEndpointResponse, error)
func (*ConsoleServer) CallRpcEndpoint ¶
func (s *ConsoleServer) CallRpcEndpoint(ctx context.Context, in *console.CallApiEndpointRequest) (*console.CallApiEndpointResponse, error)
func (*ConsoleServer) DeleteAccount ¶
func (s *ConsoleServer) DeleteAccount(ctx context.Context, in *console.AccountDeleteRequest) (*empty.Empty, error)
func (*ConsoleServer) DeleteAccounts ¶
func (*ConsoleServer) DeleteFriend ¶
func (s *ConsoleServer) DeleteFriend(ctx context.Context, in *console.DeleteFriendRequest) (*empty.Empty, error)
func (*ConsoleServer) DeleteGroupUser ¶
func (s *ConsoleServer) DeleteGroupUser(ctx context.Context, in *console.DeleteGroupUserRequest) (*empty.Empty, error)
func (*ConsoleServer) DeleteLeaderboard ¶
func (s *ConsoleServer) DeleteLeaderboard(ctx context.Context, in *console.LeaderboardRequest) (*empty.Empty, error)
func (*ConsoleServer) DeleteLeaderboardRecord ¶
func (s *ConsoleServer) DeleteLeaderboardRecord(ctx context.Context, in *console.DeleteLeaderboardRecordRequest) (*empty.Empty, error)
func (*ConsoleServer) DeleteStorage ¶
func (*ConsoleServer) DeleteStorageObject ¶
func (s *ConsoleServer) DeleteStorageObject(ctx context.Context, in *console.DeleteStorageObjectRequest) (*empty.Empty, error)
func (*ConsoleServer) DeleteUser ¶
func (*ConsoleServer) DeleteWalletLedger ¶
func (s *ConsoleServer) DeleteWalletLedger(ctx context.Context, in *console.DeleteWalletLedgerRequest) (*empty.Empty, error)
func (*ConsoleServer) ExportAccount ¶
func (s *ConsoleServer) ExportAccount(ctx context.Context, in *console.AccountId) (*console.AccountExport, error)
func (*ConsoleServer) GetAccount ¶
func (*ConsoleServer) GetFriends ¶
func (s *ConsoleServer) GetFriends(ctx context.Context, in *console.AccountId) (*api.FriendList, error)
func (*ConsoleServer) GetGroups ¶
func (s *ConsoleServer) GetGroups(ctx context.Context, in *console.AccountId) (*api.UserGroupList, error)
func (*ConsoleServer) GetLeaderboard ¶
func (s *ConsoleServer) GetLeaderboard(ctx context.Context, in *console.LeaderboardRequest) (*console.Leaderboard, error)
func (*ConsoleServer) GetMatchState ¶
func (s *ConsoleServer) GetMatchState(ctx context.Context, in *console.MatchStateRequest) (*console.MatchState, error)
func (*ConsoleServer) GetRuntime ¶
func (s *ConsoleServer) GetRuntime(ctx context.Context, in *empty.Empty) (*console.RuntimeInfo, error)
func (*ConsoleServer) GetStatus ¶
func (s *ConsoleServer) GetStatus(ctx context.Context, in *empty.Empty) (*console.StatusList, error)
func (*ConsoleServer) GetStorage ¶
func (s *ConsoleServer) GetStorage(ctx context.Context, in *api.ReadStorageObjectId) (*api.StorageObject, error)
func (*ConsoleServer) GetWalletLedger ¶
func (s *ConsoleServer) GetWalletLedger(ctx context.Context, in *console.AccountId) (*console.WalletLedgerList, error)
func (*ConsoleServer) ListAccounts ¶
func (s *ConsoleServer) ListAccounts(ctx context.Context, in *console.ListAccountsRequest) (*console.AccountList, error)
func (*ConsoleServer) ListApiEndpoints ¶
func (s *ConsoleServer) ListApiEndpoints(ctx context.Context, _ *empty.Empty) (*console.ApiEndpointList, error)
func (*ConsoleServer) ListLeaderboardRecords ¶
func (s *ConsoleServer) ListLeaderboardRecords(ctx context.Context, in *api.ListLeaderboardRecordsRequest) (*api.LeaderboardRecordList, error)
func (*ConsoleServer) ListLeaderboards ¶
func (s *ConsoleServer) ListLeaderboards(ctx context.Context, _ *empty.Empty) (*console.LeaderboardList, error)
func (*ConsoleServer) ListMatches ¶
func (s *ConsoleServer) ListMatches(ctx context.Context, in *api.ListMatchesRequest) (*api.MatchList, error)
func (*ConsoleServer) ListStorage ¶
func (s *ConsoleServer) ListStorage(ctx context.Context, in *console.ListStorageRequest) (*console.StorageList, error)
func (*ConsoleServer) ListStorageCollections ¶
func (s *ConsoleServer) ListStorageCollections(ctx context.Context, in *empty.Empty) (*console.StorageCollectionsList, error)
func (*ConsoleServer) Stop ¶
func (s *ConsoleServer) Stop()
func (*ConsoleServer) UnbanAccount ¶
func (*ConsoleServer) UnlinkApple ¶
func (*ConsoleServer) UnlinkCustom ¶
func (*ConsoleServer) UnlinkDevice ¶
func (s *ConsoleServer) UnlinkDevice(ctx context.Context, in *console.UnlinkDeviceRequest) (*empty.Empty, error)
func (*ConsoleServer) UnlinkEmail ¶
func (*ConsoleServer) UnlinkFacebook ¶
func (*ConsoleServer) UnlinkFacebookInstantGame ¶
func (*ConsoleServer) UnlinkGameCenter ¶
func (*ConsoleServer) UnlinkGoogle ¶
func (*ConsoleServer) UnlinkSteam ¶
func (*ConsoleServer) UpdateAccount ¶
func (s *ConsoleServer) UpdateAccount(ctx context.Context, in *console.UpdateAccountRequest) (*empty.Empty, error)
func (*ConsoleServer) WriteStorageObject ¶
func (s *ConsoleServer) WriteStorageObject(ctx context.Context, in *console.WriteStorageObjectRequest) (*api.StorageObjectAck, error)
type ConsoleTokenClaims ¶
type ConsoleTokenClaims struct {
Username string `json:"usn,omitempty"`
Email string `json:"ema,omitempty"`
Role console.UserRole `json:"rol,omitempty"`
ExpiresAt int64 `json:"exp,omitempty"`
Cookie string `json:"cki,omitempty"`
}
func (*ConsoleTokenClaims) Valid ¶
func (stc *ConsoleTokenClaims) Valid() error
type DatabaseConfig ¶
type DatabaseConfig struct {
Addresses []string `` /* 135-byte string literal not displayed */
ConnMaxLifetimeMs int `` /* 199-byte string literal not displayed */
MaxOpenConns int `yaml:"max_open_conns" json:"max_open_conns" usage:"Maximum number of allowed open connections to the database. Default 100."`
MaxIdleConns int `` /* 135-byte string literal not displayed */
}
DatabaseConfig is configuration relevant to the Database storage.
func NewDatabaseConfig ¶
func NewDatabaseConfig() *DatabaseConfig
NewDatabaseConfig creates a new DatabaseConfig struct.
type DeferredMessage ¶
type DeferredMessage struct {
PresenceIDs []*PresenceID
Envelope *rtapi.Envelope
Reliable bool
}
Deferred message expected to be batched with other deferred messages. All deferred messages in a batch are expected to be for the same stream/mode and share a logger context.
type ErrorCauser ¶
type ErrorCauser interface {
// Cause returns the proximate cause of this error.
Cause() error
}
ErrorCauser is the type implemented by an error that remembers its cause.
ErrorCauser is intentionally equivalent to the causer interface used by the github.com/pkg/errors package.
type JsErrorType ¶
type JsErrorType int
const ( JsErrorException JsErrorType = iota JsErrorRuntime )
func (JsErrorType) String ¶
func (e JsErrorType) String() string
type LSentinelType ¶
type LSentinelType struct {
lua.LNilType
}
func (*LSentinelType) String ¶
func (s *LSentinelType) String() string
func (*LSentinelType) Type ¶
func (s *LSentinelType) Type() lua.LValueType
type Leaderboard ¶
type Leaderboard struct {
Id string
Authoritative bool
SortOrder int
Operator int
ResetScheduleStr string
ResetSchedule *cronexpr.Expression
Metadata string
CreateTime int64
Category int
Description string
Duration int
EndTime int64
JoinRequired bool
MaxSize int
MaxNumScore int
Title string
StartTime int64
}
func (*Leaderboard) GetAuthoritative ¶
func (l *Leaderboard) GetAuthoritative() bool
func (*Leaderboard) GetCreateTime ¶
func (l *Leaderboard) GetCreateTime() int64
func (*Leaderboard) GetId ¶
func (l *Leaderboard) GetId() string
func (*Leaderboard) GetMetadata ¶
func (l *Leaderboard) GetMetadata() map[string]interface{}
func (*Leaderboard) GetOperator ¶
func (l *Leaderboard) GetOperator() string
func (*Leaderboard) GetReset ¶
func (l *Leaderboard) GetReset() string
func (*Leaderboard) GetSortOrder ¶
func (l *Leaderboard) GetSortOrder() string
func (*Leaderboard) IsTournament ¶
func (l *Leaderboard) IsTournament() bool
type LeaderboardCache ¶
type LeaderboardCache interface {
Get(id string) *Leaderboard
GetAllLeaderboards() []*Leaderboard
RefreshAllLeaderboards(ctx context.Context) error
Create(ctx context.Context, id string, authoritative bool, sortOrder, operator int, resetSchedule, metadata string) (*Leaderboard, error)
Insert(id string, authoritative bool, sortOrder, operator int, resetSchedule, metadata string, createTime int64)
CreateTournament(ctx context.Context, id string, sortOrder, operator int, resetSchedule, metadata, title, description string, category, startTime, endTime, duration, maxSize, maxNumScore int, joinRequired bool) (*Leaderboard, error)
InsertTournament(id string, sortOrder, operator int, resetSchedule, metadata, title, description string, category, duration, maxSize, maxNumScore int, joinRequired bool, createTime, startTime, endTime int64)
ListTournaments(now int64, categoryStart, categoryEnd int, startTime, endTime int64, limit int, cursor *TournamentListCursor) ([]*Leaderboard, *TournamentListCursor, error)
Delete(ctx context.Context, id string) error
Remove(id string)
}
func NewLocalLeaderboardCache ¶
func NewLocalLeaderboardCache(logger, startupLogger *zap.Logger, db *sql.DB) LeaderboardCache
type LeaderboardConfig ¶
type LeaderboardConfig struct {
BlacklistRankCache []string `` /* 211-byte string literal not displayed */
CallbackQueueSize int `` /* 175-byte string literal not displayed */
CallbackQueueWorkers int `` /* 170-byte string literal not displayed */
}
LeaderboardConfig is configuration relevant to the leaderboard system.
func NewLeaderboardConfig ¶
func NewLeaderboardConfig() *LeaderboardConfig
NewLeaderboardConfig creates a new LeaderboardConfig struct.
type LeaderboardRankCache ¶
type LeaderboardRankCache interface {
Get(leaderboardId string, expiryUnix int64, ownerID uuid.UUID) int64
Fill(leaderboardId string, expiryUnix int64, records []*api.LeaderboardRecord)
Insert(leaderboardId string, expiryUnix int64, sortOrder int, ownerID uuid.UUID, score, subscore int64) int64
Delete(leaderboardId string, expiryUnix int64, ownerID uuid.UUID) bool
DeleteLeaderboard(leaderboardId string, expiryUnix int64) bool
TrimExpired(nowUnix int64) bool
}
func NewLocalLeaderboardRankCache ¶
func NewLocalLeaderboardRankCache(startupLogger *zap.Logger, db *sql.DB, config *LeaderboardConfig, leaderboardCache LeaderboardCache) LeaderboardRankCache
type LeaderboardScheduler ¶
type LeaderboardScheduler interface {
Start(runtime *Runtime)
Pause()
Resume()
Stop()
Update()
}
func NewLocalLeaderboardScheduler ¶
func NewLocalLeaderboardScheduler(logger *zap.Logger, db *sql.DB, config Config, cache LeaderboardCache, rankCache LeaderboardRankCache) LeaderboardScheduler
type LeaderboardSchedulerCallback ¶
type LeaderboardSchedulerCallback struct {
// contains filtered or unexported fields
}
type LeaderboardWithExpiry ¶
type LocalLeaderboardCache ¶
func (*LocalLeaderboardCache) Create ¶
func (l *LocalLeaderboardCache) Create(ctx context.Context, id string, authoritative bool, sortOrder, operator int, resetSchedule, metadata string) (*Leaderboard, error)
func (*LocalLeaderboardCache) CreateTournament ¶
func (l *LocalLeaderboardCache) CreateTournament(ctx context.Context, id string, sortOrder, operator int, resetSchedule, metadata, title, description string, category, startTime, endTime, duration, maxSize, maxNumScore int, joinRequired bool) (*Leaderboard, error)
func (*LocalLeaderboardCache) Delete ¶
func (l *LocalLeaderboardCache) Delete(ctx context.Context, id string) error
func (*LocalLeaderboardCache) Get ¶
func (l *LocalLeaderboardCache) Get(id string) *Leaderboard
func (*LocalLeaderboardCache) GetAllLeaderboards ¶
func (l *LocalLeaderboardCache) GetAllLeaderboards() []*Leaderboard
func (*LocalLeaderboardCache) InsertTournament ¶
func (*LocalLeaderboardCache) ListTournaments ¶
func (l *LocalLeaderboardCache) ListTournaments(now int64, categoryStart, categoryEnd int, startTime, endTime int64, limit int, cursor *TournamentListCursor) ([]*Leaderboard, *TournamentListCursor, error)
func (*LocalLeaderboardCache) RefreshAllLeaderboards ¶
func (l *LocalLeaderboardCache) RefreshAllLeaderboards(ctx context.Context) error
func (*LocalLeaderboardCache) Remove ¶
func (l *LocalLeaderboardCache) Remove(id string)
type LocalLeaderboardRankCache ¶
func (*LocalLeaderboardRankCache) DeleteLeaderboard ¶
func (l *LocalLeaderboardRankCache) DeleteLeaderboard(leaderboardId string, expiryUnix int64) bool
func (*LocalLeaderboardRankCache) Fill ¶
func (l *LocalLeaderboardRankCache) Fill(leaderboardId string, expiryUnix int64, records []*api.LeaderboardRecord)
func (*LocalLeaderboardRankCache) TrimExpired ¶
func (l *LocalLeaderboardRankCache) TrimExpired(nowUnix int64) bool
type LocalLeaderboardScheduler ¶
func (*LocalLeaderboardScheduler) Pause ¶
func (ls *LocalLeaderboardScheduler) Pause()
func (*LocalLeaderboardScheduler) Resume ¶
func (ls *LocalLeaderboardScheduler) Resume()
func (*LocalLeaderboardScheduler) Start ¶
func (ls *LocalLeaderboardScheduler) Start(runtime *Runtime)
func (*LocalLeaderboardScheduler) Stop ¶
func (ls *LocalLeaderboardScheduler) Stop()
func (*LocalLeaderboardScheduler) Update ¶
func (ls *LocalLeaderboardScheduler) Update()
type LocalMatchRegistry ¶
type LocalMatchRegistry struct {
// contains filtered or unexported fields
}
func (*LocalMatchRegistry) Count ¶
func (r *LocalMatchRegistry) Count() int
func (*LocalMatchRegistry) CreateMatch ¶
func (r *LocalMatchRegistry) CreateMatch(ctx context.Context, logger *zap.Logger, createFn RuntimeMatchCreateFunction, module string, params map[string]interface{}) (string, error)
func (*LocalMatchRegistry) Join ¶
func (r *LocalMatchRegistry) Join(id uuid.UUID, presences []*MatchPresence)
func (*LocalMatchRegistry) JoinAttempt ¶
func (*LocalMatchRegistry) Kick ¶
func (r *LocalMatchRegistry) Kick(stream PresenceStream, presences []*MatchPresence)
func (*LocalMatchRegistry) Leave ¶
func (r *LocalMatchRegistry) Leave(id uuid.UUID, presences []*MatchPresence)
func (*LocalMatchRegistry) ListMatches ¶
func (r *LocalMatchRegistry) ListMatches(ctx context.Context, limit int, authoritative *wrappers.BoolValue, label *wrappers.StringValue, minSize *wrappers.Int32Value, maxSize *wrappers.Int32Value, queryString *wrappers.StringValue) ([]*api.Match, error)
func (*LocalMatchRegistry) NewMatch ¶
func (r *LocalMatchRegistry) NewMatch(logger *zap.Logger, id uuid.UUID, core RuntimeMatchCore, stopped *atomic.Bool, params map[string]interface{}) (*MatchHandler, error)
func (*LocalMatchRegistry) RemoveMatch ¶
func (r *LocalMatchRegistry) RemoveMatch(id uuid.UUID, stream PresenceStream)
func (*LocalMatchRegistry) Stop ¶
func (r *LocalMatchRegistry) Stop(graceSeconds int) chan struct{}
func (*LocalMatchRegistry) UpdateMatchLabel ¶
type LocalMatchmaker ¶
func (*LocalMatchmaker) Add ¶
func (m *LocalMatchmaker) Add(presences []*MatchmakerPresence, sessionID, partyId, query string, minCount, maxCount int, stringProperties map[string]string, numericProperties map[string]float64) (string, error)
func (*LocalMatchmaker) RemoveParty ¶
func (m *LocalMatchmaker) RemoveParty(partyID, ticket string) error
func (*LocalMatchmaker) RemovePartyAll ¶
func (m *LocalMatchmaker) RemovePartyAll(partyID string) error
func (*LocalMatchmaker) RemoveSession ¶
func (m *LocalMatchmaker) RemoveSession(sessionID, ticket string) error
func (*LocalMatchmaker) RemoveSessionAll ¶
func (m *LocalMatchmaker) RemoveSessionAll(sessionID string) error
func (*LocalMatchmaker) Stop ¶
func (m *LocalMatchmaker) Stop()
type LocalMessageRouter ¶
type LocalMessageRouter struct {
// contains filtered or unexported fields
}
func (*LocalMessageRouter) SendDeferred ¶
func (r *LocalMessageRouter) SendDeferred(logger *zap.Logger, messages []*DeferredMessage)
func (*LocalMessageRouter) SendToPresenceIDs ¶
func (r *LocalMessageRouter) SendToPresenceIDs(logger *zap.Logger, presenceIDs []*PresenceID, envelope *rtapi.Envelope, reliable bool)
func (*LocalMessageRouter) SendToStream ¶
func (r *LocalMessageRouter) SendToStream(logger *zap.Logger, stream PresenceStream, envelope *rtapi.Envelope, reliable bool)
type LocalPartyRegistry ¶
type LocalPartyRegistry struct {
// contains filtered or unexported fields
}
func (*LocalPartyRegistry) Create ¶
func (p *LocalPartyRegistry) Create(open bool, maxSize int) *PartyHandler
func (*LocalPartyRegistry) Delete ¶
func (p *LocalPartyRegistry) Delete(id uuid.UUID)
func (*LocalPartyRegistry) Join ¶
func (p *LocalPartyRegistry) Join(id uuid.UUID, presences []*Presence)
func (*LocalPartyRegistry) Leave ¶
func (p *LocalPartyRegistry) Leave(id uuid.UUID, presences []*Presence)
func (*LocalPartyRegistry) PartyAccept ¶
func (p *LocalPartyRegistry) PartyAccept(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, presence *rtapi.UserPresence) error
func (*LocalPartyRegistry) PartyClose ¶
func (*LocalPartyRegistry) PartyDataSend ¶
func (*LocalPartyRegistry) PartyJoinRequest ¶
func (*LocalPartyRegistry) PartyJoinRequestList ¶
func (p *LocalPartyRegistry) PartyJoinRequestList(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string) ([]*rtapi.UserPresence, error)
func (*LocalPartyRegistry) PartyMatchmakerAdd ¶
func (*LocalPartyRegistry) PartyMatchmakerRemove ¶
func (*LocalPartyRegistry) PartyPromote ¶
func (p *LocalPartyRegistry) PartyPromote(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, presence *rtapi.UserPresence) error
func (*LocalPartyRegistry) PartyRemove ¶
func (p *LocalPartyRegistry) PartyRemove(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, presence *rtapi.UserPresence) error
type LocalSessionRegistry ¶
type LocalSessionRegistry struct {
// contains filtered or unexported fields
}
func (*LocalSessionRegistry) Add ¶
func (r *LocalSessionRegistry) Add(session Session)
func (*LocalSessionRegistry) Count ¶
func (r *LocalSessionRegistry) Count() int
func (*LocalSessionRegistry) Disconnect ¶
func (*LocalSessionRegistry) Remove ¶
func (r *LocalSessionRegistry) Remove(sessionID uuid.UUID)
func (*LocalSessionRegistry) Stop ¶
func (r *LocalSessionRegistry) Stop()
type LocalStatusHandler ¶
type LocalStatusHandler struct {
// contains filtered or unexported fields
}
func (*LocalStatusHandler) GetStatus ¶
func (s *LocalStatusHandler) GetStatus(ctx context.Context) ([]*console.StatusList_Status, error)
type LocalStreamManager ¶
type LocalStreamManager struct {
// contains filtered or unexported fields
}
func (*LocalStreamManager) UserJoin ¶
func (m *LocalStreamManager) UserJoin(stream PresenceStream, userID, sessionID uuid.UUID, hidden, persistence bool, status string) (bool, bool, error)
func (*LocalStreamManager) UserLeave ¶
func (m *LocalStreamManager) UserLeave(stream PresenceStream, userID, sessionID uuid.UUID) error
func (*LocalStreamManager) UserUpdate ¶
func (m *LocalStreamManager) UserUpdate(stream PresenceStream, userID, sessionID uuid.UUID, hidden, persistence bool, status string) (bool, error)
type LocalTracker ¶
func (*LocalTracker) Count ¶
func (t *LocalTracker) Count() int
func (*LocalTracker) CountByStream ¶
func (t *LocalTracker) CountByStream(stream PresenceStream) int
func (*LocalTracker) CountByStreamModeFilter ¶
func (t *LocalTracker) CountByStreamModeFilter(modes map[uint8]*uint8) map[*PresenceStream]int32
func (*LocalTracker) GetBySessionIDStreamUserID ¶
func (t *LocalTracker) GetBySessionIDStreamUserID(node string, sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID) *PresenceMeta
func (*LocalTracker) GetLocalBySessionIDStreamUserID ¶
func (t *LocalTracker) GetLocalBySessionIDStreamUserID(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID) *PresenceMeta
func (*LocalTracker) ListByStream ¶
func (t *LocalTracker) ListByStream(stream PresenceStream, includeHidden bool, includeNotHidden bool) []*Presence
func (*LocalTracker) ListLocalSessionIDByStream ¶
func (t *LocalTracker) ListLocalSessionIDByStream(stream PresenceStream) []uuid.UUID
func (*LocalTracker) ListNodesForStream ¶
func (t *LocalTracker) ListNodesForStream(stream PresenceStream) map[string]struct{}
func (*LocalTracker) ListPresenceIDByStream ¶
func (t *LocalTracker) ListPresenceIDByStream(stream PresenceStream) []*PresenceID
func (*LocalTracker) SetMatchJoinListener ¶
func (t *LocalTracker) SetMatchJoinListener(f func(id uuid.UUID, joins []*MatchPresence))
func (*LocalTracker) SetMatchLeaveListener ¶
func (t *LocalTracker) SetMatchLeaveListener(f func(id uuid.UUID, leaves []*MatchPresence))
func (*LocalTracker) SetPartyJoinListener ¶
func (t *LocalTracker) SetPartyJoinListener(f func(id uuid.UUID, joins []*Presence))
func (*LocalTracker) SetPartyLeaveListener ¶
func (t *LocalTracker) SetPartyLeaveListener(f func(id uuid.UUID, leaves []*Presence))
func (*LocalTracker) Stop ¶
func (t *LocalTracker) Stop()
func (*LocalTracker) StreamExists ¶
func (t *LocalTracker) StreamExists(stream PresenceStream) bool
func (*LocalTracker) Track ¶
func (t *LocalTracker) Track(ctx context.Context, sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID, meta PresenceMeta, allowIfFirstForSession bool) (bool, bool)
func (*LocalTracker) TrackMulti ¶ added in v3.1.0
func (*LocalTracker) Untrack ¶
func (t *LocalTracker) Untrack(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID)
func (*LocalTracker) UntrackAll ¶
func (t *LocalTracker) UntrackAll(sessionID uuid.UUID)
func (*LocalTracker) UntrackByStream ¶
func (t *LocalTracker) UntrackByStream(stream PresenceStream)
func (*LocalTracker) UntrackLocalByStream ¶
func (t *LocalTracker) UntrackLocalByStream(stream PresenceStream)
func (*LocalTracker) UntrackMulti ¶ added in v3.1.0
func (t *LocalTracker) UntrackMulti(sessionID uuid.UUID, streams []*PresenceStream, userID uuid.UUID)
func (*LocalTracker) Update ¶
func (t *LocalTracker) Update(ctx context.Context, sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID, meta PresenceMeta, allowIfFirstForSession bool) bool
type LoggerConfig ¶
type LoggerConfig struct {
Level string `yaml:"level" json:"level" usage:"Log level to set. Valid values are 'debug', 'info', 'warn', 'error'. Default 'info'."`
Stdout bool `yaml:"stdout" json:"stdout" usage:"Log to standard console output (as well as to a file if set). Default true."`
File string `` /* 135-byte string literal not displayed */
Rotation bool `yaml:"rotation" json:"rotation" usage:"Rotate log files. Default is false."`
// Reference: https://godoc.org/gopkg.in/natefinch/lumberjack.v2
MaxSize int `` /* 139-byte string literal not displayed */
MaxAge int `` /* 195-byte string literal not displayed */
MaxBackups int `` /* 188-byte string literal not displayed */
LocalTime bool `` /* 184-byte string literal not displayed */
Compress bool `yaml:"compress" json:"compress" usage:"This determines if the rotated log files should be compressed using gzip."`
Format string `yaml:"format" json:"format" usage:"Set logging output format. Can either be 'JSON' or 'Stackdriver'. Default is 'JSON'."`
}
LoggerConfig is configuration relevant to logging levels and output.
func NewLoggerConfig ¶
func NewLoggerConfig() *LoggerConfig
NewLoggerConfig creates a new LoggerConfig struct.
type LoggingFormat ¶
type LoggingFormat int8
const ( JSONFormat LoggingFormat = iota - 1 StackdriverFormat )
type MatchConfig ¶
type MatchConfig struct {
InputQueueSize int `` /* 181-byte string literal not displayed */
CallQueueSize int `` /* 176-byte string literal not displayed */
JoinAttemptQueueSize int `` /* 174-byte string literal not displayed */
DeferredQueueSize int `` /* 190-byte string literal not displayed */
JoinMarkerDeadlineMs int `` /* 198-byte string literal not displayed */
MaxEmptySec int `` /* 198-byte string literal not displayed */
}
MatchConfig is configuration relevant to authoritative realtime multiplayer matches.
func NewMatchConfig ¶
func NewMatchConfig() *MatchConfig
NewMatchConfig creates a new MatchConfig struct.
type MatchDataMessage ¶
type MatchDataMessage struct {
UserID uuid.UUID
SessionID uuid.UUID
Username string
Node string
OpCode int64
Data []byte
Reliable bool
ReceiveTime int64
}
func (*MatchDataMessage) GetData ¶
func (m *MatchDataMessage) GetData() []byte
func (*MatchDataMessage) GetHidden ¶
func (m *MatchDataMessage) GetHidden() bool
func (*MatchDataMessage) GetNodeId ¶
func (m *MatchDataMessage) GetNodeId() string
func (*MatchDataMessage) GetOpCode ¶
func (m *MatchDataMessage) GetOpCode() int64
func (*MatchDataMessage) GetPersistence ¶
func (m *MatchDataMessage) GetPersistence() bool
func (*MatchDataMessage) GetReceiveTime ¶
func (m *MatchDataMessage) GetReceiveTime() int64
func (*MatchDataMessage) GetReliable ¶
func (m *MatchDataMessage) GetReliable() bool
func (*MatchDataMessage) GetSessionId ¶
func (m *MatchDataMessage) GetSessionId() string
func (*MatchDataMessage) GetStatus ¶
func (m *MatchDataMessage) GetStatus() string
func (*MatchDataMessage) GetUserId ¶
func (m *MatchDataMessage) GetUserId() string
func (*MatchDataMessage) GetUsername ¶
func (m *MatchDataMessage) GetUsername() string
type MatchGetStateResult ¶
type MatchGetStateResult struct {
Error error
Presences []*MatchPresence
Tick int64
State string
}
type MatchHandler ¶
type MatchHandler struct {
JoinMarkerList *MatchJoinMarkerList
PresenceList *MatchPresenceList
Core RuntimeMatchCore
// Identification not (directly) controlled by match init.
ID uuid.UUID
Node string
IDStr string
Stream PresenceStream
// Configuration set by match init.
Rate int64
// contains filtered or unexported fields
}
func NewMatchHandler ¶
func NewMatchHandler(logger *zap.Logger, config Config, sessionRegistry SessionRegistry, matchRegistry MatchRegistry, router MessageRouter, core RuntimeMatchCore, id uuid.UUID, node string, stopped *atomic.Bool, params map[string]interface{}) (*MatchHandler, error)
func (*MatchHandler) Label ¶
func (mh *MatchHandler) Label() string
func (*MatchHandler) QueueData ¶
func (mh *MatchHandler) QueueData(m *MatchDataMessage)
func (*MatchHandler) QueueGetState ¶
func (mh *MatchHandler) QueueGetState(ctx context.Context, resultCh chan<- *MatchGetStateResult) bool
func (*MatchHandler) QueueJoin ¶
func (mh *MatchHandler) QueueJoin(joins []*MatchPresence, mark bool) bool
func (*MatchHandler) QueueJoinAttempt ¶
func (*MatchHandler) QueueLeave ¶
func (mh *MatchHandler) QueueLeave(leaves []*MatchPresence) bool
func (*MatchHandler) QueueTerminate ¶
func (mh *MatchHandler) QueueTerminate(graceSeconds int) bool
func (*MatchHandler) Stop ¶
func (mh *MatchHandler) Stop()
Stop the match handler and clean up all its resources.
type MatchIndexEntry ¶
type MatchJoinMarker ¶
type MatchJoinMarker struct {
// contains filtered or unexported fields
}
Used to monitor when match presences begin and complete their match join process.
type MatchJoinMarkerList ¶
func NewMatchJoinMarkerList ¶
func NewMatchJoinMarkerList(config Config, tickRate int64) *MatchJoinMarkerList
func (*MatchJoinMarkerList) Add ¶
func (m *MatchJoinMarkerList) Add(presence *MatchPresence, currentTick int64)
func (*MatchJoinMarkerList) ClearExpired ¶
func (m *MatchJoinMarkerList) ClearExpired(tick int64) []*MatchPresence
func (*MatchJoinMarkerList) Mark ¶
func (m *MatchJoinMarkerList) Mark(sessionID uuid.UUID)
type MatchJoinResult ¶
type MatchNamesListFunction ¶
type MatchNamesListFunction func() []string
type MatchPresence ¶
Represents routing and identify information for a single match participant.
func (*MatchPresence) GetHidden ¶
func (p *MatchPresence) GetHidden() bool
func (*MatchPresence) GetNodeId ¶
func (p *MatchPresence) GetNodeId() string
func (*MatchPresence) GetPersistence ¶
func (p *MatchPresence) GetPersistence() bool
func (*MatchPresence) GetSessionId ¶
func (p *MatchPresence) GetSessionId() string
func (*MatchPresence) GetStatus ¶
func (p *MatchPresence) GetStatus() string
func (*MatchPresence) GetUserId ¶
func (p *MatchPresence) GetUserId() string
func (*MatchPresence) GetUsername ¶
func (p *MatchPresence) GetUsername() string
type MatchPresenceList ¶
Maintains the match presences for routing and validation purposes.
func NewMatchPresenceList ¶
func NewMatchPresenceList() *MatchPresenceList
func (*MatchPresenceList) Contains ¶
func (m *MatchPresenceList) Contains(presence *PresenceID) bool
func (*MatchPresenceList) FilterPresenceIDs ¶ added in v3.1.0
func (m *MatchPresenceList) FilterPresenceIDs(ids []*PresenceID) []*PresenceID
func (*MatchPresenceList) Join ¶
func (m *MatchPresenceList) Join(joins []*MatchPresence) []*MatchPresence
func (*MatchPresenceList) Leave ¶
func (m *MatchPresenceList) Leave(leaves []*MatchPresence) []*MatchPresence
func (*MatchPresenceList) ListPresenceIDs ¶
func (m *MatchPresenceList) ListPresenceIDs() []*PresenceID
func (*MatchPresenceList) ListPresences ¶
func (m *MatchPresenceList) ListPresences() []*MatchPresence
func (*MatchPresenceList) Size ¶
func (m *MatchPresenceList) Size() int
type MatchPresenceListItem ¶
type MatchPresenceListItem struct {
PresenceID *PresenceID
Presence *MatchPresence
}
type MatchProvider ¶
func NewMatchProvider ¶
func NewMatchProvider() *MatchProvider
func (*MatchProvider) CreateMatch ¶
func (*MatchProvider) RegisterCreateFn ¶
func (mp *MatchProvider) RegisterCreateFn(name string, fn RuntimeMatchCreateFunction)
type MatchRegistry ¶
type MatchRegistry interface {
// Create and start a new match, given a Lua module name or registered Go match function.
CreateMatch(ctx context.Context, logger *zap.Logger, createFn RuntimeMatchCreateFunction, module string, params map[string]interface{}) (string, error)
// Register and initialise a match that's ready to run.
NewMatch(logger *zap.Logger, id uuid.UUID, core RuntimeMatchCore, stopped *atomic.Bool, params map[string]interface{}) (*MatchHandler, error)
// Return a match by ID.
GetMatch(ctx context.Context, id string) (*api.Match, error)
// Remove a tracked match and ensure all its presences are cleaned up.
// Does not ensure the match process itself is no longer running, that must be handled separately.
RemoveMatch(id uuid.UUID, stream PresenceStream)
// Update the label entry for a given match.
UpdateMatchLabel(id uuid.UUID, tickRate int, handlerName, label string) error
// List (and optionally filter) currently running matches.
// This can list across both authoritative and relayed matches.
ListMatches(ctx context.Context, limit int, authoritative *wrappers.BoolValue, label *wrappers.StringValue, minSize *wrappers.Int32Value, maxSize *wrappers.Int32Value, query *wrappers.StringValue) ([]*api.Match, error)
// Stop the match registry and close all matches it's tracking.
Stop(graceSeconds int) chan struct{}
// Returns the total number of currently active authoritative matches.
Count() int
// Pass a user join attempt to a match handler. Returns if the match was found, if the join was accepted, if it's a new user for this match, a reason for any rejection, the match label, and the list of existing match participants.
JoinAttempt(ctx context.Context, id uuid.UUID, node string, userID, sessionID uuid.UUID, username string, sessionExpiry int64, vars map[string]string, clientIP, clientPort, fromNode string, metadata map[string]string) (bool, bool, bool, string, string, []*MatchPresence)
// Notify a match handler that one or more users have successfully joined the match.
// Expects that the caller has already determined the match is hosted on the current node.
Join(id uuid.UUID, presences []*MatchPresence)
// Notify a match handler that one or more users have left or disconnected.
// Expects that the caller has already determined the match is hosted on the current node.
Leave(id uuid.UUID, presences []*MatchPresence)
// Called by match handlers to request the removal fo a match participant.
Kick(stream PresenceStream, presences []*MatchPresence)
// Pass a data payload (usually from a user) to the appropriate match handler.
// Assumes that the data sender has already been validated as a match participant before this call.
SendData(id uuid.UUID, node string, userID, sessionID uuid.UUID, username, fromNode string, opCode int64, data []byte, reliable bool, receiveTime int64)
// Get a snapshot of the match state in a string representation.
GetState(ctx context.Context, id uuid.UUID, node string) ([]*rtapi.UserPresence, int64, string, error)
}
func NewLocalMatchRegistry ¶
func NewLocalMatchRegistry(logger, startupLogger *zap.Logger, config Config, sessionRegistry SessionRegistry, tracker Tracker, router MessageRouter, metrics *Metrics, node string) MatchRegistry
type Matchmaker ¶
type Matchmaker interface {
Stop()
Add(presences []*MatchmakerPresence, sessionID, partyId, query string, minCount, maxCount int, stringProperties map[string]string, numericProperties map[string]float64) (string, error)
RemoveSession(sessionID, ticket string) error
RemoveSessionAll(sessionID string) error
RemoveParty(partyID, ticket string) error
RemovePartyAll(partyID string) error
}
func NewLocalMatchmaker ¶
func NewLocalMatchmaker(logger, startupLogger *zap.Logger, config Config, router MessageRouter, runtime *Runtime) Matchmaker
type MatchmakerConfig ¶
type MatchmakerConfig struct {
MaxTickets int `` /* 135-byte string literal not displayed */
IntervalSec int `yaml:"interval_sec" json:"interval_sec" usage:"How quickly the matchmaker attempts to form matches, in seconds. Default 15."`
MaxIntervals int `` /* 171-byte string literal not displayed */
}
func NewMatchmakerConfig ¶
func NewMatchmakerConfig() *MatchmakerConfig
type MatchmakerEntry ¶
type MatchmakerEntry struct {
Ticket string `json:"ticket"`
Presence *MatchmakerPresence `json:"presence"`
Properties map[string]interface{} `json:"properties"`
PartyId string `json:"party_id"`
StringProperties map[string]string `json:"-"`
NumericProperties map[string]float64 `json:"-"`
}
func (*MatchmakerEntry) GetPartyId ¶
func (m *MatchmakerEntry) GetPartyId() string
func (*MatchmakerEntry) GetPresence ¶
func (m *MatchmakerEntry) GetPresence() runtime.Presence
func (*MatchmakerEntry) GetProperties ¶
func (m *MatchmakerEntry) GetProperties() map[string]interface{}
func (*MatchmakerEntry) GetTicket ¶
func (m *MatchmakerEntry) GetTicket() string
type MatchmakerIndex ¶
type MatchmakerIndex struct {
Ticket string `json:"ticket"`
Properties map[string]interface{} `json:"properties"`
MinCount int `json:"min_count"`
MaxCount int `json:"max_count"`
PartyId string `json:"party_id"`
CreatedAt int64 `json:"created_at"`
// Parameters used for correctly processing various matchmaker operations, but not indexed for searching.
Query string `json:"-"`
Count int `json:"-"`
SessionID string `json:"-"`
Intervals int `json:"-"`
SessionIDs map[string]struct{} `json:"-"`
}
type MatchmakerPresence ¶
type MatchmakerPresence struct {
UserId string `json:"user_id"`
SessionId string `json:"session_id"`
Username string `json:"username"`
Node string `json:"node"`
SessionID uuid.UUID `json:"-"`
}
func (*MatchmakerPresence) GetHidden ¶
func (p *MatchmakerPresence) GetHidden() bool
func (*MatchmakerPresence) GetNodeId ¶
func (p *MatchmakerPresence) GetNodeId() string
func (*MatchmakerPresence) GetPersistence ¶
func (p *MatchmakerPresence) GetPersistence() bool
func (*MatchmakerPresence) GetSessionId ¶
func (p *MatchmakerPresence) GetSessionId() string
func (*MatchmakerPresence) GetStatus ¶
func (p *MatchmakerPresence) GetStatus() string
func (*MatchmakerPresence) GetUserId ¶
func (p *MatchmakerPresence) GetUserId() string
func (*MatchmakerPresence) GetUsername ¶
func (p *MatchmakerPresence) GetUsername() string
type MessageRouter ¶
type MessageRouter interface {
SendToPresenceIDs(*zap.Logger, []*PresenceID, *rtapi.Envelope, bool)
SendToStream(*zap.Logger, PresenceStream, *rtapi.Envelope, bool)
SendDeferred(*zap.Logger, []*DeferredMessage)
}
MessageRouter is responsible for sending a message to a list of presences or to an entire stream.
func NewLocalMessageRouter ¶
func NewLocalMessageRouter(sessionRegistry SessionRegistry, tracker Tracker, jsonpbMarshaler *jsonpb.Marshaler) MessageRouter
type MethodName ¶
type MethodName string
type Metrics ¶
type Metrics struct {
SnapshotLatencyMs *atomic.Float64
SnapshotRateSec *atomic.Float64
SnapshotRecvKbSec *atomic.Float64
SnapshotSentKbSec *atomic.Float64
// contains filtered or unexported fields
}
func (*Metrics) CountDroppedEvents ¶
Increment the number of dropped events.
func (*Metrics) CountWebsocketClosed ¶
Increment the number of closed WS connections.
func (*Metrics) CountWebsocketOpened ¶
Increment the number of opened WS connections.
func (*Metrics) GaugeAuthoritativeMatches ¶
Set the absolute value of currently running authoritative matches.
func (*Metrics) GaugeJsRuntimes ¶
Set the absolute value of currently allocated JavaScript runtime VMs.
func (*Metrics) GaugeLuaRuntimes ¶
Set the absolute value of currently allocated Lua runtime VMs.
func (*Metrics) GaugePresences ¶
Set the absolute value of currently tracked presences.
func (*Metrics) GaugeRuntimes ¶
Set the absolute value of currently allocated Lua runtime VMs.
func (*Metrics) GaugeSessions ¶
Set the absolute value of currently active sessions.
func (*Metrics) MessageBytesSent ¶
type MetricsConfig ¶
type MetricsConfig struct {
ReportingFreqSec int `yaml:"reporting_freq_sec" json:"reporting_freq_sec" usage:"Frequency of metrics exports. Default is 60 seconds."`
Namespace string `yaml:"namespace" json:"namespace" usage:"Namespace for Prometheus metrics. It will always prepend node name."`
PrometheusPort int `yaml:"prometheus_port" json:"prometheus_port" usage:"Port to expose Prometheus. If '0' Prometheus exports are disabled."`
Prefix string `yaml:"prefix" json:"prefix" usage:"Prefix for metric names. Default is 'nakama', empty string '' disables the prefix."`
}
MetricsConfig is configuration relevant to metrics capturing and output.
func NewMetricsConfig ¶
func NewMetricsConfig() *MetricsConfig
NewMetricsConfig creates a new MatricsConfig struct.
type MetricsGrpcHandler ¶
type MetricsGrpcHandler struct {
// contains filtered or unexported fields
}
func (*MetricsGrpcHandler) HandleConn ¶
func (m *MetricsGrpcHandler) HandleConn(context.Context, stats.ConnStats)
HandleConn processes the Conn stats.
func (*MetricsGrpcHandler) HandleRPC ¶
func (m *MetricsGrpcHandler) HandleRPC(ctx context.Context, rs stats.RPCStats)
HandleRPC processes the RPC stats.
func (*MetricsGrpcHandler) TagConn ¶
func (m *MetricsGrpcHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context
TagConn can attach some information to the given context. The returned context will be used for stats handling. For conn stats handling, the context used in HandleConn for this connection will be derived from the context returned. For RPC stats handling,
- On server side, the context used in HandleRPC for all RPCs on this
connection will be derived from the context returned.
- On client side, the context is not derived from the context returned.
func (*MetricsGrpcHandler) TagRPC ¶
func (m *MetricsGrpcHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context
TagRPC can attach some information to the given context. The context used for the rest lifetime of the RPC will be derived from the returned context.
type OrderedTournaments ¶
type OrderedTournaments []*Leaderboard
Type alias for a list of tournaments that binds together sorting functions. Not intended to be used for sorting lists of non-tournament leaderboards.
func (OrderedTournaments) Len ¶
func (t OrderedTournaments) Len() int
func (OrderedTournaments) Less ¶
func (t OrderedTournaments) Less(i, j int) bool
func (OrderedTournaments) Swap ¶
func (t OrderedTournaments) Swap(i, j int)
type PartyHandler ¶
type PartyHandler struct {
sync.RWMutex
ID uuid.UUID
Node string
IDStr string
Open bool
MaxSize int
Stream PresenceStream
// contains filtered or unexported fields
}
func NewPartyHandler ¶
func NewPartyHandler(logger *zap.Logger, partyRegistry PartyRegistry, matchmaker Matchmaker, tracker Tracker, streamManager StreamManager, router MessageRouter, id uuid.UUID, node string, open bool, maxSize int) *PartyHandler
func (*PartyHandler) Accept ¶
func (p *PartyHandler) Accept(sessionID, node string, presence *rtapi.UserPresence) error
func (*PartyHandler) Close ¶
func (p *PartyHandler) Close(sessionID, node string) error
func (*PartyHandler) DataSend ¶
func (p *PartyHandler) DataSend(sessionID, node string, opCode int64, data []byte) error
func (*PartyHandler) Join ¶
func (p *PartyHandler) Join(presences []*Presence)
func (*PartyHandler) JoinRequest ¶
func (p *PartyHandler) JoinRequest(presence *Presence) (bool, error)
func (*PartyHandler) JoinRequestList ¶
func (p *PartyHandler) JoinRequestList(sessionID, node string) ([]*rtapi.UserPresence, error)
func (*PartyHandler) Leave ¶
func (p *PartyHandler) Leave(presences []*Presence)
func (*PartyHandler) MatchmakerAdd ¶
func (*PartyHandler) MatchmakerRemove ¶
func (p *PartyHandler) MatchmakerRemove(sessionID, node, ticket string) error
func (*PartyHandler) Promote ¶
func (p *PartyHandler) Promote(sessionID, node string, presence *rtapi.UserPresence) error
func (*PartyHandler) Remove ¶
func (p *PartyHandler) Remove(sessionID, node string, presence *rtapi.UserPresence) error
type PartyRegistry ¶
type PartyRegistry interface {
Create(open bool, maxSize int) *PartyHandler
Delete(id uuid.UUID)
Join(id uuid.UUID, presences []*Presence)
Leave(id uuid.UUID, presences []*Presence)
PartyJoinRequest(ctx context.Context, id uuid.UUID, node string, presence *Presence) (bool, error)
PartyPromote(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, presence *rtapi.UserPresence) error
PartyAccept(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, presence *rtapi.UserPresence) error
PartyRemove(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, presence *rtapi.UserPresence) error
PartyClose(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string) error
PartyJoinRequestList(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string) ([]*rtapi.UserPresence, error)
PartyMatchmakerAdd(ctx context.Context, id uuid.UUID, node, sessionID, fromNode, query string, minCount, maxCount int, stringProperties map[string]string, numericProperties map[string]float64) (string, error)
PartyMatchmakerRemove(ctx context.Context, id uuid.UUID, node, sessionID, fromNode, ticket string) error
PartyDataSend(ctx context.Context, id uuid.UUID, node, sessionID, fromNode string, opCode int64, data []byte) error
}
func NewLocalPartyRegistry ¶
func NewLocalPartyRegistry(logger *zap.Logger, matchmaker Matchmaker, tracker Tracker, streamManager StreamManager, router MessageRouter, node string) PartyRegistry
type Pipeline ¶
type Pipeline struct {
// contains filtered or unexported fields
}
func NewPipeline ¶
func NewPipeline(logger *zap.Logger, config Config, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, jsonpbUnmarshaler *jsonpb.Unmarshaler, sessionRegistry SessionRegistry, matchRegistry MatchRegistry, partyRegistry PartyRegistry, matchmaker Matchmaker, tracker Tracker, router MessageRouter, runtime *Runtime) *Pipeline
type Presence ¶
type Presence struct {
ID PresenceID
Stream PresenceStream
UserID uuid.UUID
Meta PresenceMeta
}
func (*Presence) GetPersistence ¶
func (*Presence) GetSessionId ¶
func (*Presence) GetUsername ¶
type PresenceEvent ¶
type PresenceID ¶
type PresenceMeta ¶
type PresenceMeta struct {
Format SessionFormat
Hidden bool
Persistence bool
Username string
Status string
}
func (*PresenceMeta) GetHidden ¶
func (pm *PresenceMeta) GetHidden() bool
func (*PresenceMeta) GetPersistence ¶
func (pm *PresenceMeta) GetPersistence() bool
func (*PresenceMeta) GetStatus ¶
func (pm *PresenceMeta) GetStatus() string
func (*PresenceMeta) GetUsername ¶
func (pm *PresenceMeta) GetUsername() string
type PresenceStream ¶
type Runtime ¶
type Runtime struct {
// contains filtered or unexported fields
}
func (*Runtime) AfterAddFriends ¶
func (r *Runtime) AfterAddFriends() RuntimeAfterAddFriendsFunction
func (*Runtime) AfterAddGroupUsers ¶
func (r *Runtime) AfterAddGroupUsers() RuntimeAfterAddGroupUsersFunction
func (*Runtime) AfterAuthenticateApple ¶
func (r *Runtime) AfterAuthenticateApple() RuntimeAfterAuthenticateAppleFunction
func (*Runtime) AfterAuthenticateCustom ¶
func (r *Runtime) AfterAuthenticateCustom() RuntimeAfterAuthenticateCustomFunction
func (*Runtime) AfterAuthenticateDevice ¶
func (r *Runtime) AfterAuthenticateDevice() RuntimeAfterAuthenticateDeviceFunction
func (*Runtime) AfterAuthenticateEmail ¶
func (r *Runtime) AfterAuthenticateEmail() RuntimeAfterAuthenticateEmailFunction
func (*Runtime) AfterAuthenticateFacebook ¶
func (r *Runtime) AfterAuthenticateFacebook() RuntimeAfterAuthenticateFacebookFunction
func (*Runtime) AfterAuthenticateFacebookInstantGame ¶
func (r *Runtime) AfterAuthenticateFacebookInstantGame() RuntimeAfterAuthenticateFacebookInstantGameFunction
func (*Runtime) AfterAuthenticateGameCenter ¶
func (r *Runtime) AfterAuthenticateGameCenter() RuntimeAfterAuthenticateGameCenterFunction
func (*Runtime) AfterAuthenticateGoogle ¶
func (r *Runtime) AfterAuthenticateGoogle() RuntimeAfterAuthenticateGoogleFunction
func (*Runtime) AfterAuthenticateSteam ¶
func (r *Runtime) AfterAuthenticateSteam() RuntimeAfterAuthenticateSteamFunction
func (*Runtime) AfterBanGroupUsers ¶
func (r *Runtime) AfterBanGroupUsers() RuntimeAfterBanGroupUsersFunction
func (*Runtime) AfterBlockFriends ¶
func (r *Runtime) AfterBlockFriends() RuntimeAfterBlockFriendsFunction
func (*Runtime) AfterCreateGroup ¶
func (r *Runtime) AfterCreateGroup() RuntimeAfterCreateGroupFunction
func (*Runtime) AfterDeleteFriends ¶
func (r *Runtime) AfterDeleteFriends() RuntimeAfterDeleteFriendsFunction
func (*Runtime) AfterDeleteGroup ¶
func (r *Runtime) AfterDeleteGroup() RuntimeAfterDeleteGroupFunction
func (*Runtime) AfterDeleteLeaderboardRecord ¶
func (r *Runtime) AfterDeleteLeaderboardRecord() RuntimeAfterDeleteLeaderboardRecordFunction
func (*Runtime) AfterDeleteNotification ¶
func (r *Runtime) AfterDeleteNotification() RuntimeAfterDeleteNotificationFunction
func (*Runtime) AfterDeleteStorageObjects ¶
func (r *Runtime) AfterDeleteStorageObjects() RuntimeAfterDeleteStorageObjectsFunction
func (*Runtime) AfterDemoteGroupUsers ¶
func (r *Runtime) AfterDemoteGroupUsers() RuntimeAfterDemoteGroupUsersFunction
func (*Runtime) AfterEvent ¶
func (r *Runtime) AfterEvent() RuntimeAfterEventFunction
func (*Runtime) AfterGetAccount ¶
func (r *Runtime) AfterGetAccount() RuntimeAfterGetAccountFunction
func (*Runtime) AfterGetUsers ¶
func (r *Runtime) AfterGetUsers() RuntimeAfterGetUsersFunction
func (*Runtime) AfterImportFacebookFriends ¶
func (r *Runtime) AfterImportFacebookFriends() RuntimeAfterImportFacebookFriendsFunction
func (*Runtime) AfterImportSteamFriends ¶ added in v3.1.0
func (r *Runtime) AfterImportSteamFriends() RuntimeAfterImportSteamFriendsFunction
func (*Runtime) AfterJoinGroup ¶
func (r *Runtime) AfterJoinGroup() RuntimeAfterJoinGroupFunction
func (*Runtime) AfterJoinTournament ¶
func (r *Runtime) AfterJoinTournament() RuntimeAfterJoinTournamentFunction
func (*Runtime) AfterKickGroupUsers ¶
func (r *Runtime) AfterKickGroupUsers() RuntimeAfterKickGroupUsersFunction
func (*Runtime) AfterLeaveGroup ¶
func (r *Runtime) AfterLeaveGroup() RuntimeAfterLeaveGroupFunction
func (*Runtime) AfterLinkApple ¶
func (r *Runtime) AfterLinkApple() RuntimeAfterLinkAppleFunction
func (*Runtime) AfterLinkCustom ¶
func (r *Runtime) AfterLinkCustom() RuntimeAfterLinkCustomFunction
func (*Runtime) AfterLinkDevice ¶
func (r *Runtime) AfterLinkDevice() RuntimeAfterLinkDeviceFunction
func (*Runtime) AfterLinkEmail ¶
func (r *Runtime) AfterLinkEmail() RuntimeAfterLinkEmailFunction
func (*Runtime) AfterLinkFacebook ¶
func (r *Runtime) AfterLinkFacebook() RuntimeAfterLinkFacebookFunction
func (*Runtime) AfterLinkFacebookInstantGame ¶
func (r *Runtime) AfterLinkFacebookInstantGame() RuntimeAfterLinkFacebookInstantGameFunction
func (*Runtime) AfterLinkGameCenter ¶
func (r *Runtime) AfterLinkGameCenter() RuntimeAfterLinkGameCenterFunction
func (*Runtime) AfterLinkGoogle ¶
func (r *Runtime) AfterLinkGoogle() RuntimeAfterLinkGoogleFunction
func (*Runtime) AfterLinkSteam ¶
func (r *Runtime) AfterLinkSteam() RuntimeAfterLinkSteamFunction
func (*Runtime) AfterListChannelMessages ¶
func (r *Runtime) AfterListChannelMessages() RuntimeAfterListChannelMessagesFunction
func (*Runtime) AfterListFriends ¶
func (r *Runtime) AfterListFriends() RuntimeAfterListFriendsFunction
func (*Runtime) AfterListGroupUsers ¶
func (r *Runtime) AfterListGroupUsers() RuntimeAfterListGroupUsersFunction
func (*Runtime) AfterListGroups ¶
func (r *Runtime) AfterListGroups() RuntimeAfterListGroupsFunction
func (*Runtime) AfterListLeaderboardRecords ¶
func (r *Runtime) AfterListLeaderboardRecords() RuntimeAfterListLeaderboardRecordsFunction
func (*Runtime) AfterListLeaderboardRecordsAroundOwner ¶
func (r *Runtime) AfterListLeaderboardRecordsAroundOwner() RuntimeAfterListLeaderboardRecordsAroundOwnerFunction
func (*Runtime) AfterListMatches ¶
func (r *Runtime) AfterListMatches() RuntimeAfterListMatchesFunction
func (*Runtime) AfterListNotifications ¶
func (r *Runtime) AfterListNotifications() RuntimeAfterListNotificationsFunction
func (*Runtime) AfterListStorageObjects ¶
func (r *Runtime) AfterListStorageObjects() RuntimeAfterListStorageObjectsFunction
func (*Runtime) AfterListTournamentRecords ¶
func (r *Runtime) AfterListTournamentRecords() RuntimeAfterListTournamentRecordsFunction
func (*Runtime) AfterListTournamentRecordsAroundOwner ¶
func (r *Runtime) AfterListTournamentRecordsAroundOwner() RuntimeAfterListTournamentRecordsAroundOwnerFunction
func (*Runtime) AfterListTournaments ¶
func (r *Runtime) AfterListTournaments() RuntimeAfterListTournamentsFunction
func (*Runtime) AfterListUserGroups ¶
func (r *Runtime) AfterListUserGroups() RuntimeAfterListUserGroupsFunction
func (*Runtime) AfterPromoteGroupUsers ¶
func (r *Runtime) AfterPromoteGroupUsers() RuntimeAfterPromoteGroupUsersFunction
func (*Runtime) AfterReadStorageObjects ¶
func (r *Runtime) AfterReadStorageObjects() RuntimeAfterReadStorageObjectsFunction
func (*Runtime) AfterRt ¶
func (r *Runtime) AfterRt(id string) RuntimeAfterRtFunction
func (*Runtime) AfterSessionRefresh ¶
func (r *Runtime) AfterSessionRefresh() RuntimeAfterSessionRefreshFunction
func (*Runtime) AfterUnlinkApple ¶
func (r *Runtime) AfterUnlinkApple() RuntimeAfterUnlinkAppleFunction
func (*Runtime) AfterUnlinkCustom ¶
func (r *Runtime) AfterUnlinkCustom() RuntimeAfterUnlinkCustomFunction
func (*Runtime) AfterUnlinkDevice ¶
func (r *Runtime) AfterUnlinkDevice() RuntimeAfterUnlinkDeviceFunction
func (*Runtime) AfterUnlinkEmail ¶
func (r *Runtime) AfterUnlinkEmail() RuntimeAfterUnlinkEmailFunction
func (*Runtime) AfterUnlinkFacebook ¶
func (r *Runtime) AfterUnlinkFacebook() RuntimeAfterUnlinkFacebookFunction
func (*Runtime) AfterUnlinkFacebookInstantGame ¶
func (r *Runtime) AfterUnlinkFacebookInstantGame() RuntimeAfterUnlinkFacebookInstantGameFunction
func (*Runtime) AfterUnlinkGameCenter ¶
func (r *Runtime) AfterUnlinkGameCenter() RuntimeAfterUnlinkGameCenterFunction
func (*Runtime) AfterUnlinkGoogle ¶
func (r *Runtime) AfterUnlinkGoogle() RuntimeAfterUnlinkGoogleFunction
func (*Runtime) AfterUnlinkSteam ¶
func (r *Runtime) AfterUnlinkSteam() RuntimeAfterUnlinkSteamFunction
func (*Runtime) AfterUpdateAccount ¶
func (r *Runtime) AfterUpdateAccount() RuntimeAfterUpdateAccountFunction
func (*Runtime) AfterUpdateGroup ¶
func (r *Runtime) AfterUpdateGroup() RuntimeAfterUpdateGroupFunction
func (*Runtime) AfterWriteLeaderboardRecord ¶
func (r *Runtime) AfterWriteLeaderboardRecord() RuntimeAfterWriteLeaderboardRecordFunction
func (*Runtime) AfterWriteStorageObjects ¶
func (r *Runtime) AfterWriteStorageObjects() RuntimeAfterWriteStorageObjectsFunction
func (*Runtime) AfterWriteTournamentRecord ¶
func (r *Runtime) AfterWriteTournamentRecord() RuntimeAfterWriteTournamentRecordFunction
func (*Runtime) BeforeAddFriends ¶
func (r *Runtime) BeforeAddFriends() RuntimeBeforeAddFriendsFunction
func (*Runtime) BeforeAddGroupUsers ¶
func (r *Runtime) BeforeAddGroupUsers() RuntimeBeforeAddGroupUsersFunction
func (*Runtime) BeforeAuthenticateApple ¶
func (r *Runtime) BeforeAuthenticateApple() RuntimeBeforeAuthenticateAppleFunction
func (*Runtime) BeforeAuthenticateCustom ¶
func (r *Runtime) BeforeAuthenticateCustom() RuntimeBeforeAuthenticateCustomFunction
func (*Runtime) BeforeAuthenticateDevice ¶
func (r *Runtime) BeforeAuthenticateDevice() RuntimeBeforeAuthenticateDeviceFunction
func (*Runtime) BeforeAuthenticateEmail ¶
func (r *Runtime) BeforeAuthenticateEmail() RuntimeBeforeAuthenticateEmailFunction
func (*Runtime) BeforeAuthenticateFacebook ¶
func (r *Runtime) BeforeAuthenticateFacebook() RuntimeBeforeAuthenticateFacebookFunction
func (*Runtime) BeforeAuthenticateFacebookInstantGame ¶
func (r *Runtime) BeforeAuthenticateFacebookInstantGame() RuntimeBeforeAuthenticateFacebookInstantGameFunction
func (*Runtime) BeforeAuthenticateGameCenter ¶
func (r *Runtime) BeforeAuthenticateGameCenter() RuntimeBeforeAuthenticateGameCenterFunction
func (*Runtime) BeforeAuthenticateGoogle ¶
func (r *Runtime) BeforeAuthenticateGoogle() RuntimeBeforeAuthenticateGoogleFunction
func (*Runtime) BeforeAuthenticateSteam ¶
func (r *Runtime) BeforeAuthenticateSteam() RuntimeBeforeAuthenticateSteamFunction
func (*Runtime) BeforeBanGroupUsers ¶
func (r *Runtime) BeforeBanGroupUsers() RuntimeBeforeBanGroupUsersFunction
func (*Runtime) BeforeBlockFriends ¶
func (r *Runtime) BeforeBlockFriends() RuntimeBeforeBlockFriendsFunction
func (*Runtime) BeforeCreateGroup ¶
func (r *Runtime) BeforeCreateGroup() RuntimeBeforeCreateGroupFunction
func (*Runtime) BeforeDeleteFriends ¶
func (r *Runtime) BeforeDeleteFriends() RuntimeBeforeDeleteFriendsFunction
func (*Runtime) BeforeDeleteGroup ¶
func (r *Runtime) BeforeDeleteGroup() RuntimeBeforeDeleteGroupFunction
func (*Runtime) BeforeDeleteLeaderboardRecord ¶
func (r *Runtime) BeforeDeleteLeaderboardRecord() RuntimeBeforeDeleteLeaderboardRecordFunction
func (*Runtime) BeforeDeleteNotification ¶
func (r *Runtime) BeforeDeleteNotification() RuntimeBeforeDeleteNotificationFunction
func (*Runtime) BeforeDeleteStorageObjects ¶
func (r *Runtime) BeforeDeleteStorageObjects() RuntimeBeforeDeleteStorageObjectsFunction
func (*Runtime) BeforeDemoteGroupUsers ¶
func (r *Runtime) BeforeDemoteGroupUsers() RuntimeBeforeDemoteGroupUsersFunction
func (*Runtime) BeforeEvent ¶
func (r *Runtime) BeforeEvent() RuntimeBeforeEventFunction
func (*Runtime) BeforeGetAccount ¶
func (r *Runtime) BeforeGetAccount() RuntimeBeforeGetAccountFunction
func (*Runtime) BeforeGetUsers ¶
func (r *Runtime) BeforeGetUsers() RuntimeBeforeGetUsersFunction
func (*Runtime) BeforeImportFacebookFriends ¶
func (r *Runtime) BeforeImportFacebookFriends() RuntimeBeforeImportFacebookFriendsFunction
func (*Runtime) BeforeImportSteamFriends ¶ added in v3.1.0
func (r *Runtime) BeforeImportSteamFriends() RuntimeBeforeImportSteamFriendsFunction
func (*Runtime) BeforeJoinGroup ¶
func (r *Runtime) BeforeJoinGroup() RuntimeBeforeJoinGroupFunction
func (*Runtime) BeforeJoinTournament ¶
func (r *Runtime) BeforeJoinTournament() RuntimeBeforeJoinTournamentFunction
func (*Runtime) BeforeKickGroupUsers ¶
func (r *Runtime) BeforeKickGroupUsers() RuntimeBeforeKickGroupUsersFunction
func (*Runtime) BeforeLeaveGroup ¶
func (r *Runtime) BeforeLeaveGroup() RuntimeBeforeLeaveGroupFunction
func (*Runtime) BeforeLinkApple ¶
func (r *Runtime) BeforeLinkApple() RuntimeBeforeLinkAppleFunction
func (*Runtime) BeforeLinkCustom ¶
func (r *Runtime) BeforeLinkCustom() RuntimeBeforeLinkCustomFunction
func (*Runtime) BeforeLinkDevice ¶
func (r *Runtime) BeforeLinkDevice() RuntimeBeforeLinkDeviceFunction
func (*Runtime) BeforeLinkEmail ¶
func (r *Runtime) BeforeLinkEmail() RuntimeBeforeLinkEmailFunction
func (*Runtime) BeforeLinkFacebook ¶
func (r *Runtime) BeforeLinkFacebook() RuntimeBeforeLinkFacebookFunction
func (*Runtime) BeforeLinkFacebookInstantGame ¶
func (r *Runtime) BeforeLinkFacebookInstantGame() RuntimeBeforeLinkFacebookInstantGameFunction
func (*Runtime) BeforeLinkGameCenter ¶
func (r *Runtime) BeforeLinkGameCenter() RuntimeBeforeLinkGameCenterFunction
func (*Runtime) BeforeLinkGoogle ¶
func (r *Runtime) BeforeLinkGoogle() RuntimeBeforeLinkGoogleFunction
func (*Runtime) BeforeLinkSteam ¶
func (r *Runtime) BeforeLinkSteam() RuntimeBeforeLinkSteamFunction
func (*Runtime) BeforeListChannelMessages ¶
func (r *Runtime) BeforeListChannelMessages() RuntimeBeforeListChannelMessagesFunction
func (*Runtime) BeforeListFriends ¶
func (r *Runtime) BeforeListFriends() RuntimeBeforeListFriendsFunction
func (*Runtime) BeforeListGroupUsers ¶
func (r *Runtime) BeforeListGroupUsers() RuntimeBeforeListGroupUsersFunction
func (*Runtime) BeforeListGroups ¶
func (r *Runtime) BeforeListGroups() RuntimeBeforeListGroupsFunction
func (*Runtime) BeforeListLeaderboardRecords ¶
func (r *Runtime) BeforeListLeaderboardRecords() RuntimeBeforeListLeaderboardRecordsFunction
func (*Runtime) BeforeListLeaderboardRecordsAroundOwner ¶
func (r *Runtime) BeforeListLeaderboardRecordsAroundOwner() RuntimeBeforeListLeaderboardRecordsAroundOwnerFunction
func (*Runtime) BeforeListMatches ¶
func (r *Runtime) BeforeListMatches() RuntimeBeforeListMatchesFunction
func (*Runtime) BeforeListNotifications ¶
func (r *Runtime) BeforeListNotifications() RuntimeBeforeListNotificationsFunction
func (*Runtime) BeforeListStorageObjects ¶
func (r *Runtime) BeforeListStorageObjects() RuntimeBeforeListStorageObjectsFunction
func (*Runtime) BeforeListTournamentRecords ¶
func (r *Runtime) BeforeListTournamentRecords() RuntimeBeforeListTournamentRecordsFunction
func (*Runtime) BeforeListTournamentRecordsAroundOwner ¶
func (r *Runtime) BeforeListTournamentRecordsAroundOwner() RuntimeBeforeListTournamentRecordsAroundOwnerFunction
func (*Runtime) BeforeListTournaments ¶
func (r *Runtime) BeforeListTournaments() RuntimeBeforeListTournamentsFunction
func (*Runtime) BeforeListUserGroups ¶
func (r *Runtime) BeforeListUserGroups() RuntimeBeforeListUserGroupsFunction
func (*Runtime) BeforePromoteGroupUsers ¶
func (r *Runtime) BeforePromoteGroupUsers() RuntimeBeforePromoteGroupUsersFunction
func (*Runtime) BeforeReadStorageObjects ¶
func (r *Runtime) BeforeReadStorageObjects() RuntimeBeforeReadStorageObjectsFunction
func (*Runtime) BeforeRt ¶
func (r *Runtime) BeforeRt(id string) RuntimeBeforeRtFunction
func (*Runtime) BeforeSessionRefresh ¶
func (r *Runtime) BeforeSessionRefresh() RuntimeBeforeSessionRefreshFunction
func (*Runtime) BeforeUnlinkApple ¶
func (r *Runtime) BeforeUnlinkApple() RuntimeBeforeUnlinkAppleFunction
func (*Runtime) BeforeUnlinkCustom ¶
func (r *Runtime) BeforeUnlinkCustom() RuntimeBeforeUnlinkCustomFunction
func (*Runtime) BeforeUnlinkDevice ¶
func (r *Runtime) BeforeUnlinkDevice() RuntimeBeforeUnlinkDeviceFunction
func (*Runtime) BeforeUnlinkEmail ¶
func (r *Runtime) BeforeUnlinkEmail() RuntimeBeforeUnlinkEmailFunction
func (*Runtime) BeforeUnlinkFacebook ¶
func (r *Runtime) BeforeUnlinkFacebook() RuntimeBeforeUnlinkFacebookFunction
func (*Runtime) BeforeUnlinkFacebookInstantGame ¶
func (r *Runtime) BeforeUnlinkFacebookInstantGame() RuntimeBeforeUnlinkFacebookInstantGameFunction
func (*Runtime) BeforeUnlinkGameCenter ¶
func (r *Runtime) BeforeUnlinkGameCenter() RuntimeBeforeUnlinkGameCenterFunction
func (*Runtime) BeforeUnlinkGoogle ¶
func (r *Runtime) BeforeUnlinkGoogle() RuntimeBeforeUnlinkGoogleFunction
func (*Runtime) BeforeUnlinkSteam ¶
func (r *Runtime) BeforeUnlinkSteam() RuntimeBeforeUnlinkSteamFunction
func (*Runtime) BeforeUpdateAccount ¶
func (r *Runtime) BeforeUpdateAccount() RuntimeBeforeUpdateAccountFunction
func (*Runtime) BeforeUpdateGroup ¶
func (r *Runtime) BeforeUpdateGroup() RuntimeBeforeUpdateGroupFunction
func (*Runtime) BeforeWriteLeaderboardRecord ¶
func (r *Runtime) BeforeWriteLeaderboardRecord() RuntimeBeforeWriteLeaderboardRecordFunction
func (*Runtime) BeforeWriteStorageObjects ¶
func (r *Runtime) BeforeWriteStorageObjects() RuntimeBeforeWriteStorageObjectsFunction
func (*Runtime) BeforeWriteTournamentRecord ¶
func (r *Runtime) BeforeWriteTournamentRecord() RuntimeBeforeWriteTournamentRecordFunction
func (*Runtime) Event ¶
func (r *Runtime) Event() RuntimeEventCustomFunction
func (*Runtime) EventSessionEnd ¶
func (r *Runtime) EventSessionEnd() RuntimeEventSessionEndFunction
func (*Runtime) EventSessionStart ¶
func (r *Runtime) EventSessionStart() RuntimeEventSessionStartFunction
func (*Runtime) LeaderboardReset ¶
func (r *Runtime) LeaderboardReset() RuntimeLeaderboardResetFunction
func (*Runtime) MatchCreateFunction ¶
func (r *Runtime) MatchCreateFunction() RuntimeMatchCreateFunction
func (*Runtime) MatchmakerMatched ¶
func (r *Runtime) MatchmakerMatched() RuntimeMatchmakerMatchedFunction
func (*Runtime) Rpc ¶
func (r *Runtime) Rpc(id string) RuntimeRpcFunction
func (*Runtime) TournamentEnd ¶
func (r *Runtime) TournamentEnd() RuntimeTournamentEndFunction
func (*Runtime) TournamentReset ¶
func (r *Runtime) TournamentReset() RuntimeTournamentResetFunction
type RuntimeAfterImportSteamFriendsFunction ¶ added in v3.1.0
type RuntimeAfterReqFunctions ¶
type RuntimeAfterReqFunctions struct {
// contains filtered or unexported fields
}
type RuntimeAfterRtFunction ¶
type RuntimeBeforeAuthenticateFacebookInstantGameFunction ¶
type RuntimeBeforeAuthenticateFacebookInstantGameFunction func(ctx context.Context, logger *zap.Logger, userID, username string, vars map[string]string, expiry int64, clientIP, clientPort string, in *api.AuthenticateFacebookInstantGameRequest) (*api.AuthenticateFacebookInstantGameRequest, error, codes.Code)
type RuntimeBeforeImportSteamFriendsFunction ¶ added in v3.1.0
type RuntimeBeforeListLeaderboardRecordsAroundOwnerFunction ¶
type RuntimeBeforeListLeaderboardRecordsAroundOwnerFunction func(ctx context.Context, logger *zap.Logger, userID, username string, vars map[string]string, expiry int64, clientIP, clientPort string, in *api.ListLeaderboardRecordsAroundOwnerRequest) (*api.ListLeaderboardRecordsAroundOwnerRequest, error, codes.Code)
type RuntimeBeforeListTournamentRecordsAroundOwnerFunction ¶
type RuntimeBeforeListTournamentRecordsAroundOwnerFunction func(ctx context.Context, logger *zap.Logger, userID, username string, vars map[string]string, expiry int64, clientIP, clientPort string, in *api.ListTournamentRecordsAroundOwnerRequest) (*api.ListTournamentRecordsAroundOwnerRequest, error, codes.Code)
type RuntimeBeforeReqFunctions ¶
type RuntimeBeforeReqFunctions struct {
// contains filtered or unexported fields
}
type RuntimeBeforeRtFunction ¶
type RuntimeConfig ¶
type RuntimeConfig struct {
Environment map[string]string `yaml:"-" json:"-"`
Env []string `yaml:"env" json:"env" usage:"Values to pass into Runtime as environment variables."`
Path string `yaml:"path" json:"path" usage:"Path for the server to scan for Lua and Go library files."`
HTTPKey string `yaml:"http_key" json:"http_key" usage:"Runtime HTTP Invocation key."`
MinCount int `yaml:"min_count" json:"min_count" usage:"Minimum number of Lua runtime instances to allocate. Default 16."` // Kept for backwards compatibility
LuaMinCount int `yaml:"lua_min_count" json:"lua_min_count" usage:"Minimum number of Lua runtime instances to allocate. Default 16."`
MaxCount int `yaml:"max_count" json:"max_count" usage:"Maximum number of Lua runtime instances to allocate. Default 48."` // Kept for backwards compatibility
LuaMaxCount int `yaml:"lua_max_count" json:"lua_max_count" usage:"Maximum number of Lua runtime instances to allocate. Default 48."`
JsMinCount int `yaml:"js_min_count" json:"js_min_count" usage:"Maximum number of Javascript runtime instances to allocate. Default 48."`
JsMaxCount int `yaml:"js_max_count" json:"js_max_count" usage:"Maximum number of Javascript runtime instances to allocate. Default 48."`
CallStackSize int `yaml:"call_stack_size" json:"call_stack_size" usage:"Size of each runtime instance's call stack. Default 128."` // Kept for backwards compatibility
LuaCallStackSize int `yaml:"lua_call_stack_size" json:"lua_call_stack_size" usage:"Size of each runtime instance's call stack. Default 128."`
RegistrySize int `yaml:"registry_size" json:"registry_size" usage:"Size of each Lua runtime instance's registry. Default 512."` // Kept for backwards compatibility
LuaRegistrySize int `yaml:"lua_registry_size" json:"lua_registry_size" usage:"Size of each Lua runtime instance's registry. Default 512."`
EventQueueSize int `yaml:"event_queue_size" json:"event_queue_size" usage:"Size of the event queue buffer. Default 65536."`
EventQueueWorkers int `` /* 134-byte string literal not displayed */
ReadOnlyGlobals bool `` // Kept for backwards compatibility
/* 161-byte string literal not displayed */
LuaReadOnlyGlobals bool `` /* 169-byte string literal not displayed */
JsEntrypoint string `yaml:"js_entrypoint" json:"js_entrypoint" usage:"Specifies the location of the bundled JavaScript runtime source code."`
}
RuntimeConfig is configuration relevant to the Runtime Lua VM.
func NewRuntimeConfig ¶
func NewRuntimeConfig() *RuntimeConfig
NewRuntimeConfig creates a new RuntimeConfig struct.
func (*RuntimeConfig) GetLuaCallStackSize ¶
func (r *RuntimeConfig) GetLuaCallStackSize() int
Function to allow backwards compatibility for CallStackSize config
func (*RuntimeConfig) GetLuaMaxCount ¶
func (r *RuntimeConfig) GetLuaMaxCount() int
Function to allow backwards compatibility for MaxCount config
func (*RuntimeConfig) GetLuaMinCount ¶
func (r *RuntimeConfig) GetLuaMinCount() int
Function to allow backwards compatibility for MinCount config
func (*RuntimeConfig) GetLuaReadOnlyGlobals ¶
func (r *RuntimeConfig) GetLuaReadOnlyGlobals() bool
Function to allow backwards compatibility for LuaReadOnlyGlobals config
func (*RuntimeConfig) GetLuaRegistrySize ¶
func (r *RuntimeConfig) GetLuaRegistrySize() int
Function to allow backwards compatibility for RegistrySize config
type RuntimeEventFunction ¶
type RuntimeEventFunctions ¶
type RuntimeEventFunctions struct {
// contains filtered or unexported fields
}
type RuntimeEventQueue ¶
type RuntimeEventQueue struct {
// contains filtered or unexported fields
}
func NewRuntimeEventQueue ¶
func NewRuntimeEventQueue(logger *zap.Logger, config Config, metrics *Metrics) *RuntimeEventQueue
func (*RuntimeEventQueue) Queue ¶
func (b *RuntimeEventQueue) Queue(fn func())
func (*RuntimeEventQueue) Stop ¶
func (b *RuntimeEventQueue) Stop()
type RuntimeExecutionMode ¶
type RuntimeExecutionMode int
const ( RuntimeExecutionModeEvent RuntimeExecutionMode = iota RuntimeExecutionModeRunOnce RuntimeExecutionModeRPC RuntimeExecutionModeBefore RuntimeExecutionModeAfter RuntimeExecutionModeMatch RuntimeExecutionModeMatchmaker RuntimeExecutionModeMatchCreate RuntimeExecutionModeTournamentEnd RuntimeExecutionModeTournamentReset RuntimeExecutionModeLeaderboardReset )
func (RuntimeExecutionMode) String ¶
func (e RuntimeExecutionMode) String() string
type RuntimeGoInitializer ¶
type RuntimeGoInitializer struct {
// contains filtered or unexported fields
}
func (*RuntimeGoInitializer) RegisterAfterAddFriends ¶
func (ri *RuntimeGoInitializer) RegisterAfterAddFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AddFriendsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterAddGroupUsers ¶
func (ri *RuntimeGoInitializer) RegisterAfterAddGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AddGroupUsersRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterAuthenticateApple ¶
func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.Session, in *api.AuthenticateAppleRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterAuthenticateCustom ¶
func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateCustom(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.Session, in *api.AuthenticateCustomRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterAuthenticateDevice ¶
func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateDevice(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.Session, in *api.AuthenticateDeviceRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterAuthenticateEmail ¶
func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateEmail(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.Session, in *api.AuthenticateEmailRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterAuthenticateFacebook ¶
func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateFacebook(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.Session, in *api.AuthenticateFacebookRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterAuthenticateFacebookInstantGame ¶
func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateFacebookInstantGame(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.Session, in *api.AuthenticateFacebookInstantGameRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterAuthenticateGameCenter ¶
func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateGameCenter(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.Session, in *api.AuthenticateGameCenterRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterAuthenticateGoogle ¶
func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.Session, in *api.AuthenticateGoogleRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterAuthenticateSteam ¶
func (ri *RuntimeGoInitializer) RegisterAfterAuthenticateSteam(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.Session, in *api.AuthenticateSteamRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterBanGroupUsers ¶
func (ri *RuntimeGoInitializer) RegisterAfterBanGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.BanGroupUsersRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterBlockFriends ¶
func (ri *RuntimeGoInitializer) RegisterAfterBlockFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.BlockFriendsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterCreateGroup ¶
func (ri *RuntimeGoInitializer) RegisterAfterCreateGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.Group, in *api.CreateGroupRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterDeleteFriends ¶
func (ri *RuntimeGoInitializer) RegisterAfterDeleteFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.DeleteFriendsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterDeleteGroup ¶
func (ri *RuntimeGoInitializer) RegisterAfterDeleteGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.DeleteGroupRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterDeleteLeaderboardRecord ¶
func (ri *RuntimeGoInitializer) RegisterAfterDeleteLeaderboardRecord(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.DeleteLeaderboardRecordRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterDeleteNotification ¶
func (ri *RuntimeGoInitializer) RegisterAfterDeleteNotification(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.DeleteNotificationsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterDeleteStorageObjects ¶
func (ri *RuntimeGoInitializer) RegisterAfterDeleteStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.DeleteStorageObjectsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterDemoteGroupUsers ¶
func (ri *RuntimeGoInitializer) RegisterAfterDemoteGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.DemoteGroupUsersRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterEvent ¶
func (*RuntimeGoInitializer) RegisterAfterGetAccount ¶
func (*RuntimeGoInitializer) RegisterAfterGetUsers ¶
func (ri *RuntimeGoInitializer) RegisterAfterGetUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.Users, in *api.GetUsersRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterImportFacebookFriends ¶
func (ri *RuntimeGoInitializer) RegisterAfterImportFacebookFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ImportFacebookFriendsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterImportSteamFriends ¶ added in v3.1.0
func (ri *RuntimeGoInitializer) RegisterAfterImportSteamFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ImportSteamFriendsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterJoinGroup ¶
func (ri *RuntimeGoInitializer) RegisterAfterJoinGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.JoinGroupRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterJoinTournament ¶
func (ri *RuntimeGoInitializer) RegisterAfterJoinTournament(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.JoinTournamentRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterKickGroupUsers ¶
func (ri *RuntimeGoInitializer) RegisterAfterKickGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.KickGroupUsersRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterLeaveGroup ¶
func (ri *RuntimeGoInitializer) RegisterAfterLeaveGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.LeaveGroupRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterLinkApple ¶
func (ri *RuntimeGoInitializer) RegisterAfterLinkApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountApple) error) error
func (*RuntimeGoInitializer) RegisterAfterLinkCustom ¶
func (ri *RuntimeGoInitializer) RegisterAfterLinkCustom(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountCustom) error) error
func (*RuntimeGoInitializer) RegisterAfterLinkDevice ¶
func (ri *RuntimeGoInitializer) RegisterAfterLinkDevice(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountDevice) error) error
func (*RuntimeGoInitializer) RegisterAfterLinkEmail ¶
func (ri *RuntimeGoInitializer) RegisterAfterLinkEmail(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountEmail) error) error
func (*RuntimeGoInitializer) RegisterAfterLinkFacebook ¶
func (ri *RuntimeGoInitializer) RegisterAfterLinkFacebook(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.LinkFacebookRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterLinkFacebookInstantGame ¶
func (ri *RuntimeGoInitializer) RegisterAfterLinkFacebookInstantGame(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountFacebookInstantGame) error) error
func (*RuntimeGoInitializer) RegisterAfterLinkGameCenter ¶
func (ri *RuntimeGoInitializer) RegisterAfterLinkGameCenter(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountGameCenter) error) error
func (*RuntimeGoInitializer) RegisterAfterLinkGoogle ¶
func (ri *RuntimeGoInitializer) RegisterAfterLinkGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountGoogle) error) error
func (*RuntimeGoInitializer) RegisterAfterLinkSteam ¶
func (ri *RuntimeGoInitializer) RegisterAfterLinkSteam(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.LinkSteamRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterListChannelMessages ¶
func (ri *RuntimeGoInitializer) RegisterAfterListChannelMessages(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.ChannelMessageList, in *api.ListChannelMessagesRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterListFriends ¶
func (ri *RuntimeGoInitializer) RegisterAfterListFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.FriendList) error) error
func (*RuntimeGoInitializer) RegisterAfterListGroupUsers ¶
func (ri *RuntimeGoInitializer) RegisterAfterListGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.GroupUserList, in *api.ListGroupUsersRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterListGroups ¶
func (ri *RuntimeGoInitializer) RegisterAfterListGroups(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.GroupList, in *api.ListGroupsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterListLeaderboardRecords ¶
func (ri *RuntimeGoInitializer) RegisterAfterListLeaderboardRecords(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.LeaderboardRecordList, in *api.ListLeaderboardRecordsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterListLeaderboardRecordsAroundOwner ¶
func (ri *RuntimeGoInitializer) RegisterAfterListLeaderboardRecordsAroundOwner(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.LeaderboardRecordList, in *api.ListLeaderboardRecordsAroundOwnerRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterListMatches ¶
func (ri *RuntimeGoInitializer) RegisterAfterListMatches(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.MatchList, in *api.ListMatchesRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterListNotifications ¶
func (ri *RuntimeGoInitializer) RegisterAfterListNotifications(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.NotificationList, in *api.ListNotificationsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterListStorageObjects ¶
func (ri *RuntimeGoInitializer) RegisterAfterListStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.StorageObjectList, in *api.ListStorageObjectsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterListTournamentRecords ¶
func (ri *RuntimeGoInitializer) RegisterAfterListTournamentRecords(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.TournamentRecordList, in *api.ListTournamentRecordsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterListTournamentRecordsAroundOwner ¶
func (ri *RuntimeGoInitializer) RegisterAfterListTournamentRecordsAroundOwner(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.TournamentRecordList, in *api.ListTournamentRecordsAroundOwnerRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterListTournaments ¶
func (ri *RuntimeGoInitializer) RegisterAfterListTournaments(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.TournamentList, in *api.ListTournamentsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterListUserGroups ¶
func (ri *RuntimeGoInitializer) RegisterAfterListUserGroups(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.UserGroupList, in *api.ListUserGroupsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterPromoteGroupUsers ¶
func (ri *RuntimeGoInitializer) RegisterAfterPromoteGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.PromoteGroupUsersRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterReadStorageObjects ¶
func (ri *RuntimeGoInitializer) RegisterAfterReadStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.StorageObjects, in *api.ReadStorageObjectsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterRt ¶
func (*RuntimeGoInitializer) RegisterAfterSessionRefresh ¶
func (ri *RuntimeGoInitializer) RegisterAfterSessionRefresh(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.Session, in *api.SessionRefreshRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterUnlinkApple ¶
func (ri *RuntimeGoInitializer) RegisterAfterUnlinkApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountApple) error) error
func (*RuntimeGoInitializer) RegisterAfterUnlinkCustom ¶
func (ri *RuntimeGoInitializer) RegisterAfterUnlinkCustom(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountCustom) error) error
func (*RuntimeGoInitializer) RegisterAfterUnlinkDevice ¶
func (ri *RuntimeGoInitializer) RegisterAfterUnlinkDevice(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountDevice) error) error
func (*RuntimeGoInitializer) RegisterAfterUnlinkEmail ¶
func (ri *RuntimeGoInitializer) RegisterAfterUnlinkEmail(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountEmail) error) error
func (*RuntimeGoInitializer) RegisterAfterUnlinkFacebook ¶
func (ri *RuntimeGoInitializer) RegisterAfterUnlinkFacebook(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountFacebook) error) error
func (*RuntimeGoInitializer) RegisterAfterUnlinkFacebookInstantGame ¶
func (ri *RuntimeGoInitializer) RegisterAfterUnlinkFacebookInstantGame(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountFacebookInstantGame) error) error
func (*RuntimeGoInitializer) RegisterAfterUnlinkGameCenter ¶
func (ri *RuntimeGoInitializer) RegisterAfterUnlinkGameCenter(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountGameCenter) error) error
func (*RuntimeGoInitializer) RegisterAfterUnlinkGoogle ¶
func (ri *RuntimeGoInitializer) RegisterAfterUnlinkGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountGoogle) error) error
func (*RuntimeGoInitializer) RegisterAfterUnlinkSteam ¶
func (ri *RuntimeGoInitializer) RegisterAfterUnlinkSteam(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountSteam) error) error
func (*RuntimeGoInitializer) RegisterAfterUpdateAccount ¶
func (ri *RuntimeGoInitializer) RegisterAfterUpdateAccount(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.UpdateAccountRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterUpdateGroup ¶
func (ri *RuntimeGoInitializer) RegisterAfterUpdateGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.UpdateGroupRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterWriteLeaderboardRecord ¶
func (ri *RuntimeGoInitializer) RegisterAfterWriteLeaderboardRecord(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.LeaderboardRecord, in *api.WriteLeaderboardRecordRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterWriteStorageObjects ¶
func (ri *RuntimeGoInitializer) RegisterAfterWriteStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.StorageObjectAcks, in *api.WriteStorageObjectsRequest) error) error
func (*RuntimeGoInitializer) RegisterAfterWriteTournamentRecord ¶
func (ri *RuntimeGoInitializer) RegisterAfterWriteTournamentRecord(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, out *api.LeaderboardRecord, in *api.WriteTournamentRecordRequest) error) error
func (*RuntimeGoInitializer) RegisterBeforeAddFriends ¶
func (ri *RuntimeGoInitializer) RegisterBeforeAddFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AddFriendsRequest) (*api.AddFriendsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeAddGroupUsers ¶
func (ri *RuntimeGoInitializer) RegisterBeforeAddGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AddGroupUsersRequest) (*api.AddGroupUsersRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeAuthenticateApple ¶
func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AuthenticateAppleRequest) (*api.AuthenticateAppleRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeAuthenticateCustom ¶
func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateCustom(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AuthenticateCustomRequest) (*api.AuthenticateCustomRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeAuthenticateDevice ¶
func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateDevice(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AuthenticateDeviceRequest) (*api.AuthenticateDeviceRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeAuthenticateEmail ¶
func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateEmail(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AuthenticateEmailRequest) (*api.AuthenticateEmailRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeAuthenticateFacebook ¶
func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateFacebook(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AuthenticateFacebookRequest) (*api.AuthenticateFacebookRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeAuthenticateFacebookInstantGame ¶
func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateFacebookInstantGame(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AuthenticateFacebookInstantGameRequest) (*api.AuthenticateFacebookInstantGameRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeAuthenticateGameCenter ¶
func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateGameCenter(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AuthenticateGameCenterRequest) (*api.AuthenticateGameCenterRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeAuthenticateGoogle ¶
func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AuthenticateGoogleRequest) (*api.AuthenticateGoogleRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeAuthenticateSteam ¶
func (ri *RuntimeGoInitializer) RegisterBeforeAuthenticateSteam(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AuthenticateSteamRequest) (*api.AuthenticateSteamRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeBanGroupUsers ¶
func (ri *RuntimeGoInitializer) RegisterBeforeBanGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.BanGroupUsersRequest) (*api.BanGroupUsersRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeBlockFriends ¶
func (ri *RuntimeGoInitializer) RegisterBeforeBlockFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.BlockFriendsRequest) (*api.BlockFriendsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeCreateGroup ¶
func (ri *RuntimeGoInitializer) RegisterBeforeCreateGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.CreateGroupRequest) (*api.CreateGroupRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeDeleteFriends ¶
func (ri *RuntimeGoInitializer) RegisterBeforeDeleteFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.DeleteFriendsRequest) (*api.DeleteFriendsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeDeleteGroup ¶
func (ri *RuntimeGoInitializer) RegisterBeforeDeleteGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.DeleteGroupRequest) (*api.DeleteGroupRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeDeleteLeaderboardRecord ¶
func (ri *RuntimeGoInitializer) RegisterBeforeDeleteLeaderboardRecord(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.DeleteLeaderboardRecordRequest) (*api.DeleteLeaderboardRecordRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeDeleteNotification ¶
func (ri *RuntimeGoInitializer) RegisterBeforeDeleteNotification(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.DeleteNotificationsRequest) (*api.DeleteNotificationsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeDeleteStorageObjects ¶
func (ri *RuntimeGoInitializer) RegisterBeforeDeleteStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.DeleteStorageObjectsRequest) (*api.DeleteStorageObjectsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeDemoteGroupUsers ¶
func (ri *RuntimeGoInitializer) RegisterBeforeDemoteGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.DemoteGroupUsersRequest) (*api.DemoteGroupUsersRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeEvent ¶
func (*RuntimeGoInitializer) RegisterBeforeGetAccount ¶
func (*RuntimeGoInitializer) RegisterBeforeGetUsers ¶
func (ri *RuntimeGoInitializer) RegisterBeforeGetUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.GetUsersRequest) (*api.GetUsersRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeImportFacebookFriends ¶
func (ri *RuntimeGoInitializer) RegisterBeforeImportFacebookFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ImportFacebookFriendsRequest) (*api.ImportFacebookFriendsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeImportSteamFriends ¶ added in v3.1.0
func (ri *RuntimeGoInitializer) RegisterBeforeImportSteamFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ImportSteamFriendsRequest) (*api.ImportSteamFriendsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeJoinGroup ¶
func (ri *RuntimeGoInitializer) RegisterBeforeJoinGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.JoinGroupRequest) (*api.JoinGroupRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeJoinTournament ¶
func (ri *RuntimeGoInitializer) RegisterBeforeJoinTournament(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.JoinTournamentRequest) (*api.JoinTournamentRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeKickGroupUsers ¶
func (ri *RuntimeGoInitializer) RegisterBeforeKickGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.KickGroupUsersRequest) (*api.KickGroupUsersRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeLeaveGroup ¶
func (ri *RuntimeGoInitializer) RegisterBeforeLeaveGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.LeaveGroupRequest) (*api.LeaveGroupRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeLinkApple ¶
func (ri *RuntimeGoInitializer) RegisterBeforeLinkApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountApple) (*api.AccountApple, error)) error
func (*RuntimeGoInitializer) RegisterBeforeLinkCustom ¶
func (ri *RuntimeGoInitializer) RegisterBeforeLinkCustom(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountCustom) (*api.AccountCustom, error)) error
func (*RuntimeGoInitializer) RegisterBeforeLinkDevice ¶
func (ri *RuntimeGoInitializer) RegisterBeforeLinkDevice(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountDevice) (*api.AccountDevice, error)) error
func (*RuntimeGoInitializer) RegisterBeforeLinkEmail ¶
func (ri *RuntimeGoInitializer) RegisterBeforeLinkEmail(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountEmail) (*api.AccountEmail, error)) error
func (*RuntimeGoInitializer) RegisterBeforeLinkFacebook ¶
func (ri *RuntimeGoInitializer) RegisterBeforeLinkFacebook(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.LinkFacebookRequest) (*api.LinkFacebookRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeLinkFacebookInstantGame ¶
func (ri *RuntimeGoInitializer) RegisterBeforeLinkFacebookInstantGame(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountFacebookInstantGame) (*api.AccountFacebookInstantGame, error)) error
func (*RuntimeGoInitializer) RegisterBeforeLinkGameCenter ¶
func (ri *RuntimeGoInitializer) RegisterBeforeLinkGameCenter(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountGameCenter) (*api.AccountGameCenter, error)) error
func (*RuntimeGoInitializer) RegisterBeforeLinkGoogle ¶
func (ri *RuntimeGoInitializer) RegisterBeforeLinkGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountGoogle) (*api.AccountGoogle, error)) error
func (*RuntimeGoInitializer) RegisterBeforeLinkSteam ¶
func (ri *RuntimeGoInitializer) RegisterBeforeLinkSteam(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.LinkSteamRequest) (*api.LinkSteamRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeListChannelMessages ¶
func (ri *RuntimeGoInitializer) RegisterBeforeListChannelMessages(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ListChannelMessagesRequest) (*api.ListChannelMessagesRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeListFriends ¶
func (ri *RuntimeGoInitializer) RegisterBeforeListFriends(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ListFriendsRequest) (*api.ListFriendsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeListGroupUsers ¶
func (ri *RuntimeGoInitializer) RegisterBeforeListGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ListGroupUsersRequest) (*api.ListGroupUsersRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeListGroups ¶
func (ri *RuntimeGoInitializer) RegisterBeforeListGroups(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ListGroupsRequest) (*api.ListGroupsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeListLeaderboardRecords ¶
func (ri *RuntimeGoInitializer) RegisterBeforeListLeaderboardRecords(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ListLeaderboardRecordsRequest) (*api.ListLeaderboardRecordsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeListLeaderboardRecordsAroundOwner ¶
func (ri *RuntimeGoInitializer) RegisterBeforeListLeaderboardRecordsAroundOwner(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ListLeaderboardRecordsAroundOwnerRequest) (*api.ListLeaderboardRecordsAroundOwnerRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeListMatches ¶
func (ri *RuntimeGoInitializer) RegisterBeforeListMatches(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ListMatchesRequest) (*api.ListMatchesRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeListNotifications ¶
func (ri *RuntimeGoInitializer) RegisterBeforeListNotifications(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ListNotificationsRequest) (*api.ListNotificationsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeListStorageObjects ¶
func (ri *RuntimeGoInitializer) RegisterBeforeListStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ListStorageObjectsRequest) (*api.ListStorageObjectsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeListTournamentRecords ¶
func (ri *RuntimeGoInitializer) RegisterBeforeListTournamentRecords(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ListTournamentRecordsRequest) (*api.ListTournamentRecordsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeListTournamentRecordsAroundOwner ¶
func (ri *RuntimeGoInitializer) RegisterBeforeListTournamentRecordsAroundOwner(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ListTournamentRecordsAroundOwnerRequest) (*api.ListTournamentRecordsAroundOwnerRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeListTournaments ¶
func (ri *RuntimeGoInitializer) RegisterBeforeListTournaments(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ListTournamentsRequest) (*api.ListTournamentsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeListUserGroups ¶
func (ri *RuntimeGoInitializer) RegisterBeforeListUserGroups(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ListUserGroupsRequest) (*api.ListUserGroupsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforePromoteGroupUsers ¶
func (ri *RuntimeGoInitializer) RegisterBeforePromoteGroupUsers(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.PromoteGroupUsersRequest) (*api.PromoteGroupUsersRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeReadStorageObjects ¶
func (ri *RuntimeGoInitializer) RegisterBeforeReadStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.ReadStorageObjectsRequest) (*api.ReadStorageObjectsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeRt ¶
func (*RuntimeGoInitializer) RegisterBeforeSessionRefresh ¶
func (ri *RuntimeGoInitializer) RegisterBeforeSessionRefresh(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.SessionRefreshRequest) (*api.SessionRefreshRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeUnlinkApple ¶
func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkApple(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountApple) (*api.AccountApple, error)) error
func (*RuntimeGoInitializer) RegisterBeforeUnlinkCustom ¶
func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkCustom(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountCustom) (*api.AccountCustom, error)) error
func (*RuntimeGoInitializer) RegisterBeforeUnlinkDevice ¶
func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkDevice(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountDevice) (*api.AccountDevice, error)) error
func (*RuntimeGoInitializer) RegisterBeforeUnlinkEmail ¶
func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkEmail(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountEmail) (*api.AccountEmail, error)) error
func (*RuntimeGoInitializer) RegisterBeforeUnlinkFacebook ¶
func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkFacebook(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountFacebook) (*api.AccountFacebook, error)) error
func (*RuntimeGoInitializer) RegisterBeforeUnlinkFacebookInstantGame ¶
func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkFacebookInstantGame(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountFacebookInstantGame) (*api.AccountFacebookInstantGame, error)) error
func (*RuntimeGoInitializer) RegisterBeforeUnlinkGameCenter ¶
func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkGameCenter(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountGameCenter) (*api.AccountGameCenter, error)) error
func (*RuntimeGoInitializer) RegisterBeforeUnlinkGoogle ¶
func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkGoogle(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountGoogle) (*api.AccountGoogle, error)) error
func (*RuntimeGoInitializer) RegisterBeforeUnlinkSteam ¶
func (ri *RuntimeGoInitializer) RegisterBeforeUnlinkSteam(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.AccountSteam) (*api.AccountSteam, error)) error
func (*RuntimeGoInitializer) RegisterBeforeUpdateAccount ¶
func (ri *RuntimeGoInitializer) RegisterBeforeUpdateAccount(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.UpdateAccountRequest) (*api.UpdateAccountRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeUpdateGroup ¶
func (ri *RuntimeGoInitializer) RegisterBeforeUpdateGroup(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.UpdateGroupRequest) (*api.UpdateGroupRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeWriteLeaderboardRecord ¶
func (ri *RuntimeGoInitializer) RegisterBeforeWriteLeaderboardRecord(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.WriteLeaderboardRecordRequest) (*api.WriteLeaderboardRecordRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeWriteStorageObjects ¶
func (ri *RuntimeGoInitializer) RegisterBeforeWriteStorageObjects(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.WriteStorageObjectsRequest) (*api.WriteStorageObjectsRequest, error)) error
func (*RuntimeGoInitializer) RegisterBeforeWriteTournamentRecord ¶
func (ri *RuntimeGoInitializer) RegisterBeforeWriteTournamentRecord(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, in *api.WriteTournamentRecordRequest) (*api.WriteTournamentRecordRequest, error)) error
func (*RuntimeGoInitializer) RegisterEvent ¶
func (*RuntimeGoInitializer) RegisterEventSessionEnd ¶
func (*RuntimeGoInitializer) RegisterEventSessionStart ¶
func (*RuntimeGoInitializer) RegisterLeaderboardReset ¶
func (ri *RuntimeGoInitializer) RegisterLeaderboardReset(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, leaderboard runtime.Leaderboard, reset int64) error) error
func (*RuntimeGoInitializer) RegisterMatch ¶
func (*RuntimeGoInitializer) RegisterMatchmakerMatched ¶
func (ri *RuntimeGoInitializer) RegisterMatchmakerMatched(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, entries []runtime.MatchmakerEntry) (string, error)) error
func (*RuntimeGoInitializer) RegisterRpc ¶
func (*RuntimeGoInitializer) RegisterTournamentEnd ¶
func (ri *RuntimeGoInitializer) RegisterTournamentEnd(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, tournament *api.Tournament, end, reset int64) error) error
func (*RuntimeGoInitializer) RegisterTournamentReset ¶
func (ri *RuntimeGoInitializer) RegisterTournamentReset(fn func(ctx context.Context, logger runtime.Logger, db *sql.DB, nk runtime.NakamaModule, tournament *api.Tournament, end, reset int64) error) error
type RuntimeGoLogger ¶
type RuntimeGoLogger struct {
// contains filtered or unexported fields
}
func (*RuntimeGoLogger) Debug ¶
func (l *RuntimeGoLogger) Debug(format string, v ...interface{})
func (*RuntimeGoLogger) Error ¶
func (l *RuntimeGoLogger) Error(format string, v ...interface{})
func (*RuntimeGoLogger) Fields ¶
func (l *RuntimeGoLogger) Fields() map[string]interface{}
func (*RuntimeGoLogger) Info ¶
func (l *RuntimeGoLogger) Info(format string, v ...interface{})
func (*RuntimeGoLogger) Warn ¶
func (l *RuntimeGoLogger) Warn(format string, v ...interface{})
func (*RuntimeGoLogger) WithField ¶
func (l *RuntimeGoLogger) WithField(key string, v interface{}) nkruntime.Logger
func (*RuntimeGoLogger) WithFields ¶
func (l *RuntimeGoLogger) WithFields(fields map[string]interface{}) nkruntime.Logger
type RuntimeGoMatchCore ¶
type RuntimeGoMatchCore struct {
// contains filtered or unexported fields
}
func (*RuntimeGoMatchCore) BroadcastMessage ¶
func (*RuntimeGoMatchCore) BroadcastMessageDeferred ¶
func (*RuntimeGoMatchCore) Cancel ¶
func (r *RuntimeGoMatchCore) Cancel()
func (*RuntimeGoMatchCore) GetState ¶
func (r *RuntimeGoMatchCore) GetState(state interface{}) (string, error)
func (*RuntimeGoMatchCore) HandlerName ¶
func (r *RuntimeGoMatchCore) HandlerName() string
func (*RuntimeGoMatchCore) Label ¶
func (r *RuntimeGoMatchCore) Label() string
func (*RuntimeGoMatchCore) MatchInit ¶
func (r *RuntimeGoMatchCore) MatchInit(presenceList *MatchPresenceList, deferMessageFn RuntimeMatchDeferMessageFunction, params map[string]interface{}) (interface{}, int, error)
func (*RuntimeGoMatchCore) MatchJoin ¶
func (r *RuntimeGoMatchCore) MatchJoin(tick int64, state interface{}, joins []*MatchPresence) (interface{}, error)
func (*RuntimeGoMatchCore) MatchJoinAttempt ¶
func (*RuntimeGoMatchCore) MatchKick ¶
func (r *RuntimeGoMatchCore) MatchKick(presences []runtime.Presence) error
func (*RuntimeGoMatchCore) MatchLabelUpdate ¶
func (r *RuntimeGoMatchCore) MatchLabelUpdate(label string) error
func (*RuntimeGoMatchCore) MatchLeave ¶
func (r *RuntimeGoMatchCore) MatchLeave(tick int64, state interface{}, leaves []*MatchPresence) (interface{}, error)
func (*RuntimeGoMatchCore) MatchLoop ¶
func (r *RuntimeGoMatchCore) MatchLoop(tick int64, state interface{}, inputCh <-chan *MatchDataMessage) (interface{}, error)
func (*RuntimeGoMatchCore) MatchTerminate ¶
func (r *RuntimeGoMatchCore) MatchTerminate(tick int64, state interface{}, graceSeconds int) (interface{}, error)
type RuntimeGoNakamaModule ¶
func NewRuntimeGoNakamaModule ¶
func NewRuntimeGoNakamaModule(logger *zap.Logger, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, config Config, socialClient *social.Client, leaderboardCache LeaderboardCache, leaderboardRankCache LeaderboardRankCache, leaderboardScheduler LeaderboardScheduler, sessionRegistry SessionRegistry, matchRegistry MatchRegistry, tracker Tracker, streamManager StreamManager, router MessageRouter) *RuntimeGoNakamaModule
func (*RuntimeGoNakamaModule) AccountDeleteId ¶
func (*RuntimeGoNakamaModule) AccountExportId ¶
func (*RuntimeGoNakamaModule) AccountGetId ¶
func (*RuntimeGoNakamaModule) AccountUpdateId ¶
func (*RuntimeGoNakamaModule) AccountsGetId ¶
func (*RuntimeGoNakamaModule) AuthenticateApple ¶
func (*RuntimeGoNakamaModule) AuthenticateCustom ¶
func (*RuntimeGoNakamaModule) AuthenticateDevice ¶
func (*RuntimeGoNakamaModule) AuthenticateEmail ¶
func (*RuntimeGoNakamaModule) AuthenticateFacebook ¶
func (*RuntimeGoNakamaModule) AuthenticateFacebookInstantGame ¶
func (*RuntimeGoNakamaModule) AuthenticateGameCenter ¶
func (*RuntimeGoNakamaModule) AuthenticateGoogle ¶
func (*RuntimeGoNakamaModule) AuthenticateSteam ¶
func (*RuntimeGoNakamaModule) AuthenticateTokenGenerate ¶
func (*RuntimeGoNakamaModule) FriendsList ¶
func (*RuntimeGoNakamaModule) GroupCreate ¶
func (*RuntimeGoNakamaModule) GroupDelete ¶
func (n *RuntimeGoNakamaModule) GroupDelete(ctx context.Context, id string) error
func (*RuntimeGoNakamaModule) GroupUpdate ¶
func (*RuntimeGoNakamaModule) GroupUserJoin ¶
func (n *RuntimeGoNakamaModule) GroupUserJoin(ctx context.Context, groupID, userID, username string) error
func (*RuntimeGoNakamaModule) GroupUserLeave ¶
func (n *RuntimeGoNakamaModule) GroupUserLeave(ctx context.Context, groupID, userID, username string) error
func (*RuntimeGoNakamaModule) GroupUsersAdd ¶
func (*RuntimeGoNakamaModule) GroupUsersDemote ¶
func (*RuntimeGoNakamaModule) GroupUsersKick ¶
func (*RuntimeGoNakamaModule) GroupUsersList ¶
func (*RuntimeGoNakamaModule) GroupUsersPromote ¶
func (*RuntimeGoNakamaModule) GroupsGetId ¶
func (*RuntimeGoNakamaModule) LeaderboardCreate ¶
func (*RuntimeGoNakamaModule) LeaderboardDelete ¶
func (n *RuntimeGoNakamaModule) LeaderboardDelete(ctx context.Context, id string) error
func (*RuntimeGoNakamaModule) LeaderboardRecordDelete ¶
func (n *RuntimeGoNakamaModule) LeaderboardRecordDelete(ctx context.Context, id, ownerID string) error
func (*RuntimeGoNakamaModule) LeaderboardRecordWrite ¶
func (n *RuntimeGoNakamaModule) LeaderboardRecordWrite(ctx context.Context, id, ownerID, username string, score, subscore int64, metadata map[string]interface{}) (*api.LeaderboardRecord, error)
func (*RuntimeGoNakamaModule) LeaderboardRecordsList ¶
func (n *RuntimeGoNakamaModule) LeaderboardRecordsList(ctx context.Context, id string, ownerIDs []string, limit int, cursor string, expiry int64) ([]*api.LeaderboardRecord, []*api.LeaderboardRecord, string, string, error)
func (*RuntimeGoNakamaModule) LinkApple ¶
func (n *RuntimeGoNakamaModule) LinkApple(ctx context.Context, userID, token string) error
func (*RuntimeGoNakamaModule) LinkCustom ¶
func (n *RuntimeGoNakamaModule) LinkCustom(ctx context.Context, userID, customID string) error
func (*RuntimeGoNakamaModule) LinkDevice ¶
func (n *RuntimeGoNakamaModule) LinkDevice(ctx context.Context, userID, deviceID string) error
func (*RuntimeGoNakamaModule) LinkEmail ¶
func (n *RuntimeGoNakamaModule) LinkEmail(ctx context.Context, userID, email, password string) error
func (*RuntimeGoNakamaModule) LinkFacebook ¶
func (*RuntimeGoNakamaModule) LinkFacebookInstantGame ¶
func (n *RuntimeGoNakamaModule) LinkFacebookInstantGame(ctx context.Context, userID, signedPlayerInfo string) error
func (*RuntimeGoNakamaModule) LinkGameCenter ¶
func (*RuntimeGoNakamaModule) LinkGoogle ¶
func (n *RuntimeGoNakamaModule) LinkGoogle(ctx context.Context, userID, token string) error
func (*RuntimeGoNakamaModule) MatchCreate ¶
func (*RuntimeGoNakamaModule) MultiUpdate ¶
func (n *RuntimeGoNakamaModule) MultiUpdate(ctx context.Context, accountUpdates []*runtime.AccountUpdate, storageWrites []*runtime.StorageWrite, walletUpdates []*runtime.WalletUpdate, updateLedger bool) ([]*api.StorageObjectAck, []*runtime.WalletUpdateResult, error)
func (*RuntimeGoNakamaModule) NotificationSend ¶
func (*RuntimeGoNakamaModule) NotificationsSend ¶
func (n *RuntimeGoNakamaModule) NotificationsSend(ctx context.Context, notifications []*runtime.NotificationSend) error
func (*RuntimeGoNakamaModule) ReadFile ¶
func (n *RuntimeGoNakamaModule) ReadFile(relPath string) (*os.File, error)
func (*RuntimeGoNakamaModule) SessionDisconnect ¶
func (n *RuntimeGoNakamaModule) SessionDisconnect(ctx context.Context, sessionID string) error
func (*RuntimeGoNakamaModule) SetEventFn ¶
func (n *RuntimeGoNakamaModule) SetEventFn(fn RuntimeEventCustomFunction)
func (*RuntimeGoNakamaModule) StorageDelete ¶
func (n *RuntimeGoNakamaModule) StorageDelete(ctx context.Context, deletes []*runtime.StorageDelete) error
func (*RuntimeGoNakamaModule) StorageList ¶
func (n *RuntimeGoNakamaModule) StorageList(ctx context.Context, userID, collection string, limit int, cursor string) ([]*api.StorageObject, string, error)
func (*RuntimeGoNakamaModule) StorageRead ¶
func (n *RuntimeGoNakamaModule) StorageRead(ctx context.Context, reads []*runtime.StorageRead) ([]*api.StorageObject, error)
func (*RuntimeGoNakamaModule) StorageWrite ¶
func (n *RuntimeGoNakamaModule) StorageWrite(ctx context.Context, writes []*runtime.StorageWrite) ([]*api.StorageObjectAck, error)
func (*RuntimeGoNakamaModule) StreamClose ¶
func (n *RuntimeGoNakamaModule) StreamClose(mode uint8, subject, subcontext, label string) error
func (*RuntimeGoNakamaModule) StreamCount ¶
func (n *RuntimeGoNakamaModule) StreamCount(mode uint8, subject, subcontext, label string) (int, error)
func (*RuntimeGoNakamaModule) StreamSend ¶
func (*RuntimeGoNakamaModule) StreamSendRaw ¶
func (*RuntimeGoNakamaModule) StreamUserGet ¶
func (n *RuntimeGoNakamaModule) StreamUserGet(mode uint8, subject, subcontext, label, userID, sessionID string) (runtime.PresenceMeta, error)
func (*RuntimeGoNakamaModule) StreamUserJoin ¶
func (*RuntimeGoNakamaModule) StreamUserKick ¶
func (*RuntimeGoNakamaModule) StreamUserLeave ¶
func (n *RuntimeGoNakamaModule) StreamUserLeave(mode uint8, subject, subcontext, label, userID, sessionID string) error
func (*RuntimeGoNakamaModule) StreamUserList ¶
func (*RuntimeGoNakamaModule) StreamUserUpdate ¶
func (*RuntimeGoNakamaModule) TournamentAddAttempt ¶
func (*RuntimeGoNakamaModule) TournamentCreate ¶
func (*RuntimeGoNakamaModule) TournamentDelete ¶
func (n *RuntimeGoNakamaModule) TournamentDelete(ctx context.Context, id string) error
func (*RuntimeGoNakamaModule) TournamentJoin ¶
func (n *RuntimeGoNakamaModule) TournamentJoin(ctx context.Context, id, ownerID, username string) error
func (*RuntimeGoNakamaModule) TournamentList ¶
func (n *RuntimeGoNakamaModule) TournamentList(ctx context.Context, categoryStart, categoryEnd, startTime, endTime, limit int, cursor string) (*api.TournamentList, error)
func (*RuntimeGoNakamaModule) TournamentRecordWrite ¶
func (n *RuntimeGoNakamaModule) TournamentRecordWrite(ctx context.Context, id, ownerID, username string, score, subscore int64, metadata map[string]interface{}) (*api.LeaderboardRecord, error)
func (*RuntimeGoNakamaModule) TournamentRecordsHaystack ¶
func (n *RuntimeGoNakamaModule) TournamentRecordsHaystack(ctx context.Context, id, ownerID string, limit int, expiry int64) ([]*api.LeaderboardRecord, error)
func (*RuntimeGoNakamaModule) TournamentRecordsList ¶
func (n *RuntimeGoNakamaModule) TournamentRecordsList(ctx context.Context, tournamentId string, ownerIDs []string, limit int, cursor string, overrideExpiry int64) ([]*api.LeaderboardRecord, []*api.LeaderboardRecord, string, string, error)
func (*RuntimeGoNakamaModule) TournamentsGetId ¶
func (n *RuntimeGoNakamaModule) TournamentsGetId(ctx context.Context, tournamentIDs []string) ([]*api.Tournament, error)
func (*RuntimeGoNakamaModule) UnlinkApple ¶
func (n *RuntimeGoNakamaModule) UnlinkApple(ctx context.Context, userID, token string) error
func (*RuntimeGoNakamaModule) UnlinkCustom ¶
func (n *RuntimeGoNakamaModule) UnlinkCustom(ctx context.Context, userID, customID string) error
func (*RuntimeGoNakamaModule) UnlinkDevice ¶
func (n *RuntimeGoNakamaModule) UnlinkDevice(ctx context.Context, userID, deviceID string) error
func (*RuntimeGoNakamaModule) UnlinkEmail ¶
func (n *RuntimeGoNakamaModule) UnlinkEmail(ctx context.Context, userID, email string) error
func (*RuntimeGoNakamaModule) UnlinkFacebook ¶
func (n *RuntimeGoNakamaModule) UnlinkFacebook(ctx context.Context, userID, token string) error
func (*RuntimeGoNakamaModule) UnlinkFacebookInstantGame ¶
func (n *RuntimeGoNakamaModule) UnlinkFacebookInstantGame(ctx context.Context, userID, signedPlayerInfo string) error
func (*RuntimeGoNakamaModule) UnlinkGameCenter ¶
func (*RuntimeGoNakamaModule) UnlinkGoogle ¶
func (n *RuntimeGoNakamaModule) UnlinkGoogle(ctx context.Context, userID, token string) error
func (*RuntimeGoNakamaModule) UnlinkSteam ¶
func (n *RuntimeGoNakamaModule) UnlinkSteam(ctx context.Context, userID, token string) error
func (*RuntimeGoNakamaModule) UserGroupsList ¶
func (*RuntimeGoNakamaModule) UsersBanId ¶
func (n *RuntimeGoNakamaModule) UsersBanId(ctx context.Context, userIDs []string) error
func (*RuntimeGoNakamaModule) UsersGetId ¶
func (*RuntimeGoNakamaModule) UsersGetUsername ¶
func (*RuntimeGoNakamaModule) UsersUnbanId ¶
func (n *RuntimeGoNakamaModule) UsersUnbanId(ctx context.Context, userIDs []string) error
func (*RuntimeGoNakamaModule) WalletLedgerList ¶
func (n *RuntimeGoNakamaModule) WalletLedgerList(ctx context.Context, userID string, limit int, cursor string) ([]runtime.WalletLedgerItem, string, error)
func (*RuntimeGoNakamaModule) WalletLedgerUpdate ¶
func (n *RuntimeGoNakamaModule) WalletLedgerUpdate(ctx context.Context, itemID string, metadata map[string]interface{}) (runtime.WalletLedgerItem, error)
func (*RuntimeGoNakamaModule) WalletUpdate ¶
func (*RuntimeGoNakamaModule) WalletsUpdate ¶
func (n *RuntimeGoNakamaModule) WalletsUpdate(ctx context.Context, updates []*runtime.WalletUpdate, updateLedger bool) ([]*runtime.WalletUpdateResult, error)
type RuntimeInfo ¶
type RuntimeJS ¶
type RuntimeJS struct {
// contains filtered or unexported fields
}
func (*RuntimeJS) GetCallback ¶
func (r *RuntimeJS) GetCallback(e RuntimeExecutionMode, key string) interface{}
func (*RuntimeJS) InvokeFunction ¶
type RuntimeJSModule ¶
type RuntimeJSModuleCache ¶
type RuntimeJSModuleCache struct {
Names []string
Modules map[string]*RuntimeJSModule
}
func (*RuntimeJSModuleCache) Add ¶
func (mc *RuntimeJSModuleCache) Add(m *RuntimeJSModule)
type RuntimeJavaScriptMatchCore ¶
type RuntimeJavaScriptMatchCore struct {
// contains filtered or unexported fields
}
func (*RuntimeJavaScriptMatchCore) Cancel ¶
func (rm *RuntimeJavaScriptMatchCore) Cancel()
func (*RuntimeJavaScriptMatchCore) GetState ¶
func (rm *RuntimeJavaScriptMatchCore) GetState(state interface{}) (string, error)
func (*RuntimeJavaScriptMatchCore) HandlerName ¶
func (rm *RuntimeJavaScriptMatchCore) HandlerName() string
func (*RuntimeJavaScriptMatchCore) Label ¶
func (rm *RuntimeJavaScriptMatchCore) Label() string
func (*RuntimeJavaScriptMatchCore) MatchInit ¶
func (rm *RuntimeJavaScriptMatchCore) MatchInit(presenceList *MatchPresenceList, deferMessageFn RuntimeMatchDeferMessageFunction, params map[string]interface{}) (interface{}, int, error)
func (*RuntimeJavaScriptMatchCore) MatchJoin ¶
func (rm *RuntimeJavaScriptMatchCore) MatchJoin(tick int64, state interface{}, joins []*MatchPresence) (interface{}, error)
func (*RuntimeJavaScriptMatchCore) MatchJoinAttempt ¶
func (*RuntimeJavaScriptMatchCore) MatchLeave ¶
func (rm *RuntimeJavaScriptMatchCore) MatchLeave(tick int64, state interface{}, leaves []*MatchPresence) (interface{}, error)
func (*RuntimeJavaScriptMatchCore) MatchLoop ¶
func (rm *RuntimeJavaScriptMatchCore) MatchLoop(tick int64, state interface{}, inputCh <-chan *MatchDataMessage) (interface{}, error)
func (*RuntimeJavaScriptMatchCore) MatchTerminate ¶
func (rm *RuntimeJavaScriptMatchCore) MatchTerminate(tick int64, state interface{}, graceSeconds int) (interface{}, error)
type RuntimeJavascriptInitModule ¶
type RuntimeJavascriptInitModule struct {
Logger *zap.Logger
Callbacks *RuntimeJavascriptCallbacks
MatchCallbacks *RuntimeJavascriptMatchHandlers
// contains filtered or unexported fields
}
func NewRuntimeJavascriptInitModule ¶
func NewRuntimeJavascriptInitModule(logger *zap.Logger, ast *ast.Program, announceCallbackFn func(RuntimeExecutionMode, string)) *RuntimeJavascriptInitModule
func (*RuntimeJavascriptInitModule) Constructor ¶
func (im *RuntimeJavascriptInitModule) Constructor(r *goja.Runtime) func(goja.ConstructorCall) *goja.Object
type RuntimeJavascriptLocalCache ¶ added in v3.1.0
func NewRuntimeJavascriptLocalCache ¶ added in v3.1.0
func NewRuntimeJavascriptLocalCache() *RuntimeJavascriptLocalCache
func (*RuntimeJavascriptLocalCache) Delete ¶ added in v3.1.0
func (lc *RuntimeJavascriptLocalCache) Delete(key string)
type RuntimeJavascriptMatchHandlers ¶
type RuntimeJavascriptMatchHandlers struct {
// contains filtered or unexported fields
}
func (*RuntimeJavascriptMatchHandlers) Add ¶
func (rmh *RuntimeJavascriptMatchHandlers) Add(name string, handlers *jsMatchHandlers)
func (*RuntimeJavascriptMatchHandlers) Get ¶
func (rmh *RuntimeJavascriptMatchHandlers) Get(name string) *jsMatchHandlers
type RuntimeLua ¶
type RuntimeLua struct {
// contains filtered or unexported fields
}
func (*RuntimeLua) GetCallback ¶
func (r *RuntimeLua) GetCallback(e RuntimeExecutionMode, key string) *lua.LFunction
func (*RuntimeLua) InvokeFunction ¶
func (r *RuntimeLua) InvokeFunction(execMode RuntimeExecutionMode, fn *lua.LFunction, queryParams map[string][]string, uid string, username string, vars map[string]string, sessionExpiry int64, sid string, clientIP string, clientPort string, payloads ...interface{}) (interface{}, error, codes.Code, bool)
func (*RuntimeLua) Stop ¶
func (r *RuntimeLua) Stop()
type RuntimeLuaCallbacks ¶
type RuntimeLuaLocalCache ¶
func NewRuntimeLuaLocalCache ¶
func NewRuntimeLuaLocalCache() *RuntimeLuaLocalCache
func (*RuntimeLuaLocalCache) Delete ¶
func (lc *RuntimeLuaLocalCache) Delete(key string)
type RuntimeLuaMatchCore ¶
type RuntimeLuaMatchCore struct {
// contains filtered or unexported fields
}
func (*RuntimeLuaMatchCore) Cancel ¶
func (r *RuntimeLuaMatchCore) Cancel()
func (*RuntimeLuaMatchCore) GetState ¶
func (r *RuntimeLuaMatchCore) GetState(state interface{}) (string, error)
func (*RuntimeLuaMatchCore) HandlerName ¶
func (r *RuntimeLuaMatchCore) HandlerName() string
func (*RuntimeLuaMatchCore) Label ¶
func (r *RuntimeLuaMatchCore) Label() string
func (*RuntimeLuaMatchCore) MatchInit ¶
func (r *RuntimeLuaMatchCore) MatchInit(presenceList *MatchPresenceList, deferMessageFn RuntimeMatchDeferMessageFunction, params map[string]interface{}) (interface{}, int, error)
func (*RuntimeLuaMatchCore) MatchJoin ¶
func (r *RuntimeLuaMatchCore) MatchJoin(tick int64, state interface{}, joins []*MatchPresence) (interface{}, error)
func (*RuntimeLuaMatchCore) MatchJoinAttempt ¶
func (*RuntimeLuaMatchCore) MatchLeave ¶
func (r *RuntimeLuaMatchCore) MatchLeave(tick int64, state interface{}, leaves []*MatchPresence) (interface{}, error)
func (*RuntimeLuaMatchCore) MatchLoop ¶
func (r *RuntimeLuaMatchCore) MatchLoop(tick int64, state interface{}, inputCh <-chan *MatchDataMessage) (interface{}, error)
func (*RuntimeLuaMatchCore) MatchTerminate ¶
func (r *RuntimeLuaMatchCore) MatchTerminate(tick int64, state interface{}, graceSeconds int) (interface{}, error)
type RuntimeLuaModule ¶
type RuntimeLuaModuleCache ¶
type RuntimeLuaModuleCache struct {
Names []string
Modules map[string]*RuntimeLuaModule
}
func (*RuntimeLuaModuleCache) Add ¶
func (mc *RuntimeLuaModuleCache) Add(m *RuntimeLuaModule)
type RuntimeLuaNakamaModule ¶
type RuntimeLuaNakamaModule struct {
// contains filtered or unexported fields
}
func NewRuntimeLuaNakamaModule ¶
func NewRuntimeLuaNakamaModule(logger *zap.Logger, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, jsonpbUnmarshaler *jsonpb.Unmarshaler, config Config, socialClient *social.Client, leaderboardCache LeaderboardCache, rankCache LeaderboardRankCache, leaderboardScheduler LeaderboardScheduler, sessionRegistry SessionRegistry, matchRegistry MatchRegistry, tracker Tracker, streamManager StreamManager, router MessageRouter, once *sync.Once, localCache *RuntimeLuaLocalCache, matchCreateFn RuntimeMatchCreateFunction, eventFn RuntimeEventCustomFunction, registerCallbackFn func(RuntimeExecutionMode, string, *lua.LFunction), announceCallbackFn func(RuntimeExecutionMode, string)) *RuntimeLuaNakamaModule
type RuntimeMatchCore ¶
type RuntimeMatchCore interface {
MatchInit(presenceList *MatchPresenceList, deferMessageFn RuntimeMatchDeferMessageFunction, params map[string]interface{}) (interface{}, int, error)
MatchJoinAttempt(tick int64, state interface{}, userID, sessionID uuid.UUID, username string, sessionExpiry int64, vars map[string]string, clientIP, clientPort, node string, metadata map[string]string) (interface{}, bool, string, error)
MatchJoin(tick int64, state interface{}, joins []*MatchPresence) (interface{}, error)
MatchLeave(tick int64, state interface{}, leaves []*MatchPresence) (interface{}, error)
MatchLoop(tick int64, state interface{}, inputCh <-chan *MatchDataMessage) (interface{}, error)
MatchTerminate(tick int64, state interface{}, graceSeconds int) (interface{}, error)
GetState(state interface{}) (string, error)
Label() string
HandlerName() string
Cancel()
}
func NewRuntimeGoMatchCore ¶
func NewRuntimeGoMatchCore(logger *zap.Logger, module string, matchRegistry MatchRegistry, router MessageRouter, id uuid.UUID, node string, stopped *atomic.Bool, db *sql.DB, env map[string]string, nk runtime.NakamaModule, match runtime.Match) (RuntimeMatchCore, error)
func NewRuntimeJavascriptMatchCore ¶
func NewRuntimeJavascriptMatchCore(logger *zap.Logger, module string, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, jsonpbUnmarshaler *jsonpb.Unmarshaler, config Config, socialClient *social.Client, leaderboardCache LeaderboardCache, rankCache LeaderboardRankCache, localCache *RuntimeJavascriptLocalCache, leaderboardScheduler LeaderboardScheduler, sessionRegistry SessionRegistry, matchRegistry MatchRegistry, tracker Tracker, streamManager StreamManager, router MessageRouter, matchCreateFn RuntimeMatchCreateFunction, eventFn RuntimeEventCustomFunction, id uuid.UUID, node string, stopped *atomic.Bool, matchHandlers *jsMatchHandlers, modCache *RuntimeJSModuleCache) (RuntimeMatchCore, error)
func NewRuntimeLuaMatchCore ¶
func NewRuntimeLuaMatchCore(logger *zap.Logger, module string, db *sql.DB, jsonpbMarshaler *jsonpb.Marshaler, jsonpbUnmarshaler *jsonpb.Unmarshaler, config Config, socialClient *social.Client, leaderboardCache LeaderboardCache, rankCache LeaderboardRankCache, leaderboardScheduler LeaderboardScheduler, sessionRegistry SessionRegistry, matchRegistry MatchRegistry, tracker Tracker, streamManager StreamManager, router MessageRouter, stdLibs map[string]lua.LGFunction, once *sync.Once, localCache *RuntimeLuaLocalCache, eventFn RuntimeEventCustomFunction, sharedReg, sharedGlobals *lua.LTable, id uuid.UUID, node string, stopped *atomic.Bool, name string, matchProvider *MatchProvider) (RuntimeMatchCore, error)
type RuntimeMatchDeferMessageFunction ¶
type RuntimeMatchDeferMessageFunction func(msg *DeferredMessage) error
type RuntimeProviderJS ¶
type RuntimeProviderJS struct {
// contains filtered or unexported fields
}
func (*RuntimeProviderJS) Get ¶
func (rp *RuntimeProviderJS) Get(ctx context.Context) (*RuntimeJS, error)
func (*RuntimeProviderJS) LeaderboardReset ¶
func (rp *RuntimeProviderJS) LeaderboardReset(ctx context.Context, leaderboard runtime.Leaderboard, reset int64) error
func (*RuntimeProviderJS) MatchmakerMatched ¶
func (rp *RuntimeProviderJS) MatchmakerMatched(ctx context.Context, entries []*MatchmakerEntry) (string, bool, error)
func (*RuntimeProviderJS) Put ¶
func (rp *RuntimeProviderJS) Put(r *RuntimeJS)
func (*RuntimeProviderJS) TournamentEnd ¶
func (rp *RuntimeProviderJS) TournamentEnd(ctx context.Context, tournament *api.Tournament, end, reset int64) error
func (*RuntimeProviderJS) TournamentReset ¶
func (rp *RuntimeProviderJS) TournamentReset(ctx context.Context, tournament *api.Tournament, end, reset int64) error
type RuntimeProviderLua ¶
type RuntimeProviderLua struct {
// contains filtered or unexported fields
}
func (*RuntimeProviderLua) Get ¶
func (rp *RuntimeProviderLua) Get(ctx context.Context) (*RuntimeLua, error)
func (*RuntimeProviderLua) LeaderboardReset ¶
func (rp *RuntimeProviderLua) LeaderboardReset(ctx context.Context, leaderboard runtime.Leaderboard, reset int64) error
func (*RuntimeProviderLua) MatchmakerMatched ¶
func (rp *RuntimeProviderLua) MatchmakerMatched(ctx context.Context, entries []*MatchmakerEntry) (string, bool, error)
func (*RuntimeProviderLua) Put ¶
func (rp *RuntimeProviderLua) Put(r *RuntimeLua)
func (*RuntimeProviderLua) TournamentEnd ¶
func (rp *RuntimeProviderLua) TournamentEnd(ctx context.Context, tournament *api.Tournament, end, reset int64) error
func (*RuntimeProviderLua) TournamentReset ¶
func (rp *RuntimeProviderLua) TournamentReset(ctx context.Context, tournament *api.Tournament, end, reset int64) error
type RuntimeRpcFunction ¶
type Scannable ¶
type Scannable interface {
Scan(dest ...interface{}) error
}
Interface to help utility functions accept either *sql.Row or *sql.Rows for scanning one row at a time.
type Session ¶
type Session interface {
Logger() *zap.Logger
ID() uuid.UUID
UserID() uuid.UUID
Vars() map[string]string
ClientIP() string
ClientPort() string
Context() context.Context
Username() string
SetUsername(string)
Expiry() int64
Consume()
Format() SessionFormat
Send(envelope *rtapi.Envelope, reliable bool) error
SendBytes(payload []byte, reliable bool) error
Close(reason string)
}
func NewSessionWS ¶
func NewSessionWS(logger *zap.Logger, config Config, format SessionFormat, sessionID, userID uuid.UUID, username string, vars map[string]string, expiry int64, clientIP string, clientPort string, jsonpbMarshaler *jsonpb.Marshaler, jsonpbUnmarshaler *jsonpb.Unmarshaler, conn *websocket.Conn, sessionRegistry SessionRegistry, matchmaker Matchmaker, tracker Tracker, metrics *Metrics, pipeline *Pipeline, runtime *Runtime) Session
type SessionConfig ¶
type SessionConfig struct {
EncryptionKey string `yaml:"encryption_key" json:"encryption_key" usage:"The encryption key used to produce the client token."`
TokenExpirySec int64 `yaml:"token_expiry_sec" json:"token_expiry_sec" usage:"Token expiry in seconds."`
RefreshEncryptionKey string `` /* 128-byte string literal not displayed */
RefreshTokenExpirySec int64 `yaml:"refresh_token_expiry_sec" json:"refresh_token_expiry_sec" usage:"Refresh token expiry in seconds."`
}
SessionConfig is configuration relevant to the session.
func NewSessionConfig ¶
func NewSessionConfig() *SessionConfig
NewSessionConfig creates a new SessionConfig struct.
type SessionFormat ¶
type SessionFormat uint8
const ( SessionFormatJson SessionFormat = iota SessionFormatProtobuf )
type SessionRegistry ¶
type SessionRegistry interface {
Stop()
Count() int
Get(sessionID uuid.UUID) Session
Add(session Session)
Remove(sessionID uuid.UUID)
Disconnect(ctx context.Context, sessionID uuid.UUID) error
}
func NewLocalSessionRegistry ¶
func NewLocalSessionRegistry(metrics *Metrics) SessionRegistry
type SessionTokenClaims ¶
type SessionTokenClaims struct {
UserId string `json:"uid,omitempty"`
Username string `json:"usn,omitempty"`
Vars map[string]string `json:"vrs,omitempty"`
ExpiresAt int64 `json:"exp,omitempty"`
}
func (*SessionTokenClaims) Valid ¶
func (stc *SessionTokenClaims) Valid() error
type SocialConfig ¶
type SocialConfig struct {
Steam *SocialConfigSteam `yaml:"steam" json:"steam" usage:"Steam configuration."`
FacebookInstantGame *SocialConfigFacebookInstantGame `yaml:"facebook_instant_game" json:"facebook_instant_game" usage:"Facebook Instant Game configuration"`
Apple *SocialConfigApple `yaml:"apple" json:"apple" usage:"Apple Sign In configuration."`
}
SocialConfig is configuration relevant to the social authentication providers.
func NewSocialConfig ¶
func NewSocialConfig() *SocialConfig
NewSocialConfig creates a new SocialConfig struct.
type SocialConfigApple ¶
type SocialConfigApple struct {
BundleId string `yaml:"bundle_id" json:"bundle_id" usage:"Apple Sign In bundle ID."`
}
SocialConfigApple is configuration relevant to Apple Sign In.
type SocialConfigFacebookInstantGame ¶
type SocialConfigFacebookInstantGame struct {
AppSecret string `yaml:"app_secret" json:"app_secret" usage:"Facebook Instant App secret."`
}
SocialConfigFacebookInstantGame is configuration relevant to Facebook Instant Games.
type SocialConfigSteam ¶
type SocialConfigSteam struct {
PublisherKey string `yaml:"publisher_key" json:"publisher_key" usage:"Steam Publisher Key value."`
AppID int `yaml:"app_id" json:"app_id" usage:"Steam App ID."`
}
SocialConfigSteam is configuration relevant to Steam.
type SocketConfig ¶
type SocketConfig struct {
ServerKey string `yaml:"server_key" json:"server_key" usage:"Server key to use to establish a connection to the server."`
Port int `` /* 154-byte string literal not displayed */
Address string `` /* 156-byte string literal not displayed */
Protocol string `` /* 198-byte string literal not displayed */
MaxMessageSizeBytes int64 `` /* 186-byte string literal not displayed */
MaxRequestSizeBytes int64 `` /* 180-byte string literal not displayed */
ReadBufferSizeBytes int `` /* 136-byte string literal not displayed */
WriteBufferSizeBytes int `` /* 139-byte string literal not displayed */
ReadTimeoutMs int `` /* 145-byte string literal not displayed */
WriteTimeoutMs int `` /* 157-byte string literal not displayed */
IdleTimeoutMs int `` /* 178-byte string literal not displayed */
WriteWaitMs int `` /* 156-byte string literal not displayed */
PongWaitMs int `` /* 156-byte string literal not displayed */
PingPeriodMs int `` /* 204-byte string literal not displayed */
PingBackoffThreshold int `` /* 293-byte string literal not displayed */
OutgoingQueueSize int `` /* 245-byte string literal not displayed */
SSLCertificate string `` /* 192-byte string literal not displayed */
SSLPrivateKey string `` /* 192-byte string literal not displayed */
CertPEMBlock []byte `yaml:"-" json:"-"` // Created by fully reading the file contents of SSLCertificate, not set from input args directly.
KeyPEMBlock []byte `yaml:"-" json:"-"` // Created by fully reading the file contents of SSLPrivateKey, not set from input args directly.
TLSCert []tls.Certificate `yaml:"-" json:"-"` // Created by processing CertPEMBlock and KeyPEMBlock, not set from input args directly.
}
SocketConfig is configuration relevant to the transport socket and protocol.
func NewSocketConfig ¶
func NewSocketConfig() *SocketConfig
NewTransportConfig creates a new TransportConfig struct.
type StatusHandler ¶
type StatusHandler interface {
GetStatus(ctx context.Context) ([]*console.StatusList_Status, error)
}
func NewLocalStatusHandler ¶
func NewLocalStatusHandler(logger *zap.Logger, sessionRegistry SessionRegistry, matchRegistry MatchRegistry, tracker Tracker, metrics *Metrics, node string) StatusHandler
type StorageOpDelete ¶
type StorageOpDelete struct {
OwnerID string
ObjectID *api.DeleteStorageObjectId
}
type StorageOpDeletes ¶
type StorageOpDeletes []*StorageOpDelete
Internal representation for a batch of storage delete operations.
func (StorageOpDeletes) Len ¶
func (s StorageOpDeletes) Len() int
func (StorageOpDeletes) Less ¶
func (s StorageOpDeletes) Less(i, j int) bool
func (StorageOpDeletes) Swap ¶
func (s StorageOpDeletes) Swap(i, j int)
type StorageOpWrite ¶
type StorageOpWrite struct {
OwnerID string
Object *api.WriteStorageObject
}
type StorageOpWrites ¶
type StorageOpWrites []*StorageOpWrite
Internal representation for a batch of storage write operations.
func (StorageOpWrites) Len ¶
func (s StorageOpWrites) Len() int
func (StorageOpWrites) Less ¶
func (s StorageOpWrites) Less(i, j int) bool
func (StorageOpWrites) Swap ¶
func (s StorageOpWrites) Swap(i, j int)
type StreamManager ¶
type StreamManager interface {
UserJoin(stream PresenceStream, userID, sessionID uuid.UUID, hidden, persistence bool, status string) (bool, bool, error)
UserUpdate(stream PresenceStream, userID, sessionID uuid.UUID, hidden, persistence bool, status string) (bool, error)
UserLeave(stream PresenceStream, userID, sessionID uuid.UUID) error
}
func NewLocalStreamManager ¶
func NewLocalStreamManager(config Config, sessionRegistry SessionRegistry, tracker Tracker) StreamManager
type TournamentListCursor ¶
type TournamentListCursor struct {
Id string
}
type Tracker ¶
type Tracker interface {
SetMatchJoinListener(func(id uuid.UUID, joins []*MatchPresence))
SetMatchLeaveListener(func(id uuid.UUID, leaves []*MatchPresence))
SetPartyJoinListener(func(id uuid.UUID, joins []*Presence))
SetPartyLeaveListener(func(id uuid.UUID, leaves []*Presence))
Stop()
// Track returns success true/false, and new presence true/false.
Track(ctx context.Context, sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID, meta PresenceMeta, allowIfFirstForSession bool) (bool, bool)
TrackMulti(ctx context.Context, sessionID uuid.UUID, ops []*TrackerOp, userID uuid.UUID, allowIfFirstForSession bool) bool
Untrack(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID)
UntrackMulti(sessionID uuid.UUID, streams []*PresenceStream, userID uuid.UUID)
UntrackAll(sessionID uuid.UUID)
// Update returns success true/false - will only fail if the user has no presence and allowIfFirstForSession is false, otherwise is an upsert.
Update(ctx context.Context, sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID, meta PresenceMeta, allowIfFirstForSession bool) bool
// Remove all presences on a stream, effectively closing it.
UntrackByStream(stream PresenceStream)
// Remove all presences on a stream from the local node.
UntrackLocalByStream(stream PresenceStream)
// List the nodes that have at least one presence for the given stream.
ListNodesForStream(stream PresenceStream) map[string]struct{}
// Check if a stream exists (has any presences) or not.
StreamExists(stream PresenceStream) bool
// Get current total number of presences.
Count() int
// Get the number of presences in the given stream.
CountByStream(stream PresenceStream) int
// Get a snapshot of current presence counts for streams with one of the given stream modes.
CountByStreamModeFilter(modes map[uint8]*uint8) map[*PresenceStream]int32
// Check if a single presence on the current node exists.
GetLocalBySessionIDStreamUserID(sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID) *PresenceMeta
// Check if a single presence on any node exists.
GetBySessionIDStreamUserID(node string, sessionID uuid.UUID, stream PresenceStream, userID uuid.UUID) *PresenceMeta
// List presences by stream, optionally include hidden ones and not hidden ones.
ListByStream(stream PresenceStream, includeHidden bool, includeNotHidden bool) []*Presence
// Fast lookup of local session IDs to use for message delivery.
ListLocalSessionIDByStream(stream PresenceStream) []uuid.UUID
// Fast lookup of node + session IDs to use for message delivery.
ListPresenceIDByStream(stream PresenceStream) []*PresenceID
}
func StartLocalTracker ¶
type TrackerConfig ¶
type TrackerConfig struct {
EventQueueSize int `` /* 210-byte string literal not displayed */
}
TrackerConfig is configuration relevant to the presence tracker.
func NewTrackerConfig ¶
func NewTrackerConfig() *TrackerConfig
NewTrackerConfig creates a new TrackerConfig struct.
type TrackerOp ¶ added in v3.1.0
type TrackerOp struct {
Stream PresenceStream
Meta PresenceMeta
}
type Tx ¶
type Tx interface {
ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
Commit() error
Rollback() error
}
Tx is used to permit clients to implement custom transaction logic.
type TxnRestartError ¶
type TxnRestartError struct {
// contains filtered or unexported fields
}
TxnRestartError represents an error when restarting a transaction. `cause` is the error from restarting the txn and `retryCause` is the original error which triggered the restart.
func (*TxnRestartError) Cause ¶
func (e *TxnRestartError) Cause() error
Cause implements the ErrorCauser interface.
func (*TxnRestartError) Error ¶
func (e *TxnRestartError) Error() string
Error implements the error interface.
func (*TxnRestartError) RetryCause ¶
func (e *TxnRestartError) RetryCause() error
RetryCause returns the error that caused the transaction to be restarted.
Source Files
¶
- api.go
- api_account.go
- api_authenticate.go
- api_channel.go
- api_event.go
- api_friend.go
- api_group.go
- api_leaderboard.go
- api_link.go
- api_match.go
- api_notification.go
- api_rpc.go
- api_session.go
- api_storage.go
- api_tournament.go
- api_unlink.go
- api_user.go
- config.go
- console.go
- console_account.go
- console_api_explorer.go
- console_authenticate.go
- console_config.go
- console_leaderboard.go
- console_match.go
- console_runtime.go
- console_status.go
- console_storage.go
- console_storage_import.go
- console_unlink.go
- console_user.go
- core_account.go
- core_authenticate.go
- core_channel.go
- core_file.go
- core_friend.go
- core_group.go
- core_leaderboard.go
- core_link.go
- core_multi.go
- core_notification.go
- core_session.go
- core_storage.go
- core_tournament.go
- core_unlink.go
- core_user.go
- core_wallet.go
- db.go
- db_error.go
- leaderboard_cache.go
- leaderboard_rank_cache.go
- leaderboard_scheduler.go
- logger.go
- match_handler.go
- match_presence.go
- match_registry.go
- matchmaker.go
- message_router.go
- metrics.go
- metrics_grpc_handler.go
- party_handler.go
- party_registry.go
- pipeline.go
- pipeline_channel.go
- pipeline_match.go
- pipeline_matchmaker.go
- pipeline_party.go
- pipeline_ping.go
- pipeline_rpc.go
- pipeline_status.go
- runtime.go
- runtime_event.go
- runtime_go.go
- runtime_go_context.go
- runtime_go_logger.go
- runtime_go_match_core.go
- runtime_go_nakama.go
- runtime_javascript.go
- runtime_javascript_context.go
- runtime_javascript_init.go
- runtime_javascript_localcache.go
- runtime_javascript_logger.go
- runtime_javascript_match_core.go
- runtime_javascript_nakama.go
- runtime_lua.go
- runtime_lua_bit32.go
- runtime_lua_context.go
- runtime_lua_loadlib.go
- runtime_lua_localcache.go
- runtime_lua_match_core.go
- runtime_lua_nakama.go
- runtime_lua_oslib.go
- runtime_lua_utils.go
- session_registry.go
- session_ws.go
- socket_ws.go
- status_handler.go
- stream_manager.go
- tracker.go
Click to show internal directories.
Click to hide internal directories.