server

Documentation

Index

• Variables
• func GetProcessState() map[string]ZbProcess
• func GuardServer(serversState ServersState)
• func GuardServers()
• func MarngeServers(f func(MStartProcess))
• func StartServer4Marnge(serverName string, param1 int, param2 interface{})
• func StopServer(stopName string) bool
• type MStartProcess
  • func (startProcess *MStartProcess) GetSubProcess() (subProcessName string)
• type ProcessChannel
• type ServersState
• type ZbProcess

Variables

var (
	MProcessName = make(chan string) // 进程管理

	MProcessChannelMap = make(map[string]ProcessChannel) // 维护的进程列表  进程需要知道自己的名称,通过这个通道传递退出信号, 如果有退出信号则退出 Quit 有值则退出

	MStartProcessName     = make(chan MStartProcess) // 需要启动的进程名称
	MStopProcessName      = make(chan string)        // 需要关停的进程名称
	MLocalStopProcessName = make(chan string)        // 进程内部发起的关停

	MQueryProcessState = make(chan int) // 传递进程状态

	MServers = make(chan map[string]ZbProcess) // 在运行的进程

	MAutoServers = make(chan ServersState) // 进程运行状态
)

Functions

func GetProcessState

func GetProcessState() map[string]ZbProcess

func GuardServer

func GuardServer(serversState ServersState)

func GuardServers

func GuardServers()

func MarngeServers

func MarngeServers(f func(MStartProcess))

启动进程管理 接收各种进程启动事件

func StartServer4Marnge

func StartServer4Marnge(serverName string, param1 int, param2 interface{})

func StopServer

func StopServer(stopName string) bool

关闭一个服务

Types

type MStartProcess

type MStartProcess struct {
	ProcessName string
	Param1      int
	Param2      interface{}
}

func (*MStartProcess) GetSubProcess

func (startProcess *MStartProcess) GetSubProcess() (subProcessName string)

根据参数1重新编辑子程的名称 主进程名称+"-"+编号

type ProcessChannel

type ProcessChannel struct {
	Quit chan string
}

type ServersState

type ServersState map[string]ZbProcess

进程执行的状态

type ZbProcess

type ZbProcess struct {
	State          int    // 0是关闭 1是启动
	ProcessName    string // 原始进程名称
	SubProcessName string // 子进程名称
}

进程类