// AddLiveMixNotifyConfig 添加连麦回调配置
// {@link https://help.aliyun.com/document_detail/52719.html?spm=5176.doc51316.6.686.imrZss}
514401
func (l *Live) AddLiveMixNotifyConfig(notifyUrl string, resp interface{}) (err error) {
	req := l.cloneRequest(AddLiveMixNotifyConfigAction)
	req.SetArgs("NotifyUrl", notifyUrl)
	err = l.rpc.Query(req, resp)
	return
}
269566
func (p *Project) AddVolumeConfig(name string, config *config.VolumeConfig) error {
	p.Notify(events.VolumeAdd, name, nil)
	p.VolumeConfigs[name] = config
	return nil
}
78355
func (l *Live) DescribeLiveMixConfig(resp interface{}) (err error) {
	req := l.cloneRequest(DescribeLiveMixConfigAction)
	err = l.rpc.Query(req, resp)
	return
}
946160
func (client *Client) AddLIFF(view View) *AddLIFFCall {
	return &AddLIFFCall{
		c:    client,
		view: view,
	}
}
472635
func (h *Health) AddCheck(cfg *Config) error {
	if h.active.val() {
		return ErrNoAddCfgWhenActive
	}

	h.configs = append(h.configs, cfg)
	return nil
}
869050
func (b *BucketNotification) AddLambda(lambdaConfig NotificationConfig) bool {
	newLambdaConfig := LambdaConfig{NotificationConfig: lambdaConfig, Lambda: lambdaConfig.Arn.String()}
	for _, n := range b.LambdaConfigs {
		if n.Lambda == newLambdaConfig.Arn.String() && newLambdaConfig.Filter == n.Filter {

			existingConfig := set.NewStringSet()
			for _, v := range n.Events {
				existingConfig.Add(string(v))
			}

			newConfig := set.NewStringSet()
			for _, v := range lambdaConfig.Events {
				newConfig.Add(string(v))
			}

			if !newConfig.Intersection(existingConfig).IsEmpty() {
				return false
			}
		}
	}
	b.LambdaConfigs = append(b.LambdaConfigs, newLambdaConfig)
	return true
}
586498
func (f *ListenerStack) Add(fx ElemEventMux) int {
	var ind int

	f.lock.RLock()
	ind = len(f.listeners)
	f.lock.RUnlock()

	f.lock.Lock()
	f.listeners = append(f.listeners, fx)
	f.lock.Unlock()

	return ind
}
365367
func (_m *API) AddSnapshot(_a0 api.SnapshotConfig) (string, error) {
	ret := _m.Called(_a0)

	var r0 string
	if rf, ok := ret.Get(0).(func(api.SnapshotConfig) string); ok {
		r0 = rf(_a0)
	} else {
		r0 = ret.Get(0).(string)
	}

	var r1 error
	if rf, ok := ret.Get(1).(func(api.SnapshotConfig) error); ok {
		r1 = rf(_a0)
	} else {
		r1 = ret.Error(1)
	}

	return r0, r1
}
1294077
func (m *RWatcher) Add(name string) error {
	if m.isClosed {
		return errors.New("rfsnotify instance already closed")
	}
	return m.fsnotify.Add(name)
}
559735
func (client DefaultClient) AddFixVersion(issueKey string, fixVersion string) (int, error) {

	var change struct {
		Update struct {
			FixedVersions [1]struct {
				Add struct {
					Name string `json:"name"`
				} `json:"add"`
			} `json:"fixVersions"`
		} `json:"update"`
	}

	change.Update.FixedVersions[0].Add.Name = fixVersion

	data, err := json.Marshal(&change)
	if err != nil {
		return http.StatusBadRequest, err
	}

	req, err := http.NewRequest("PUT", fmt.Sprintf("%s/rest/api/2/issue/%s", client.baseURL, issueKey), bytes.NewBuffer(data))
	if err != nil {
		return http.StatusBadRequest, err
	}
	req.Header.Set("Content-type", "application/json")
	req.SetBasicAuth(client.username, client.password)

	rc, data, err := client.consumeResponse(req)
	if err != nil {
		return rc, err
	} else if rc != http.StatusNoContent {
		logger.Printf("Returned %s, becuase %s", rc, string(data))
	}

	return rc, nil
}
1300120
func (h *Health) AddChecks(cfgs []*Config) error {
	if h.active.val() {
		return ErrNoAddCfgWhenActive
	}

	h.configs = append(h.configs, cfgs...)

	return nil
}
1127802
func (s *AccountTakeoverRiskConfigurationType) SetNotifyConfiguration(v *NotifyConfigurationType) *AccountTakeoverRiskConfigurationType {
	s.NotifyConfiguration = v
	return s
}
1307365
func (m *Mixer) Add(s ...Streamer) {
	m.streamers = append(m.streamers, s...)
}
297536
func (config *Config) AddPlugin(plugin Plugin) {
	config.pluginsConfig.Plugins[plugin.Name] = plugin
}
890097
func (c *Config) AddPlugin(m plugin.Plugin) {
	c.Plugin = append(c.Plugin, m)
}
702503
func (t *NotificationConfig) AddEvents(events ...NotificationEventType) {
	t.Events = append(t.Events, events...)
}
1207575
func (r *configs) Add(configs ...api.Config) {
	r.mu.Lock()
	defer r.mu.Unlock()
	for _, config := range configs {
		r.m[config.ID] = config.Copy()
	}
}