pan-doc

type Server struct {
	mqs           []string        //已注册mq类型
	tcp           net.Listener    //tcp监听对象
	unix          net.Listener    //unixSocket监听对象
	path          string          //socket文件地址
	Input         chan<- []byte   //下游pchan中的input管道
	locker        *sync.RWMutex   //锁
	counter       int64           //成功发送消息计数
	failcnt       int64           //失败消息计数
	validTopic    map[string]bool //kafka rocketmq nsa 白名单
	validExchange map[string]bool //rabbitmq 白名单
	exit          chan struct{}   //退出信号
}