Method Push

plugin.go:326–351

(streamPath string, url string, pusher IPusher, save bool)

var Pushers sync.Map

func (opt *Plugin) Push(streamPath string, url string, pusher IPusher, save bool) (err error) {
	zp, zu := zap.String("stream", streamPath), zap.String("url", url)
	opt.Info("push", zp, zu)
	defer func() {
		if err != nil {
			opt.Error("push faild", zap.Error(err))
		}
	}()
	conf, ok := opt.Config.(config.PushConfig)
	if !ok {
		return ErrNoPushConfig
	}
	pushConfig := conf.GetPushConfig()
	pusher.init(streamPath, url, pushConfig)
	pusher.SetLogger(opt.Logger.With(zp, zu))
	opt.AssignSubConfig(pusher.GetSubscriber())
	go pusher.startPush(pusher)
	if save {
		pushConfig.AddPush(url, streamPath)
		opt.RawConfig.Get("push").Get("pushlist").Modify = pushConfig.PushList
		if err = opt.Save(); err != nil {
			opt.Error("save faild", zap.Error(err))
		}
	}
	return
}