minibox

package
v0.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 16, 2023 License: Apache-2.0, BSD-3-Clause, ISC Imports: 40 Imported by: 0

Documentation

Index

Constants

View Source 
const ShutdownTimeout = 10 * time.Second

Variables

View Source 
var ErrServiceNotConfigured = errors.New("service is not configured") // +checklocksignore
View Source 
var ErrServiceRunning = errors.New("service is already running") // +checklocksignore
View Source 
var ErrServiceStopped = errors.New("service is already stopped") // +checklocksignore
View Source 
var ErrStopping = errors.New("stopping service") // +checklocksignore

Functions

This section is empty.

Types

type AdminOptions 

type AdminOptions struct {
	Logger zerolog.Logger
	Addr   string
}

type AdminServer 

type AdminServer struct {
	// contains filtered or unexported fields
}

func NewAdmin 

func NewAdmin(ctx context.Context) *AdminServer

func (*AdminServer) Configure 

func (w *AdminServer) Configure(opts AdminOptions) error

func (*AdminServer) Running 

func (w *AdminServer) Running() bool

func (*AdminServer) Start 

func (w *AdminServer) Start() error

func (*AdminServer) Stop 

func (w *AdminServer) Stop() error

type DataOptions 

type DataOptions struct {
	DatabaseURI string `json:"URI"`
}

type GameOptions 

type GameOptions struct {
	Logger          zerolog.Logger
	Addr            string
	TopologyClient  topologypbconnect.TopologyServiceClient
	AccountsService *accounts.Service
	PangyaIFF       *iff.Archive
	ServerID        uint32
	ChannelName     string
}

type GameServer 

type GameServer struct {
	// contains filtered or unexported fields
}

func NewGameServer 

func NewGameServer(ctx context.Context) *GameServer

func (*GameServer) Configure 

func (g *GameServer) Configure(opts GameOptions) error

func (*GameServer) Running 

func (g *GameServer) Running() bool

func (*GameServer) Start 

func (g *GameServer) Start() error

func (*GameServer) Stop 

func (g *GameServer) Stop() error

type LoginOptions 

type LoginOptions struct {
	Logger          zerolog.Logger
	Addr            string
	TopologyClient  topologypbconnect.TopologyServiceClient
	AccountsService *accounts.Service
}

type LoginServer 

type LoginServer struct {
	// contains filtered or unexported fields
}

func NewLoginServer 

func NewLoginServer(ctx context.Context) *LoginServer

func (*LoginServer) Configure 

func (l *LoginServer) Configure(opts LoginOptions) error

func (*LoginServer) Running 

func (l *LoginServer) Running() bool

func (*LoginServer) Start 

func (l *LoginServer) Start() error

func (*LoginServer) Stop 

func (l *LoginServer) Stop() error

type MessageOptions 

type MessageOptions struct {
	Logger          zerolog.Logger
	Addr            string
	TopologyClient  topologypbconnect.TopologyServiceClient
	AccountsService *accounts.Service
}

type MessageServer 

type MessageServer struct {
	// contains filtered or unexported fields
}

func NewMessageServer 

func NewMessageServer(ctx context.Context) *MessageServer

func (*MessageServer) Configure 

func (m *MessageServer) Configure(opts MessageOptions) error

func (*MessageServer) Running 

func (m *MessageServer) Running() bool

func (*MessageServer) Start 

func (m *MessageServer) Start() error

func (*MessageServer) Stop 

func (m *MessageServer) Stop() error

type Options 

type Options struct {
	WebAddr         string `json:"WebAddr"`
	AdminAddr       string `json:"AdminAddr"`
	QAAuthAddr      string `json:"QAAuthAddr"`
	LoginAddr       string `json:"LoginAddr"`
	GameAddr        string `json:"GameAddr"`
	MessageAddr     string `json:"MessageAddr"`
	ServerIP        string `json:"ServerIP"`
	GameServerName  string `json:"GameServerName"`
	GameChannelName string `json:"GameChannelName"`
	PangyaRegion    string `json:"PangyaRegion"`
	PangyaDir       string `json:"PangyaDir"`
	PangyaIFF       string `json:"PangyaIFF"`
}

func (*Options) ShouldConfigureAdmin 

func (options *Options) ShouldConfigureAdmin(newOpts Options) bool

ShouldConfigureAdmin returns true if the options changed require the admin server to be re-configured.

func (*Options) ShouldConfigureGame 

func (options *Options) ShouldConfigureGame(newOpts Options) bool

ShouldConfigureGame returns true if the options changed require the game server to be re-configured.

func (*Options) ShouldConfigureLogin 

func (options *Options) ShouldConfigureLogin(newOpts Options) bool

ShouldConfigureLogin returns true if the options changed require the login server to be re-configured.

func (*Options) ShouldConfigureMessage 

func (options *Options) ShouldConfigureMessage(newOpts Options) bool

ShouldConfigureMessage returns true if the options changed require the message server to be re-configured.

func (*Options) ShouldConfigureQAAuth 

func (options *Options) ShouldConfigureQAAuth(newOpts Options) bool

ShouldConfigureQAAuth returns true if the options changed require the QA auth server to be re-configured.

func (*Options) ShouldConfigureTopology 

func (options *Options) ShouldConfigureTopology(newOpts Options) bool

ShouldConfigureMessage returns true if the options changed require the message server to be re-configured.

func (*Options) ShouldConfigureWeb 

