Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for SetNotifyNSQ (0.33 sec)

  1. internal/config/notify/legacy.go

    		},
    		config.KV{
    			Key:   target.PostgresMaxOpenConnections,
    			Value: strconv.Itoa(cfg.MaxOpenConnections),
    		},
    	}
    
    	return nil
    }
    
    // SetNotifyNSQ - helper for config migration from older config.
    func SetNotifyNSQ(s config.Config, nsqName string, cfg target.NSQArgs) error {
    	if !cfg.Enable {
    		return nil
    	}
    
    	if err := cfg.Validate(); err != nil {
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 04:37:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  2. cmd/config-migrate.go

    		notify.SetNotifyMySQL(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.NATS {
    		notify.SetNotifyNATS(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.NSQ {
    		notify.SetNotifyNSQ(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.PostgreSQL {
    		notify.SetNotifyPostgres(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.Redis {
    		notify.SetNotifyRedis(newCfg, k, args)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
Back to top