server

Apr 25, 2018

Changes in this version

+ var ErrNoDeletes = errors.New("no deletes")

Apr 22, 2018

Changes in this version

+ var ErrBadInput = errors.New("bad input")

+ var ErrRejected = errors.New("rejected")

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

+ func StatusError(code Error_Code, status, cause error) error

Mar 30, 2018

Changes in this version

type SocketConfig

+ SSLCertificate string

+ SSLPrivateKey string

Nov 6, 2017

Changes in this version

+ func NewUDPSession(logger *zap.Logger, config Config, userID string, handle string, lang string, ...) session

+ func NewWSSession(logger *zap.Logger, config Config, userID string, handle string, lang string, ...) session

type PresenceMeta

+ Format SessionFormat

type RuntimePool

+ func (rp *RuntimePool) HasAfter(messageName string) bool

+ func (rp *RuntimePool) HasBefore(messageName string) bool

+ func (rp *RuntimePool) HasHTTP(path string) bool

+ func (rp *RuntimePool) HasRPC(id string) bool

type SessionConfig

+ UdpKey string

+ type SessionFormat int

+ const SessionFormatJson

+ const SessionFormatProtobuf

type SocketConfig

+ ListenAddress string

+ PublicAddress string

Oct 17, 2017

Changes in this version

+ type Cbuffer struct

+ func NewCbuffer(maxSize int) *Cbuffer

+ type CbufferPool struct

+ func NewCbufferPool() *CbufferPool

+ type Filter int

+ const BOOL

+ const RANGE

+ const TERM

+ type MatchmakerAcceptedProperty struct

+ Filters map[string]MatchmakerFilter

+ Properties map[string]interface{}

+ UserID uuid.UUID

+ type MatchmakerBoolFilter struct

+ Value bool

+ func (*MatchmakerBoolFilter) Type() Filter

+ type MatchmakerFilter interface

+ Type func() Filter

type MatchmakerProfile

+ Filters map[string]MatchmakerFilter

+ Properties map[string]interface{}

+ type MatchmakerRangeFilter struct

+ LowerBound int64

+ UpperBound int64

+ func (*MatchmakerRangeFilter) Type() Filter

+ type MatchmakerTermFilter struct

+ AllTerms bool

+ Terms []string

+ func (*MatchmakerTermFilter) Type() Filter

+ type RuntimeModule struct

+ type RuntimePool struct

+ func NewRuntimePool(logger *zap.Logger, multiLogger *zap.Logger, db *sql.DB, config *RuntimeConfig, ...) (*RuntimePool, error)

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

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

Aug 5, 2017

Changes in this version

+ func ConvertEnvelopeToLTable(l *lua.LState, jsonpbMarshaler *jsonpb.Marshaler, envelope *Envelope) (lua.LValue, error)

type Runtime

+ func (r *Runtime) InvokeFunctionBeforeAuthentication(fn *lua.LFunction, uid uuid.UUID, handle string, sessionExpiry int64, ...) (map[string]interface{}, error)

Aug 1, 2017

Changes in this version

+ const NOTIFICATION_DM_REQUEST

+ const NOTIFICATION_FRIEND_ACCEPT

+ const NOTIFICATION_FRIEND_JOIN_GAME

+ const NOTIFICATION_FRIEND_REQUEST

+ const NOTIFICATION_GROUP_ADD

+ const NOTIFICATION_GROUP_JOIN_REQUEST

+ var RUNTIME_MESSAGES = map[string]string

+ func GroupUsersList(logger *zap.Logger, db *sql.DB, caller uuid.UUID, groupID uuid.UUID) ([]*GroupUser, Error_Code, error)

+ func GroupsSelfList(logger *zap.Logger, db *sql.DB, caller uuid.UUID, userID uuid.UUID) ([]*TGroupsSelf_GroupSelf, Error_Code, error)

+ func NewDashboardService(logger *zap.Logger, multiLogger *zap.Logger, version string, config Config, ...) *dashboardService

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

+ func StorageList(logger *zap.Logger, db *sql.DB, caller uuid.UUID, userID []byte, bucket string, ...) ([]*StorageData, []byte, Error_Code, error)

+ func StorageUpdate(logger *zap.Logger, db *sql.DB, caller uuid.UUID, updates []*StorageKeyUpdate) ([]*StorageKey, Error_Code, error)

