conf

type Config struct {
	Log      map[string]interface{}       `mqant:"Log"`
	RPC      RPC                          `mqant:"RPC"`
	Module   map[string][]*ModuleSettings `mqant:"Module"`
	Mqtt     Mqtt                         `mqant:"Mqtt"`
	Settings map[string]interface{}       `mqant:"Settings"`
}

type ModuleSettings struct {
	ID        string                 `mqant:"ID"`
	Host      string                 `mqant:"Host"`
	ProcessID string                 `mqant:"ProcessID"`
	Settings  map[string]interface{} `mqant:"Settings"`
}

type Mqtt struct {
	WirteLoopChanNum int `mqant:"WirteLoopChanNum"` // 最大写入包队列缓存 (1,+∞)
	ReadPackLoop     int `mqant:"ReadPackLoop"`     // 最大读取包队列缓存
	ReadTimeout      int `mqant:"ReadTimeout"`      // 读取超时
	WriteTimeout     int `mqant:"WriteTimeout"`     // 写入超时
}

type RPC struct {
	// 模块同时可以创建的最大协程数量默认是100
	MaxCoroutine int `mqant:"MaxCoroutine"`
	// 远程访问最后期限值 单位秒[默认5秒] 这个值指定了在客户端可以等待服务端多长时间来应答
	RPCExpired int `mqant:"RPCExpired"`
	// 是否打印RPC的日志
	Log bool `mqant:"Log"`
}