server

package

Go to main page

Versions in this module

v1

v1.0.0-rc.1

Jul 18, 2017

v0

v0.13.1

Jun 8, 2017

v0.13.0

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

v0.12.2

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

v0.12.1

Mar 28, 2017

v0.12.0

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)

v0.11.3

Feb 25, 2017

v0.11.2

Feb 17, 2017

v0.11.1

Feb 12, 2017

v0.11.0

Feb 9, 2017

v0.10.0

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

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