+ func UsersBan(logger *zap.Logger, db *sql.DB, userIds [][]byte, handles []string) error

+ type ApplePurchaseProviderConfig struct

+ Password string

+ Production bool

+ TimeoutMs int

type Config

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

+ GetDashboard func() *DashboardConfig

+ GetLog func() *LogConfig

+ GetPurchase func() *PurchaseConfig

+ GetSocket func() *SocketConfig

+ type DashboardConfig struct

+ Port int

+ func NewDashboardConfig() *DashboardConfig

type DatabaseConfig

+ Addresses []string

+ type GooglePurchaseProviderConfig struct

+ PackageName string

+ ServiceKeyFilePath string

+ TimeoutMs int

+ type GroupCreateParam struct

+ AvatarURL string

+ Creator uuid.UUID

+ Description string

+ Lang string

+ Metadata []byte

+ Name string

+ Private bool

+ type LogConfig struct

+ Stdout bool

+ Verbose bool

+ func NewLogConfig() *LogConfig

+ type NNotification struct

+ Code int64

+ Content []byte

+ CreatedAt int64

+ ExpiresAt int64

+ Id []byte

+ Persistent bool

+ SenderID []byte

+ Subject string

+ UserID []byte

+ type NotificationConfig struct

+ ExpiryMs int64

+ type NotificationService struct

+ func NewNotificationService(logger *zap.Logger, db *sql.DB, tracker Tracker, messageRouter MessageRouter, ...) *NotificationService

+ func (n *NotificationService) NotificationSend(notifications []*NNotification) error

+ func (n *NotificationService) NotificationsList(userID uuid.UUID, limit int64, cursor []byte) ([]*NNotification, []byte, error)

+ func (n *NotificationService) NotificationsRemove(userID uuid.UUID, notificationIDs [][]byte) error

+ type PurchaseConfig struct

+ Apple *ApplePurchaseProviderConfig

+ Google *GooglePurchaseProviderConfig

+ func NewPurchaseConfig() *PurchaseConfig

+ type PurchaseService struct

+ AppleClient *iap.AppleClient

+ GoogleClient *iap.GoogleClient

+ func NewPurchaseService(jsonLogger *zap.Logger, multiLogger *zap.Logger, db *sql.DB, ...) *PurchaseService

+ func (p *PurchaseService) ValidateApplePurchase(userID uuid.UUID, purchase *iap.ApplePurchase) *iap.PurchaseVerifyResponse

+ func (p *PurchaseService) ValidateGooglePurchaseProduct(userID uuid.UUID, purchase *iap.GooglePurchase) *iap.PurchaseVerifyResponse

+ func (p *PurchaseService) ValidateGooglePurchaseSubscription(userID uuid.UUID, purchase *iap.GooglePurchase) *iap.PurchaseVerifyResponse

+ type SelfUpdateOp struct

+ AvatarUrl string

+ Fullname string

+ Handle string

+ Lang string

+ Location string

+ Metadata []byte

+ Timezone string

+ UserId []byte

type SocialConfig

+ Notification *NotificationConfig

+ type SocketConfig struct

+ MaxMessageSizeBytes int64

+ PingPeriodMs int

+ PongWaitMs int

+ Port int

+ ServerKey string

+ WriteWaitMs int

+ func NewSocketConfig() *SocketConfig

+ type StorageKeyUpdate struct

+ Key *StorageKey

+ Patch jsonpatch.ExtendedPatch

+ PermissionRead int64

+ PermissionWrite int64

type Tracker

+ ListByTopicUser func(topic string, userID uuid.UUID) []Presence

type TrackerService

+ func (t *TrackerService) ListByTopicUser(topic string, userID uuid.UUID) []Presence

May 29, 2017

Changes in this version

+ const CALLBACKS

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

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

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

+ func OpenOs(L *lua.LState) int

+ func RuntimeAfterHook(logger *zap.Logger, runtime *Runtime, jsonpbMarshaler *jsonpb.Marshaler, ...)

+ func RuntimeAfterHookAuthentication(logger *zap.Logger, runtime *Runtime, jsonpbMarshaler *jsonpb.Marshaler, ...)

+ func StorageFetch(logger *zap.Logger, db *sql.DB, caller uuid.UUID, keys []*StorageKey) ([]*StorageData, Error_Code, error)