func (options *Options) ShouldConfigureWeb(newOpts Options) bool

ShouldConfigureWeb returns true if the options changed require the webserver to be re-configured.

func (*Options) ShouldRedetectPangyaKey 

func (options *Options) ShouldRedetectPangyaKey(newOpts Options) bool

ShouldRedetectPangyaKey returns true if the options changed require the PangYa key to be re-detected.

type QAAuthOptions 

type QAAuthOptions struct {
	Logger zerolog.Logger
	Addr   string
}

type QAAuthServer 

type QAAuthServer struct {
	// contains filtered or unexported fields
}

func NewQAAuth 

func NewQAAuth(ctx context.Context) *QAAuthServer

func (*QAAuthServer) Configure 

func (q *QAAuthServer) Configure(opts QAAuthOptions) error

func (*QAAuthServer) Running 

func (q *QAAuthServer) Running() bool

func (*QAAuthServer) Start 

func (q *QAAuthServer) Start() error

func (*QAAuthServer) Stop 

func (q *QAAuthServer) Stop() error

type RugburnOptions 

type RugburnOptions struct {
	Logger    zerolog.Logger
	PangyaDir string
}

type RugburnPatcher 

type RugburnPatcher struct {
	// contains filtered or unexported fields
}

func NewRugburnPatcher 

func NewRugburnPatcher() *RugburnPatcher

func (*RugburnPatcher) Configure 

func (p *RugburnPatcher) Configure(opts RugburnOptions)

func (*RugburnPatcher) HaveOriginal 

func (p *RugburnPatcher) HaveOriginal() bool

func (*RugburnPatcher) Patch 

func (p *RugburnPatcher) Patch() error

func (*RugburnPatcher) RugburnVersion 

func (p *RugburnPatcher) RugburnVersion() (string, error)

func (*RugburnPatcher) Unpatch 

func (p *RugburnPatcher) Unpatch() error

type Server 

type Server struct {

	// Network services
	// +checklocks:mu
	Topology *TopologyServer
	// +checklocks:mu
	Web *WebServer
	// +checklocks:mu
	Admin *AdminServer
	// +checklocks:mu
	Login *LoginServer
	// +checklocks:mu
	Game *GameServer
	// +checklocks:mu
	Message *MessageServer
	// +checklocks:mu
	QAAuth *QAAuthServer

	// Misc
	// +checklocks:mu
	Rugburn *RugburnPatcher
	// contains filtered or unexported fields
}

func NewServer 

func NewServer(ctx context.Context, log zerolog.Logger) *Server

func (*Server) ConfigureDatabase 

func (server *Server) ConfigureDatabase(opts DataOptions) error

ConfigureDatabase configures the database, including running pending migrations. If the services are already configured, it will also re-run service configuration with the last configuration.

func (*Server) ConfigureServices 

func (server *Server) ConfigureServices(opts Options) error

ConfigureServices reconfigures services. You must successfully configure the database before running this.

type Service 

type Service struct {
	// contains filtered or unexported fields
}

func NewService 

func NewService(ctx context.Context) *Service

func (*Service) Configure 

func (s *Service) Configure(spawn ServiceSpawnFunc) error

func (*Service) ConfigureContext 

func (s *Service) ConfigureContext(shutdownCtx context.Context, spawn ServiceSpawnFunc) error

func (*Service) Running 

func (s *Service) Running() bool

func (*Service) SetShutdownFunc 

func (s *Service) SetShutdownFunc(shutdown ServiceShutdownFunc)

func (*Service) Start 

func (s *Service) Start() error

func (*Service) Stop 

func (s *Service) Stop() error

func (*Service) StopContext 

func (s *Service) StopContext(shutdownCtx context.Context) error

type ServiceShutdownFunc 

type ServiceShutdownFunc func(shutdownCtx context.Context) error

type ServiceSpawnFunc 

type ServiceSpawnFunc func(ctx context.Context, service *Service)

type TopologyServer 

type TopologyServer struct {
	// contains filtered or unexported fields
}

func NewLocalTopology 

func NewLocalTopology(ctx context.Context) *TopologyServer

func (*TopologyServer) Client 

func (t *TopologyServer) Client() topologypbconnect.TopologyServiceClient

func (*TopologyServer) Configure 

func (t *TopologyServer) Configure(opts TopologyServerOptions) error

func (*TopologyServer) Running 

func (t *TopologyServer) Running() bool

func (*TopologyServer) Start 

func (t *TopologyServer) Start() error

func (*TopologyServer) Stop 

func (t *TopologyServer) Stop() error

type TopologyServerOptions 

type TopologyServerOptions struct {
	Logger zerolog.Logger

	ServerIP       string
	GameServerName string

	GamePort    uint16
	MessagePort uint16
}

type WebOptions 

type WebOptions struct {
	Logger          zerolog.Logger
	Addr            string
	PangyaKey       pyxtea.Key
	PangyaDir       string
	AccountsService *accounts.Service
}

type WebServer 

type WebServer struct {
	// contains filtered or unexported fields
}

func NewWeb 

func NewWeb(ctx context.Context) *WebServer

func (*WebServer) Configure 

func (w *WebServer) Configure(opts WebOptions) error

func (*WebServer) Running 

func (w *WebServer) Running() bool

func (*WebServer) Start 

func (w *WebServer) Start() error

func (*WebServer) Stop 

func (w *WebServer) Stop() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.