mss

type CalyHandFunc func(result interface{}, err error)

type ControlHandle struct {
	ICtrlOwner // 用继承的方式又有嵌入之意。
}

type EContrlState int32 //

type EEvtFireMode int //

type EMSCMode int //

type EServiceState int32 //

type GoComponent struct {
}

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

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

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

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

type Gore struct {
	Rate, Capy int
}

type IControler interface {

	// 线程ID[0:没启动loop]
	GoId() int

	// 控制器名称
	Name() string

	// 控制器状态
	State() EContrlState

	// 控制器ID
	CtrlId() TCtrlId

	// 控制器状况
	Status() string

	// 线程暂停
	ThreadSusp() error

	// 线程唤醒
	ThreadWake() error

	// 投递消息
	PostMsg(msg IMsger) error
	// contains filtered or unexported methods
}

type ICtrlHandler interface {

	// 控制器参数 - [--重--载--] 控制器初始化参数 [argv = nil 则使用默认值]
	HandleGore() *Gore

	// 控制器准备 - [基类->派生] 当控制器创建后调用 初始数据
	HandleInit(own ICtrlOwner)

	// 控制器销毁 - [派生->基类] 当控制器销毁时调用 清理数据
	HandleTerm()

	// 控制器首次 - [基类->派生] 当控制器运行时最先调用且调用一次
	HandleLaun()

	// 控制器更新 - [基类->派生] 当控制器tick时调用 定时更新
	HandleTick(now time.Time)

	// 控制器暂停 - [基类->派生] 当控制器被暂停时调用
	HandleSusp()

	// 控制器恢复 - [基类->派生] 当控制器被恢复时调用
	HandleWake()

	// 运行状况   - [基类->派生] 当调用Status时调用 建议JSON格式
	HandleStat() string
}

type ICtrlOwner interface {
	// 继承接口
	ILogMe
	// 继承接口
	IGoTimer
	// 继承接口
	IControler

	// 获取Handler
	Handler() ICtrlHandler

	// 注册消息处理函数
	SetCMHandle(mid TMsgId, handle MCMsgHandFunc)

	// 获取主读写锁
	Mutex() *sync.RWMutex

	// 控制器主写锁
	WLock() interface{}
	WUnLock(i interface{})

	// 控制器主读锁
	RLock() interface{}
	RUnLock(i interface{})
}

type IDebuger interface {

	// 设置开关
	EnDebug(enable bool)

	// 是否开关
	IsDebug() bool
}

type IGoTimer interface {

	// 添加定时器[当tickFun返回false时自动删除此TimerHandler]
	TimerHandler(d time.Duration, tickFun TimerHandFunc, right ...bool)

	// 添加每天一次的定时器[同上](after0:每天超过零点多少时间)
	DayerHandler(after0 time.Duration, tickFun TimerHandFunc, right ...bool)

	// 移除定时器
	UnTimHandler(tickFun func() bool)
}

type IMsger interface {
	MsgId() TMsgId
}

type ISeriHandler interface {

	// 初始参数 - [重载--覆盖] 当返回!nil时初始化服务 否则禁用此服务
	HandleGore() *Gore

	// 先初始化 - [基类->派生] 当此服务创建后调用 初始化数据
	HandleInit(own ISeriOwner)

	// 首次运行 - [派生--基类] 当服务首次运行前调用一次
	HandleLaun()

	// 服务更新 - [基类->派生] 当服务tick时调用 定时更新
	HandleTick(now time.Time)

	// 服务销毁 - [派生->基类] 当服务销毁时调用 清理服务数据
	HandleTerm(reason error)

	// 运行状态 - [基类->派生] 当调用Status时调用 推荐JSON格式
	HandleStat() string
}

type ISeriOwner interface {
	// 继承接口
	ILogMe
	// 继承接口
	IGoTimer
	// 继承接口
	IServicer

	// 获取Handler
	Handler() ISeriHandler

	// 设置Cast命令[Cast: handle(...); Call:handle(...)(data,err)]
	SetCmdHandler(handles ...interface{})

	// 检测Cast命令有效性
	HasCmdHandler(cmdId TCmdId) bool

	// 注册事件
	RegisterEvent(eveSignal interface{})
	// 注销事件
	UnRegistEvent(eveSignal interface{})

	// 触发此服务的某个事件[不用等待] 以[EEFM_CAST]的方式执行所有careHandle
	Trigger(eId TEventId, args ...interface{})

	// 触发此服务的某个事件[同步等待] 以[EEFM_CALL]的方式执行所有careHandle
	Emitter(eId TEventId, args ...interface{})

	// 触发此服务的某个事件[异步等待] 以[EEFM_CASY]的方式执行所有careHandle 当所有的careHandle执行完后回调doneFun
	Emitasy(eId TEventId, args []interface{}, doneFun func())
}

type IServicer interface {

	// 获取此服务GoId[默认0]
	GoId() int

	// 获取此服务的名称
	Name() string

	// 此服务运行状态
	State() EServiceState

	// 获取此服务的ID
	SieId() TSvieId

	// 调用此服务命令[不用等待] (除非目标服务死了,否则一定会处理这个cast)
	Cast(cmdId TCmdId, args ...interface{})

	// 调用此服务命令[同步等待] (目标服务繁忙:0.1s超时错误 目标服务空闲:1s等待结果超时错误且有可能返回超时最终其实是调用成功的)
	Call(cmdId TCmdId, args ...interface{}) (interface{}, error) // if call myself then gg...

	// 调用此服务命令[异步等待] (done不可为nil)
	// > from 为nil : 调用完成后将结果为参数执行done(CallRet)
	// > from 非nil : 调用完成后将结果为参数Cast到from服务在源服务中执行done(CallRet),此时如果from服务gg...
	Caly(cmdId TCmdId, args []interface{}, from IServicer, done CalyHandFunc)

	// 调用此服务的特定函数[自行调用]
	Exec(selfFun interface{}, args ...interface{})

	// 监听此服务的某个事件
	// > care 为空 : 当此事件触发时直接执行careHandle(...)
	// > care 非空 : 当此事件触发时根据触发类型以不同的方式来执行careHandle(...),方式见:EEvtFireMode
	Listen(eId TEventId, care IServicer, careHandle interface{}) error

	// 取消监听此服务的某个事件
	UnListen(eId TEventId, care IServicer, careHandle interface{}) error

	// 停止此服务[自我调用是异步，其他调用是同步]
	Stop(reason error, wait bool)

	// 此服务运行时状况
	Status() string
}

type ISettinger interface {

	// 配置初加载
	HandleInit() error

	// 配置名称
	HandlePath() string

	// 配置内容
	HandleContent() string

	// 配置热加载[自行保证线程安全]
	HandleReload() error
}

type MCMsgHandFunc func(IMsger)

type ServiceHandle struct {
	ISeriOwner // 用继承的方式又有嵌入之意。
}

type StateHandFunc func(enter bool)

type StateHandler interface {
	OnHandleState(enter bool)
}

type SvieFunc struct {
	Svie IServicer
	Func CalyHandFunc
}

type TCmdId = string //

type TCtrlId int //

type TEventId = string //

type TMsgId int //

type TSvieId int //

type Task struct {
	Param interface{}
	Donef *SvieFunc
}

type TaskHandFunc func(*TaskOwn, interface{}) (ret interface{}, err error)

type TaskHandler interface {
	OnHandleTask(o *TaskOwn, param interface{}) (ret interface{}, err error)
}

type TaskOwn struct {
	GoId   int
	UsrDat interface{}
}

type TimerHandFunc func(now time.Time) (keep bool)