mq

Documentation

Index

• Variables
• func AddMatch(playerIDs []uint, baseContestID uint, tag string, ...) (matchID uint, err error)
• func CallJSFunction(loop *eventloop.EventLoop, funcName string, args ...interface{}) (result goja.Value, err error)
• func CallOnAIAssigned(contestant model.Contestant) error
• func CallOnMatchFinished(matchID uint, replay string) error
• func ChangeMatch(tag string, state string, matchID uint) (err error)
• func CreateRuntimeWithJSFile(baseContestID uint) error
• func InitGameMq(baseContestID uint, vm *goja.Runtime)
• func InitGameMqAndRunScript(baseContestID uint)
• func InitMq()
• func ListenMsgForMatchFinished()
• func SendBuildAIMsg(ctx context.Context, aiID uint) error
• func SendBuildGameLogicMsg(ctx context.Context, gameID uint) error
• func SendRunAutoMatchMsg(ctx context.Context, matchID uint) error
• func SetCreateMatch(baseContestID uint, vm *goja.Runtime) error
• func SetGetContestantsByRanking(baseContestID uint, vm *goja.Runtime) error
• func SetGoFuncForJS(baseContestID uint, funcName string, goFunc func(goja.FunctionCall) goja.Value, ...) error
• func SetUpdateContestant(baseContestID uint, vm *goja.Runtime) error
• func Startup()
• type Msg

Variables

var (
	BaseContestIDToRuntime = make(map[uint]*eventloop.EventLoop)
	RuntimeToBaseContestID = make(map[*eventloop.EventLoop]uint)
	Mutex                  = &sync.Mutex{} // 用于保护 map 的并发访问
)

定义全局 map

var Ctx_callback = context.Background()

Functions

func AddMatch

func AddMatch(playerIDs []uint, baseContestID uint, tag string, extraInfo map[string]interface{}) (matchID uint, err error)

func CallJSFunction

func CallJSFunction(loop *eventloop.EventLoop, funcName string, args ...interface{}) (result goja.Value, err error)

func CallOnAIAssigned

func CallOnAIAssigned(contestant model.Contestant) error

func CallOnMatchFinished

func CallOnMatchFinished(matchID uint, replay string) error

func ChangeMatch

func ChangeMatch(tag string, state string, matchID uint) (err error)

func CreateRuntimeWithJSFile

func CreateRuntimeWithJSFile(baseContestID uint) error

func InitGameMq

func InitGameMq(baseContestID uint, vm *goja.Runtime)

func InitGameMqAndRunScript

func InitGameMqAndRunScript(baseContestID uint)

func InitMq

func InitMq()

func ListenMsgForMatchFinished

func ListenMsgForMatchFinished()

func SendBuildAIMsg

func SendBuildAIMsg(ctx context.Context, aiID uint) error

func SendBuildGameLogicMsg

func SendBuildGameLogicMsg(ctx context.Context, gameID uint) error

func SendRunAutoMatchMsg

func SendRunAutoMatchMsg(ctx context.Context, matchID uint) error

func SetCreateMatch

func SetCreateMatch(baseContestID uint, vm *goja.Runtime) error

func SetGetContestantsByRanking

func SetGetContestantsByRanking(baseContestID uint, vm *goja.Runtime) error

func SetGoFuncForJS

func SetGoFuncForJS(baseContestID uint, funcName string, goFunc func(goja.FunctionCall) goja.Value, vm *goja.Runtime) error

func SetUpdateContestant

func SetUpdateContestant(baseContestID uint, vm *goja.Runtime) error

func Startup

func Startup()

Types

type Msg

type Msg struct {
	ID        string // 消息的编号
	Topic     string // 消息的主题(Build/Run)
	Body      []byte // 消息的Body
	Partition int    // 分区号
	Type      string // 消息类型(AI/Game_logic/SDK)
}

Msg 消息