func (p *PluginManager) OnLiveStart(video *ProcessVideo) {
    var wg sync.WaitGroup
    wg.Add(len(p.plugins))
    for _, plug := range p.plugins {
        go func(callback PluginCallback) {