func NewReaderGroup(
initializer ReaderInitializer,
return &ReaderGroup{
initializer: initializer,
status: common.DaemonStatusInitialized,
readerMap: make(map[int64]Reader),
}
}
func (g *ReaderGroup) Start() {