Interface WorkerPool

module/worker_pool.go:12–19

var worker_pools_map sync.Map

type WorkerPool interface {
	ForEachModule(func(m Module))
	RegisterRpcHandler(string, RpcHandler)
	RegisterHandler(ProtoTypeID, MsgHandler)
	RpcCall(string, ...interface{})
	Balancer() Module
	Const(string) Module
}

type ModuleWorkerPool struct {
	modules    []Module