dispatch

type ConnNameer interface {
	ConnName() string // 连接对象名字，用来输出日志
}

type MsgDispatch[Mr utils.RecvMsger, Cr any] struct {
	//【需要外部来设置】
	// 必须设置，注册时获取具体消息的msgid
	RegMsgID func(msgType reflect.Type) string
	// 如果使用RegReqResp注册必须设置，用来发送Resp消息
	SendResp func(ctx context.Context, m Mr, c *Cr, resp interface{})
	// contains filtered or unexported fields
}

type ParamConfig struct {
	// 日志级别和zerolog.Level一致
	LogLevelMsg   int            `json:"loglevelmsg,omitempty"`   // msg消息默认的消息级别，不配置就是debug级别
	LogLevelByMsg map[string]int `json:"loglevelbymsg,omitempty"` // 根据消息ID区分的消息日志级别，消息ID：日志级别，不配置就使用LogLevelMsg级别

	TimeOutCheck int `json:"timeoutcheck,omitempty"` // 消息超时监控 单位秒 默认0不开启监控
	// Timeout: 执行 command 的超时时间 单位为毫秒
	// MaxConcurrentRequests: 最大并发量
	// RequestVolumeThreshold: 一个统计窗口 10 秒内请求数量 达到这个请求数量后才去判断是否要开启熔断
	// SleepWindow: 熔断器被打开后 SleepWindow的时间就是控制过多久后去尝试服务是否可用了 单位为毫秒
	// ErrorPercentThreshold: 错误百分比 请求数量大于等于 RequestVolumeThreshold 并且错误率到达这个百分比后就会启动熔断
	HystrixMsg map[string]*hystrix.CommandConfig `json:"hystrixmsg,omitempty"` // 熔断器 [msid:Config]，目前不支持动态删除
}