api

Documentation

Index

• func NewDelayTime(t config.DelayTimerType, r *config.RedisOpt) (timer.Operator[int64], error)
• func NewEntryManagers() *entry.Mgrs
• func NewGlicko2Matcher(roomChannel chan common.Result, conf *config.MatchConfig, mgrs *entry.Mgrs) *glicko2.Matcher
• type API
  • func NewAPI(configer config.Configer[config.MatchConfig], groupChannel chan entry.Group, ...) *API
  • func Start(sc config.Configer[config.ServerConfig], ...) (api *API, shutdown func())
  • func (api *API) ReloadEntries() error
  • func (api *API) SaveEntries() error
• type InfraBase
  • func NewInfraBase(sc config.Configer[config.ServerConfig], ...) *InfraBase
  • func (i *InfraBase) Start()
  • func (i *InfraBase) Stop()

Functions

func NewDelayTime

func NewDelayTime(t config.DelayTimerType, r *config.RedisOpt) (timer.Operator[int64], error)

func NewEntryManagers

func NewEntryManagers() *entry.Mgrs

func NewGlicko2Matcher

func NewGlicko2Matcher(roomChannel chan common.Result, conf *config.MatchConfig, mgrs *entry.Mgrs) *glicko2.Matcher

Types

type API

type API struct {
	MS service.Match
	M  *matcher.Matcher
	PM *entry.PlayerMgr
	GM *entry.GroupMgr
	TM *entry.TeamMgr
	RM *entry.RoomMgr
}

func NewAPI

func NewAPI(configer config.Configer[config.MatchConfig],
	groupChannel chan entry.Group, roomChannel chan common.Result,
	dt timer.Operator[int64], gm *glicko2.Matcher, mgrs *entry.Mgrs) *API

func Start

func Start(
	sc config.Configer[config.ServerConfig],
	mc config.Configer[config.MatchConfig],
) (api *API, shutdown func())

Start initializes the api components and starts them.

func (*API) ReloadEntries

func (api *API) ReloadEntries() error

ReloadEntries reloads the entries when the server starts.

func (*API) SaveEntries

func (api *API) SaveEntries() error

SaveEntries saves the entries when the server stops.

type InfraBase

type InfraBase struct {
	*goapm.Infra

	SC config.Configer[config.ServerConfig]
	MC config.Configer[config.MatchConfig]
}

InfraBase is the base infrastructure for the api.

func NewInfraBase

func NewInfraBase(
	sc config.Configer[config.ServerConfig],
	mc config.Configer[config.MatchConfig],
) *InfraBase

NewInfraBase creates a new InfraBase.

func (*InfraBase) Start

func (i *InfraBase) Start()

Start starts the infrastructure, if any errors occur, it will panic.

func (*InfraBase) Stop

func (i *InfraBase) Stop()

Stop stops the infrastructure.