Interface DataManger

app/demo/dispatch/datamanager/data_interface.go:14–22

本demo的数据存储在内存中（只实现了DataManagerMemory），所以存在单点风险（指的是dispatch永久性发生故障，短暂故障或重启是ok的）， 生产环境可以把数据存储在redis、mysql等数据库中（实现DataManager interface即可）。

// 生产环境可以把数据存储在redis、mysql等数据库中（实现DataManager interface即可）。

type DataManger interface {
	AddPub(streamName, serverId string)
	DelPub(streamName, serverId string)
	QueryPub(streamName string) (serverId string, exist bool)

	// 1. 全量校正。比如自身服务重启了，lal节点重启了，或其他原因Add、Del消息丢失了
	// 2. 心跳保活
	UpdatePub(serverId string, streamNameList []string)
}

type DataManagerType int