+ func StorageWrite(logger *zap.Logger, db *sql.DB, caller uuid.UUID, data []*StorageData) ([]*StorageKey, Error_Code, error)

+ type BuiltinModule interface

+ Loader func(l *lua.LState) int

+ type Callbacks struct

+ After map[string]*lua.LFunction

+ Before map[string]*lua.LFunction

+ HTTP map[string]*lua.LFunction

+ RPC map[string]*lua.LFunction

type Config

+ GetRuntime func() *RuntimeConfig

+ type ExecutionMode int

+ const AFTER

+ const BEFORE

+ const HTTP

+ const JOB

+ const LEADERBOARD_RESET

+ const RPC

+ func (e ExecutionMode) String() string

+ type Matchmaker interface

+ Add func(sessionID uuid.UUID, userID uuid.UUID, meta PresenceMeta, requiredCount int64) (uuid.UUID, map[MatchmakerKey]*MatchmakerProfile)

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

+ RemoveAll func(sessionID uuid.UUID)

+ UpdateAll func(sessionID uuid.UUID, meta PresenceMeta)

+ type MatchmakerKey struct

+ ID PresenceID

+ Ticket uuid.UUID

+ UserID uuid.UUID

+ type MatchmakerProfile struct

+ Meta PresenceMeta

+ RequiredCount int64

+ type MatchmakerService struct

+ func NewMatchmakerService(name string) *MatchmakerService

+ func (m *MatchmakerService) Add(sessionID uuid.UUID, userID uuid.UUID, meta PresenceMeta, requiredCount int64) (uuid.UUID, map[MatchmakerKey]*MatchmakerProfile)

+ func (m *MatchmakerService) Remove(sessionID uuid.UUID, userID uuid.UUID, ticket uuid.UUID) error

+ func (m *MatchmakerService) RemoveAll(sessionID uuid.UUID)

+ func (m *MatchmakerService) UpdateAll(sessionID uuid.UUID, meta PresenceMeta)

+ type NakamaModule struct

+ func NewNakamaModule(logger *zap.Logger, db *sql.DB, l *lua.LState) *NakamaModule

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

+ type NakamaxModule struct

+ func NewNakamaxModule(logger *zap.Logger) *NakamaxModule

+ func (nx *NakamaxModule) Loader(l *lua.LState) int

+ type Runtime struct

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

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

+ func (r *Runtime) InvokeFunctionAfter(fn *lua.LFunction, uid uuid.UUID, handle string, sessionExpiry int64, ...) error

+ func (r *Runtime) InvokeFunctionBefore(fn *lua.LFunction, uid uuid.UUID, handle string, sessionExpiry int64, ...) (map[string]interface{}, error)

+ func (r *Runtime) InvokeFunctionHTTP(fn *lua.LFunction, uid uuid.UUID, handle string, sessionExpiry int64, ...) (map[string]interface{}, error)

+ func (r *Runtime) InvokeFunctionRPC(fn *lua.LFunction, uid uuid.UUID, handle string, sessionExpiry int64, ...) ([]byte, error)

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

+ func (r *Runtime) Stop()

+ type RuntimeConfig struct

+ Environment map[string]interface{}

+ HTTPKey string

+ Path string

+ func NewRuntimeConfig(dataDirectory string) *RuntimeConfig

+ type StorageData struct

+ Bucket string

+ Collection string

+ CreatedAt int64

+ ExpiresAt int64

+ PermissionRead int64

+ PermissionWrite int64

+ Record string

+ UpdatedAt int64

+ UserId []byte

+ Value []byte

+ Version []byte

+ type StorageKey struct

+ Bucket string

+ Collection string

+ Record string

+ UserId []byte

+ Version []byte

Apr 22, 2017

Changes in this version

+ var StdoutLogging = false

+ var VerboseLogging = true

+ func NewConsoleLogger(output *os.File) *zap.Logger

+ func NewJSONLogger(output *os.File) *zap.Logger

+ func NewLogger(consoleLogger *zap.Logger, config Config) *zap.Logger

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

Mar 19, 2017

Changes in this version

type PresenceMeta

+ Handle string

type Tracker

+ UpdateAll func(sessionID uuid.UUID, meta PresenceMeta)

type TrackerService

+ func (t *TrackerService) UpdateAll(sessionID uuid.UUID, meta PresenceMeta)

Jan 14, 2017

Changes in this version

+ func NewAuthenticationService(logger zap.Logger, config Config, db *sql.DB, registry *SessionRegistry, ...) *authenticationService

+ func NewConfig() *config

+ func NewMessageRouterService(registry *SessionRegistry) *messageRouterService

+ func NewOpsService(logger zap.Logger, multiLogger zap.Logger, version string, config Config, ...) *opsService

+ func NewPipeline(config Config, db *sql.DB, socialClient *social.Client, tracker Tracker, ...) *pipeline

+ func NewPresenceNotifier(logger zap.Logger, name string, tracker Tracker, messageRouter MessageRouter) *presenceNotifier

+ func NewSession(logger zap.Logger, config Config, userID uuid.UUID, ...) *session

+ type Config interface

+ GetDSNS func() []string

+ GetDataDir func() string

+ GetDatabase func() *DatabaseConfig

+ GetName func() string

+ GetOpsPort func() int

+ GetPort func() int

+ GetSession func() *SessionConfig

+ GetSocial func() *SocialConfig

+ GetTransport func() *TransportConfig

+ type DatabaseConfig struct

+ ConnMaxLifetimeMs int

+ MaxIdleConns int

+ MaxOpenConns int

+ func NewDatabaseConfig() *DatabaseConfig

+ type MessageRouter interface

+ Send func(zap.Logger, []Presence, proto.Message)

+ type Presence struct

+ ID PresenceID

+ Meta PresenceMeta

+ Topic string

+ UserID uuid.UUID

+ type PresenceID struct

+ Node string

+ SessionID uuid.UUID

+ type PresenceMeta struct

+ type SessionConfig struct

+ EncryptionKey string

+ TokenExpiryMs int64

+ func NewSessionConfig() *SessionConfig

+ type SessionRegistry struct

+ func NewSessionRegistry(logger zap.Logger, config Config, tracker Tracker) *SessionRegistry

+ func (a *SessionRegistry) Get(sessionID uuid.UUID) *session

+ type SocialConfig struct

+ Steam *SocialConfigSteam

+ func NewSocialConfig() *SocialConfig

+ type SocialConfigSteam struct

+ AppID int

+ PublisherKey string

+ type StatsService interface

+ GetHealthStatus func() int

+ GetStats func() []map[string]interface{}

+ func NewStatsService(logger zap.Logger, config Config, version string, tracker Tracker) StatsService

+ type Tracker interface

+ AddDiffListener func(func([]Presence, []Presence))

+ CheckLocalByIDTopicUser func(sessionID uuid.UUID, topic string, userID uuid.UUID) bool

+ Count func() int

+ ListByTopic func(topic string) []Presence

+ ListLocalByTopic func(topic string) []Presence

+ Stop func()

+ Track func(sessionID uuid.UUID, topic string, userID uuid.UUID, meta PresenceMeta)

+ Untrack func(sessionID uuid.UUID, topic string, userID uuid.UUID)

+ UntrackAll func(sessionID uuid.UUID)

+ Update func(sessionID uuid.UUID, topic string, userID uuid.UUID, meta PresenceMeta) error

+ type TrackerService struct

+ func NewTrackerService(name string) *TrackerService

+ func (t *TrackerService) AddDiffListener(f func([]Presence, []Presence))

+ func (t *TrackerService) CheckLocalByIDTopicUser(sessionID uuid.UUID, topic string, userID uuid.UUID) bool

+ func (t *TrackerService) Count() int

+ func (t *TrackerService) ListByTopic(topic string) []Presence

+ func (t *TrackerService) ListLocalByTopic(topic string) []Presence

+ func (t *TrackerService) Stop()

+ func (t *TrackerService) Track(sessionID uuid.UUID, topic string, userID uuid.UUID, meta PresenceMeta)

+ func (t *TrackerService) Untrack(sessionID uuid.UUID, topic string, userID uuid.UUID)

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

+ func (t *TrackerService) Update(sessionID uuid.UUID, topic string, userID uuid.UUID, meta PresenceMeta) error

+ type TransportConfig struct

+ MaxMessageSizeBytes int64

+ PingPeriodMs int

+ PongWaitMs int

+ ServerKey string

+ WriteWaitMs int

+ func NewTransportConfig() *TransportConfig